2
# -*- mode: python; coding: utf-8; after-save-hook: (lambda () (let ((command (if (and (boundp 'tramp-file-name-structure) (string-match (car tramp-file-name-structure) (buffer-file-name))) (tramp-file-name-localname (tramp-dissect-file-name (buffer-file-name))) (buffer-file-name)))) (if (= (shell-command (format "%s --check" (shell-quote-argument command)) "*Test*") 0) (let ((w (get-buffer-window "*Test*"))) (if w (delete-window w)) (kill-buffer "*Test*")) (display-buffer "*Test*")))); -*-
2
# -*- mode: python; coding: utf-8 -*-
4
4
# Mandos Monitor - Control and monitor the Mandos server
6
# Copyright © 2008-2019 Teddy Hogeborn
7
# Copyright © 2008-2019 Björn Påhlsson
9
# This file is part of Mandos.
11
# Mandos is free software: you can redistribute it and/or modify it
12
# under the terms of the GNU General Public License as published by
6
# Copyright © 2008-2014 Teddy Hogeborn
7
# Copyright © 2008-2014 Björn Påhlsson
9
# This program is free software: you can redistribute it and/or modify
10
# it under the terms of the GNU General Public License as published by
13
11
# the Free Software Foundation, either version 3 of the License, or
14
12
# (at your option) any later version.
16
# Mandos is distributed in the hope that it will be useful, but
17
# WITHOUT ANY WARRANTY; without even the implied warranty of
14
# This program is distributed in the hope that it will be useful,
15
# but WITHOUT ANY WARRANTY; without even the implied warranty of
18
16
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19
17
# GNU General Public License for more details.
21
19
# You should have received a copy of the GNU General Public License
22
# along with Mandos. If not, see <http://www.gnu.org/licenses/>.
20
# along with this program. If not, see
21
# <http://www.gnu.org/licenses/>.
24
23
# Contact the authors at <mandos@recompile.se>.
27
26
from __future__ import (division, absolute_import, print_function,
48
# Show warnings by default
49
if not sys.warnoptions:
51
warnings.simplefilter("default")
53
log = logging.getLogger(sys.argv[0])
54
logging.basicConfig(level="INFO", # Show info level messages
55
format="%(message)s") # Show basic log messages
57
logging.captureWarnings(True) # Show warnings via the logging system
59
if sys.version_info.major == 2:
45
if sys.version_info[0] == 2:
62
48
locale.setlocale(locale.LC_ALL, "")
79
64
"ApprovalDelay": "Approval Delay",
80
65
"ApprovalDuration": "Approval Duration",
81
66
"Checker": "Checker",
82
"ExtendedTimeout": "Extended Timeout",
84
"LastCheckerStatus": "Last Checker Status",
67
"ExtendedTimeout" : "Extended Timeout"
86
69
defaultkeywords = ("Name", "Enabled", "Timeout", "LastCheckedOK")
87
70
domain = "se.recompile"
88
71
busname = domain + ".Mandos"
90
73
server_interface = domain + ".Mandos"
91
74
client_interface = domain + ".Mandos.Client"
96
dbus.OBJECT_MANAGER_IFACE
97
except AttributeError:
98
dbus.OBJECT_MANAGER_IFACE = "org.freedesktop.DBus.ObjectManager"
77
def timedelta_to_milliseconds(td):
78
"""Convert a datetime.timedelta object to milliseconds"""
79
return ((td.days * 24 * 60 * 60 * 1000)
81
+ (td.microseconds // 1000))
101
83
def milliseconds_to_string(ms):
102
84
td = datetime.timedelta(0, 0, 0, ms)
103
85
return ("{days}{hours:02}:{minutes:02}:{seconds:02}"
104
.format(days="{}T".format(td.days) if td.days else "",
105
hours=td.seconds // 3600,
106
minutes=(td.seconds % 3600) // 60,
107
seconds=td.seconds % 60))
86
.format(days = "{}T".format(td.days) if td.days else "",
87
hours = td.seconds // 3600,
88
minutes = (td.seconds % 3600) // 60,
89
seconds = td.seconds % 60,
110
93
def rfc3339_duration_to_delta(duration):
111
94
"""Parse an RFC 3339 "duration" and return a datetime.timedelta
113
96
>>> rfc3339_duration_to_delta("P7D")
114
97
datetime.timedelta(7)
115
98
>>> rfc3339_duration_to_delta("PT60S")
116
99
datetime.timedelta(0, 60)
117
100
>>> rfc3339_duration_to_delta("PT60M")
118
101
datetime.timedelta(0, 3600)
119
>>> rfc3339_duration_to_delta("P60M")
120
datetime.timedelta(1680)
121
102
>>> rfc3339_duration_to_delta("PT24H")
122
103
datetime.timedelta(1)
123
104
>>> rfc3339_duration_to_delta("P1W")
126
107
datetime.timedelta(0, 330)
127
108
>>> rfc3339_duration_to_delta("P1DT3M20S")
128
109
datetime.timedelta(1, 200)
129
>>> # Can not be empty:
130
>>> rfc3339_duration_to_delta("")
131
Traceback (most recent call last):
133
ValueError: Invalid RFC 3339 duration: u''
134
>>> # Must start with "P":
135
>>> rfc3339_duration_to_delta("1D")
136
Traceback (most recent call last):
138
ValueError: Invalid RFC 3339 duration: u'1D'
139
>>> # Must use correct order
140
>>> rfc3339_duration_to_delta("PT1S2M")
141
Traceback (most recent call last):
143
ValueError: Invalid RFC 3339 duration: u'PT1S2M'
144
>>> # Time needs time marker
145
>>> rfc3339_duration_to_delta("P1H2S")
146
Traceback (most recent call last):
148
ValueError: Invalid RFC 3339 duration: u'P1H2S'
149
>>> # Weeks can not be combined with anything else
150
>>> rfc3339_duration_to_delta("P1D2W")
151
Traceback (most recent call last):
153
ValueError: Invalid RFC 3339 duration: u'P1D2W'
154
>>> rfc3339_duration_to_delta("P2W2H")
155
Traceback (most recent call last):
157
ValueError: Invalid RFC 3339 duration: u'P2W2H'
160
112
# Parsing an RFC 3339 duration with regular expressions is not
161
113
# possible - there would have to be multiple places for the same
162
114
# values, like seconds. The current code, while more esoteric, is
163
115
# cleaner without depending on a parsing library. If Python had a
164
116
# built-in library for parsing we would use it, but we'd like to
165
117
# avoid excessive use of external libraries.
167
119
# New type for defining tokens, syntax, and semantics all-in-one
168
Token = collections.namedtuple("Token", (
169
"regexp", # To match token; if "value" is not None, must have
170
# a "group" containing digits
171
"value", # datetime.timedelta or None
172
"followers")) # Tokens valid after this token
120
Token = collections.namedtuple("Token",
121
("regexp", # To match token; if
122
# "value" is not None,
123
# must have a "group"
125
"value", # datetime.timedelta or
127
"followers")) # Tokens valid after
173
129
# RFC 3339 "duration" tokens, syntax, and semantics; taken from
174
130
# the "duration" ABNF definition in RFC 3339, Appendix A.
175
131
token_end = Token(re.compile(r"$"), None, frozenset())
176
132
token_second = Token(re.compile(r"(\d+)S"),
177
133
datetime.timedelta(seconds=1),
178
frozenset((token_end, )))
134
frozenset((token_end,)))
179
135
token_minute = Token(re.compile(r"(\d+)M"),
180
136
datetime.timedelta(minutes=1),
181
137
frozenset((token_second, token_end)))
197
153
frozenset((token_month, token_end)))
198
154
token_week = Token(re.compile(r"(\d+)W"),
199
155
datetime.timedelta(weeks=1),
200
frozenset((token_end, )))
156
frozenset((token_end,)))
201
157
token_duration = Token(re.compile(r"P"), None,
202
158
frozenset((token_year, token_month,
203
159
token_day, token_time,
205
# Define starting values:
207
value = datetime.timedelta()
161
# Define starting values
162
value = datetime.timedelta() # Value so far
208
163
found_token = None
209
# Following valid tokens
210
followers = frozenset((token_duration, ))
211
# String left to parse
164
followers = frozenset((token_duration,)) # Following valid tokens
165
s = duration # String left to parse
213
166
# Loop until end token is found
214
167
while found_token is not token_end:
215
168
# Search for any currently valid tokens
233
186
# No currently valid tokens were found
234
raise ValueError("Invalid RFC 3339 duration: {!r}"
187
raise ValueError("Invalid RFC 3339 duration")
236
188
# End token found
240
192
def string_to_delta(interval):
241
193
"""Parse a string and return a datetime.timedelta
195
>>> string_to_delta("7d")
196
datetime.timedelta(7)
197
>>> string_to_delta("60s")
198
datetime.timedelta(0, 60)
199
>>> string_to_delta("60m")
200
datetime.timedelta(0, 3600)
201
>>> string_to_delta("24h")
202
datetime.timedelta(1)
203
>>> string_to_delta("1w")
204
datetime.timedelta(7)
205
>>> string_to_delta("5m 30s")
206
datetime.timedelta(0, 330)
245
210
return rfc3339_duration_to_delta(interval)
246
except ValueError as e:
247
log.warning("%s - Parsing as pre-1.6.1 interval instead",
249
return parse_pre_1_6_1_interval(interval)
252
def parse_pre_1_6_1_interval(interval):
253
"""Parse an interval string as documented by Mandos before 1.6.1, and
254
return a datetime.timedelta
255
>>> parse_pre_1_6_1_interval('7d')
256
datetime.timedelta(7)
257
>>> parse_pre_1_6_1_interval('60s')
258
datetime.timedelta(0, 60)
259
>>> parse_pre_1_6_1_interval('60m')
260
datetime.timedelta(0, 3600)
261
>>> parse_pre_1_6_1_interval('24h')
262
datetime.timedelta(1)
263
>>> parse_pre_1_6_1_interval('1w')
264
datetime.timedelta(7)
265
>>> parse_pre_1_6_1_interval('5m 30s')
266
datetime.timedelta(0, 330)
267
>>> parse_pre_1_6_1_interval('')
268
datetime.timedelta(0)
269
>>> # Ignore unknown characters, allow any order and repetitions
270
>>> parse_pre_1_6_1_interval('2dxy7zz11y3m5m')
271
datetime.timedelta(2, 480, 18000)
275
214
value = datetime.timedelta(0)
276
215
regexp = re.compile(r"(\d+)([dsmhw]?)")
278
217
for num, suffix in regexp.findall(interval):
279
218
if suffix == "d":
280
219
value += datetime.timedelta(int(num))
290
229
value += datetime.timedelta(0, 0, 0, int(num))
294
232
def print_clients(clients, keywords):
295
233
def valuetostring(value, keyword):
296
if isinstance(value, dbus.Boolean):
234
if type(value) is dbus.Boolean:
297
235
return "Yes" if value else "No"
298
236
if keyword in ("Timeout", "Interval", "ApprovalDelay",
299
237
"ApprovalDuration", "ExtendedTimeout"):
300
238
return milliseconds_to_string(value)
301
239
return str(value)
303
241
# Create format string to print table rows
304
242
format_string = " ".join("{{{key}:{width}}}".format(
305
width=max(len(tablewords[key]),
306
max(len(valuetostring(client[key], key))
307
for client in clients)),
243
width = max(len(tablewords[key]),
244
max(len(valuetostring(client[key],
248
key = key) for key in keywords)
310
249
# Print header line
311
250
print(format_string.format(**tablewords))
312
251
for client in clients:
314
.format(**{key: valuetostring(client[key], key)
315
for key in keywords}))
252
print(format_string.format(**{ key:
253
valuetostring(client[key],
255
for key in keywords }))
318
257
def has_actions(options):
319
258
return any((options.enable,
340
278
parser = argparse.ArgumentParser()
341
279
parser.add_argument("--version", action="version",
342
version="%(prog)s {}".format(version),
280
version = "%(prog)s {}".format(version),
343
281
help="show version number and exit")
344
282
parser.add_argument("-a", "--all", action="store_true",
345
283
help="Select all clients")
346
284
parser.add_argument("-v", "--verbose", action="store_true",
347
285
help="Print all fields")
348
parser.add_argument("-j", "--dump-json", action="store_true",
349
help="Dump client data in JSON format")
350
286
parser.add_argument("-e", "--enable", action="store_true",
351
287
help="Enable client")
352
288
parser.add_argument("-d", "--disable", action="store_true",
391
327
help="Run self-test")
392
328
parser.add_argument("client", nargs="*", help="Client name")
393
329
options = parser.parse_args()
395
331
if has_actions(options) and not (options.client or options.all):
396
332
parser.error("Options require clients names or --all.")
397
333
if options.verbose and has_actions(options):
398
parser.error("--verbose can only be used alone.")
399
if options.dump_json and (options.verbose
400
or has_actions(options)):
401
parser.error("--dump-json can only be used alone.")
334
parser.error("--verbose can only be used alone or with"
402
336
if options.all and not has_actions(options):
403
337
parser.error("--all requires an action.")
340
fail_count, test_count = doctest.testmod()
341
sys.exit(os.EX_OK if fail_count == 0 else 1)
406
344
bus = dbus.SystemBus()
407
345
mandos_dbus_objc = bus.get_object(busname, server_path)
408
346
except dbus.exceptions.DBusException:
409
log.critical("Could not connect to Mandos server")
347
print("Could not connect to Mandos server",
412
351
mandos_serv = dbus.Interface(mandos_dbus_objc,
413
dbus_interface=server_interface)
414
mandos_serv_object_manager = dbus.Interface(
415
mandos_dbus_objc, dbus_interface=dbus.OBJECT_MANAGER_IFACE)
417
# block stderr since dbus library prints to stderr
352
dbus_interface = server_interface)
354
#block stderr since dbus library prints to stderr
418
355
null = os.open(os.path.devnull, os.O_RDWR)
419
356
stderrcopy = os.dup(sys.stderr.fileno())
420
357
os.dup2(null, sys.stderr.fileno())
424
mandos_clients = {path: ifs_and_props[client_interface]
425
for path, ifs_and_props in
426
mandos_serv_object_manager
427
.GetManagedObjects().items()
428
if client_interface in ifs_and_props}
361
mandos_clients = mandos_serv.GetAllClientsWithProperties()
431
364
os.dup2(stderrcopy, sys.stderr.fileno())
432
365
os.close(stderrcopy)
433
except dbus.exceptions.DBusException as e:
434
log.critical("Failed to access Mandos server through D-Bus:"
366
except dbus.exceptions.DBusException:
367
print("Access denied: Accessing mandos server through dbus.",
438
371
# Compile dict of (clients: properties) to process
441
374
if options.all or not options.client:
442
clients = {bus.get_object(busname, path): properties
443
for path, properties in mandos_clients.items()}
375
clients = { bus.get_object(busname, path): properties
376
for path, properties in mandos_clients.items() }
445
378
for name in options.client:
446
379
for path, client in mandos_clients.items():
449
382
clients[client_objc] = client
452
log.critical("Client not found on server: %r", name)
385
print("Client not found on server: {!r}"
386
.format(name), file=sys.stderr)
455
389
if not has_actions(options) and clients:
456
if options.verbose or options.dump_json:
457
keywords = ("Name", "Enabled", "Timeout", "LastCheckedOK",
458
"Created", "Interval", "Host", "KeyID",
459
"Fingerprint", "CheckerRunning",
391
keywords = ("Name", "Enabled", "Timeout",
392
"LastCheckedOK", "Created", "Interval",
393
"Host", "Fingerprint", "CheckerRunning",
460
394
"LastEnabled", "ApprovalPending",
461
"ApprovedByDefault", "LastApprovalRequest",
462
"ApprovalDelay", "ApprovalDuration",
463
"Checker", "ExtendedTimeout", "Expires",
396
"LastApprovalRequest", "ApprovalDelay",
397
"ApprovalDuration", "Checker",
466
400
keywords = defaultkeywords
468
if options.dump_json:
469
json.dump({client["Name"]: {key:
471
if isinstance(client[key],
475
for client in clients.values()},
476
fp=sys.stdout, indent=4,
477
separators=(',', ': '))
480
print_clients(clients.values(), keywords)
402
print_clients(clients.values(), keywords)
482
404
# Process each client in the list by all selected options
483
405
for client in clients:
485
406
def set_client_prop(prop, value):
486
407
"""Set a Client D-Bus property"""
487
408
client.Set(client_interface, prop, value,
488
409
dbus_interface=dbus.PROPERTIES_IFACE)
490
410
def set_client_prop_ms(prop, value):
491
411
"""Set a Client D-Bus property, converted
492
412
from a string to milliseconds."""
493
413
set_client_prop(prop,
494
string_to_delta(value).total_seconds()
414
timedelta_to_milliseconds
415
(string_to_delta(value)))
497
416
if options.remove:
498
417
mandos_serv.RemoveClient(client.__dbus_object_path__)
499
418
if options.enable:
507
426
if options.stop_checker:
508
427
set_client_prop("CheckerRunning", dbus.Boolean(False))
509
428
if options.is_enabled:
510
if client.Get(client_interface, "Enabled",
511
dbus_interface=dbus.PROPERTIES_IFACE):
429
sys.exit(0 if client.Get(client_interface,
432
dbus.PROPERTIES_IFACE)
515
434
if options.checker is not None:
516
435
set_client_prop("Checker", options.checker)
517
436
if options.host is not None:
543
462
client.Approve(dbus.Boolean(False),
544
463
dbus_interface=client_interface)
547
class Test_milliseconds_to_string(unittest.TestCase):
549
self.assertEqual(milliseconds_to_string(93785000),
551
def test_no_days(self):
552
self.assertEqual(milliseconds_to_string(7385000), "02:03:05")
553
def test_all_zero(self):
554
self.assertEqual(milliseconds_to_string(0), "00:00:00")
555
def test_no_fractional_seconds(self):
556
self.assertEqual(milliseconds_to_string(400), "00:00:00")
557
self.assertEqual(milliseconds_to_string(900), "00:00:00")
558
self.assertEqual(milliseconds_to_string(1900), "00:00:01")
561
def should_only_run_tests():
562
parser = argparse.ArgumentParser(add_help=False)
563
parser.add_argument("--check", action='store_true')
564
args, unknown_args = parser.parse_known_args()
565
run_tests = args.check
567
# Remove --check argument from sys.argv
568
sys.argv[1:] = unknown_args
571
# Add all tests from doctest strings
572
def load_tests(loader, tests, none):
574
tests.addTests(doctest.DocTestSuite())
577
465
if __name__ == "__main__":
578
if should_only_run_tests():
579
# Call using ./tdd-python-script --check [--verbose]