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,
40
# Type conversion mapping
42
dbus.ObjectPath: unicode,
44
dbus.Signature: unicode,
52
dbus.Dictionary: dict,
49
59
self.proxy = proxy_object # Mandos Client proxy object
51
self.properties = dict()
52
self.proxy.connect_to_signal(u"PropertyChanged",
61
if properties is None:
62
self.properties = dict()
64
self.properties = dict(self.convert_property(prop, val)
66
properties.iteritems())
67
self.proxy.connect_to_signal("PropertyChanged",
53
68
self.property_changed,
57
self.properties.update(
58
self.proxy.GetAll(client_interface,
59
dbus_interface = dbus.PROPERTIES_IFACE))
61
#XXX This break good super behaviour!
62
# super(MandosClientPropertyCache, self).__init__(
72
if properties is None:
73
self.properties.update(
74
self.convert_property(prop, val)
76
self.proxy.GetAll(client_interface,
78
dbus.PROPERTIES_IFACE).iteritems())
79
super(MandosClientPropertyCache, self).__init__(
80
proxy_object=proxy_object,
81
properties=properties, *args, **kwargs)
83
def convert_property(self, property, value):
84
"""This converts the arguments from a D-Bus signal, which are
85
D-Bus types, into normal Python types, using a conversion
86
function from "self.type_map".
88
property_name = unicode(property) # Always a dbus.String
89
if isinstance(value, dbus.UTF8String):
90
# Should not happen, but prepare for it anyway
91
value = dbus.String(str(value).decode("utf-8"))
93
convfunc = self.type_map[type(value)]
95
# Unknown type, return unmodified
96
return property_name, value
97
return property_name, convfunc(value)
65
98
def property_changed(self, property=None, value=None):
66
99
"""This is called whenever we get a PropertyChanged signal
67
100
It updates the changed property in the "properties" dict.
102
# Convert name and value
103
property_name, cvalue = self.convert_property(property, value)
69
104
# Update properties dict with new value
70
self.properties[property] = value
105
self.properties[property_name] = cvalue
73
108
class MandosClientWidget(urwid.FlowWidget, MandosClientPropertyCache):
77
112
def __init__(self, server_proxy_object=None, update_hook=None,
78
delete_hook=None, logger=None, *args, **kwargs):
113
delete_hook=None, *args, **kwargs):
79
114
# Called on update
80
115
self.update_hook = update_hook
81
116
# Called on delete
82
117
self.delete_hook = delete_hook
83
118
# Mandos Server proxy object
84
119
self.server_proxy_object = server_proxy_object
88
121
# The widget shown normally
89
self._text_widget = urwid.Text(u"")
122
self._text_widget = urwid.Text("")
90
123
# The widget shown when we have focus
91
self._focus_text_widget = urwid.Text(u"")
124
self._focus_text_widget = urwid.Text("")
92
125
super(MandosClientWidget, self).__init__(
93
126
update_hook=update_hook, delete_hook=delete_hook,
96
129
self.opened = False
97
self.proxy.connect_to_signal(u"CheckerCompleted",
98
self.checker_completed,
101
self.proxy.connect_to_signal(u"CheckerStarted",
102
self.checker_started,
105
self.proxy.connect_to_signal(u"GotSecret",
109
self.proxy.connect_to_signal(u"NeedApproval",
113
self.proxy.connect_to_signal(u"Rejected",
118
def checker_completed(self, exitstatus, condition, command):
120
#self.logger(u'Checker for client %s (command "%s")'
122
# % (self.properties[u"name"], command))
124
if os.WIFEXITED(condition):
125
self.logger(u'Checker for client %s (command "%s")'
126
u' failed with exit code %s'
127
% (self.properties[u"name"], command,
128
os.WEXITSTATUS(condition)))
130
if os.WIFSIGNALED(condition):
131
self.logger(u'Checker for client %s (command "%s")'
132
u' was killed by signal %s'
133
% (self.properties[u"name"], command,
134
os.WTERMSIG(condition)))
136
if os.WCOREDUMP(condition):
137
self.logger(u'Checker for client %s (command "%s")'
139
% (self.properties[u"name"], command))
140
self.logger(u'Checker for client %s completed mysteriously')
142
def checker_started(self, command):
143
#self.logger(u'Client %s started checker "%s"'
144
# % (self.properties[u"name"], unicode(command)))
147
def got_secret(self):
148
self.logger(u'Client %s received its secret'
149
% self.properties[u"name"])
151
def need_approval(self, timeout, default):
153
message = u'Client %s needs approval within %s seconds'
155
message = u'Client %s will get its secret in %s seconds'
157
% (self.properties[u"name"], timeout/1000))
159
def rejected(self, reason):
160
self.logger(u'Client %s was rejected; reason: %s'
161
% (self.properties[u"name"], reason))
163
131
def selectable(self):
164
132
"""Make this a "selectable" widget.
186
154
u"bold-underline-blink":
187
155
u"bold-underline-blink-standout",
190
158
# Rebuild focus and non-focus widgets using current properties
192
# Base part of a client. Name!
193
self._text = (u'%(name)s: '
194
% {u"name": self.properties[u"name"]})
196
if self.properties[u"approved_pending"]:
197
if self.properties[u"approved_by_default"]:
198
self._text += u"Connection established to client. (d)eny?"
200
self._text += u"Seeks approval to send secret. (a)pprove?"
202
self._text += (u'%(enabled)s'
205
if self.properties[u"enabled"]
159
self._text = (u'name="%(name)s", enabled=%(enabled)s'
207
161
if not urwid.supports_unicode():
208
162
self._text = self._text.encode("ascii", "replace")
209
textlist = [(u"normal", self._text)]
163
textlist = [(u"normal", u"BLÄRGH: "), (u"bold", self._text)]
210
164
self._text_widget.set_text(textlist)
211
165
self._focus_text_widget.set_text([(with_standout[text[0]],
233
187
def keypress(self, (maxcol,), key):
235
189
This overrides the method from urwid.FlowWidget"""
237
self.proxy.Enable(dbus_interface = client_interface)
239
self.proxy.Disable(dbus_interface = client_interface)
241
self.proxy.Approve(dbus.Boolean(True, variant_level=1),
242
dbus_interface = client_interface)
244
self.proxy.Approve(dbus.Boolean(False, variant_level=1),
245
dbus_interface = client_interface)
246
elif key == u"r" or key == u"_" or key == u"ctrl k":
190
if key == u"e" or key == u"+":
192
elif key == u"d" or key == u"-":
194
elif key == u"r" or key == u"_":
247
195
self.server_proxy_object.RemoveClient(self.proxy
249
197
elif key == u"s":
250
self.proxy.StartChecker(dbus_interface = client_interface)
198
self.proxy.StartChecker()
200
self.proxy.StopChecker()
251
201
elif key == u"S":
252
self.proxy.StopChecker(dbus_interface = client_interface)
254
self.proxy.CheckedOK(dbus_interface = client_interface)
202
self.proxy.CheckedOK()
256
204
# elif key == u"p" or key == "=":
257
205
# self.proxy.pause()
281
class ConstrainedListBox(urwid.ListBox):
282
"""Like a normal urwid.ListBox, but will consume all "up" or
283
"down" key presses, thus not allowing any containing widgets to
284
use them as an excuse to shift focus away from this widget.
286
def keypress(self, (maxcol, maxrow), key):
287
ret = super(ConstrainedListBox, self).keypress((maxcol, maxrow), key)
288
if ret in (u"up", u"down"):
293
225
class UserInterface(object):
294
226
"""This is the entire user interface - the whole screen
295
227
with boxes, lists of client widgets, etc.
297
def __init__(self, max_log_length=1000):
298
DBusGMainLoop(set_as_default=True)
230
DBusGMainLoop(set_as_default=True )
300
232
self.screen = urwid.curses_display.Screen()
322
if urwid.supports_unicode():
323
self.divider = u"─" # \u2500
324
#self.divider = u"━" # \u2501
326
#self.divider = u"-" # \u002d
327
self.divider = u"_" # \u005f
329
254
self.screen.start()
331
256
self.size = self.screen.get_cols_rows()
333
258
self.clients = urwid.SimpleListWalker([])
334
259
self.clients_dict = {}
336
# We will add Text widgets to this list
338
self.max_log_length = max_log_length
340
# We keep a reference to the log widget so we can remove it
341
# from the ListWalker without it getting destroyed
342
self.logbox = ConstrainedListBox(self.log)
344
# This keeps track of whether self.uilist currently has
345
# self.logbox in it or not
346
self.log_visible = True
347
self.log_wrap = u"any"
350
self.log_message_raw((u"bold",
351
u"Mandos Monitor version " + version))
352
self.log_message_raw((u"bold",
260
self.topwidget = urwid.LineBox(urwid.ListBox(self.clients))
261
#self.topwidget = urwid.ListBox(clients)
355
263
self.busname = domain + '.Mandos'
356
264
self.main_loop = gobject.MainLoop()
367
275
mandos_clients = dbus.Dictionary()
369
277
(self.mandos_serv
370
.connect_to_signal(u"ClientRemoved",
278
.connect_to_signal("ClientRemoved",
371
279
self.find_and_remove_client,
372
280
dbus_interface=server_interface,
373
281
byte_arrays=True))
374
282
(self.mandos_serv
375
.connect_to_signal(u"ClientAdded",
283
.connect_to_signal("ClientAdded",
376
284
self.add_new_client,
377
285
dbus_interface=server_interface,
378
286
byte_arrays=True))
380
.connect_to_signal(u"ClientNotFound",
381
self.client_not_found,
382
dbus_interface=server_interface,
384
for path, client in mandos_clients.iteritems():
287
for path, client in (mandos_clients.iteritems()):
385
288
client_proxy_object = self.bus.get_object(self.busname,
387
290
self.add_client(MandosClientWidget(server_proxy_object
298
=self.remove_client),
400
def client_not_found(self, fingerprint, address):
401
self.log_message((u"Client with address %s and fingerprint %s"
402
u" could not be found" % (address,
406
"""This rebuilds the User Interface.
407
Call this when the widget layout needs to change"""
409
#self.uilist.append(urwid.ListBox(self.clients))
410
self.uilist.append(urwid.Frame(ConstrainedListBox(self.clients),
411
#header=urwid.Divider(),
413
footer=urwid.Divider(div_char=self.divider)))
415
self.uilist.append(self.logbox)
417
self.topwidget = urwid.Pile(self.uilist)
419
def log_message(self, message):
420
timestamp = datetime.datetime.now().isoformat()
421
self.log_message_raw(timestamp + u": " + message)
423
def log_message_raw(self, markup):
424
"""Add a log message to the log buffer."""
425
self.log.append(urwid.Text(markup, wrap=self.log_wrap))
426
if (self.max_log_length
427
and len(self.log) > self.max_log_length):
428
del self.log[0:len(self.log)-self.max_log_length-1]
429
self.logbox.set_focus(len(self.logbox.body.contents),
430
coming_from=u"above")
433
def toggle_log_display(self):
434
"""Toggle visibility of the log buffer."""
435
self.log_visible = not self.log_visible
437
self.log_message(u"Log visibility changed to: "
438
+ unicode(self.log_visible))
440
def change_log_display(self):
441
"""Change type of log display.
442
Currently, this toggles wrapping of text lines."""
443
if self.log_wrap == u"clip":
444
self.log_wrap = u"any"
446
self.log_wrap = u"clip"
447
for textwidget in self.log:
448
textwidget.set_wrap_mode(self.log_wrap)
449
self.log_message(u"Wrap mode: " + self.log_wrap)
451
301
def find_and_remove_client(self, path, name):
452
302
"""Find an client from its object path and remove it.
517
361
def process_input(self, source, condition):
518
362
keys = self.screen.get_input()
519
translations = { u"ctrl n": u"down", # Emacs
520
u"ctrl p": u"up", # Emacs
521
u"ctrl v": u"page down", # Emacs
522
u"meta v": u"page up", # Emacs
523
u" ": u"page down", # less
524
u"f": u"page down", # less
525
u"b": u"page up", # less
363
translations = { u"j": u"down",
538
375
elif key == u"window resize":
539
376
self.size = self.screen.get_cols_rows()
541
elif key == u"\f": # Ctrl-L
543
elif key == u"l" or key == u"D":
544
self.toggle_log_display()
546
elif key == u"w" or key == u"i":
547
self.change_log_display()
549
elif key == u"?" or key == u"f1" or key == u"esc":
550
if not self.log_visible:
551
self.log_visible = True
553
self.log_message_raw((u"bold",
557
u"l: Log window toggle",
558
u"TAB: Switch window",
560
self.log_message_raw((u"bold",
566
u"s: Start new checker",
573
if self.topwidget.get_focus() is self.logbox:
574
self.topwidget.set_focus(0)
576
self.topwidget.set_focus(self.logbox)
578
#elif (key == u"end" or key == u"meta >" or key == u"G"
580
# pass # xxx end-of-buffer
581
#elif (key == u"home" or key == u"meta <" or key == u"g"
583
# pass # xxx beginning-of-buffer
584
#elif key == u"ctrl e" or key == u"$":
585
# pass # xxx move-end-of-line
586
#elif key == u"ctrl a" or key == u"^":
587
# pass # xxx move-beginning-of-line
588
#elif key == u"ctrl b" or key == u"meta (" or key == u"h":
590
#elif key == u"ctrl f" or key == u"meta )" or key == u"l":
593
# pass # scroll up log
595
# pass # scroll down log
596
380
elif self.topwidget.selectable():
597
381
self.topwidget.keypress(self.size, key)