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