130
84
self.logger = logger
132
self._update_timer_callback_tag = None
133
self._update_timer_callback_lock = 0
134
self.last_checker_failed = False
136
86
# The widget shown normally
137
self._text_widget = urwid.Text("")
87
self._text_widget = urwid.Text(u"")
138
88
# The widget shown when we have focus
139
self._focus_text_widget = urwid.Text("")
89
self._focus_text_widget = urwid.Text(u"")
140
90
super(MandosClientWidget, self).__init__(
141
91
update_hook=update_hook, delete_hook=delete_hook,
144
94
self.opened = False
146
last_checked_ok = isoformat_to_datetime(self.properties
148
if last_checked_ok is None:
149
self.last_checker_failed = True
151
self.last_checker_failed = ((datetime.datetime.utcnow()
158
if self.last_checker_failed:
159
self.using_timer(True)
161
if self.need_approval:
162
self.using_timer(True)
164
self.match_objects = (
165
self.proxy.connect_to_signal("CheckerCompleted",
166
self.checker_completed,
169
self.proxy.connect_to_signal("CheckerStarted",
170
self.checker_started,
173
self.proxy.connect_to_signal("GotSecret",
177
self.proxy.connect_to_signal("NeedApproval",
181
self.proxy.connect_to_signal("Rejected",
185
#self.logger('Created client %s' % (self.properties["Name"]))
187
def property_changed(self, property=None, value=None):
188
super(self, MandosClientWidget).property_changed(property,
190
if property == "ApprovalPending":
191
using_timer(bool(value))
193
def using_timer(self, flag):
194
"""Call this method with True or False when timer should be
195
activated or deactivated.
197
old = self._update_timer_callback_lock
199
self._update_timer_callback_lock += 1
201
self._update_timer_callback_lock -= 1
202
if old == 0 and self._update_timer_callback_lock:
203
# Will update the shown timer value every second
204
self._update_timer_callback_tag = (gobject.timeout_add
207
elif old and self._update_timer_callback_lock == 0:
208
gobject.source_remove(self._update_timer_callback_tag)
209
self._update_timer_callback_tag = None
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",
211
116
def checker_completed(self, exitstatus, condition, command):
212
117
if exitstatus == 0:
213
if self.last_checker_failed:
214
self.last_checker_failed = False
215
self.using_timer(False)
216
#self.logger('Checker for client %s (command "%s")'
218
# % (self.properties["Name"], command))
118
#self.logger(u'Checker for client %s (command "%s")'
120
# % (self.properties[u"name"], command))
222
if not self.last_checker_failed:
223
self.last_checker_failed = True
224
self.using_timer(True)
225
122
if os.WIFEXITED(condition):
226
self.logger('Checker for client %s (command "%s")'
227
' failed with exit code %s'
228
% (self.properties["Name"], command,
123
self.logger(u'Checker for client %s (command "%s")'
124
u' failed with exit code %s'
125
% (self.properties[u"name"], command,
229
126
os.WEXITSTATUS(condition)))
230
elif os.WIFSIGNALED(condition):
231
self.logger('Checker for client %s (command "%s")'
232
' was killed by signal %s'
233
% (self.properties["Name"], command,
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,
234
132
os.WTERMSIG(condition)))
235
elif os.WCOREDUMP(condition):
236
self.logger('Checker for client %s (command "%s")'
238
% (self.properties["Name"], command))
240
self.logger('Checker for client %s completed'
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')
244
140
def checker_started(self, command):
245
"""Server signals that a checker started. This could be useful
246
to log in the future. """
247
#self.logger('Client %s started checker "%s"'
248
# % (self.properties["Name"], unicode(command)))
141
#self.logger(u'Client %s started checker "%s"'
142
# % (self.properties[u"name"], unicode(command)))
251
145
def got_secret(self):
252
self.last_checker_failed = False
253
self.logger('Client %s received its secret'
254
% self.properties["Name"])
146
self.logger(u'Client %s received its secret'
147
% self.properties[u"name"])
256
149
def need_approval(self, timeout, default):
258
message = 'Client %s needs approval within %s seconds'
151
message = u'Client %s needs approval within %s seconds'
260
message = 'Client %s will get its secret in %s seconds'
153
message = u'Client %s will get its secret in %s seconds'
261
154
self.logger(message
262
% (self.properties["Name"], timeout/1000))
263
self.using_timer(True)
155
% (self.properties[u"name"], timeout/1000))
265
157
def rejected(self, reason):
266
self.logger('Client %s was rejected; reason: %s'
267
% (self.properties["Name"], reason))
158
self.logger(u'Client %s was rejected; reason: %s'
159
% (self.properties[u"name"], reason))
269
161
def selectable(self):
270
162
"""Make this a "selectable" widget.
271
163
This overrides the method from urwid.FlowWidget."""
274
def rows(self, maxcolrow, focus=False):
166
def rows(self, (maxcol,), focus=False):
275
167
"""How many rows this widget will occupy might depend on
276
168
whether we have focus or not.
277
169
This overrides the method from urwid.FlowWidget"""
278
return self.current_widget(focus).rows(maxcolrow, focus=focus)
170
return self.current_widget(focus).rows((maxcol,), focus=focus)
280
172
def current_widget(self, focus=False):
281
173
if focus or self.opened:
285
177
def update(self):
286
178
"Called when what is visible on the screen should be updated."
287
179
# How to add standout mode to a style
288
with_standout = { "normal": "standout",
289
"bold": "bold-standout",
291
"underline-blink-standout",
292
"bold-underline-blink":
293
"bold-underline-blink-standout",
180
with_standout = { u"normal": u"standout",
181
u"bold": u"bold-standout",
183
u"underline-blink-standout",
184
u"bold-underline-blink":
185
u"bold-underline-blink-standout",
296
188
# Rebuild focus and non-focus widgets using current properties
298
# Base part of a client. Name!
300
% {"name": self.properties["Name"]})
301
if not self.properties["Enabled"]:
303
elif self.properties["ApprovalPending"]:
304
timeout = datetime.timedelta(milliseconds
307
last_approval_request = isoformat_to_datetime(
308
self.properties["LastApprovalRequest"])
309
if last_approval_request is not None:
310
timer = timeout - (datetime.datetime.utcnow()
311
- last_approval_request)
313
timer = datetime.timedelta()
314
if self.properties["ApprovedByDefault"]:
315
message = "Approval in %s. (d)eny?"
317
message = "Denial in %s. (a)pprove?"
318
message = message % unicode(timer).rsplit(".", 1)[0]
319
elif self.last_checker_failed:
320
# When checker has failed, print a timer until client expires
321
expires = self.properties["Expires"]
323
timer = datetime.timedelta(0)
325
expires = datetime.datetime.strptime(expires,
326
'%Y-%m-%dT%H:%M:%S.%f')
327
timer = expires - datetime.datetime.utcnow()
328
message = ('A checker has failed! Time until client'
330
% unicode(timer).rsplit(".", 1)[0])
333
self._text = "%s%s" % (base, message)
189
self._text = (u'%(name)s: %(enabled)s'
190
% { u"name": self.properties[u"name"],
193
if self.properties[u"enabled"]
335
195
if not urwid.supports_unicode():
336
196
self._text = self._text.encode("ascii", "replace")
337
textlist = [("normal", self._text)]
197
textlist = [(u"normal", self._text)]
338
198
self._text_widget.set_text(textlist)
339
199
self._focus_text_widget.set_text([(with_standout[text[0]],
348
208
if self.update_hook is not None:
349
209
self.update_hook()
351
def update_timer(self):
352
"""called by gobject. Will indefinitely loop until
353
gobject.source_remove() on tag is called"""
355
return True # Keep calling this
357
def delete(self, *args, **kwargs):
358
if self._update_timer_callback_tag is not None:
359
gobject.source_remove(self._update_timer_callback_tag)
360
self._update_timer_callback_tag = None
361
for match in self.match_objects:
363
self.match_objects = ()
364
212
if self.delete_hook is not None:
365
213
self.delete_hook(self)
366
return super(MandosClientWidget, self).delete(*args, **kwargs)
368
def render(self, maxcolrow, focus=False):
215
def render(self, (maxcol,), focus=False):
369
216
"""Render differently if we have focus.
370
217
This overrides the method from urwid.FlowWidget"""
371
return self.current_widget(focus).render(maxcolrow,
218
return self.current_widget(focus).render((maxcol,),
374
def keypress(self, maxcolrow, key):
221
def keypress(self, (maxcol,), key):
376
223
This overrides the method from urwid.FlowWidget"""
378
self.proxy.Enable(dbus_interface = client_interface,
381
self.proxy.Disable(dbus_interface = client_interface,
384
self.proxy.Approve(dbus.Boolean(True, variant_level=1),
385
dbus_interface = client_interface,
388
self.proxy.Approve(dbus.Boolean(False, variant_level=1),
389
dbus_interface = client_interface,
391
elif key == "R" or key == "_" or key == "ctrl k":
224
if key == u"e" or key == u"+":
226
elif key == u"d" or key == u"-":
228
elif key == u"r" or key == u"_" or key == u"ctrl k":
392
229
self.server_proxy_object.RemoveClient(self.proxy
396
self.proxy.StartChecker(dbus_interface = client_interface,
399
self.proxy.StopChecker(dbus_interface = client_interface,
402
self.proxy.CheckedOK(dbus_interface = client_interface,
232
self.proxy.StartChecker()
234
self.proxy.StopChecker()
236
self.proxy.CheckedOK()
405
# elif key == "p" or key == "=":
238
# elif key == u"p" or key == "=":
406
239
# self.proxy.pause()
407
# elif key == "u" or key == ":":
240
# elif key == u"u" or key == ":":
408
241
# self.proxy.unpause()
242
# elif key == u"RET":
245
self.proxy.Approve(True)
247
self.proxy.Approve(False)
445
282
self.screen = urwid.curses_display.Screen()
447
284
self.screen.register_palette((
449
"default", "default", None),
451
"default", "default", "bold"),
453
"default", "default", "underline"),
455
"default", "default", "standout"),
456
("bold-underline-blink",
457
"default", "default", ("bold", "underline")),
459
"default", "default", ("bold", "standout")),
460
("underline-blink-standout",
461
"default", "default", ("underline", "standout")),
462
("bold-underline-blink-standout",
463
"default", "default", ("bold", "underline",
286
u"default", u"default", None),
288
u"default", u"default", u"bold"),
290
u"default", u"default", u"underline"),
292
u"default", u"default", u"standout"),
293
(u"bold-underline-blink",
294
u"default", u"default", (u"bold", u"underline")),
296
u"default", u"default", (u"bold", u"standout")),
297
(u"underline-blink-standout",
298
u"default", u"default", (u"underline", u"standout")),
299
(u"bold-underline-blink-standout",
300
u"default", u"default", (u"bold", u"underline",
467
304
if urwid.supports_unicode():
468
self.divider = "─" # \u2500
469
#self.divider = "━" # \u2501
305
self.divider = u"─" # \u2500
306
#self.divider = u"━" # \u2501
471
#self.divider = "-" # \u002d
472
self.divider = "_" # \u005f
308
#self.divider = u"-" # \u002d
309
self.divider = u"_" # \u005f
474
311
self.screen.start()
489
326
# This keeps track of whether self.uilist currently has
490
327
# self.logbox in it or not
491
328
self.log_visible = True
492
self.log_wrap = "any"
329
self.log_wrap = u"any"
495
self.log_message_raw(("bold",
496
"Mandos Monitor version " + version))
497
self.log_message_raw(("bold",
332
self.log_message_raw((u"bold",
333
u"Mandos Monitor version " + version))
334
self.log_message_raw((u"bold",
500
337
self.busname = domain + '.Mandos'
501
338
self.main_loop = gobject.MainLoop()
339
self.bus = dbus.SystemBus()
340
mandos_dbus_objc = self.bus.get_object(
341
self.busname, u"/", follow_name_owner_changes=True)
342
self.mandos_serv = dbus.Interface(mandos_dbus_objc,
346
mandos_clients = (self.mandos_serv
347
.GetAllClientsWithProperties())
348
except dbus.exceptions.DBusException:
349
mandos_clients = dbus.Dictionary()
352
.connect_to_signal(u"ClientRemoved",
353
self.find_and_remove_client,
354
dbus_interface=server_interface,
357
.connect_to_signal(u"ClientAdded",
359
dbus_interface=server_interface,
362
.connect_to_signal(u"ClientNotFound",
363
self.client_not_found,
364
dbus_interface=server_interface,
366
for path, client in mandos_clients.iteritems():
367
client_proxy_object = self.bus.get_object(self.busname,
369
self.add_client(MandosClientWidget(server_proxy_object
372
=client_proxy_object,
503
382
def client_not_found(self, fingerprint, address):
504
self.log_message(("Client with address %s and fingerprint %s"
505
" could not be found" % (address,
383
self.log_message((u"Client with address %s and fingerprint %s"
384
u" could not be found" % (address,
508
387
def rebuild(self):
532
409
and len(self.log) > self.max_log_length):
533
410
del self.log[0:len(self.log)-self.max_log_length-1]
534
411
self.logbox.set_focus(len(self.logbox.body.contents),
412
coming_from=u"above")
538
415
def toggle_log_display(self):
539
416
"""Toggle visibility of the log buffer."""
540
417
self.log_visible = not self.log_visible
542
#self.log_message("Log visibility changed to: "
543
# + unicode(self.log_visible))
419
self.log_message(u"Log visibility changed to: "
420
+ unicode(self.log_visible))
545
422
def change_log_display(self):
546
423
"""Change type of log display.
547
424
Currently, this toggles wrapping of text lines."""
548
if self.log_wrap == "clip":
549
self.log_wrap = "any"
425
if self.log_wrap == u"clip":
426
self.log_wrap = u"any"
551
self.log_wrap = "clip"
428
self.log_wrap = u"clip"
552
429
for textwidget in self.log:
553
430
textwidget.set_wrap_mode(self.log_wrap)
554
#self.log_message("Wrap mode: " + self.log_wrap)
431
self.log_message(u"Wrap mode: " + self.log_wrap)
556
433
def find_and_remove_client(self, path, name):
557
"""Find a client by its object path and remove it.
434
"""Find an client from its object path and remove it.
559
436
This is connected to the ClientRemoved signal from the
560
437
Mandos server object."""
610
485
"""Start the main loop and exit when it's done."""
611
self.bus = dbus.SystemBus()
612
mandos_dbus_objc = self.bus.get_object(
613
self.busname, "/", follow_name_owner_changes=True)
614
self.mandos_serv = dbus.Interface(mandos_dbus_objc,
618
mandos_clients = (self.mandos_serv
619
.GetAllClientsWithProperties())
620
except dbus.exceptions.DBusException:
621
mandos_clients = dbus.Dictionary()
624
.connect_to_signal("ClientRemoved",
625
self.find_and_remove_client,
626
dbus_interface=server_interface,
629
.connect_to_signal("ClientAdded",
631
dbus_interface=server_interface,
634
.connect_to_signal("ClientNotFound",
635
self.client_not_found,
636
dbus_interface=server_interface,
638
for path, client in mandos_clients.iteritems():
639
client_proxy_object = self.bus.get_object(self.busname,
641
self.add_client(MandosClientWidget(server_proxy_object
644
=client_proxy_object,
655
487
self._input_callback_tag = (gobject.io_add_watch
656
488
(sys.stdin.fileno(),
682
514
except KeyError: # :-)
685
if key == "q" or key == "Q":
517
if key == u"q" or key == u"Q":
688
elif key == "window resize":
520
elif key == u"window resize":
689
521
self.size = self.screen.get_cols_rows()
691
elif key == "\f": # Ctrl-L
523
elif key == u"\f": # Ctrl-L
693
elif key == "l" or key == "D":
525
elif key == u"l" or key == u"D":
694
526
self.toggle_log_display()
696
elif key == "w" or key == "i":
528
elif key == u"w" or key == u"i":
697
529
self.change_log_display()
699
elif key == "?" or key == "f1" or key == "esc":
531
elif key == u"?" or key == u"f1" or key == u"esc":
700
532
if not self.log_visible:
701
533
self.log_visible = True
703
self.log_message_raw(("bold",
707
"l: Log window toggle",
708
"TAB: Switch window",
710
self.log_message_raw(("bold",
716
"s: Start new checker",
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",
723
553
if self.topwidget.get_focus() is self.logbox:
724
554
self.topwidget.set_focus(0)
726
556
self.topwidget.set_focus(self.logbox)
728
#elif (key == "end" or key == "meta >" or key == "G"
558
#elif (key == u"end" or key == u"meta >" or key == u"G"
730
560
# pass # xxx end-of-buffer
731
#elif (key == "home" or key == "meta <" or key == "g"
561
#elif (key == u"home" or key == u"meta <" or key == u"g"
733
563
# pass # xxx beginning-of-buffer
734
#elif key == "ctrl e" or key == "$":
564
#elif key == u"ctrl e" or key == u"$":
735
565
# pass # xxx move-end-of-line
736
#elif key == "ctrl a" or key == "^":
566
#elif key == u"ctrl a" or key == u"^":
737
567
# pass # xxx move-beginning-of-line
738
#elif key == "ctrl b" or key == "meta (" or key == "h":
568
#elif key == u"ctrl b" or key == u"meta (" or key == u"h":
739
569
# pass # xxx left
740
#elif key == "ctrl f" or key == "meta )" or key == "l":
570
#elif key == u"ctrl f" or key == u"meta )" or key == u"l":
741
571
# pass # xxx right
743
573
# pass # scroll up log
745
575
# pass # scroll down log
746
576
elif self.topwidget.selectable():
747
577
self.topwidget.keypress(self.size, key)