2
2
# -*- mode: python; coding: utf-8 -*-
4
# Mandos Monitor - Control and monitor the Mandos server
6
# Copyright © 2009-2011 Teddy Hogeborn
7
# Copyright © 2009-2011 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 <http://www.gnu.org/licenses/>.
22
# Contact the authors at <mandos@fukt.bsnet.se>.
4
from __future__ import division, absolute_import, with_statement
25
from __future__ import division, absolute_import, print_function, unicode_literals
102
123
self.logger = logger
104
125
self._update_timer_callback_tag = None
126
self._update_timer_callback_lock = 0
105
127
self.last_checker_failed = False
107
129
# The widget shown normally
108
self._text_widget = urwid.Text(u"")
130
self._text_widget = urwid.Text("")
109
131
# The widget shown when we have focus
110
self._focus_text_widget = urwid.Text(u"")
132
self._focus_text_widget = urwid.Text("")
111
133
super(MandosClientWidget, self).__init__(
112
134
update_hook=update_hook, delete_hook=delete_hook,
115
137
self.opened = False
116
self.proxy.connect_to_signal(u"CheckerCompleted",
117
self.checker_completed,
120
self.proxy.connect_to_signal(u"CheckerStarted",
121
self.checker_started,
124
self.proxy.connect_to_signal(u"GotSecret",
128
self.proxy.connect_to_signal(u"NeedApproval",
132
self.proxy.connect_to_signal(u"Rejected",
136
139
last_checked_ok = isoformat_to_datetime(self.properties
138
141
if last_checked_ok is None:
139
142
self.last_checker_failed = True
142
145
- last_checked_ok)
143
146
> datetime.timedelta
145
self.properties["interval"]))
146
151
if self.last_checker_failed:
152
self.using_timer(True)
154
if self.need_approval:
155
self.using_timer(True)
157
self.proxy.connect_to_signal("CheckerCompleted",
158
self.checker_completed,
161
self.proxy.connect_to_signal("CheckerStarted",
162
self.checker_started,
165
self.proxy.connect_to_signal("GotSecret",
169
self.proxy.connect_to_signal("NeedApproval",
173
self.proxy.connect_to_signal("Rejected",
178
def property_changed(self, property=None, value=None):
179
super(self, MandosClientWidget).property_changed(property,
181
if property == "ApprovalPending":
182
using_timer(bool(value))
184
def using_timer(self, flag):
185
"""Call this method with True or False when timer should be
186
activated or deactivated.
188
old = self._update_timer_callback_lock
190
self._update_timer_callback_lock += 1
192
self._update_timer_callback_lock -= 1
193
if old == 0 and self._update_timer_callback_lock:
147
194
self._update_timer_callback_tag = (gobject.timeout_add
149
196
self.update_timer))
197
elif old and self._update_timer_callback_lock == 0:
198
gobject.source_remove(self._update_timer_callback_tag)
199
self._update_timer_callback_tag = None
151
201
def checker_completed(self, exitstatus, condition, command):
152
202
if exitstatus == 0:
153
203
if self.last_checker_failed:
154
204
self.last_checker_failed = False
155
gobject.source_remove(self._update_timer_callback_tag)
156
self._update_timer_callback_tag = None
157
self.logger(u'Checker for client %s (command "%s")'
159
% (self.properties[u"name"], command))
205
self.using_timer(False)
206
#self.logger('Checker for client %s (command "%s")'
208
# % (self.properties["Name"], command))
163
212
if not self.last_checker_failed:
164
213
self.last_checker_failed = True
165
self._update_timer_callback_tag = (gobject.timeout_add
214
self.using_timer(True)
168
215
if os.WIFEXITED(condition):
169
self.logger(u'Checker for client %s (command "%s")'
170
u' failed with exit code %s'
171
% (self.properties[u"name"], command,
216
self.logger('Checker for client %s (command "%s")'
217
' failed with exit code %s'
218
% (self.properties["Name"], command,
172
219
os.WEXITSTATUS(condition)))
173
220
elif os.WIFSIGNALED(condition):
174
self.logger(u'Checker for client %s (command "%s")'
175
u' was killed by signal %s'
176
% (self.properties[u"name"], command,
221
self.logger('Checker for client %s (command "%s")'
222
' was killed by signal %s'
223
% (self.properties["Name"], command,
177
224
os.WTERMSIG(condition)))
178
225
elif os.WCOREDUMP(condition):
179
self.logger(u'Checker for client %s (command "%s")'
181
% (self.properties[u"name"], command))
226
self.logger('Checker for client %s (command "%s")'
228
% (self.properties["Name"], command))
183
self.logger(u'Checker for client %s completed mysteriously')
230
self.logger('Checker for client %s completed'
186
234
def checker_started(self, command):
187
#self.logger(u'Client %s started checker "%s"'
188
# % (self.properties[u"name"], unicode(command)))
235
#self.logger('Client %s started checker "%s"'
236
# % (self.properties["Name"], unicode(command)))
191
239
def got_secret(self):
192
self.logger(u'Client %s received its secret'
193
% self.properties[u"name"])
240
self.last_checker_failed = False
241
self.logger('Client %s received its secret'
242
% self.properties["Name"])
195
244
def need_approval(self, timeout, default):
197
message = u'Client %s needs approval within %s seconds'
246
message = 'Client %s needs approval within %s seconds'
199
message = u'Client %s will get its secret in %s seconds'
248
message = 'Client %s will get its secret in %s seconds'
200
249
self.logger(message
201
% (self.properties[u"name"], timeout/1000))
250
% (self.properties["Name"], timeout/1000))
251
self.using_timer(True)
203
253
def rejected(self, reason):
204
self.logger(u'Client %s was rejected; reason: %s'
205
% (self.properties[u"name"], reason))
254
self.logger('Client %s was rejected; reason: %s'
255
% (self.properties["Name"], reason))
207
257
def selectable(self):
208
258
"""Make this a "selectable" widget.
209
259
This overrides the method from urwid.FlowWidget."""
212
def rows(self, (maxcol,), focus=False):
262
def rows(self, maxcolrow, focus=False):
213
263
"""How many rows this widget will occupy might depend on
214
264
whether we have focus or not.
215
265
This overrides the method from urwid.FlowWidget"""
216
return self.current_widget(focus).rows((maxcol,), focus=focus)
266
return self.current_widget(focus).rows(maxcolrow, focus=focus)
218
268
def current_widget(self, focus=False):
219
269
if focus or self.opened:
223
273
def update(self):
224
274
"Called when what is visible on the screen should be updated."
225
275
# How to add standout mode to a style
226
with_standout = { u"normal": u"standout",
227
u"bold": u"bold-standout",
229
u"underline-blink-standout",
230
u"bold-underline-blink":
231
u"bold-underline-blink-standout",
276
with_standout = { "normal": "standout",
277
"bold": "bold-standout",
279
"underline-blink-standout",
280
"bold-underline-blink":
281
"bold-underline-blink-standout",
234
284
# Rebuild focus and non-focus widgets using current properties
236
286
# Base part of a client. Name!
237
base = (u'%(name)s: '
238
% {u"name": self.properties[u"name"]})
239
if not self.properties[u"enabled"]:
240
message = u"DISABLED"
288
% {"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 %s. (d)eny?"
305
message = "Denial in %s. (a)pprove?"
306
message = message % unicode(timer).rsplit(".", 1)[0]
241
307
elif self.last_checker_failed:
242
308
timeout = datetime.timedelta(milliseconds
243
= self.properties[u"timeout"])
244
311
last_ok = isoformat_to_datetime(
245
max((self.properties["last_checked_ok"]
246
or self.properties["created"]),
247
self.properties[u"last_enabled"]))
312
max((self.properties["LastCheckedOK"]
313
or self.properties["Created"]),
314
self.properties["LastEnabled"]))
248
315
timer = timeout - (datetime.datetime.utcnow() - last_ok)
250
message = (u'A checker has failed! Time until client gets diabled: %s'
252
elif self.properties[u"approved_pending"]:
253
if self.properties[u"approved_by_default"]:
254
message = u"Connection established to client. (d)eny?"
256
message = u"Seeks approval to send secret. (a)pprove?"
316
message = ('A checker has failed! Time until client'
318
% unicode(timer).rsplit(".", 1)[0])
259
321
self._text = "%s%s" % (base, message)
261
323
if not urwid.supports_unicode():
262
324
self._text = self._text.encode("ascii", "replace")
263
textlist = [(u"normal", self._text)]
325
textlist = [("normal", self._text)]
264
326
self._text_widget.set_text(textlist)
265
327
self._focus_text_widget.set_text([(with_standout[text[0]],
286
348
if self.delete_hook is not None:
287
349
self.delete_hook(self)
289
def render(self, (maxcol,), focus=False):
351
def render(self, maxcolrow, focus=False):
290
352
"""Render differently if we have focus.
291
353
This overrides the method from urwid.FlowWidget"""
292
return self.current_widget(focus).render((maxcol,),
354
return self.current_widget(focus).render(maxcolrow,
295
def keypress(self, (maxcol,), key):
357
def keypress(self, maxcolrow, key):
297
359
This overrides the method from urwid.FlowWidget"""
299
361
self.proxy.Enable(dbus_interface = client_interface)
301
363
self.proxy.Disable(dbus_interface = client_interface)
303
365
self.proxy.Approve(dbus.Boolean(True, variant_level=1),
304
366
dbus_interface = client_interface)
306
368
self.proxy.Approve(dbus.Boolean(False, variant_level=1),
307
369
dbus_interface = client_interface)
308
elif key == u"r" or key == u"_" or key == u"ctrl k":
370
elif key == "R" or key == "_" or key == "ctrl k":
309
371
self.server_proxy_object.RemoveClient(self.proxy
312
374
self.proxy.StartChecker(dbus_interface = client_interface)
314
376
self.proxy.StopChecker(dbus_interface = client_interface)
316
378
self.proxy.CheckedOK(dbus_interface = client_interface)
318
# elif key == u"p" or key == "=":
380
# elif key == "p" or key == "=":
319
381
# self.proxy.pause()
320
# elif key == u"u" or key == ":":
382
# elif key == "u" or key == ":":
321
383
# self.proxy.unpause()
322
# elif key == u"RET":
325
# self.proxy.Approve(True)
327
# self.proxy.Approve(False)
362
420
self.screen = urwid.curses_display.Screen()
364
422
self.screen.register_palette((
366
u"default", u"default", None),
368
u"default", u"default", u"bold"),
370
u"default", u"default", u"underline"),
372
u"default", u"default", u"standout"),
373
(u"bold-underline-blink",
374
u"default", u"default", (u"bold", u"underline")),
376
u"default", u"default", (u"bold", u"standout")),
377
(u"underline-blink-standout",
378
u"default", u"default", (u"underline", u"standout")),
379
(u"bold-underline-blink-standout",
380
u"default", u"default", (u"bold", u"underline",
424
"default", "default", None),
426
"default", "default", "bold"),
428
"default", "default", "underline"),
430
"default", "default", "standout"),
431
("bold-underline-blink",
432
"default", "default", ("bold", "underline")),
434
"default", "default", ("bold", "standout")),
435
("underline-blink-standout",
436
"default", "default", ("underline", "standout")),
437
("bold-underline-blink-standout",
438
"default", "default", ("bold", "underline",
384
442
if urwid.supports_unicode():
385
self.divider = u"─" # \u2500
386
#self.divider = u"━" # \u2501
443
self.divider = "─" # \u2500
444
#self.divider = "━" # \u2501
388
#self.divider = u"-" # \u002d
389
self.divider = u"_" # \u005f
446
#self.divider = "-" # \u002d
447
self.divider = "_" # \u005f
391
449
self.screen.start()
406
464
# This keeps track of whether self.uilist currently has
407
465
# self.logbox in it or not
408
466
self.log_visible = True
409
self.log_wrap = u"any"
467
self.log_wrap = "any"
412
self.log_message_raw((u"bold",
413
u"Mandos Monitor version " + version))
414
self.log_message_raw((u"bold",
470
self.log_message_raw(("bold",
471
"Mandos Monitor version " + version))
472
self.log_message_raw(("bold",
417
475
self.busname = domain + '.Mandos'
418
476
self.main_loop = gobject.MainLoop()
419
477
self.bus = dbus.SystemBus()
420
478
mandos_dbus_objc = self.bus.get_object(
421
self.busname, u"/", follow_name_owner_changes=True)
479
self.busname, "/", follow_name_owner_changes=True)
422
480
self.mandos_serv = dbus.Interface(mandos_dbus_objc,
424
482
= server_interface)
489
550
and len(self.log) > self.max_log_length):
490
551
del self.log[0:len(self.log)-self.max_log_length-1]
491
552
self.logbox.set_focus(len(self.logbox.body.contents),
492
coming_from=u"above")
495
556
def toggle_log_display(self):
496
557
"""Toggle visibility of the log buffer."""
497
558
self.log_visible = not self.log_visible
499
self.log_message(u"Log visibility changed to: "
500
+ unicode(self.log_visible))
560
#self.log_message("Log visibility changed to: "
561
# + unicode(self.log_visible))
502
563
def change_log_display(self):
503
564
"""Change type of log display.
504
565
Currently, this toggles wrapping of text lines."""
505
if self.log_wrap == u"clip":
506
self.log_wrap = u"any"
566
if self.log_wrap == "clip":
567
self.log_wrap = "any"
508
self.log_wrap = u"clip"
569
self.log_wrap = "clip"
509
570
for textwidget in self.log:
510
571
textwidget.set_wrap_mode(self.log_wrap)
511
self.log_message(u"Wrap mode: " + self.log_wrap)
572
#self.log_message("Wrap mode: " + self.log_wrap)
513
574
def find_and_remove_client(self, path, name):
514
575
"""Find an client from its object path and remove it.
594
655
except KeyError: # :-)
597
if key == u"q" or key == u"Q":
658
if key == "q" or key == "Q":
600
elif key == u"window resize":
661
elif key == "window resize":
601
662
self.size = self.screen.get_cols_rows()
603
elif key == u"\f": # Ctrl-L
664
elif key == "\f": # Ctrl-L
605
elif key == u"l" or key == u"D":
666
elif key == "l" or key == "D":
606
667
self.toggle_log_display()
608
elif key == u"w" or key == u"i":
669
elif key == "w" or key == "i":
609
670
self.change_log_display()
611
elif key == u"?" or key == u"f1" or key == u"esc":
672
elif key == "?" or key == "f1" or key == "esc":
612
673
if not self.log_visible:
613
674
self.log_visible = True
615
self.log_message_raw((u"bold",
619
u"l: Log window toggle",
620
u"TAB: Switch window",
622
self.log_message_raw((u"bold",
628
u"s: Start new checker",
676
self.log_message_raw(("bold",
680
"l: Log window toggle",
681
"TAB: Switch window",
683
self.log_message_raw(("bold",
689
"s: Start new checker",
635
696
if self.topwidget.get_focus() is self.logbox:
636
697
self.topwidget.set_focus(0)
638
699
self.topwidget.set_focus(self.logbox)
640
#elif (key == u"end" or key == u"meta >" or key == u"G"
701
#elif (key == "end" or key == "meta >" or key == "G"
642
703
# pass # xxx end-of-buffer
643
#elif (key == u"home" or key == u"meta <" or key == u"g"
704
#elif (key == "home" or key == "meta <" or key == "g"
645
706
# pass # xxx beginning-of-buffer
646
#elif key == u"ctrl e" or key == u"$":
707
#elif key == "ctrl e" or key == "$":
647
708
# pass # xxx move-end-of-line
648
#elif key == u"ctrl a" or key == u"^":
709
#elif key == "ctrl a" or key == "^":
649
710
# pass # xxx move-beginning-of-line
650
#elif key == u"ctrl b" or key == u"meta (" or key == u"h":
711
#elif key == "ctrl b" or key == "meta (" or key == "h":
651
712
# pass # xxx left
652
#elif key == u"ctrl f" or key == u"meta )" or key == u"l":
713
#elif key == "ctrl f" or key == "meta )" or key == "l":
653
714
# pass # xxx right
655
716
# pass # scroll up log
657
718
# pass # scroll down log
658
719
elif self.topwidget.selectable():
659
720
self.topwidget.keypress(self.size, key)