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)
249
message = (u'A checker has failed! Time until client gets diabled: %s'
316
message = ('A checker has failed! Time until client'
250
318
% unicode(timer).rsplit(".", 1)[0])
251
elif self.properties[u"approved_pending"]:
252
if self.properties[u"approved_by_default"]:
253
message = u"Connection established to client. (d)eny?"
255
message = u"Seeks approval to send secret. (a)pprove?"
258
321
self._text = "%s%s" % (base, message)
260
323
if not urwid.supports_unicode():
261
324
self._text = self._text.encode("ascii", "replace")
262
textlist = [(u"normal", self._text)]
325
textlist = [("normal", self._text)]
263
326
self._text_widget.set_text(textlist)
264
327
self._focus_text_widget.set_text([(with_standout[text[0]],
285
348
if self.delete_hook is not None:
286
349
self.delete_hook(self)
288
def render(self, (maxcol,), focus=False):
351
def render(self, maxcolrow, focus=False):
289
352
"""Render differently if we have focus.
290
353
This overrides the method from urwid.FlowWidget"""
291
return self.current_widget(focus).render((maxcol,),
354
return self.current_widget(focus).render(maxcolrow,
294
def keypress(self, (maxcol,), key):
357
def keypress(self, maxcolrow, key):
296
359
This overrides the method from urwid.FlowWidget"""
298
361
self.proxy.Enable(dbus_interface = client_interface)
300
363
self.proxy.Disable(dbus_interface = client_interface)
302
365
self.proxy.Approve(dbus.Boolean(True, variant_level=1),
303
366
dbus_interface = client_interface)
305
368
self.proxy.Approve(dbus.Boolean(False, variant_level=1),
306
369
dbus_interface = client_interface)
307
elif key == u"r" or key == u"_" or key == u"ctrl k":
370
elif key == "R" or key == "_" or key == "ctrl k":
308
371
self.server_proxy_object.RemoveClient(self.proxy
311
374
self.proxy.StartChecker(dbus_interface = client_interface)
313
376
self.proxy.StopChecker(dbus_interface = client_interface)
315
378
self.proxy.CheckedOK(dbus_interface = client_interface)
317
# elif key == u"p" or key == "=":
380
# elif key == "p" or key == "=":
318
381
# self.proxy.pause()
319
# elif key == u"u" or key == ":":
382
# elif key == "u" or key == ":":
320
383
# self.proxy.unpause()
321
# elif key == u"RET":
324
# self.proxy.Approve(True)
326
# self.proxy.Approve(False)
361
420
self.screen = urwid.curses_display.Screen()
363
422
self.screen.register_palette((
365
u"default", u"default", None),
367
u"default", u"default", u"bold"),
369
u"default", u"default", u"underline"),
371
u"default", u"default", u"standout"),
372
(u"bold-underline-blink",
373
u"default", u"default", (u"bold", u"underline")),
375
u"default", u"default", (u"bold", u"standout")),
376
(u"underline-blink-standout",
377
u"default", u"default", (u"underline", u"standout")),
378
(u"bold-underline-blink-standout",
379
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",
383
442
if urwid.supports_unicode():
384
self.divider = u"─" # \u2500
385
#self.divider = u"━" # \u2501
443
self.divider = "─" # \u2500
444
#self.divider = "━" # \u2501
387
#self.divider = u"-" # \u002d
388
self.divider = u"_" # \u005f
446
#self.divider = "-" # \u002d
447
self.divider = "_" # \u005f
390
449
self.screen.start()
405
464
# This keeps track of whether self.uilist currently has
406
465
# self.logbox in it or not
407
466
self.log_visible = True
408
self.log_wrap = u"any"
467
self.log_wrap = "any"
411
self.log_message_raw((u"bold",
412
u"Mandos Monitor version " + version))
413
self.log_message_raw((u"bold",
470
self.log_message_raw(("bold",
471
"Mandos Monitor version " + version))
472
self.log_message_raw(("bold",
416
475
self.busname = domain + '.Mandos'
417
476
self.main_loop = gobject.MainLoop()
418
477
self.bus = dbus.SystemBus()
419
478
mandos_dbus_objc = self.bus.get_object(
420
self.busname, u"/", follow_name_owner_changes=True)
479
self.busname, "/", follow_name_owner_changes=True)
421
480
self.mandos_serv = dbus.Interface(mandos_dbus_objc,
423
482
= server_interface)
488
550
and len(self.log) > self.max_log_length):
489
551
del self.log[0:len(self.log)-self.max_log_length-1]
490
552
self.logbox.set_focus(len(self.logbox.body.contents),
491
coming_from=u"above")
494
556
def toggle_log_display(self):
495
557
"""Toggle visibility of the log buffer."""
496
558
self.log_visible = not self.log_visible
498
self.log_message(u"Log visibility changed to: "
499
+ unicode(self.log_visible))
560
#self.log_message("Log visibility changed to: "
561
# + unicode(self.log_visible))
501
563
def change_log_display(self):
502
564
"""Change type of log display.
503
565
Currently, this toggles wrapping of text lines."""
504
if self.log_wrap == u"clip":
505
self.log_wrap = u"any"
566
if self.log_wrap == "clip":
567
self.log_wrap = "any"
507
self.log_wrap = u"clip"
569
self.log_wrap = "clip"
508
570
for textwidget in self.log:
509
571
textwidget.set_wrap_mode(self.log_wrap)
510
self.log_message(u"Wrap mode: " + self.log_wrap)
572
#self.log_message("Wrap mode: " + self.log_wrap)
512
574
def find_and_remove_client(self, path, name):
513
575
"""Find an client from its object path and remove it.
593
655
except KeyError: # :-)
596
if key == u"q" or key == u"Q":
658
if key == "q" or key == "Q":
599
elif key == u"window resize":
661
elif key == "window resize":
600
662
self.size = self.screen.get_cols_rows()
602
elif key == u"\f": # Ctrl-L
664
elif key == "\f": # Ctrl-L
604
elif key == u"l" or key == u"D":
666
elif key == "l" or key == "D":
605
667
self.toggle_log_display()
607
elif key == u"w" or key == u"i":
669
elif key == "w" or key == "i":
608
670
self.change_log_display()
610
elif key == u"?" or key == u"f1" or key == u"esc":
672
elif key == "?" or key == "f1" or key == "esc":
611
673
if not self.log_visible:
612
674
self.log_visible = True
614
self.log_message_raw((u"bold",
618
u"l: Log window toggle",
619
u"TAB: Switch window",
621
self.log_message_raw((u"bold",
627
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",
634
696
if self.topwidget.get_focus() is self.logbox:
635
697
self.topwidget.set_focus(0)
637
699
self.topwidget.set_focus(self.logbox)
639
#elif (key == u"end" or key == u"meta >" or key == u"G"
701
#elif (key == "end" or key == "meta >" or key == "G"
641
703
# pass # xxx end-of-buffer
642
#elif (key == u"home" or key == u"meta <" or key == u"g"
704
#elif (key == "home" or key == "meta <" or key == "g"
644
706
# pass # xxx beginning-of-buffer
645
#elif key == u"ctrl e" or key == u"$":
707
#elif key == "ctrl e" or key == "$":
646
708
# pass # xxx move-end-of-line
647
#elif key == u"ctrl a" or key == u"^":
709
#elif key == "ctrl a" or key == "^":
648
710
# pass # xxx move-beginning-of-line
649
#elif key == u"ctrl b" or key == u"meta (" or key == u"h":
711
#elif key == "ctrl b" or key == "meta (" or key == "h":
650
712
# pass # xxx left
651
#elif key == u"ctrl f" or key == u"meta )" or key == u"l":
713
#elif key == "ctrl f" or key == "meta )" or key == "l":
652
714
# pass # xxx right
654
716
# pass # scroll up log
656
718
# pass # scroll down log
657
719
elif self.topwidget.selectable():
658
720
self.topwidget.keypress(self.size, key)