35
42
properties and calls a hook function when any of them are
38
def __init__(self, proxy_object=None, properties=None, *args,
45
def __init__(self, proxy_object=None, *args, **kwargs):
40
46
self.proxy = proxy_object # Mandos Client proxy object
42
if properties is None:
43
self.properties = dict()
45
self.properties = properties
46
self.proxy.connect_to_signal("PropertyChanged",
48
self.properties = dict()
49
self.proxy.connect_to_signal(u"PropertyChanged",
47
50
self.property_changed,
51
if properties is None:
52
self.properties.update(self.proxy.GetAll(client_interface,
54
dbus.PROPERTIES_IFACE))
54
self.properties.update(
55
self.proxy.GetAll(client_interface,
56
dbus_interface = dbus.PROPERTIES_IFACE))
55
57
super(MandosClientPropertyCache, self).__init__(
56
proxy_object=proxy_object,
57
properties=properties, *args, **kwargs)
58
proxy_object=proxy_object, *args, **kwargs)
59
60
def property_changed(self, property=None, value=None):
60
61
"""This is called whenever we get a PropertyChanged signal
71
72
def __init__(self, server_proxy_object=None, update_hook=None,
72
delete_hook=None, *args, **kwargs):
73
delete_hook=None, logger=None, *args, **kwargs):
74
75
self.update_hook = update_hook
76
77
self.delete_hook = delete_hook
77
78
# Mandos Server proxy object
78
79
self.server_proxy_object = server_proxy_object
80
83
# The widget shown normally
81
self._text_widget = urwid.Text("")
84
self._text_widget = urwid.Text(u"")
82
85
# The widget shown when we have focus
83
self._focus_text_widget = urwid.Text("")
86
self._focus_text_widget = urwid.Text(u"")
84
87
super(MandosClientWidget, self).__init__(
85
88
update_hook=update_hook, delete_hook=delete_hook,
88
91
self.opened = False
92
self.proxy.connect_to_signal(u"CheckerCompleted",
93
self.checker_completed,
96
self.proxy.connect_to_signal(u"CheckerStarted",
100
self.proxy.connect_to_signal(u"GotSecret",
104
self.proxy.connect_to_signal(u"Rejected",
109
def checker_completed(self, exitstatus, condition, command):
111
self.logger(u'Checker for client %s (command "%s")'
113
% (self.properties[u"name"], command))
115
if os.WIFEXITED(condition):
116
self.logger(u'Checker for client %s (command "%s")'
117
u' failed with exit code %s'
118
% (self.properties[u"name"], command,
119
os.WEXITSTATUS(condition)))
121
if os.WIFSIGNALED(condition):
122
self.logger(u'Checker for client %s (command "%s")'
123
u' was killed by signal %s'
124
% (self.properties[u"name"], command,
125
os.WTERMSIG(condition)))
127
if os.WCOREDUMP(condition):
128
self.logger(u'Checker for client %s (command "%s")'
130
% (self.properties[u"name"], command))
131
self.logger(u'Checker for client %s completed mysteriously')
133
def checker_started(self, command):
134
self.logger(u'Client %s started checker "%s"'
135
% (self.properties[u"name"], unicode(command)))
137
def got_secret(self):
138
self.logger(u'Client %s received its secret'
139
% self.properties[u"name"])
142
self.logger(u'Client %s was rejected'
143
% self.properties[u"name"])
90
145
def selectable(self):
91
146
"""Make this a "selectable" widget.
117
172
# Rebuild focus and non-focus widgets using current properties
118
self._text = (u'name="%(name)s", enabled=%(enabled)s'
173
self._text = (u'%(name)s: %(enabled)s'
174
% { u"name": self.properties[u"name"],
177
if self.properties[u"enabled"]
120
179
if not urwid.supports_unicode():
121
180
self._text = self._text.encode("ascii", "replace")
122
textlist = [(u"normal", u"BLARGH: "), (u"bold", self._text)]
181
textlist = [(u"normal", self._text)]
123
182
self._text_widget.set_text(textlist)
124
183
self._focus_text_widget.set_text([(with_standout[text[0]],
250
309
self.log_wrap = u"any"
253
self.log_message(u"Message")
254
self.log_message(u"Message0 Message1 Message2 Message3 Message4 Message5 Message6 Message7 Message8 Message9")
255
self.log_message(u"Message10 Message11 Message12 Message13 Message14 Message15 Message16 Message17 Message18 Message19")
256
self.log_message(u"Message20 Message21 Message22 Message23 Message24 Message25 Message26 Message27 Message28 Message29")
312
self.log_message_raw((u"bold",
313
u"Mandos Monitor version " + version))
314
self.log_message_raw((u"bold",
258
317
self.busname = domain + '.Mandos'
259
318
self.main_loop = gobject.MainLoop()
270
329
mandos_clients = dbus.Dictionary()
272
331
(self.mandos_serv
273
.connect_to_signal("ClientRemoved",
332
.connect_to_signal(u"ClientRemoved",
274
333
self.find_and_remove_client,
275
334
dbus_interface=server_interface,
276
335
byte_arrays=True))
277
336
(self.mandos_serv
278
.connect_to_signal("ClientAdded",
337
.connect_to_signal(u"ClientAdded",
279
338
self.add_new_client,
280
339
dbus_interface=server_interface,
281
340
byte_arrays=True))
342
.connect_to_signal(u"ClientNotFound",
343
self.client_not_found,
344
dbus_interface=server_interface,
282
346
for path, client in mandos_clients.iteritems():
283
347
client_proxy_object = self.bus.get_object(self.busname,
308
379
self.topwidget = urwid.Pile(self.uilist)
310
def log_message(self, markup):
381
def log_message(self, message):
382
timestamp = datetime.datetime.now().isoformat()
383
self.log_message_raw(timestamp + u": " + message)
385
def log_message_raw(self, markup):
311
386
"""Add a log message to the log buffer."""
312
387
self.log.append(urwid.Text(markup, wrap=self.log_wrap))
313
388
if (self.max_log_length
314
389
and len(self.log) > self.max_log_length):
315
390
del self.log[0:len(self.log)-self.max_log_length-1]
391
self.logbox.set_focus(len(self.logbox.body.contents),
392
coming_from=u"above")
317
395
def toggle_log_display(self):
318
396
"""Toggle visibility of the log buffer."""
345
423
self.remove_client(client, path)
347
def add_new_client(self, path, properties):
425
def add_new_client(self, path):
348
426
client_proxy_object = self.bus.get_object(self.busname, path)
349
427
self.add_client(MandosClientWidget(server_proxy_object
350
428
=self.mandos_serv,
352
430
=client_proxy_object,
353
properties=properties,
357
=self.remove_client),
360
439
def add_client(self, client, path=None):
429
508
elif key == u"w" or key == u"i":
430
509
self.change_log_display()
432
elif key == u"?" or key == u"f1":
433
self.log_message(u"Help!")
511
elif key == u"?" or key == u"f1" or key == u"esc":
512
if not self.log_visible:
513
self.log_visible = True
515
self.log_message_raw((u"bold",
519
u"l: Log window toggle",
520
u"TAB: Switch window",
522
self.log_message_raw((u"bold",
528
u"s: Start new checker",
435
532
elif key == u"tab":
436
533
if self.topwidget.get_focus() is self.logbox:
439
536
self.topwidget.set_focus(self.logbox)
441
elif (key == u"end" or key == u"meta >" or key == u"G"
443
pass # xxx end-of-buffer
444
elif (key == u"home" or key == u"meta <" or key == u"g"
446
pass # xxx beginning-of-buffer
447
elif key == u"ctrl e" or key == u"$":
448
pass # xxx move-end-of-line
449
elif key == u"ctrl a" or key == u"^":
450
pass # xxx move-beginning-of-line
451
elif key == u"ctrl b" or key == u"meta (" or key == u"h":
453
elif key == u"ctrl f" or key == u"meta )" or key == u"l":
458
pass # scroll down log
538
#elif (key == u"end" or key == u"meta >" or key == u"G"
540
# pass # xxx end-of-buffer
541
#elif (key == u"home" or key == u"meta <" or key == u"g"
543
# pass # xxx beginning-of-buffer
544
#elif key == u"ctrl e" or key == u"$":
545
# pass # xxx move-end-of-line
546
#elif key == u"ctrl a" or key == u"^":
547
# pass # xxx move-beginning-of-line
548
#elif key == u"ctrl b" or key == u"meta (" or key == u"h":
550
#elif key == u"ctrl f" or key == u"meta )" or key == u"l":
553
# pass # scroll up log
555
# pass # scroll down log
459
556
elif self.topwidget.selectable():
460
557
self.topwidget.keypress(self.size, key)