45
35
properties and calls a hook function when any of them are
48
def __init__(self, proxy_object=None, *args, **kwargs):
38
def __init__(self, proxy_object=None, properties=None, *args,
49
40
self.proxy = proxy_object # Mandos Client proxy object
51
self.properties = dict()
52
self.proxy.connect_to_signal(u"PropertyChanged",
42
if properties is None:
43
self.properties = dict()
45
self.properties = properties
46
self.proxy.connect_to_signal("PropertyChanged",
53
47
self.property_changed,
57
self.properties.update(
58
self.proxy.GetAll(client_interface,
59
dbus_interface = dbus.PROPERTIES_IFACE))
51
if properties is None:
52
self.properties.update(self.proxy.GetAll(client_interface,
54
dbus.PROPERTIES_IFACE))
60
55
super(MandosClientPropertyCache, self).__init__(
61
proxy_object=proxy_object, *args, **kwargs)
56
proxy_object=proxy_object,
57
properties=properties, *args, **kwargs)
63
59
def property_changed(self, property=None, value=None):
64
60
"""This is called whenever we get a PropertyChanged signal
75
71
def __init__(self, server_proxy_object=None, update_hook=None,
76
delete_hook=None, logger=None, *args, **kwargs):
72
delete_hook=None, *args, **kwargs):
78
74
self.update_hook = update_hook
80
76
self.delete_hook = delete_hook
81
77
# Mandos Server proxy object
82
78
self.server_proxy_object = server_proxy_object
86
80
# The widget shown normally
87
self._text_widget = urwid.Text(u"")
81
self._text_widget = urwid.Text("")
88
82
# The widget shown when we have focus
89
self._focus_text_widget = urwid.Text(u"")
83
self._focus_text_widget = urwid.Text("")
90
84
super(MandosClientWidget, self).__init__(
91
85
update_hook=update_hook, delete_hook=delete_hook,
94
88
self.opened = False
95
self.proxy.connect_to_signal(u"CheckerCompleted",
96
self.checker_completed,
99
self.proxy.connect_to_signal(u"CheckerStarted",
100
self.checker_started,
103
self.proxy.connect_to_signal(u"GotSecret",
107
self.proxy.connect_to_signal(u"NeedApproval",
111
self.proxy.connect_to_signal(u"Rejected",
116
def checker_completed(self, exitstatus, condition, command):
118
#self.logger(u'Checker for client %s (command "%s")'
120
# % (self.properties[u"name"], command))
122
if os.WIFEXITED(condition):
123
self.logger(u'Checker for client %s (command "%s")'
124
u' failed with exit code %s'
125
% (self.properties[u"name"], command,
126
os.WEXITSTATUS(condition)))
128
if os.WIFSIGNALED(condition):
129
self.logger(u'Checker for client %s (command "%s")'
130
u' was killed by signal %s'
131
% (self.properties[u"name"], command,
132
os.WTERMSIG(condition)))
134
if os.WCOREDUMP(condition):
135
self.logger(u'Checker for client %s (command "%s")'
137
% (self.properties[u"name"], command))
138
self.logger(u'Checker for client %s completed mysteriously')
140
def checker_started(self, command):
141
#self.logger(u'Client %s started checker "%s"'
142
# % (self.properties[u"name"], unicode(command)))
145
def got_secret(self):
146
self.logger(u'Client %s received its secret'
147
% self.properties[u"name"])
149
def need_approval(self, timeout, default):
151
message = u'Client %s needs approval within %s seconds'
153
message = u'Client %s will get its secret in %s seconds'
155
% (self.properties[u"name"], timeout/1000))
157
def rejected(self, reason):
158
self.logger(u'Client %s was rejected; reason: %s'
159
% (self.properties[u"name"], reason))
161
90
def selectable(self):
162
91
"""Make this a "selectable" widget.
188
117
# Rebuild focus and non-focus widgets using current properties
189
self._text = (u'%(name)s: %(enabled)s'
190
% { u"name": self.properties[u"name"],
193
if self.properties[u"enabled"]
118
self._text = (u'name="%(name)s", enabled=%(enabled)s'
195
120
if not urwid.supports_unicode():
196
121
self._text = self._text.encode("ascii", "replace")
197
textlist = [(u"normal", self._text)]
122
textlist = [(u"normal", u"BLARGH: "), (u"bold", self._text)]
198
123
self._text_widget.set_text(textlist)
199
124
self._focus_text_widget.set_text([(with_standout[text[0]],
329
250
self.log_wrap = u"any"
332
self.log_message_raw((u"bold",
333
u"Mandos Monitor version " + version))
334
self.log_message_raw((u"bold",
253
self.log_message((u"bold",
254
u"Mandos Monitor version " + version))
255
self.log_message((u"bold",
337
258
self.busname = domain + '.Mandos'
338
259
self.main_loop = gobject.MainLoop()
349
270
mandos_clients = dbus.Dictionary()
351
272
(self.mandos_serv
352
.connect_to_signal(u"ClientRemoved",
273
.connect_to_signal("ClientRemoved",
353
274
self.find_and_remove_client,
354
275
dbus_interface=server_interface,
355
276
byte_arrays=True))
356
277
(self.mandos_serv
357
.connect_to_signal(u"ClientAdded",
278
.connect_to_signal("ClientAdded",
358
279
self.add_new_client,
359
280
dbus_interface=server_interface,
360
281
byte_arrays=True))
362
.connect_to_signal(u"ClientNotFound",
363
self.client_not_found,
364
dbus_interface=server_interface,
366
282
for path, client in mandos_clients.iteritems():
367
283
client_proxy_object = self.bus.get_object(self.busname,
399
308
self.topwidget = urwid.Pile(self.uilist)
401
def log_message(self, message):
402
timestamp = datetime.datetime.now().isoformat()
403
self.log_message_raw(timestamp + u": " + message)
405
def log_message_raw(self, markup):
310
def log_message(self, markup):
406
311
"""Add a log message to the log buffer."""
407
312
self.log.append(urwid.Text(markup, wrap=self.log_wrap))
408
313
if (self.max_log_length
409
314
and len(self.log) > self.max_log_length):
410
315
del self.log[0:len(self.log)-self.max_log_length-1]
411
self.logbox.set_focus(len(self.logbox.body.contents),
412
coming_from=u"above")
415
317
def toggle_log_display(self):
416
318
"""Toggle visibility of the log buffer."""
528
429
elif key == u"w" or key == u"i":
529
430
self.change_log_display()
531
elif key == u"?" or key == u"f1" or key == u"esc":
432
elif key == u"?" or key == u"f1":
532
433
if not self.log_visible:
533
434
self.log_visible = True
535
self.log_message_raw((u"bold",
539
u"l: Log window toggle",
540
u"TAB: Switch window",
542
self.log_message_raw((u"bold",
548
u"s: Start new checker",
436
self.log_message((u"bold",
437
u" ".join((u"q: Quit",
439
u"l: Log window toggle",
440
u"TAB: Switch window",
442
self.log_message((u"bold",
443
u" ".join((u"Clients:",
447
u"s: Start new checker",
552
451
elif key == u"tab":
553
452
if self.topwidget.get_focus() is self.logbox: