To get this branch, use:
bzr branch
http://bzr.recompile.se/loggerhead/mandos/release
« back to all changes in this revision
Viewing changes to mandos-ctl
- browse files at revision 320
- compare with another revision
- download diff
- download tarball
- view history from revision 320
- Committer: Teddy Hogeborn
- Date: 2014-07-17 03:24:57 UTC
- Revision ID: teddy@recompile.se-20140717032457-7074pobx7ft1oiio
Tags: version-1.6.7-1
* Makefile (version): Changed to "1.6.7".
* NEWS (Version 1.6.7): New entry.
* debian/changelog (1.6.7-1): - '' -
* NEWS (Version 1.6.7): New entry.
* debian/changelog (1.6.7-1): - '' -
- files added:
- debian/mandos-client.examples
- debian/upstream
- files modified:
- .bzrignore
added
removed
mandos-ctl
3
3
#
4
4
# Mandos Monitor - Control and monitor the Mandos server
5
5
#
6
# Copyright © 2008-2012 Teddy Hogeborn
7
# Copyright © 2008-2012 Björn Påhlsson
6
# Copyright © 2008-2014 Teddy Hogeborn
7
# Copyright © 2008-2014 Björn Påhlsson
8
8
#
9
9
# This program is free software: you can redistribute it and/or modify
10
10
# it under the terms of the GNU General Public License as published by
17
17
# GNU General Public License for more details.
18
18
#
19
19
# You should have received a copy of the GNU General Public License
20
# along with this program. If not, see <http://www.gnu.org/licenses/>.
20
# along with this program. If not, see
21
# <http://www.gnu.org/licenses/>.
21
22
#
22
23
# Contact the authors at <mandos@recompile.se>.
23
24
#
25
26
from __future__ import (division, absolute_import, print_function,
26
27
unicode_literals)
27
28
29
try:
30
from future_builtins import *
31
except ImportError:
32
pass
33
28
34
import sys
29
import dbus
30
35
import argparse
31
36
import locale
32
37
import datetime
33
38
import re
34
39
import os
40
import collections
41
import doctest
42
43
import dbus
44
45
if sys.version_info[0] == 2:
46
str = unicode
35
47
36
48
locale.setlocale(locale.LC_ALL, "")
37
49
60
72
server_path = "/"
61
73
server_interface = domain + ".Mandos"
62
74
client_interface = domain + ".Mandos.Client"
63
version = "1.5.1"
75
version = "1.6.7"
64
76
65
77
def timedelta_to_milliseconds(td):
66
78
"""Convert a datetime.timedelta object to milliseconds"""
70
82
71
83
def milliseconds_to_string(ms):
72
84
td = datetime.timedelta(0, 0, 0, ms)
73
return ("%(days)s%(hours)02d:%(minutes)02d:%(seconds)02d"
74
% { "days": "%dT" % td.days if td.days else "",
75
"hours": td.seconds // 3600,
76
"minutes": (td.seconds % 3600) // 60,
77
"seconds": td.seconds % 60,
78
})
85
return ("{days}{hours:02}:{minutes:02}:{seconds:02}"
86
.format(days = "{0}T".format(td.days) if td.days else "",
87
hours = td.seconds // 3600,
88
minutes = (td.seconds % 3600) // 60,
89
seconds = td.seconds % 60,
90
))
91
92
93
def rfc3339_duration_to_delta(duration):
94
"""Parse an RFC 3339 "duration" and return a datetime.timedelta
95
96
>>> rfc3339_duration_to_delta("P7D")
97
datetime.timedelta(7)
98
>>> rfc3339_duration_to_delta("PT60S")
99
datetime.timedelta(0, 60)
100
>>> rfc3339_duration_to_delta("PT60M")
101
datetime.timedelta(0, 3600)
102
>>> rfc3339_duration_to_delta("PT24H")
103
datetime.timedelta(1)
104
>>> rfc3339_duration_to_delta("P1W")
105
datetime.timedelta(7)
106
>>> rfc3339_duration_to_delta("PT5M30S")
107
datetime.timedelta(0, 330)
108
>>> rfc3339_duration_to_delta("P1DT3M20S")
109
datetime.timedelta(1, 200)
110
"""
111
112
# Parsing an RFC 3339 duration with regular expressions is not
113
# possible - there would have to be multiple places for the same
114
# values, like seconds. The current code, while more esoteric, is
115
# cleaner without depending on a parsing library. If Python had a
116
# built-in library for parsing we would use it, but we'd like to
117
# avoid excessive use of external libraries.
118
119
# New type for defining tokens, syntax, and semantics all-in-one
120
Token = collections.namedtuple("Token",
121
("regexp", # To match token; if
122
# "value" is not None,
123
# must have a "group"
124
# containing digits
125
"value", # datetime.timedelta or
126
# None
127
"followers")) # Tokens valid after
128
# this token
129
# RFC 3339 "duration" tokens, syntax, and semantics; taken from
130
# the "duration" ABNF definition in RFC 3339, Appendix A.
131
token_end = Token(re.compile(r"$"), None, frozenset())
132
token_second = Token(re.compile(r"(\d+)S"),
133
datetime.timedelta(seconds=1),
134
frozenset((token_end,)))
135
token_minute = Token(re.compile(r"(\d+)M"),
136
datetime.timedelta(minutes=1),
137
frozenset((token_second, token_end)))
138
token_hour = Token(re.compile(r"(\d+)H"),
139
datetime.timedelta(hours=1),
140
frozenset((token_minute, token_end)))
141
token_time = Token(re.compile(r"T"),
142
None,
143
frozenset((token_hour, token_minute,
144
token_second)))
145
token_day = Token(re.compile(r"(\d+)D"),
146
datetime.timedelta(days=1),
147
frozenset((token_time, token_end)))
148
token_month = Token(re.compile(r"(\d+)M"),
149
datetime.timedelta(weeks=4),
150
frozenset((token_day, token_end)))
151
token_year = Token(re.compile(r"(\d+)Y"),
152
datetime.timedelta(weeks=52),
153
frozenset((token_month, token_end)))
154
token_week = Token(re.compile(r"(\d+)W"),
155
datetime.timedelta(weeks=1),
156
frozenset((token_end,)))
157
token_duration = Token(re.compile(r"P"), None,
158
frozenset((token_year, token_month,
159
token_day, token_time,
160
token_week))),
161
# Define starting values
162
value = datetime.timedelta() # Value so far
163
found_token = None
164
followers = frozenset(token_duration,) # Following valid tokens
165
s = duration # String left to parse
166
# Loop until end token is found
167
while found_token is not token_end:
168
# Search for any currently valid tokens
169
for token in followers:
170
match = token.regexp.match(s)
171
if match is not None:
172
# Token found
173
if token.value is not None:
174
# Value found, parse digits
175
factor = int(match.group(1), 10)
176
# Add to value so far
177
value += factor * token.value
178
# Strip token from string
179
s = token.regexp.sub("", s, 1)
180
# Go to found token
181
found_token = token
182
# Set valid next tokens
183
followers = found_token.followers
184
break
185
else:
186
# No currently valid tokens were found
187
raise ValueError("Invalid RFC 3339 duration")
188
# End token found
189
return value
190
79
191
80
192
def string_to_delta(interval):
81
193
"""Parse a string and return a datetime.timedelta
93
205
>>> string_to_delta("5m 30s")
94
206
datetime.timedelta(0, 330)
95
207
"""
208
209
try:
210
return rfc3339_duration_to_delta(interval)
211
except ValueError:
212
pass
213
96
214
value = datetime.timedelta(0)
97
regexp = re.compile("(\d+)([dsmhw]?)")
215
regexp = re.compile(r"(\d+)([dsmhw]?)")
98
216
99
217
for num, suffix in regexp.findall(interval):
100
218
if suffix == "d":
116
234
if type(value) is dbus.Boolean:
117
235
return "Yes" if value else "No"
118
236
if keyword in ("Timeout", "Interval", "ApprovalDelay",
119
"ApprovalDuration"):
237
"ApprovalDuration", "ExtendedTimeout"):
120
238
return milliseconds_to_string(value)
121
return unicode(value)
239
return str(value)
122
240
123
241
# Create format string to print table rows
124
format_string = " ".join("%%-%ds" %
125
max(len(tablewords[key]),
126
max(len(valuetostring(client[key],
127
key))
128
for client in
129
clients))
130
for key in keywords)
242
format_string = " ".join("{{{key}:{width}}}".format(
243
width = max(len(tablewords[key]),
244
max(len(valuetostring(client[key],
245
key))
246
for client in
247
clients)),
248
key = key) for key in keywords)
131
249
# Print header line
132
print(format_string % tuple(tablewords[key] for key in keywords))
250
print(format_string.format(**tablewords))
133
251
for client in clients:
134
print(format_string % tuple(valuetostring(client[key], key)
135
for key in keywords))
252
print(format_string.format(**dict((key,
253
valuetostring(client[key],
254
key))
255
for key in keywords)))
136
256
137
257
def has_actions(options):
138
258
return any((options.enable,
157
277
def main():
158
278
parser = argparse.ArgumentParser()
159
279
parser.add_argument("--version", action="version",
160
version = "%%prog %s" % version,
280
version = "%(prog)s {0}".format(version),
161
281
help="show version number and exit")
162
282
parser.add_argument("-a", "--all", action="store_true",
163
283
help="Select all clients")
196
316
parser.add_argument("--approval-duration",
197
317
help="Set duration of one client approval")
198
318
parser.add_argument("-H", "--host", help="Set host for client")
199
parser.add_argument("-s", "--secret", type=file,
319
parser.add_argument("-s", "--secret",
320
type=argparse.FileType(mode="rb"),
200
321
help="Set password blob (file) for client")
201
322
parser.add_argument("-A", "--approve", action="store_true",
202
323
help="Approve any current client request")
203
324
parser.add_argument("-D", "--deny", action="store_true",
204
325
help="Deny any current client request")
326
parser.add_argument("--check", action="store_true",
327
help="Run self-test")
205
328
parser.add_argument("client", nargs="*", help="Client name")
206
329
options = parser.parse_args()
207
330
208
if has_actions(options) and not options.client and not options.all:
331
if has_actions(options) and not (options.client or options.all):
209
332
parser.error("Options require clients names or --all.")
210
333
if options.verbose and has_actions(options):
211
334
parser.error("--verbose can only be used alone or with"
212
335
" --all.")
213
336
if options.all and not has_actions(options):
214
337
parser.error("--all requires an action.")
338
339
if options.check:
340
fail_count, test_count = doctest.testmod()
341
sys.exit(os.EX_OK if fail_count == 0 else 1)
215
342
216
343
try:
217
344
bus = dbus.SystemBus()
247
374
if options.all or not options.client:
248
375
clients = dict((bus.get_object(busname, path), properties)
249
376
for path, properties in
250
mandos_clients.iteritems())
377
mandos_clients.items())
251
378
else:
252
379
for name in options.client:
253
380
for path, client in mandos_clients.iteritems():
256
383
clients[client_objc] = client
257
384
break
258
385
else:
259
print("Client not found on server: %r" % name,
260
file=sys.stderr)
386
print("Client not found on server: {0!r}"
387
.format(name), file=sys.stderr)
261
388
sys.exit(1)
262
389
263
390
if not has_actions(options) and clients:
277
404
else:
278
405
# Process each client in the list by all selected options
279
406
for client in clients:
407
def set_client_prop(prop, value):
408
"""Set a Client D-Bus property"""
409
client.Set(client_interface, prop, value,
410
dbus_interface=dbus.PROPERTIES_IFACE)
411
def set_client_prop_ms(prop, value):
412
"""Set a Client D-Bus property, converted
413
from a string to milliseconds."""
414
set_client_prop(prop,
415
timedelta_to_milliseconds
416
(string_to_delta(value)))
280
417
if options.remove:
281
418
mandos_serv.RemoveClient(client.__dbus_object_path__)
282
419
if options.enable:
283
client.Enable(dbus_interface=client_interface)
420
set_client_prop("Enabled", dbus.Boolean(True))
284
421
if options.disable:
285
client.Disable(dbus_interface=client_interface)
422
set_client_prop("Enabled", dbus.Boolean(False))
286
423
if options.bump_timeout:
287
client.CheckedOK(dbus_interface=client_interface)
424
set_client_prop("LastCheckedOK", "")
288
425
if options.start_checker:
289
client.StartChecker(dbus_interface=client_interface)
426
set_client_prop("CheckerRunning", dbus.Boolean(True))
290
427
if options.stop_checker:
291
client.StopChecker(dbus_interface=client_interface)
428
set_client_prop("CheckerRunning", dbus.Boolean(False))
292
429
if options.is_enabled:
293
430
sys.exit(0 if client.Get(client_interface,
294
431
"Enabled",
296
433
dbus.PROPERTIES_IFACE)
297
434
else 1)
298
435
if options.checker is not None:
299
client.Set(client_interface, "Checker",
300
options.checker,
301
dbus_interface=dbus.PROPERTIES_IFACE)
436
set_client_prop("Checker", options.checker)
302
437
if options.host is not None:
303
client.Set(client_interface, "Host", options.host,
304
dbus_interface=dbus.PROPERTIES_IFACE)
438
set_client_prop("Host", options.host)
305
439
if options.interval is not None:
306
client.Set(client_interface, "Interval",
307
timedelta_to_milliseconds
308
(string_to_delta(options.interval)),
309
dbus_interface=dbus.PROPERTIES_IFACE)
440
set_client_prop_ms("Interval", options.interval)
310
441
if options.approval_delay is not None:
311
client.Set(client_interface, "ApprovalDelay",
312
timedelta_to_milliseconds
313
(string_to_delta(options.
314
approval_delay)),
315
dbus_interface=dbus.PROPERTIES_IFACE)
442
set_client_prop_ms("ApprovalDelay",
443
options.approval_delay)
316
444
if options.approval_duration is not None:
317
client.Set(client_interface, "ApprovalDuration",
318
timedelta_to_milliseconds
319
(string_to_delta(options.
320
approval_duration)),
321
dbus_interface=dbus.PROPERTIES_IFACE)
445
set_client_prop_ms("ApprovalDuration",
446
options.approval_duration)
322
447
if options.timeout is not None:
323
client.Set(client_interface, "Timeout",
324
timedelta_to_milliseconds
325
(string_to_delta(options.timeout)),
326
dbus_interface=dbus.PROPERTIES_IFACE)
448
set_client_prop_ms("Timeout", options.timeout)
327
449
if options.extended_timeout is not None:
328
client.Set(client_interface, "ExtendedTimeout",
329
timedelta_to_milliseconds
330
(string_to_delta(options.extended_timeout)),
331
dbus_interface=dbus.PROPERTIES_IFACE)
450
set_client_prop_ms("ExtendedTimeout",
451
options.extended_timeout)
332
452
if options.secret is not None:
333
client.Set(client_interface, "Secret",
334
dbus.ByteArray(options.secret.read()),
335
dbus_interface=dbus.PROPERTIES_IFACE)
453
set_client_prop("Secret",
454
dbus.ByteArray(options.secret.read()))
336
455
if options.approved_by_default is not None:
337
client.Set(client_interface, "ApprovedByDefault",
338
dbus.Boolean(options
339
.approved_by_default),
340
dbus_interface=dbus.PROPERTIES_IFACE)
456
set_client_prop("ApprovedByDefault",
457
dbus.Boolean(options
458
.approved_by_default))
341
459
if options.approve:
342
460
client.Approve(dbus.Boolean(True),
343
461
dbus_interface=client_interface)
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0