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