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