2
2
# -*- mode: python; coding: utf-8 -*-
4
# Mandos Monitor - Control and monitor the Mandos server
6
# Copyright © 2009-2012 Teddy Hogeborn
7
# Copyright © 2009-2012 Björn Påhlsson
9
# This program is free software: you can redistribute it and/or modify
10
# it under the terms of the GNU General Public License as published by
11
# the Free Software Foundation, either version 3 of the License, or
12
# (at your option) any later version.
14
# This program is distributed in the hope that it will be useful,
15
# but WITHOUT ANY WARRANTY; without even the implied warranty of
16
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17
# GNU General Public License for more details.
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/>.
23
# Contact the authors at <mandos@recompile.se>.
26
from __future__ import (division, absolute_import, print_function,
4
from __future__ import division, absolute_import, with_statement
131
86
self.logger = logger
133
self._update_timer_callback_tag = None
134
self._update_timer_callback_lock = 0
136
88
# The widget shown normally
137
self._text_widget = urwid.Text("")
89
self._text_widget = urwid.Text(u"")
138
90
# The widget shown when we have focus
139
self._focus_text_widget = urwid.Text("")
91
self._focus_text_widget = urwid.Text(u"")
140
92
super(MandosClientWidget, self).__init__(
141
93
update_hook=update_hook, delete_hook=delete_hook,
144
96
self.opened = False
146
last_checked_ok = isoformat_to_datetime(self.properties
149
if self.properties ["LastCheckerStatus"] != 0:
150
self.using_timer(True)
152
if self.need_approval:
153
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"]))
179
def property_changed(self, property=None, value=None):
180
super(self, MandosClientWidget).property_changed(property,
182
if property == "ApprovalPending":
183
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
def using_timer(self, flag):
191
"""Call this method with True or False when timer should be
192
activated or deactivated.
194
old = self._update_timer_callback_lock
196
self._update_timer_callback_lock += 1
198
self._update_timer_callback_lock -= 1
199
if old == 0 and self._update_timer_callback_lock:
200
# Will update the shown timer value every second
201
self._update_timer_callback_tag = (gobject.timeout_add
204
elif old and self._update_timer_callback_lock == 0:
205
gobject.source_remove(self._update_timer_callback_tag)
206
self._update_timer_callback_tag = None
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",
208
118
def checker_completed(self, exitstatus, condition, command):
209
119
if exitstatus == 0:
120
#self.logger(u'Checker for client %s (command "%s")'
122
# % (self.properties[u"name"], command))
213
124
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)))
218
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)))
223
elif os.WCOREDUMP(condition):
224
self.logger('Checker for client {0} (command "{1}")'
226
.format(self.properties["Name"], command))
228
self.logger('Checker for client {0} completed'
230
.format(self.properties["Name"]))
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')
233
142
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"],
143
#self.logger(u'Client %s started checker "%s"'
144
# % (self.properties[u"name"], unicode(command)))
241
147
def got_secret(self):
242
self.logger('Client {0} received its secret'
243
.format(self.properties["Name"]))
148
self.logger(u'Client %s received its secret'
149
% self.properties[u"name"])
245
151
def need_approval(self, timeout, default):
247
message = 'Client {0} needs approval within {1} seconds'
153
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"],
252
self.using_timer(True)
155
message = u'Client %s will get its secret in %s seconds'
157
% (self.properties[u"name"], timeout/1000))
254
159
def rejected(self, reason):
255
self.logger('Client {0} was rejected; reason: {1}'
256
.format(self.properties["Name"], reason))
160
self.logger(u'Client %s was rejected; reason: %s'
161
% (self.properties[u"name"], reason))
258
163
def selectable(self):
259
164
"""Make this a "selectable" widget.
260
165
This overrides the method from urwid.FlowWidget."""
263
def rows(self, maxcolrow, focus=False):
168
def rows(self, (maxcol,), focus=False):
264
169
"""How many rows this widget will occupy might depend on
265
170
whether we have focus or not.
266
171
This overrides the method from urwid.FlowWidget"""
267
return self.current_widget(focus).rows(maxcolrow, focus=focus)
172
return self.current_widget(focus).rows((maxcol,), focus=focus)
269
174
def current_widget(self, focus=False):
270
175
if focus or self.opened:
274
179
def update(self):
275
180
"Called when what is visible on the screen should be updated."
276
181
# 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",
182
with_standout = { u"normal": u"standout",
183
u"bold": u"bold-standout",
185
u"underline-blink-standout",
186
u"bold-underline-blink":
187
u"bold-underline-blink-standout",
285
190
# Rebuild focus and non-focus widgets using current properties
287
192
# 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"]:
292
timeout = datetime.timedelta(milliseconds
295
last_approval_request = isoformat_to_datetime(
296
self.properties["LastApprovalRequest"])
297
if last_approval_request is not None:
298
timer = timeout - (datetime.datetime.utcnow()
299
- last_approval_request)
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]))
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?"
321
self._text = "{0}{1}".format(base, message)
202
self._text += (u'%(enabled)s'
205
if self.properties[u"enabled"]
323
207
if not urwid.supports_unicode():
324
208
self._text = self._text.encode("ascii", "replace")
325
textlist = [("normal", self._text)]
209
textlist = [(u"normal", self._text)]
326
210
self._text_widget.set_text(textlist)
327
211
self._focus_text_widget.set_text([(with_standout[text[0]],
336
220
if self.update_hook is not None:
337
221
self.update_hook()
339
def update_timer(self):
340
"""called by gobject. Will indefinitely loop until
341
gobject.source_remove() on tag is called"""
343
return True # Keep calling this
345
def delete(self, *args, **kwargs):
346
if self._update_timer_callback_tag is not None:
347
gobject.source_remove(self._update_timer_callback_tag)
348
self._update_timer_callback_tag = None
349
for match in self.match_objects:
351
self.match_objects = ()
352
224
if self.delete_hook is not None:
353
225
self.delete_hook(self)
354
return super(MandosClientWidget, self).delete(*args, **kwargs)
356
def render(self, maxcolrow, focus=False):
227
def render(self, (maxcol,), focus=False):
357
228
"""Render differently if we have focus.
358
229
This overrides the method from urwid.FlowWidget"""
359
return self.current_widget(focus).render(maxcolrow,
230
return self.current_widget(focus).render((maxcol,),
362
def keypress(self, maxcolrow, key):
233
def keypress(self, (maxcol,), key):
364
235
This overrides the method from urwid.FlowWidget"""
366
self.proxy.Enable(dbus_interface = client_interface,
369
self.proxy.Disable(dbus_interface = client_interface,
237
self.proxy.Enable(dbus_interface = client_interface)
239
self.proxy.Disable(dbus_interface = client_interface)
372
241
self.proxy.Approve(dbus.Boolean(True, variant_level=1),
373
dbus_interface = client_interface,
242
dbus_interface = client_interface)
376
244
self.proxy.Approve(dbus.Boolean(False, variant_level=1),
377
dbus_interface = client_interface,
379
elif key == "R" or key == "_" or key == "ctrl k":
245
dbus_interface = client_interface)
246
elif key == u"r" or key == u"_" or key == u"ctrl k":
380
247
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,
250
self.proxy.StartChecker(dbus_interface = client_interface)
252
self.proxy.StopChecker(dbus_interface = client_interface)
254
self.proxy.CheckedOK(dbus_interface = client_interface)
393
# elif key == "p" or key == "=":
256
# elif key == u"p" or key == "=":
394
257
# self.proxy.pause()
395
# elif key == "u" or key == ":":
258
# elif key == u"u" or key == ":":
396
259
# self.proxy.unpause()
260
# elif key == u"RET":
263
# self.proxy.Approve(True)
265
# self.proxy.Approve(False)
433
300
self.screen = urwid.curses_display.Screen()
435
302
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",
304
u"default", u"default", None),
306
u"default", u"default", u"bold"),
308
u"default", u"default", u"underline"),
310
u"default", u"default", u"standout"),
311
(u"bold-underline-blink",
312
u"default", u"default", (u"bold", u"underline")),
314
u"default", u"default", (u"bold", u"standout")),
315
(u"underline-blink-standout",
316
u"default", u"default", (u"underline", u"standout")),
317
(u"bold-underline-blink-standout",
318
u"default", u"default", (u"bold", u"underline",
455
322
if urwid.supports_unicode():
456
self.divider = "─" # \u2500
457
#self.divider = "━" # \u2501
323
self.divider = u"─" # \u2500
324
#self.divider = u"━" # \u2501
459
#self.divider = "-" # \u002d
460
self.divider = "_" # \u005f
326
#self.divider = u"-" # \u002d
327
self.divider = u"_" # \u005f
462
329
self.screen.start()
477
344
# This keeps track of whether self.uilist currently has
478
345
# self.logbox in it or not
479
346
self.log_visible = True
480
self.log_wrap = "any"
347
self.log_wrap = u"any"
483
self.log_message_raw(("bold",
484
"Mandos Monitor version " + version))
485
self.log_message_raw(("bold",
350
self.log_message_raw((u"bold",
351
u"Mandos Monitor version " + version))
352
self.log_message_raw((u"bold",
488
355
self.busname = domain + '.Mandos'
489
356
self.main_loop = gobject.MainLoop()
357
self.bus = dbus.SystemBus()
358
mandos_dbus_objc = self.bus.get_object(
359
self.busname, u"/", follow_name_owner_changes=True)
360
self.mandos_serv = dbus.Interface(mandos_dbus_objc,
364
mandos_clients = (self.mandos_serv
365
.GetAllClientsWithProperties())
366
except dbus.exceptions.DBusException:
367
mandos_clients = dbus.Dictionary()
370
.connect_to_signal(u"ClientRemoved",
371
self.find_and_remove_client,
372
dbus_interface=server_interface,
375
.connect_to_signal(u"ClientAdded",
377
dbus_interface=server_interface,
380
.connect_to_signal(u"ClientNotFound",
381
self.client_not_found,
382
dbus_interface=server_interface,
384
for path, client in mandos_clients.iteritems():
385
client_proxy_object = self.bus.get_object(self.busname,
387
self.add_client(MandosClientWidget(server_proxy_object
390
=client_proxy_object,
491
400
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))
401
self.log_message((u"Client with address %s and fingerprint %s"
402
u" could not be found" % (address,
496
405
def rebuild(self):
497
406
"""This rebuilds the User Interface.
498
407
Call this when the widget layout needs to change"""
500
409
#self.uilist.append(urwid.ListBox(self.clients))
501
self.uilist.append(urwid.Frame(ConstrainedListBox(self.
410
self.uilist.append(urwid.Frame(ConstrainedListBox(self.clients),
503
411
#header=urwid.Divider(),
506
urwid.Divider(div_char=
413
footer=urwid.Divider(div_char=self.divider)))
508
414
if self.log_visible:
509
415
self.uilist.append(self.logbox)
510
417
self.topwidget = urwid.Pile(self.uilist)
512
419
def log_message(self, message):
513
420
timestamp = datetime.datetime.now().isoformat()
514
self.log_message_raw(timestamp + ": " + message)
421
self.log_message_raw(timestamp + u": " + message)
516
423
def log_message_raw(self, markup):
517
424
"""Add a log message to the log buffer."""
520
427
and len(self.log) > self.max_log_length):
521
428
del self.log[0:len(self.log)-self.max_log_length-1]
522
429
self.logbox.set_focus(len(self.logbox.body.contents),
430
coming_from=u"above")
526
433
def toggle_log_display(self):
527
434
"""Toggle visibility of the log buffer."""
528
435
self.log_visible = not self.log_visible
530
#self.log_message("Log visibility changed to: "
531
# + unicode(self.log_visible))
437
self.log_message(u"Log visibility changed to: "
438
+ unicode(self.log_visible))
533
440
def change_log_display(self):
534
441
"""Change type of log display.
535
442
Currently, this toggles wrapping of text lines."""
536
if self.log_wrap == "clip":
537
self.log_wrap = "any"
443
if self.log_wrap == u"clip":
444
self.log_wrap = u"any"
539
self.log_wrap = "clip"
446
self.log_wrap = u"clip"
540
447
for textwidget in self.log:
541
448
textwidget.set_wrap_mode(self.log_wrap)
542
#self.log_message("Wrap mode: " + self.log_wrap)
449
self.log_message(u"Wrap mode: " + self.log_wrap)
544
451
def find_and_remove_client(self, path, name):
545
"""Find a client by its object path and remove it.
452
"""Find an client from its object path and remove it.
547
454
This is connected to the ClientRemoved signal from the
548
455
Mandos server object."""
598
503
"""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
505
self._input_callback_tag = (gobject.io_add_watch
644
506
(sys.stdin.fileno(),
670
532
except KeyError: # :-)
673
if key == "q" or key == "Q":
535
if key == u"q" or key == u"Q":
676
elif key == "window resize":
538
elif key == u"window resize":
677
539
self.size = self.screen.get_cols_rows()
679
elif key == "\f": # Ctrl-L
541
elif key == u"\f": # Ctrl-L
681
elif key == "l" or key == "D":
543
elif key == u"l" or key == u"D":
682
544
self.toggle_log_display()
684
elif key == "w" or key == "i":
546
elif key == u"w" or key == u"i":
685
547
self.change_log_display()
687
elif key == "?" or key == "f1" or key == "esc":
549
elif key == u"?" or key == u"f1" or key == u"esc":
688
550
if not self.log_visible:
689
551
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",
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",
711
573
if self.topwidget.get_focus() is self.logbox:
712
574
self.topwidget.set_focus(0)
714
576
self.topwidget.set_focus(self.logbox)
716
#elif (key == "end" or key == "meta >" or key == "G"
578
#elif (key == u"end" or key == u"meta >" or key == u"G"
718
580
# pass # xxx end-of-buffer
719
#elif (key == "home" or key == "meta <" or key == "g"
581
#elif (key == u"home" or key == u"meta <" or key == u"g"
721
583
# pass # xxx beginning-of-buffer
722
#elif key == "ctrl e" or key == "$":
584
#elif key == u"ctrl e" or key == u"$":
723
585
# pass # xxx move-end-of-line
724
#elif key == "ctrl a" or key == "^":
586
#elif key == u"ctrl a" or key == u"^":
725
587
# pass # xxx move-beginning-of-line
726
#elif key == "ctrl b" or key == "meta (" or key == "h":
588
#elif key == u"ctrl b" or key == u"meta (" or key == u"h":
727
589
# pass # xxx left
728
#elif key == "ctrl f" or key == "meta )" or key == "l":
590
#elif key == u"ctrl f" or key == u"meta )" or key == u"l":
729
591
# pass # xxx right
731
593
# pass # scroll up log
733
595
# pass # scroll down log
734
596
elif self.topwidget.selectable():
735
597
self.topwidget.keypress(self.size, key)