17
17
# GNU General Public License for more details.
19
19
# You should have received a copy of the GNU General Public License
20
# along with this program. If not, see
21
# <http://www.gnu.org/licenses/>.
20
# along with this program. If not, see <http://www.gnu.org/licenses/>.
23
# Contact the authors at <mandos@recompile.se>.
22
# Contact the authors at <mandos@fukt.bsnet.se>.
26
from __future__ import (division, absolute_import, print_function,
25
from __future__ import division, absolute_import, with_statement
47
locale.setlocale(locale.LC_ALL, '')
45
locale.setlocale(locale.LC_ALL, u'')
50
logging.getLogger('dbus.proxies').setLevel(logging.CRITICAL)
48
logging.getLogger(u'dbus.proxies').setLevel(logging.CRITICAL)
52
50
# Some useful constants
53
domain = 'se.recompile'
54
server_interface = domain + '.Mandos'
55
client_interface = domain + '.Mandos.Client'
51
domain = u'se.bsnet.fukt'
52
server_interface = domain + u'.Mandos'
53
client_interface = domain + u'.Mandos.Client'
58
56
# Always run in monochrome mode
59
57
urwid.curses_display.curses.has_colors = lambda : False
67
65
"Parse an ISO 8601 date string to a datetime.datetime()"
70
d, t = iso.split("T", 1)
71
year, month, day = d.split("-", 2)
72
hour, minute, second = t.split(":", 2)
68
d, t = iso.split(u"T", 1)
69
year, month, day = d.split(u"-", 2)
70
hour, minute, second = t.split(u":", 2)
73
71
second, fraction = divmod(float(second), 1)
74
72
return datetime.datetime(int(year),
88
86
self.proxy = proxy_object # Mandos Client proxy object
90
88
self.properties = dict()
91
self.property_changed_match = (
92
self.proxy.connect_to_signal("PropertyChanged",
93
self.property_changed,
89
self.proxy.connect_to_signal(u"PropertyChanged",
90
self.property_changed,
97
94
self.properties.update(
98
95
self.proxy.GetAll(client_interface,
99
96
dbus_interface = dbus.PROPERTIES_IFACE))
101
#XXX This breaks good super behaviour
98
#XXX This break good super behaviour!
102
99
# super(MandosClientPropertyCache, self).__init__(
103
100
# *args, **kwargs)
133
125
self._update_timer_callback_tag = None
134
126
self._update_timer_callback_lock = 0
127
self.last_checker_failed = False
136
129
# The widget shown normally
137
self._text_widget = urwid.Text("")
130
self._text_widget = urwid.Text(u"")
138
131
# The widget shown when we have focus
139
self._focus_text_widget = urwid.Text("")
132
self._focus_text_widget = urwid.Text(u"")
140
133
super(MandosClientWidget, self).__init__(
141
134
update_hook=update_hook, delete_hook=delete_hook,
144
137
self.opened = False
146
139
last_checked_ok = isoformat_to_datetime(self.properties
141
if last_checked_ok is None:
142
self.last_checker_failed = True
144
self.last_checker_failed = ((datetime.datetime.utcnow()
149
if self.properties ["LastCheckerStatus"] != 0:
151
if self.last_checker_failed:
150
152
self.using_timer(True)
152
154
if self.need_approval:
153
155
self.using_timer(True)
155
self.match_objects = (
156
self.proxy.connect_to_signal("CheckerCompleted",
157
self.checker_completed,
160
self.proxy.connect_to_signal("CheckerStarted",
161
self.checker_started,
164
self.proxy.connect_to_signal("GotSecret",
168
self.proxy.connect_to_signal("NeedApproval",
172
self.proxy.connect_to_signal("Rejected",
176
#self.logger('Created client {0}'
177
# .format(self.properties["Name"]))
157
self.proxy.connect_to_signal(u"CheckerCompleted",
158
self.checker_completed,
161
self.proxy.connect_to_signal(u"CheckerStarted",
162
self.checker_started,
165
self.proxy.connect_to_signal(u"GotSecret",
169
self.proxy.connect_to_signal(u"NeedApproval",
173
self.proxy.connect_to_signal(u"Rejected",
179
178
def property_changed(self, property=None, value=None):
180
179
super(self, MandosClientWidget).property_changed(property,
182
if property == "ApprovalPending":
181
if property == u"ApprovalPending":
183
182
using_timer(bool(value))
184
if property == "LastCheckerStatus":
185
using_timer(value != 0)
186
#self.logger('Checker for client {0} (command "{1}") was '
187
# ' successful'.format(self.properties["Name"],
190
184
def using_timer(self, flag):
191
185
"""Call this method with True or False when timer should be
192
186
activated or deactivated.
208
201
def checker_completed(self, exitstatus, condition, command):
209
202
if exitstatus == 0:
203
if self.last_checker_failed:
204
self.last_checker_failed = False
205
self.using_timer(False)
206
#self.logger(u'Checker for client %s (command "%s")'
208
# % (self.properties[u"Name"], command))
212
if not self.last_checker_failed:
213
self.last_checker_failed = True
214
self.using_timer(True)
213
215
if os.WIFEXITED(condition):
214
self.logger('Checker for client {0} (command "{1}")'
215
' failed with exit code {2}'
216
.format(self.properties["Name"], command,
217
os.WEXITSTATUS(condition)))
216
self.logger(u'Checker for client %s (command "%s")'
217
u' failed with exit code %s'
218
% (self.properties[u"Name"], command,
219
os.WEXITSTATUS(condition)))
218
220
elif os.WIFSIGNALED(condition):
219
self.logger('Checker for client {0} (command "{1}") was'
220
' killed by signal {2}'
221
.format(self.properties["Name"], command,
222
os.WTERMSIG(condition)))
221
self.logger(u'Checker for client %s (command "%s")'
222
u' was killed by signal %s'
223
% (self.properties[u"Name"], command,
224
os.WTERMSIG(condition)))
223
225
elif os.WCOREDUMP(condition):
224
self.logger('Checker for client {0} (command "{1}")'
226
.format(self.properties["Name"], command))
226
self.logger(u'Checker for client %s (command "%s")'
228
% (self.properties[u"Name"], command))
228
self.logger('Checker for client {0} completed'
230
.format(self.properties["Name"]))
230
self.logger(u'Checker for client %s completed'
233
234
def checker_started(self, command):
234
"""Server signals that a checker started. This could be useful
235
to log in the future. """
236
#self.logger('Client {0} started checker "{1}"'
237
# .format(self.properties["Name"],
235
#self.logger(u'Client %s started checker "%s"'
236
# % (self.properties[u"Name"], unicode(command)))
241
239
def got_secret(self):
242
self.logger('Client {0} received its secret'
243
.format(self.properties["Name"]))
240
self.last_checker_failed = False
241
self.logger(u'Client %s received its secret'
242
% self.properties[u"Name"])
245
244
def need_approval(self, timeout, default):
247
message = 'Client {0} needs approval within {1} seconds'
246
message = u'Client %s needs approval within %s seconds'
249
message = 'Client {0} will get its secret in {1} seconds'
250
self.logger(message.format(self.properties["Name"],
248
message = u'Client %s will get its secret in %s seconds'
250
% (self.properties[u"Name"], timeout/1000))
252
251
self.using_timer(True)
254
253
def rejected(self, reason):
255
self.logger('Client {0} was rejected; reason: {1}'
256
.format(self.properties["Name"], reason))
254
self.logger(u'Client %s was rejected; reason: %s'
255
% (self.properties[u"Name"], reason))
258
257
def selectable(self):
259
258
"""Make this a "selectable" widget.
274
273
def update(self):
275
274
"Called when what is visible on the screen should be updated."
276
275
# How to add standout mode to a style
277
with_standout = { "normal": "standout",
278
"bold": "bold-standout",
280
"underline-blink-standout",
281
"bold-underline-blink":
282
"bold-underline-blink-standout",
276
with_standout = { u"normal": u"standout",
277
u"bold": u"bold-standout",
279
u"underline-blink-standout",
280
u"bold-underline-blink":
281
u"bold-underline-blink-standout",
285
284
# Rebuild focus and non-focus widgets using current properties
287
286
# Base part of a client. Name!
288
base = '{name}: '.format(name=self.properties["Name"])
289
if not self.properties["Enabled"]:
291
elif self.properties["ApprovalPending"]:
287
base = (u'%(name)s: '
288
% {u"name": self.properties[u"Name"]})
289
if not self.properties[u"Enabled"]:
290
message = u"DISABLED"
291
elif self.properties[u"ApprovalPending"]:
292
292
timeout = datetime.timedelta(milliseconds
293
293
= self.properties
295
295
last_approval_request = isoformat_to_datetime(
296
self.properties["LastApprovalRequest"])
296
self.properties[u"LastApprovalRequest"])
297
297
if last_approval_request is not None:
298
298
timer = timeout - (datetime.datetime.utcnow()
299
299
- last_approval_request)
301
301
timer = datetime.timedelta()
302
if self.properties["ApprovedByDefault"]:
303
message = "Approval in {0}. (d)eny?"
305
message = "Denial in {0}. (a)pprove?"
306
message = message.format(unicode(timer).rsplit(".", 1)[0])
307
elif self.properties["LastCheckerStatus"] != 0:
308
# When checker has failed, show timer until client expires
309
expires = self.properties["Expires"]
311
timer = datetime.timedelta(0)
313
expires = (datetime.datetime.strptime
314
(expires, '%Y-%m-%dT%H:%M:%S.%f'))
315
timer = expires - datetime.datetime.utcnow()
316
message = ('A checker has failed! Time until client'
317
' gets disabled: {0}'
318
.format(unicode(timer).rsplit(".", 1)[0]))
302
if self.properties[u"ApprovedByDefault"]:
303
message = u"Approval in %s. (d)eny?"
305
message = u"Denial in %s. (a)pprove?"
306
message = message % unicode(timer).rsplit(".", 1)[0]
307
elif self.last_checker_failed:
308
timeout = datetime.timedelta(milliseconds
311
last_ok = isoformat_to_datetime(
312
max((self.properties[u"LastCheckedOK"]
313
or self.properties[u"Created"]),
314
self.properties[u"LastEnabled"]))
315
timer = timeout - (datetime.datetime.utcnow() - last_ok)
316
message = (u'A checker has failed! Time until client'
317
u' gets disabled: %s'
318
% unicode(timer).rsplit(".", 1)[0])
321
self._text = "{0}{1}".format(base, message)
321
self._text = u"%s%s" % (base, message)
323
323
if not urwid.supports_unicode():
324
self._text = self._text.encode("ascii", "replace")
325
textlist = [("normal", self._text)]
324
self._text = self._text.encode(u"ascii", u"replace")
325
textlist = [(u"normal", self._text)]
326
326
self._text_widget.set_text(textlist)
327
327
self._focus_text_widget.set_text([(with_standout[text[0]],
331
331
for text in textlist])
332
332
self._widget = self._text_widget
333
333
self._focus_widget = urwid.AttrWrap(self._focus_text_widget,
335
335
# Run update hook, if any
336
336
if self.update_hook is not None:
337
337
self.update_hook()
339
339
def update_timer(self):
340
"""called by gobject. Will indefinitely loop until
341
gobject.source_remove() on tag is called"""
343
342
return True # Keep calling this
345
def delete(self, *args, **kwargs):
346
345
if self._update_timer_callback_tag is not None:
347
346
gobject.source_remove(self._update_timer_callback_tag)
348
347
self._update_timer_callback_tag = None
349
for match in self.match_objects:
351
self.match_objects = ()
352
348
if self.delete_hook is not None:
353
349
self.delete_hook(self)
354
return super(MandosClientWidget, self).delete(*args, **kwargs)
356
351
def render(self, maxcolrow, focus=False):
357
352
"""Render differently if we have focus.
362
357
def keypress(self, maxcolrow, key):
364
359
This overrides the method from urwid.FlowWidget"""
366
self.proxy.Enable(dbus_interface = client_interface,
369
self.proxy.Disable(dbus_interface = client_interface,
361
self.proxy.Enable(dbus_interface = client_interface)
363
self.proxy.Disable(dbus_interface = client_interface)
372
365
self.proxy.Approve(dbus.Boolean(True, variant_level=1),
373
dbus_interface = client_interface,
366
dbus_interface = client_interface)
376
368
self.proxy.Approve(dbus.Boolean(False, variant_level=1),
377
dbus_interface = client_interface,
379
elif key == "R" or key == "_" or key == "ctrl k":
369
dbus_interface = client_interface)
370
elif key == u"R" or key == u"_" or key == u"ctrl k":
380
371
self.server_proxy_object.RemoveClient(self.proxy
384
self.proxy.StartChecker(dbus_interface = client_interface,
387
self.proxy.StopChecker(dbus_interface = client_interface,
390
self.proxy.CheckedOK(dbus_interface = client_interface,
374
self.proxy.StartChecker(dbus_interface = client_interface)
376
self.proxy.StopChecker(dbus_interface = client_interface)
378
self.proxy.CheckedOK(dbus_interface = client_interface)
393
# elif key == "p" or key == "=":
380
# elif key == u"p" or key == "=":
394
381
# self.proxy.pause()
395
# elif key == "u" or key == ":":
382
# elif key == u"u" or key == ":":
396
383
# self.proxy.unpause()
384
# elif key == u"RET":
433
420
self.screen = urwid.curses_display.Screen()
435
422
self.screen.register_palette((
437
"default", "default", None),
439
"default", "default", "bold"),
441
"default", "default", "underline"),
443
"default", "default", "standout"),
444
("bold-underline-blink",
445
"default", "default", ("bold", "underline")),
447
"default", "default", ("bold", "standout")),
448
("underline-blink-standout",
449
"default", "default", ("underline", "standout")),
450
("bold-underline-blink-standout",
451
"default", "default", ("bold", "underline",
424
u"default", u"default", None),
426
u"default", u"default", u"bold"),
428
u"default", u"default", u"underline"),
430
u"default", u"default", u"standout"),
431
(u"bold-underline-blink",
432
u"default", u"default", (u"bold", u"underline")),
434
u"default", u"default", (u"bold", u"standout")),
435
(u"underline-blink-standout",
436
u"default", u"default", (u"underline", u"standout")),
437
(u"bold-underline-blink-standout",
438
u"default", u"default", (u"bold", u"underline",
455
442
if urwid.supports_unicode():
456
self.divider = "─" # \u2500
457
#self.divider = "━" # \u2501
443
self.divider = u"─" # \u2500
444
#self.divider = u"━" # \u2501
459
#self.divider = "-" # \u002d
460
self.divider = "_" # \u005f
446
#self.divider = u"-" # \u002d
447
self.divider = u"_" # \u005f
462
449
self.screen.start()
477
464
# This keeps track of whether self.uilist currently has
478
465
# self.logbox in it or not
479
466
self.log_visible = True
480
self.log_wrap = "any"
467
self.log_wrap = u"any"
483
self.log_message_raw(("bold",
484
"Mandos Monitor version " + version))
485
self.log_message_raw(("bold",
470
self.log_message_raw((u"bold",
471
u"Mandos Monitor version " + version))
472
self.log_message_raw((u"bold",
488
475
self.busname = domain + '.Mandos'
489
476
self.main_loop = gobject.MainLoop()
477
self.bus = dbus.SystemBus()
478
mandos_dbus_objc = self.bus.get_object(
479
self.busname, u"/", follow_name_owner_changes=True)
480
self.mandos_serv = dbus.Interface(mandos_dbus_objc,
484
mandos_clients = (self.mandos_serv
485
.GetAllClientsWithProperties())
486
except dbus.exceptions.DBusException:
487
mandos_clients = dbus.Dictionary()
490
.connect_to_signal(u"ClientRemoved",
491
self.find_and_remove_client,
492
dbus_interface=server_interface,
495
.connect_to_signal(u"ClientAdded",
497
dbus_interface=server_interface,
500
.connect_to_signal(u"ClientNotFound",
501
self.client_not_found,
502
dbus_interface=server_interface,
504
for path, client in mandos_clients.iteritems():
505
client_proxy_object = self.bus.get_object(self.busname,
507
self.add_client(MandosClientWidget(server_proxy_object
510
=client_proxy_object,
491
520
def client_not_found(self, fingerprint, address):
492
self.log_message("Client with address {0} and fingerprint"
493
" {1} could not be found"
494
.format(address, fingerprint))
521
self.log_message((u"Client with address %s and fingerprint %s"
522
u" could not be found" % (address,
496
525
def rebuild(self):
497
526
"""This rebuilds the User Interface.
520
550
and len(self.log) > self.max_log_length):
521
551
del self.log[0:len(self.log)-self.max_log_length-1]
522
552
self.logbox.set_focus(len(self.logbox.body.contents),
553
coming_from=u"above")
526
556
def toggle_log_display(self):
527
557
"""Toggle visibility of the log buffer."""
528
558
self.log_visible = not self.log_visible
530
#self.log_message("Log visibility changed to: "
560
#self.log_message(u"Log visibility changed to: "
531
561
# + unicode(self.log_visible))
533
563
def change_log_display(self):
534
564
"""Change type of log display.
535
565
Currently, this toggles wrapping of text lines."""
536
if self.log_wrap == "clip":
537
self.log_wrap = "any"
566
if self.log_wrap == u"clip":
567
self.log_wrap = u"any"
539
self.log_wrap = "clip"
569
self.log_wrap = u"clip"
540
570
for textwidget in self.log:
541
571
textwidget.set_wrap_mode(self.log_wrap)
542
#self.log_message("Wrap mode: " + self.log_wrap)
572
#self.log_message(u"Wrap mode: " + self.log_wrap)
544
574
def find_and_remove_client(self, path, name):
545
"""Find a client by its object path and remove it.
575
"""Find an client from its object path and remove it.
547
577
This is connected to the ClientRemoved signal from the
548
578
Mandos server object."""
598
626
"""Start the main loop and exit when it's done."""
599
self.bus = dbus.SystemBus()
600
mandos_dbus_objc = self.bus.get_object(
601
self.busname, "/", follow_name_owner_changes=True)
602
self.mandos_serv = dbus.Interface(mandos_dbus_objc,
606
mandos_clients = (self.mandos_serv
607
.GetAllClientsWithProperties())
608
except dbus.exceptions.DBusException:
609
mandos_clients = dbus.Dictionary()
612
.connect_to_signal("ClientRemoved",
613
self.find_and_remove_client,
614
dbus_interface=server_interface,
617
.connect_to_signal("ClientAdded",
619
dbus_interface=server_interface,
622
.connect_to_signal("ClientNotFound",
623
self.client_not_found,
624
dbus_interface=server_interface,
626
for path, client in mandos_clients.iteritems():
627
client_proxy_object = self.bus.get_object(self.busname,
629
self.add_client(MandosClientWidget(server_proxy_object
632
=client_proxy_object,
643
628
self._input_callback_tag = (gobject.io_add_watch
644
629
(sys.stdin.fileno(),
655
640
def process_input(self, source, condition):
656
641
keys = self.screen.get_input()
657
translations = { "ctrl n": "down", # Emacs
658
"ctrl p": "up", # Emacs
659
"ctrl v": "page down", # Emacs
660
"meta v": "page up", # Emacs
661
" ": "page down", # less
662
"f": "page down", # less
663
"b": "page up", # less
642
translations = { u"ctrl n": u"down", # Emacs
643
u"ctrl p": u"up", # Emacs
644
u"ctrl v": u"page down", # Emacs
645
u"meta v": u"page up", # Emacs
646
u" ": u"page down", # less
647
u"f": u"page down", # less
648
u"b": u"page up", # less
670
655
except KeyError: # :-)
673
if key == "q" or key == "Q":
658
if key == u"q" or key == u"Q":
676
elif key == "window resize":
661
elif key == u"window resize":
677
662
self.size = self.screen.get_cols_rows()
679
elif key == "\f": # Ctrl-L
664
elif key == u"\f": # Ctrl-L
681
elif key == "l" or key == "D":
666
elif key == u"l" or key == u"D":
682
667
self.toggle_log_display()
684
elif key == "w" or key == "i":
669
elif key == u"w" or key == u"i":
685
670
self.change_log_display()
687
elif key == "?" or key == "f1" or key == "esc":
672
elif key == u"?" or key == u"f1" or key == u"esc":
688
673
if not self.log_visible:
689
674
self.log_visible = True
691
self.log_message_raw(("bold",
695
"l: Log window toggle",
696
"TAB: Switch window",
698
self.log_message_raw(("bold",
704
"s: Start new checker",
676
self.log_message_raw((u"bold",
680
u"l: Log window toggle",
681
u"TAB: Switch window",
683
self.log_message_raw((u"bold",
689
u"s: Start new checker",
711
696
if self.topwidget.get_focus() is self.logbox:
712
697
self.topwidget.set_focus(0)
714
699
self.topwidget.set_focus(self.logbox)
716
#elif (key == "end" or key == "meta >" or key == "G"
701
#elif (key == u"end" or key == u"meta >" or key == u"G"
718
703
# pass # xxx end-of-buffer
719
#elif (key == "home" or key == "meta <" or key == "g"
704
#elif (key == u"home" or key == u"meta <" or key == u"g"
721
706
# pass # xxx beginning-of-buffer
722
#elif key == "ctrl e" or key == "$":
707
#elif key == u"ctrl e" or key == u"$":
723
708
# pass # xxx move-end-of-line
724
#elif key == "ctrl a" or key == "^":
709
#elif key == u"ctrl a" or key == u"^":
725
710
# pass # xxx move-beginning-of-line
726
#elif key == "ctrl b" or key == "meta (" or key == "h":
711
#elif key == u"ctrl b" or key == u"meta (" or key == u"h":
727
712
# pass # xxx left
728
#elif key == "ctrl f" or key == "meta )" or key == "l":
713
#elif key == u"ctrl f" or key == u"meta )" or key == u"l":
729
714
# pass # xxx right
731
716
# pass # scroll up log
733
718
# pass # scroll down log
734
719
elif self.topwidget.selectable():
735
720
self.topwidget.keypress(self.size, key)