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