To get this branch, use:
bzr branch
http://bzr.recompile.se/loggerhead/mandos/trunk
« back to all changes in this revision
Viewing changes to mandos-monitor
- browse files at revision 542
- compare with another revision
- download diff
- download tarball
- view history from revision 542
- Committer: Björn Påhlsson
- Date: 2011-12-31 22:44:06 UTC
- Revision ID: belorn@recompile.se-20111231224406-b1w5a1p3639aymxe
fixed bug with bad stored config state for expires and last_checked_ok.
- files added:
- debian/source
- network-hooks.d
- files modified:
- .bzrignore
added
removed
mandos-monitor
3
3
#
4
4
# Mandos Monitor - Control and monitor the Mandos server
5
5
#
6
# Copyright © 2009,2010 Teddy Hogeborn
7
# Copyright © 2009,2010 Björn Påhlsson
6
# Copyright © 2009-2011 Teddy Hogeborn
7
# Copyright © 2009-2011 Björn Påhlsson
8
8
#
9
9
# This program is free software: you can redistribute it and/or modify
10
10
# it under the terms of the GNU General Public License as published by
19
19
# You should have received a copy of the GNU General Public License
20
20
# along with this program. If not, see <http://www.gnu.org/licenses/>.
21
21
#
22
# Contact the authors at <mandos@fukt.bsnet.se>.
22
# Contact the authors at <mandos@recompile.se>.
23
23
#
24
24
25
from __future__ import division, absolute_import, with_statement
25
from __future__ import (division, absolute_import, print_function,
26
unicode_literals)
26
27
27
28
import sys
28
29
import os
42
43
43
44
import locale
44
45
45
locale.setlocale(locale.LC_ALL, u'')
46
locale.setlocale(locale.LC_ALL, '')
46
47
47
48
import logging
48
49
logging.getLogger('dbus.proxies').setLevel(logging.CRITICAL)
49
50
50
51
# Some useful constants
51
domain = 'se.bsnet.fukt'
52
domain = 'se.recompile'
52
53
server_interface = domain + '.Mandos'
53
54
client_interface = domain + '.Mandos.Client'
54
version = "1.2"
55
version = "1.4.1"
55
56
56
57
# Always run in monochrome mode
57
58
urwid.curses_display.curses.has_colors = lambda : False
65
66
"Parse an ISO 8601 date string to a datetime.datetime()"
66
67
if not iso:
67
68
return None
68
d, t = iso.split(u"T", 1)
69
year, month, day = d.split(u"-", 2)
70
hour, minute, second = t.split(u":", 2)
69
d, t = iso.split("T", 1)
70
year, month, day = d.split("-", 2)
71
hour, minute, second = t.split(":", 2)
71
72
second, fraction = divmod(float(second), 1)
72
73
return datetime.datetime(int(year),
73
74
int(month),
86
87
self.proxy = proxy_object # Mandos Client proxy object
87
88
88
89
self.properties = dict()
89
self.proxy.connect_to_signal(u"PropertyChanged",
90
self.property_changed,
91
client_interface,
92
byte_arrays=True)
90
self.property_changed_match = (
91
self.proxy.connect_to_signal("PropertyChanged",
92
self.property_changed,
93
client_interface,
94
byte_arrays=True))
93
95
94
96
self.properties.update(
95
97
self.proxy.GetAll(client_interface,
96
98
dbus_interface = dbus.PROPERTIES_IFACE))
97
99
98
#XXX This break good super behaviour!
100
#XXX This breaks good super behaviour
99
101
# super(MandosClientPropertyCache, self).__init__(
100
102
# *args, **kwargs)
101
103
105
107
"""
106
108
# Update properties dict with new value
107
109
self.properties[property] = value
110
111
def delete(self, *args, **kwargs):
112
self.property_changed_match.remove()
113
super(MandosClientPropertyCache, self).__init__(
114
*args, **kwargs)
108
115
109
116
110
117
class MandosClientWidget(urwid.FlowWidget, MandosClientPropertyCache):
127
134
self.last_checker_failed = False
128
135
129
136
# The widget shown normally
130
self._text_widget = urwid.Text(u"")
137
self._text_widget = urwid.Text("")
131
138
# The widget shown when we have focus
132
self._focus_text_widget = urwid.Text(u"")
139
self._focus_text_widget = urwid.Text("")
133
140
super(MandosClientWidget, self).__init__(
134
141
update_hook=update_hook, delete_hook=delete_hook,
135
142
*args, **kwargs)
137
144
self.opened = False
138
145
139
146
last_checked_ok = isoformat_to_datetime(self.properties
140
[u"LastCheckedOK"])
147
["LastCheckedOK"])
141
148
if last_checked_ok is None:
142
149
self.last_checker_failed = True
143
150
else:
146
153
> datetime.timedelta
147
154
(milliseconds=
148
155
self.properties
149
[u"Interval"]))
156
["Interval"]))
150
157
151
158
if self.last_checker_failed:
152
159
self.using_timer(True)
154
161
if self.need_approval:
155
162
self.using_timer(True)
156
163
157
self.proxy.connect_to_signal(u"CheckerCompleted",
158
self.checker_completed,
159
client_interface,
160
byte_arrays=True)
161
self.proxy.connect_to_signal(u"CheckerStarted",
162
self.checker_started,
163
client_interface,
164
byte_arrays=True)
165
self.proxy.connect_to_signal(u"GotSecret",
166
self.got_secret,
167
client_interface,
168
byte_arrays=True)
169
self.proxy.connect_to_signal(u"NeedApproval",
170
self.need_approval,
171
client_interface,
172
byte_arrays=True)
173
self.proxy.connect_to_signal(u"Rejected",
174
self.rejected,
175
client_interface,
176
byte_arrays=True)
164
self.match_objects = (
165
self.proxy.connect_to_signal("CheckerCompleted",
166
self.checker_completed,
167
client_interface,
168
byte_arrays=True),
169
self.proxy.connect_to_signal("CheckerStarted",
170
self.checker_started,
171
client_interface,
172
byte_arrays=True),
173
self.proxy.connect_to_signal("GotSecret",
174
self.got_secret,
175
client_interface,
176
byte_arrays=True),
177
self.proxy.connect_to_signal("NeedApproval",
178
self.need_approval,
179
client_interface,
180
byte_arrays=True),
181
self.proxy.connect_to_signal("Rejected",
182
self.rejected,
183
client_interface,
184
byte_arrays=True))
185
#self.logger('Created client %s' % (self.properties["Name"]))
177
186
178
187
def property_changed(self, property=None, value=None):
179
188
super(self, MandosClientWidget).property_changed(property,
180
189
value)
181
if property == u"ApprovalPending":
190
if property == "ApprovalPending":
182
191
using_timer(bool(value))
183
192
184
193
def using_timer(self, flag):
191
200
else:
192
201
self._update_timer_callback_lock -= 1
193
202
if old == 0 and self._update_timer_callback_lock:
203
# Will update the shown timer value every second
194
204
self._update_timer_callback_tag = (gobject.timeout_add
195
205
(1000,
196
206
self.update_timer))
203
213
if self.last_checker_failed:
204
214
self.last_checker_failed = False
205
215
self.using_timer(False)
206
#self.logger(u'Checker for client %s (command "%s")'
207
# u' was successful'
208
# % (self.properties[u"Name"], command))
216
#self.logger('Checker for client %s (command "%s")'
217
# ' was successful'
218
# % (self.properties["Name"], command))
209
219
self.update()
210
220
return
211
221
# Checker failed
213
223
self.last_checker_failed = True
214
224
self.using_timer(True)
215
225
if os.WIFEXITED(condition):
216
self.logger(u'Checker for client %s (command "%s")'
217
u' failed with exit code %s'
218
% (self.properties[u"Name"], command,
226
self.logger('Checker for client %s (command "%s")'
227
' failed with exit code %s'
228
% (self.properties["Name"], command,
219
229
os.WEXITSTATUS(condition)))
220
230
elif os.WIFSIGNALED(condition):
221
self.logger(u'Checker for client %s (command "%s")'
222
u' was killed by signal %s'
223
% (self.properties[u"Name"], command,
231
self.logger('Checker for client %s (command "%s")'
232
' was killed by signal %s'
233
% (self.properties["Name"], command,
224
234
os.WTERMSIG(condition)))
225
235
elif os.WCOREDUMP(condition):
226
self.logger(u'Checker for client %s (command "%s")'
227
u' dumped core'
228
% (self.properties[u"Name"], command))
236
self.logger('Checker for client %s (command "%s")'
237
' dumped core'
238
% (self.properties["Name"], command))
229
239
else:
230
self.logger(u'Checker for client %s completed'
231
u' mysteriously')
240
self.logger('Checker for client %s completed'
241
' mysteriously')
232
242
self.update()
233
243
234
244
def checker_started(self, command):
235
#self.logger(u'Client %s started checker "%s"'
236
# % (self.properties[u"Name"], unicode(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)))
237
249
pass
238
250
239
251
def got_secret(self):
240
252
self.last_checker_failed = False
241
self.logger(u'Client %s received its secret'
242
% self.properties[u"Name"])
253
self.logger('Client %s received its secret'
254
% self.properties["Name"])
243
255
244
256
def need_approval(self, timeout, default):
245
257
if not default:
246
message = u'Client %s needs approval within %s seconds'
258
message = 'Client %s needs approval within %s seconds'
247
259
else:
248
message = u'Client %s will get its secret in %s seconds'
260
message = 'Client %s will get its secret in %s seconds'
249
261
self.logger(message
250
% (self.properties[u"Name"], timeout/1000))
262
% (self.properties["Name"], timeout/1000))
251
263
self.using_timer(True)
252
264
253
265
def rejected(self, reason):
254
self.logger(u'Client %s was rejected; reason: %s'
255
% (self.properties[u"Name"], reason))
266
self.logger('Client %s was rejected; reason: %s'
267
% (self.properties["Name"], reason))
256
268
257
269
def selectable(self):
258
270
"""Make this a "selectable" widget.
259
271
This overrides the method from urwid.FlowWidget."""
260
272
return True
261
273
262
def rows(self, (maxcol,), focus=False):
274
def rows(self, maxcolrow, focus=False):
263
275
"""How many rows this widget will occupy might depend on
264
276
whether we have focus or not.
265
277
This overrides the method from urwid.FlowWidget"""
266
return self.current_widget(focus).rows((maxcol,), focus=focus)
278
return self.current_widget(focus).rows(maxcolrow, focus=focus)
267
279
268
280
def current_widget(self, focus=False):
269
281
if focus or self.opened:
273
285
def update(self):
274
286
"Called when what is visible on the screen should be updated."
275
287
# How to add standout mode to a style
276
with_standout = { u"normal": u"standout",
277
u"bold": u"bold-standout",
278
u"underline-blink":
279
u"underline-blink-standout",
280
u"bold-underline-blink":
281
u"bold-underline-blink-standout",
288
with_standout = { "normal": "standout",
289
"bold": "bold-standout",
290
"underline-blink":
291
"underline-blink-standout",
292
"bold-underline-blink":
293
"bold-underline-blink-standout",
282
294
}
283
295
284
296
# Rebuild focus and non-focus widgets using current properties
285
297
286
298
# Base part of a client. Name!
287
base = (u'%(name)s: '
288
% {u"name": self.properties[u"Name"]})
289
if not self.properties[u"Enabled"]:
290
message = u"DISABLED"
291
elif self.properties[u"ApprovalPending"]:
299
base = ('%(name)s: '
300
% {"name": self.properties["Name"]})
301
if not self.properties["Enabled"]:
302
message = "DISABLED"
303
elif self.properties["ApprovalPending"]:
292
304
timeout = datetime.timedelta(milliseconds
293
305
= self.properties
294
[u"ApprovalDelay"])
306
["ApprovalDelay"])
295
307
last_approval_request = isoformat_to_datetime(
296
self.properties[u"LastApprovalRequest"])
308
self.properties["LastApprovalRequest"])
297
309
if last_approval_request is not None:
298
310
timer = timeout - (datetime.datetime.utcnow()
299
311
- last_approval_request)
300
312
else:
301
313
timer = datetime.timedelta()
302
if self.properties[u"ApprovedByDefault"]:
303
message = u"Approval in %s. (d)eny?"
314
if self.properties["ApprovedByDefault"]:
315
message = "Approval in %s. (d)eny?"
304
316
else:
305
message = u"Denial in %s. (a)pprove?"
317
message = "Denial in %s. (a)pprove?"
306
318
message = message % unicode(timer).rsplit(".", 1)[0]
307
319
elif self.last_checker_failed:
308
timeout = datetime.timedelta(milliseconds
309
= self.properties
310
[u"Timeout"])
311
last_ok = isoformat_to_datetime(
312
max((self.properties[u"LastCheckedOK"]
313
or self.properties[u"Created"]),
314
self.properties[u"LastEnabled"]))
315
timer = timeout - (datetime.datetime.utcnow() - last_ok)
316
message = (u'A checker has failed! Time until client'
317
u' gets disabled: %s'
320
# When checker has failed, print a timer until client expires
321
expires = self.properties["Expires"]
322
if expires == "":
323
timer = datetime.timedelta(0)
324
else:
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'
329
' gets disabled: %s'
318
330
% unicode(timer).rsplit(".", 1)[0])
319
331
else:
320
message = u"enabled"
332
message = "enabled"
321
333
self._text = "%s%s" % (base, message)
322
334
323
335
if not urwid.supports_unicode():
324
336
self._text = self._text.encode("ascii", "replace")
325
textlist = [(u"normal", self._text)]
337
textlist = [("normal", self._text)]
326
338
self._text_widget.set_text(textlist)
327
339
self._focus_text_widget.set_text([(with_standout[text[0]],
328
340
text[1])
337
349
self.update_hook()
338
350
339
351
def update_timer(self):
340
"called by gobject"
352
"""called by gobject. Will indefinitely loop until
353
gobject.source_remove() on tag is called"""
341
354
self.update()
342
355
return True # Keep calling this
343
356
344
def delete(self):
357
def delete(self, *args, **kwargs):
345
358
if self._update_timer_callback_tag is not None:
346
359
gobject.source_remove(self._update_timer_callback_tag)
347
360
self._update_timer_callback_tag = None
361
for match in self.match_objects:
362
match.remove()
363
self.match_objects = ()
348
364
if self.delete_hook is not None:
349
365
self.delete_hook(self)
366
return super(MandosClientWidget, self).delete(*args, **kwargs)
350
367
351
def render(self, (maxcol,), focus=False):
368
def render(self, maxcolrow, focus=False):
352
369
"""Render differently if we have focus.
353
370
This overrides the method from urwid.FlowWidget"""
354
return self.current_widget(focus).render((maxcol,),
371
return self.current_widget(focus).render(maxcolrow,
355
372
focus=focus)
356
373
357
def keypress(self, (maxcol,), key):
374
def keypress(self, maxcolrow, key):
358
375
"""Handle keys.
359
376
This overrides the method from urwid.FlowWidget"""
360
if key == u"+":
361
self.proxy.Enable(dbus_interface = client_interface)
362
elif key == u"-":
363
self.proxy.Disable(dbus_interface = client_interface)
364
elif key == u"a":
377
if key == "+":
378
self.proxy.Enable(dbus_interface = client_interface,
379
ignore_reply=True)
380
elif key == "-":
381
self.proxy.Disable(dbus_interface = client_interface,
382
ignore_reply=True)
383
elif key == "a":
365
384
self.proxy.Approve(dbus.Boolean(True, variant_level=1),
366
dbus_interface = client_interface)
367
elif key == u"d":
385
dbus_interface = client_interface,
386
ignore_reply=True)
387
elif key == "d":
368
388
self.proxy.Approve(dbus.Boolean(False, variant_level=1),
369
dbus_interface = client_interface)
370
elif key == u"R" or key == u"_" or key == u"ctrl k":
389
dbus_interface = client_interface,
390
ignore_reply=True)
391
elif key == "R" or key == "_" or key == "ctrl k":
371
392
self.server_proxy_object.RemoveClient(self.proxy
372
.object_path)
373
elif key == u"s":
374
self.proxy.StartChecker(dbus_interface = client_interface)
375
elif key == u"S":
376
self.proxy.StopChecker(dbus_interface = client_interface)
377
elif key == u"C":
378
self.proxy.CheckedOK(dbus_interface = client_interface)
393
.object_path,
394
ignore_reply=True)
395
elif key == "s":
396
self.proxy.StartChecker(dbus_interface = client_interface,
397
ignore_reply=True)
398
elif key == "S":
399
self.proxy.StopChecker(dbus_interface = client_interface,
400
ignore_reply=True)
401
elif key == "C":
402
self.proxy.CheckedOK(dbus_interface = client_interface,
403
ignore_reply=True)
379
404
# xxx
380
# elif key == u"p" or key == "=":
405
# elif key == "p" or key == "=":
381
406
# self.proxy.pause()
382
# elif key == u"u" or key == ":":
407
# elif key == "u" or key == ":":
383
408
# self.proxy.unpause()
384
# elif key == u"RET":
409
# elif key == "RET":
385
410
# self.open()
386
411
else:
387
412
return key
403
428
"down" key presses, thus not allowing any containing widgets to
404
429
use them as an excuse to shift focus away from this widget.
405
430
"""
406
def keypress(self, (maxcol, maxrow), key):
407
ret = super(ConstrainedListBox, self).keypress((maxcol,
408
maxrow), key)
409
if ret in (u"up", u"down"):
431
def keypress(self, maxcolrow, key):
432
ret = super(ConstrainedListBox, self).keypress(maxcolrow, key)
433
if ret in ("up", "down"):
410
434
return
411
435
return ret
412
436
421
445
self.screen = urwid.curses_display.Screen()
422
446
423
447
self.screen.register_palette((
424
(u"normal",
425
u"default", u"default", None),
426
(u"bold",
427
u"default", u"default", u"bold"),
428
(u"underline-blink",
429
u"default", u"default", u"underline"),
430
(u"standout",
431
u"default", u"default", u"standout"),
432
(u"bold-underline-blink",
433
u"default", u"default", (u"bold", u"underline")),
434
(u"bold-standout",
435
u"default", u"default", (u"bold", u"standout")),
436
(u"underline-blink-standout",
437
u"default", u"default", (u"underline", u"standout")),
438
(u"bold-underline-blink-standout",
439
u"default", u"default", (u"bold", u"underline",
440
u"standout")),
448
("normal",
449
"default", "default", None),
450
("bold",
451
"default", "default", "bold"),
452
("underline-blink",
453
"default", "default", "underline"),
454
("standout",
455
"default", "default", "standout"),
456
("bold-underline-blink",
457
"default", "default", ("bold", "underline")),
458
("bold-standout",
459
"default", "default", ("bold", "standout")),
460
("underline-blink-standout",
461
"default", "default", ("underline", "standout")),
462
("bold-underline-blink-standout",
463
"default", "default", ("bold", "underline",
464
"standout")),
441
465
))
442
466
443
467
if urwid.supports_unicode():
444
self.divider = u"─" # \u2500
445
#self.divider = u"━" # \u2501
468
self.divider = "─" # \u2500
469
#self.divider = "━" # \u2501
446
470
else:
447
#self.divider = u"-" # \u002d
448
self.divider = u"_" # \u005f
471
#self.divider = "-" # \u002d
472
self.divider = "_" # \u005f
449
473
450
474
self.screen.start()
451
475
465
489
# This keeps track of whether self.uilist currently has
466
490
# self.logbox in it or not
467
491
self.log_visible = True
468
self.log_wrap = u"any"
492
self.log_wrap = "any"
469
493
470
494
self.rebuild()
471
self.log_message_raw((u"bold",
472
u"Mandos Monitor version " + version))
473
self.log_message_raw((u"bold",
474
u"q: Quit ?: Help"))
495
self.log_message_raw(("bold",
496
"Mandos Monitor version " + version))
497
self.log_message_raw(("bold",
498
"q: Quit ?: Help"))
475
499
476
500
self.busname = domain + '.Mandos'
477
501
self.main_loop = gobject.MainLoop()
478
self.bus = dbus.SystemBus()
479
mandos_dbus_objc = self.bus.get_object(
480
self.busname, u"/", follow_name_owner_changes=True)
481
self.mandos_serv = dbus.Interface(mandos_dbus_objc,
482
dbus_interface
483
= server_interface)
484
try:
485
mandos_clients = (self.mandos_serv
486
.GetAllClientsWithProperties())
487
except dbus.exceptions.DBusException:
488
mandos_clients = dbus.Dictionary()
489
490
(self.mandos_serv
491
.connect_to_signal(u"ClientRemoved",
492
self.find_and_remove_client,
493
dbus_interface=server_interface,
494
byte_arrays=True))
495
(self.mandos_serv
496
.connect_to_signal(u"ClientAdded",
497
self.add_new_client,
498
dbus_interface=server_interface,
499
byte_arrays=True))
500
(self.mandos_serv
501
.connect_to_signal(u"ClientNotFound",
502
self.client_not_found,
503
dbus_interface=server_interface,
504
byte_arrays=True))
505
for path, client in mandos_clients.iteritems():
506
client_proxy_object = self.bus.get_object(self.busname,
507
path)
508
self.add_client(MandosClientWidget(server_proxy_object
509
=self.mandos_serv,
510
proxy_object
511
=client_proxy_object,
512
properties=client,
513
update_hook
514
=self.refresh,
515
delete_hook
516
=self.remove_client,
517
logger
518
=self.log_message),
519
path=path)
520
502
521
503
def client_not_found(self, fingerprint, address):
522
self.log_message((u"Client with address %s and fingerprint %s"
523
u" could not be found" % (address,
504
self.log_message(("Client with address %s and fingerprint %s"
505
" could not be found" % (address,
524
506
fingerprint)))
525
507
526
508
def rebuild(self):
537
519
self.divider)))
538
520
if self.log_visible:
539
521
self.uilist.append(self.logbox)
540
pass
541
522
self.topwidget = urwid.Pile(self.uilist)
542
523
543
524
def log_message(self, message):
544
525
timestamp = datetime.datetime.now().isoformat()
545
self.log_message_raw(timestamp + u": " + message)
526
self.log_message_raw(timestamp + ": " + message)
546
527
547
528
def log_message_raw(self, markup):
548
529
"""Add a log message to the log buffer."""
551
532
and len(self.log) > self.max_log_length):
552
533
del self.log[0:len(self.log)-self.max_log_length-1]
553
534
self.logbox.set_focus(len(self.logbox.body.contents),
554
coming_from=u"above")
535
coming_from="above")
555
536
self.refresh()
556
537
557
538
def toggle_log_display(self):
558
539
"""Toggle visibility of the log buffer."""
559
540
self.log_visible = not self.log_visible
560
541
self.rebuild()
561
#self.log_message(u"Log visibility changed to: "
542
#self.log_message("Log visibility changed to: "
562
543
# + unicode(self.log_visible))
563
544
564
545
def change_log_display(self):
565
546
"""Change type of log display.
566
547
Currently, this toggles wrapping of text lines."""
567
if self.log_wrap == u"clip":
568
self.log_wrap = u"any"
548
if self.log_wrap == "clip":
549
self.log_wrap = "any"
569
550
else:
570
self.log_wrap = u"clip"
551
self.log_wrap = "clip"
571
552
for textwidget in self.log:
572
553
textwidget.set_wrap_mode(self.log_wrap)
573
#self.log_message(u"Wrap mode: " + self.log_wrap)
554
#self.log_message("Wrap mode: " + self.log_wrap)
574
555
575
556
def find_and_remove_client(self, path, name):
576
"""Find an client from its object path and remove it.
557
"""Find a client by its object path and remove it.
577
558
578
559
This is connected to the ClientRemoved signal from the
579
560
Mandos server object."""
581
562
client = self.clients_dict[path]
582
563
except KeyError:
583
564
# not found?
565
self.log_message("Unknown client %r (%r) removed", name,
566
path)
584
567
return
585
self.remove_client(client, path)
568
client.delete()
586
569
587
570
def add_new_client(self, path):
588
571
client_proxy_object = self.bus.get_object(self.busname, path)
603
586
if path is None:
604
587
path = client.proxy.object_path
605
588
self.clients_dict[path] = client
606
self.clients.sort(None, lambda c: c.properties[u"Name"])
589
self.clients.sort(None, lambda c: c.properties["Name"])
607
590
self.refresh()
608
591
609
592
def remove_client(self, client, path=None):
625
608
626
609
def run(self):
627
610
"""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,
615
dbus_interface
616
= server_interface)
617
try:
618
mandos_clients = (self.mandos_serv
619
.GetAllClientsWithProperties())
620
except dbus.exceptions.DBusException:
621
mandos_clients = dbus.Dictionary()
622
623
(self.mandos_serv
624
.connect_to_signal("ClientRemoved",
625
self.find_and_remove_client,
626
dbus_interface=server_interface,
627
byte_arrays=True))
628
(self.mandos_serv
629
.connect_to_signal("ClientAdded",
630
self.add_new_client,
631
dbus_interface=server_interface,
632
byte_arrays=True))
633
(self.mandos_serv
634
.connect_to_signal("ClientNotFound",
635
self.client_not_found,
636
dbus_interface=server_interface,
637
byte_arrays=True))
638
for path, client in mandos_clients.iteritems():
639
client_proxy_object = self.bus.get_object(self.busname,
640
path)
641
self.add_client(MandosClientWidget(server_proxy_object
642
=self.mandos_serv,
643
proxy_object
644
=client_proxy_object,
645
properties=client,
646
update_hook
647
=self.refresh,
648
delete_hook
649
=self.remove_client,
650
logger
651
=self.log_message),
652
path=path)
653
628
654
self.refresh()
629
655
self._input_callback_tag = (gobject.io_add_watch
630
656
(sys.stdin.fileno(),
640
666
641
667
def process_input(self, source, condition):
642
668
keys = self.screen.get_input()
643
translations = { u"ctrl n": u"down", # Emacs
644
u"ctrl p": u"up", # Emacs
645
u"ctrl v": u"page down", # Emacs
646
u"meta v": u"page up", # Emacs
647
u" ": u"page down", # less
648
u"f": u"page down", # less
649
u"b": u"page up", # less
650
u"j": u"down", # vi
651
u"k": u"up", # vi
669
translations = { "ctrl n": "down", # Emacs
670
"ctrl p": "up", # Emacs
671
"ctrl v": "page down", # Emacs
672
"meta v": "page up", # Emacs
673
" ": "page down", # less
674
"f": "page down", # less
675
"b": "page up", # less
676
"j": "down", # vi
677
"k": "up", # vi
652
678
}
653
679
for key in keys:
654
680
try:
656
682
except KeyError: # :-)
657
683
pass
658
684
659
if key == u"q" or key == u"Q":
685
if key == "q" or key == "Q":
660
686
self.stop()
661
687
break
662
elif key == u"window resize":
688
elif key == "window resize":
663
689
self.size = self.screen.get_cols_rows()
664
690
self.refresh()
665
elif key == u"\f": # Ctrl-L
691
elif key == "\f": # Ctrl-L
666
692
self.refresh()
667
elif key == u"l" or key == u"D":
693
elif key == "l" or key == "D":
668
694
self.toggle_log_display()
669
695
self.refresh()
670
elif key == u"w" or key == u"i":
696
elif key == "w" or key == "i":
671
697
self.change_log_display()
672
698
self.refresh()
673
elif key == u"?" or key == u"f1" or key == u"esc":
699
elif key == "?" or key == "f1" or key == "esc":
674
700
if not self.log_visible:
675
701
self.log_visible = True
676
702
self.rebuild()
677
self.log_message_raw((u"bold",
678
u" ".
679
join((u"q: Quit",
680
u"?: Help",
681
u"l: Log window toggle",
682
u"TAB: Switch window",
683
u"w: Wrap (log)"))))
684
self.log_message_raw((u"bold",
685
u" "
686
.join((u"Clients:",
687
u"+: Enable",
688
u"-: Disable",
689
u"R: Remove",
690
u"s: Start new checker",
691
u"S: Stop checker",
692
u"C: Checker OK",
693
u"a: Approve",
694
u"d: Deny"))))
703
self.log_message_raw(("bold",
704
" ".
705
join(("q: Quit",
706
"?: Help",
707
"l: Log window toggle",
708
"TAB: Switch window",
709
"w: Wrap (log)"))))
710
self.log_message_raw(("bold",
711
" "
712
.join(("Clients:",
713
"+: Enable",
714
"-: Disable",
715
"R: Remove",
716
"s: Start new checker",
717
"S: Stop checker",
718
"C: Checker OK",
719
"a: Approve",
720
"d: Deny"))))
695
721
self.refresh()
696
elif key == u"tab":
722
elif key == "tab":
697
723
if self.topwidget.get_focus() is self.logbox:
698
724
self.topwidget.set_focus(0)
699
725
else:
700
726
self.topwidget.set_focus(self.logbox)
701
727
self.refresh()
702
#elif (key == u"end" or key == u"meta >" or key == u"G"
703
# or key == u">"):
728
#elif (key == "end" or key == "meta >" or key == "G"
729
# or key == ">"):
704
730
# pass # xxx end-of-buffer
705
#elif (key == u"home" or key == u"meta <" or key == u"g"
706
# or key == u"<"):
731
#elif (key == "home" or key == "meta <" or key == "g"
732
# or key == "<"):
707
733
# pass # xxx beginning-of-buffer
708
#elif key == u"ctrl e" or key == u"$":
734
#elif key == "ctrl e" or key == "$":
709
735
# pass # xxx move-end-of-line
710
#elif key == u"ctrl a" or key == u"^":
736
#elif key == "ctrl a" or key == "^":
711
737
# pass # xxx move-beginning-of-line
712
#elif key == u"ctrl b" or key == u"meta (" or key == u"h":
738
#elif key == "ctrl b" or key == "meta (" or key == "h":
713
739
# pass # xxx left
714
#elif key == u"ctrl f" or key == u"meta )" or key == u"l":
740
#elif key == "ctrl f" or key == "meta )" or key == "l":
715
741
# pass # xxx right
716
#elif key == u"a":
742
#elif key == "a":
717
743
# pass # scroll up log
718
#elif key == u"z":
744
#elif key == "z":
719
745
# pass # scroll down log
720
746
elif self.topwidget.selectable():
721
747
self.topwidget.keypress(self.size, key)
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0