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 237.7.345
- compare with another revision
- download diff
- download tarball
- view history from revision 237.7.345
- Committer: Teddy Hogeborn
- Date: 2016-02-21 12:43:51 UTC
- mto: (237.7.594 trunk)
- mto: This revision was merged to the branch mainline in revision 331.
- Revision ID: teddy@recompile.se-20160221124351-3g9bc5eu90at8yis
plugin-runner.c: Use size_t to realloc() for custom plugin args.
* plugin-runner.c (main): Cast argument to realloc() to size_t when
allocating additional custom plugin command
line arguments.
* plugin-runner.c (main): Cast argument to realloc() to size_t when
allocating additional custom plugin command
line arguments.
- files added:
- debian/mandos-client.examples
- debian/upstream
- network-hooks.d
- plugin-helpers
- files modified:
- .bzrignore
added
removed
mandos-monitor
3
3
#
4
4
# Mandos Monitor - Control and monitor the Mandos server
5
5
#
6
# Copyright © 2009-2011 Teddy Hogeborn
7
# Copyright © 2009-2011 Björn Påhlsson
6
# Copyright © 2009-2015 Teddy Hogeborn
7
# Copyright © 2009-2015 Björn Påhlsson
8
8
#
9
9
# This program is free software: you can redistribute it and/or modify
10
10
# it under the terms of the GNU General Public License as published by
17
17
# GNU General Public License for more details.
18
18
#
19
19
# You should have received a copy of the GNU General Public License
20
# along with this program. If not, see <http://www.gnu.org/licenses/>.
20
# along with this program. If not, see
21
# <http://www.gnu.org/licenses/>.
21
22
#
22
23
# Contact the authors at <mandos@recompile.se>.
23
24
#
24
25
25
26
from __future__ import (division, absolute_import, print_function,
26
27
unicode_literals)
28
try:
29
from future_builtins import *
30
except ImportError:
31
pass
27
32
28
33
import sys
29
34
import os
30
import signal
31
35
32
36
import datetime
33
37
35
39
import urwid
36
40
37
41
from dbus.mainloop.glib import DBusGMainLoop
38
import gobject
42
try:
43
import gobject
44
except ImportError:
45
from gi.repository import GObject as gobject
39
46
40
47
import dbus
41
48
42
import UserList
43
44
49
import locale
45
50
51
if sys.version_info.major == 2:
52
str = unicode
53
46
54
locale.setlocale(locale.LC_ALL, '')
47
55
48
56
import logging
52
60
domain = 'se.recompile'
53
61
server_interface = domain + '.Mandos'
54
62
client_interface = domain + '.Mandos.Client'
55
version = "1.4.1"
56
57
# Always run in monochrome mode
58
urwid.curses_display.curses.has_colors = lambda : False
59
60
# Urwid doesn't support blinking, but we want it. Since we have no
61
# use for underline on its own, we make underline also always blink.
62
urwid.curses_display.curses.A_UNDERLINE |= (
63
urwid.curses_display.curses.A_BLINK)
63
version = "1.7.1"
64
65
try:
66
dbus.OBJECT_MANAGER_IFACE
67
except AttributeError:
68
dbus.OBJECT_MANAGER_IFACE = "org.freedesktop.DBus.ObjectManager"
64
69
65
70
def isoformat_to_datetime(iso):
66
71
"Parse an ISO 8601 date string to a datetime.datetime()"
83
88
properties and calls a hook function when any of them are
84
89
changed.
85
90
"""
86
def __init__(self, proxy_object=None, *args, **kwargs):
91
def __init__(self, proxy_object=None, properties=None, **kwargs):
87
92
self.proxy = proxy_object # Mandos Client proxy object
88
89
self.properties = dict()
93
self.properties = dict() if properties is None else properties
90
94
self.property_changed_match = (
91
self.proxy.connect_to_signal("PropertyChanged",
92
self.property_changed,
93
client_interface,
95
self.proxy.connect_to_signal("PropertiesChanged",
96
self.properties_changed,
97
dbus.PROPERTIES_IFACE,
94
98
byte_arrays=True))
95
99
96
self.properties.update(
97
self.proxy.GetAll(client_interface,
98
dbus_interface = dbus.PROPERTIES_IFACE))
99
100
#XXX This breaks good super behaviour
101
# super(MandosClientPropertyCache, self).__init__(
102
# *args, **kwargs)
100
if properties is None:
101
self.properties.update(
102
self.proxy.GetAll(client_interface,
103
dbus_interface
104
= dbus.PROPERTIES_IFACE))
105
106
super(MandosClientPropertyCache, self).__init__(**kwargs)
103
107
104
def property_changed(self, property=None, value=None):
105
"""This is called whenever we get a PropertyChanged signal
106
It updates the changed property in the "properties" dict.
108
def properties_changed(self, interface, properties, invalidated):
109
"""This is called whenever we get a PropertiesChanged signal
110
It updates the changed properties in the "properties" dict.
107
111
"""
108
112
# Update properties dict with new value
109
self.properties[property] = value
113
if interface == client_interface:
114
self.properties.update(properties)
110
115
111
def delete(self, *args, **kwargs):
116
def delete(self):
112
117
self.property_changed_match.remove()
113
super(MandosClientPropertyCache, self).__init__(
114
*args, **kwargs)
115
118
116
119
117
120
class MandosClientWidget(urwid.FlowWidget, MandosClientPropertyCache):
119
122
"""
120
123
121
124
def __init__(self, server_proxy_object=None, update_hook=None,
122
delete_hook=None, logger=None, *args, **kwargs):
125
delete_hook=None, logger=None, **kwargs):
123
126
# Called on update
124
127
self.update_hook = update_hook
125
128
# Called on delete
130
133
self.logger = logger
131
134
132
135
self._update_timer_callback_tag = None
133
self._update_timer_callback_lock = 0
134
self.last_checker_failed = False
135
136
136
137
# The widget shown normally
137
138
self._text_widget = urwid.Text("")
138
139
# The widget shown when we have focus
139
140
self._focus_text_widget = urwid.Text("")
140
super(MandosClientWidget, self).__init__(
141
update_hook=update_hook, delete_hook=delete_hook,
142
*args, **kwargs)
141
super(MandosClientWidget, self).__init__(**kwargs)
143
142
self.update()
144
143
self.opened = False
145
144
146
last_checked_ok = isoformat_to_datetime(self.properties
147
["LastCheckedOK"])
148
if last_checked_ok is None:
149
self.last_checker_failed = True
150
else:
151
self.last_checker_failed = ((datetime.datetime.utcnow()
152
- last_checked_ok)
153
> datetime.timedelta
154
(milliseconds=
155
self.properties
156
["Interval"]))
157
158
if self.last_checker_failed:
159
self.using_timer(True)
160
161
if self.need_approval:
162
self.using_timer(True)
163
164
145
self.match_objects = (
165
146
self.proxy.connect_to_signal("CheckerCompleted",
166
147
self.checker_completed,
182
163
self.rejected,
183
164
client_interface,
184
165
byte_arrays=True))
185
#self.logger('Created client %s' % (self.properties["Name"]))
166
self.logger('Created client {}'
167
.format(self.properties["Name"]), level=0)
186
168
187
def property_changed(self, property=None, value=None):
188
super(self, MandosClientWidget).property_changed(property,
189
value)
190
if property == "ApprovalPending":
191
using_timer(bool(value))
192
193
169
def using_timer(self, flag):
194
170
"""Call this method with True or False when timer should be
195
171
activated or deactivated.
196
172
"""
197
old = self._update_timer_callback_lock
198
if flag:
199
self._update_timer_callback_lock += 1
200
else:
201
self._update_timer_callback_lock -= 1
202
if old == 0 and self._update_timer_callback_lock:
173
if flag and self._update_timer_callback_tag is None:
203
174
# Will update the shown timer value every second
204
175
self._update_timer_callback_tag = (gobject.timeout_add
205
176
(1000,
206
177
self.update_timer))
207
elif old and self._update_timer_callback_lock == 0:
178
elif not (flag or self._update_timer_callback_tag is None):
208
179
gobject.source_remove(self._update_timer_callback_tag)
209
180
self._update_timer_callback_tag = None
210
181
211
182
def checker_completed(self, exitstatus, condition, command):
212
183
if exitstatus == 0:
213
if self.last_checker_failed:
214
self.last_checker_failed = False
215
self.using_timer(False)
216
#self.logger('Checker for client %s (command "%s")'
217
# ' was successful'
218
# % (self.properties["Name"], command))
184
self.logger('Checker for client {} (command "{}")'
185
' succeeded'.format(self.properties["Name"],
186
command), level=0)
219
187
self.update()
220
188
return
221
189
# Checker failed
222
if not self.last_checker_failed:
223
self.last_checker_failed = True
224
self.using_timer(True)
225
190
if os.WIFEXITED(condition):
226
self.logger('Checker for client %s (command "%s")'
227
' failed with exit code %s'
228
% (self.properties["Name"], command,
229
os.WEXITSTATUS(condition)))
191
self.logger('Checker for client {} (command "{}") failed'
192
' with exit code {}'
193
.format(self.properties["Name"], command,
194
os.WEXITSTATUS(condition)))
230
195
elif os.WIFSIGNALED(condition):
231
self.logger('Checker for client %s (command "%s")'
232
' was killed by signal %s'
233
% (self.properties["Name"], command,
234
os.WTERMSIG(condition)))
235
elif os.WCOREDUMP(condition):
236
self.logger('Checker for client %s (command "%s")'
237
' dumped core'
238
% (self.properties["Name"], command))
239
else:
240
self.logger('Checker for client %s completed'
241
' mysteriously')
196
self.logger('Checker for client {} (command "{}") was'
197
' killed by signal {}'
198
.format(self.properties["Name"], command,
199
os.WTERMSIG(condition)))
242
200
self.update()
243
201
244
202
def checker_started(self, command):
245
#self.logger('Client %s started checker "%s"'
246
# % (self.properties["Name"], unicode(command)))
247
pass
203
"""Server signals that a checker started."""
204
self.logger('Client {} started checker "{}"'
205
.format(self.properties["Name"],
206
command), level=0)
248
207
249
208
def got_secret(self):
250
self.last_checker_failed = False
251
self.logger('Client %s received its secret'
252
% self.properties["Name"])
209
self.logger('Client {} received its secret'
210
.format(self.properties["Name"]))
253
211
254
212
def need_approval(self, timeout, default):
255
213
if not default:
256
message = 'Client %s needs approval within %s seconds'
214
message = 'Client {} needs approval within {} seconds'
257
215
else:
258
message = 'Client %s will get its secret in %s seconds'
259
self.logger(message
260
% (self.properties["Name"], timeout/1000))
261
self.using_timer(True)
216
message = 'Client {} will get its secret in {} seconds'
217
self.logger(message.format(self.properties["Name"],
218
timeout/1000))
262
219
263
220
def rejected(self, reason):
264
self.logger('Client %s was rejected; reason: %s'
265
% (self.properties["Name"], reason))
221
self.logger('Client {} was rejected; reason: {}'
222
.format(self.properties["Name"], reason))
266
223
267
224
def selectable(self):
268
225
"""Make this a "selectable" widget.
290
247
"bold-underline-blink":
291
248
"bold-underline-blink-standout",
292
249
}
293
250
294
251
# Rebuild focus and non-focus widgets using current properties
295
252
296
253
# Base part of a client. Name!
297
base = ('%(name)s: '
298
% {"name": self.properties["Name"]})
254
base = '{name}: '.format(name=self.properties["Name"])
299
255
if not self.properties["Enabled"]:
300
256
message = "DISABLED"
257
self.using_timer(False)
301
258
elif self.properties["ApprovalPending"]:
302
259
timeout = datetime.timedelta(milliseconds
303
260
= self.properties
305
262
last_approval_request = isoformat_to_datetime(
306
263
self.properties["LastApprovalRequest"])
307
264
if last_approval_request is not None:
308
timer = timeout - (datetime.datetime.utcnow()
309
- last_approval_request)
265
timer = max(timeout - (datetime.datetime.utcnow()
266
- last_approval_request),
267
datetime.timedelta())
310
268
else:
311
269
timer = datetime.timedelta()
312
270
if self.properties["ApprovedByDefault"]:
313
message = "Approval in %s. (d)eny?"
271
message = "Approval in {}. (d)eny?"
314
272
else:
315
message = "Denial in %s. (a)pprove?"
316
message = message % unicode(timer).rsplit(".", 1)[0]
317
elif self.last_checker_failed:
318
# When checker has failed, print a timer until client expires
273
message = "Denial in {}. (a)pprove?"
274
message = message.format(str(timer).rsplit(".", 1)[0])
275
self.using_timer(True)
276
elif self.properties["LastCheckerStatus"] != 0:
277
# When checker has failed, show timer until client expires
319
278
expires = self.properties["Expires"]
320
279
if expires == "":
321
280
timer = datetime.timedelta(0)
322
281
else:
323
expires = datetime.datetime.strptime(expires,
324
'%Y-%m-%dT%H:%M:%S.%f')
325
timer = expires - datetime.datetime.utcnow()
282
expires = (datetime.datetime.strptime
283
(expires, '%Y-%m-%dT%H:%M:%S.%f'))
284
timer = max(expires - datetime.datetime.utcnow(),
285
datetime.timedelta())
326
286
message = ('A checker has failed! Time until client'
327
' gets disabled: %s'
328
% unicode(timer).rsplit(".", 1)[0])
287
' gets disabled: {}'
288
.format(str(timer).rsplit(".", 1)[0]))
289
self.using_timer(True)
329
290
else:
330
291
message = "enabled"
331
self._text = "%s%s" % (base, message)
332
292
self.using_timer(False)
293
self._text = "{}{}".format(base, message)
294
333
295
if not urwid.supports_unicode():
334
296
self._text = self._text.encode("ascii", "replace")
335
297
textlist = [("normal", self._text)]
352
314
self.update()
353
315
return True # Keep calling this
354
316
355
def delete(self, *args, **kwargs):
317
def delete(self, **kwargs):
356
318
if self._update_timer_callback_tag is not None:
357
319
gobject.source_remove(self._update_timer_callback_tag)
358
320
self._update_timer_callback_tag = None
361
323
self.match_objects = ()
362
324
if self.delete_hook is not None:
363
325
self.delete_hook(self)
364
return super(MandosClientWidget, self).delete(*args, **kwargs)
326
return super(MandosClientWidget, self).delete(**kwargs)
365
327
366
328
def render(self, maxcolrow, focus=False):
367
329
"""Render differently if we have focus.
373
335
"""Handle keys.
374
336
This overrides the method from urwid.FlowWidget"""
375
337
if key == "+":
376
self.proxy.Enable(dbus_interface = client_interface,
377
ignore_reply=True)
338
self.proxy.Set(client_interface, "Enabled",
339
dbus.Boolean(True), ignore_reply = True,
340
dbus_interface = dbus.PROPERTIES_IFACE)
378
341
elif key == "-":
379
self.proxy.Disable(dbus_interface = client_interface,
380
ignore_reply=True)
342
self.proxy.Set(client_interface, "Enabled", False,
343
ignore_reply = True,
344
dbus_interface = dbus.PROPERTIES_IFACE)
381
345
elif key == "a":
382
346
self.proxy.Approve(dbus.Boolean(True, variant_level=1),
383
347
dbus_interface = client_interface,
391
355
.object_path,
392
356
ignore_reply=True)
393
357
elif key == "s":
394
self.proxy.StartChecker(dbus_interface = client_interface,
395
ignore_reply=True)
358
self.proxy.Set(client_interface, "CheckerRunning",
359
dbus.Boolean(True), ignore_reply = True,
360
dbus_interface = dbus.PROPERTIES_IFACE)
396
361
elif key == "S":
397
self.proxy.StopChecker(dbus_interface = client_interface,
398
ignore_reply=True)
362
self.proxy.Set(client_interface, "CheckerRunning",
363
dbus.Boolean(False), ignore_reply = True,
364
dbus_interface = dbus.PROPERTIES_IFACE)
399
365
elif key == "C":
400
366
self.proxy.CheckedOK(dbus_interface = client_interface,
401
367
ignore_reply=True)
409
375
else:
410
376
return key
411
377
412
def property_changed(self, property=None, value=None,
413
*args, **kwargs):
414
"""Call self.update() if old value is not new value.
378
def properties_changed(self, interface, properties, invalidated):
379
"""Call self.update() if any properties changed.
415
380
This overrides the method from MandosClientPropertyCache"""
416
property_name = unicode(property)
417
old_value = self.properties.get(property_name)
418
super(MandosClientWidget, self).property_changed(
419
property=property, value=value, *args, **kwargs)
420
if self.properties.get(property_name) != old_value:
381
old_values = { key: self.properties.get(key)
382
for key in properties.keys() }
383
super(MandosClientWidget, self).properties_changed(
384
interface, properties, invalidated)
385
if any(old_values[key] != self.properties.get(key)
386
for key in old_values):
421
387
self.update()
422
388
423
389
426
392
"down" key presses, thus not allowing any containing widgets to
427
393
use them as an excuse to shift focus away from this widget.
428
394
"""
429
def keypress(self, maxcolrow, key):
430
ret = super(ConstrainedListBox, self).keypress(maxcolrow, key)
395
def keypress(self, *args, **kwargs):
396
ret = super(ConstrainedListBox, self).keypress(*args, **kwargs)
431
397
if ret in ("up", "down"):
432
398
return
433
399
return ret
437
403
"""This is the entire user interface - the whole screen
438
404
with boxes, lists of client widgets, etc.
439
405
"""
440
def __init__(self, max_log_length=1000):
406
def __init__(self, max_log_length=1000, log_level=1):
441
407
DBusGMainLoop(set_as_default=True)
442
408
443
409
self.screen = urwid.curses_display.Screen()
446
412
("normal",
447
413
"default", "default", None),
448
414
("bold",
449
"default", "default", "bold"),
415
"bold", "default", "bold"),
450
416
("underline-blink",
451
"default", "default", "underline"),
417
"underline,blink", "default", "underline,blink"),
452
418
("standout",
453
"default", "default", "standout"),
419
"standout", "default", "standout"),
454
420
("bold-underline-blink",
455
"default", "default", ("bold", "underline")),
421
"bold,underline,blink", "default", "bold,underline,blink"),
456
422
("bold-standout",
457
"default", "default", ("bold", "standout")),
423
"bold,standout", "default", "bold,standout"),
458
424
("underline-blink-standout",
459
"default", "default", ("underline", "standout")),
425
"underline,blink,standout", "default",
426
"underline,blink,standout"),
460
427
("bold-underline-blink-standout",
461
"default", "default", ("bold", "underline",
462
"standout")),
428
"bold,underline,blink,standout", "default",
429
"bold,underline,blink,standout"),
463
430
))
464
431
465
432
if urwid.supports_unicode():
480
447
self.log = []
481
448
self.max_log_length = max_log_length
482
449
450
self.log_level = log_level
451
483
452
# We keep a reference to the log widget so we can remove it
484
453
# from the ListWalker without it getting destroyed
485
454
self.logbox = ConstrainedListBox(self.log)
497
466
498
467
self.busname = domain + '.Mandos'
499
468
self.main_loop = gobject.MainLoop()
500
self.bus = dbus.SystemBus()
501
mandos_dbus_objc = self.bus.get_object(
502
self.busname, "/", follow_name_owner_changes=True)
503
self.mandos_serv = dbus.Interface(mandos_dbus_objc,
504
dbus_interface
505
= server_interface)
506
try:
507
mandos_clients = (self.mandos_serv
508
.GetAllClientsWithProperties())
509
except dbus.exceptions.DBusException:
510
mandos_clients = dbus.Dictionary()
511
512
(self.mandos_serv
513
.connect_to_signal("ClientRemoved",
514
self.find_and_remove_client,
515
dbus_interface=server_interface,
516
byte_arrays=True))
517
(self.mandos_serv
518
.connect_to_signal("ClientAdded",
519
self.add_new_client,
520
dbus_interface=server_interface,
521
byte_arrays=True))
522
(self.mandos_serv
523
.connect_to_signal("ClientNotFound",
524
self.client_not_found,
525
dbus_interface=server_interface,
526
byte_arrays=True))
527
for path, client in mandos_clients.iteritems():
528
client_proxy_object = self.bus.get_object(self.busname,
529
path)
530
self.add_client(MandosClientWidget(server_proxy_object
531
=self.mandos_serv,
532
proxy_object
533
=client_proxy_object,
534
properties=client,
535
update_hook
536
=self.refresh,
537
delete_hook
538
=self.remove_client,
539
logger
540
=self.log_message),
541
path=path)
542
469
543
470
def client_not_found(self, fingerprint, address):
544
self.log_message(("Client with address %s and fingerprint %s"
545
" could not be found" % (address,
546
fingerprint)))
471
self.log_message("Client with address {} and fingerprint {}"
472
" could not be found"
473
.format(address, fingerprint))
547
474
548
475
def rebuild(self):
549
476
"""This rebuilds the User Interface.
559
486
self.divider)))
560
487
if self.log_visible:
561
488
self.uilist.append(self.logbox)
562
pass
563
489
self.topwidget = urwid.Pile(self.uilist)
564
490
565
def log_message(self, message):
491
def log_message(self, message, level=1):
492
"""Log message formatted with timestamp"""
493
if level < self.log_level:
494
return
566
495
timestamp = datetime.datetime.now().isoformat()
567
self.log_message_raw(timestamp + ": " + message)
496
self.log_message_raw("{}: {}".format(timestamp, message),
497
level=level)
568
498
569
def log_message_raw(self, markup):
499
def log_message_raw(self, markup, level=1):
570
500
"""Add a log message to the log buffer."""
501
if level < self.log_level:
502
return
571
503
self.log.append(urwid.Text(markup, wrap=self.log_wrap))
572
504
if (self.max_log_length
573
505
and len(self.log) > self.max_log_length):
580
512
"""Toggle visibility of the log buffer."""
581
513
self.log_visible = not self.log_visible
582
514
self.rebuild()
583
#self.log_message("Log visibility changed to: "
584
# + unicode(self.log_visible))
515
self.log_message("Log visibility changed to: {}"
516
.format(self.log_visible), level=0)
585
517
586
518
def change_log_display(self):
587
519
"""Change type of log display.
592
524
self.log_wrap = "clip"
593
525
for textwidget in self.log:
594
526
textwidget.set_wrap_mode(self.log_wrap)
595
#self.log_message("Wrap mode: " + self.log_wrap)
527
self.log_message("Wrap mode: {}".format(self.log_wrap),
528
level=0)
596
529
597
def find_and_remove_client(self, path, name):
530
def find_and_remove_client(self, path, interfaces):
598
531
"""Find a client by its object path and remove it.
599
532
600
This is connected to the ClientRemoved signal from the
533
This is connected to the InterfacesRemoved signal from the
601
534
Mandos server object."""
535
if client_interface not in interfaces:
536
# Not a Mandos client object; ignore
537
return
602
538
try:
603
539
client = self.clients_dict[path]
604
540
except KeyError:
605
541
# not found?
606
self.log_message("Unknown client %r (%r) removed", name,
607
path)
542
self.log_message("Unknown client {!r} removed"
543
.format(path))
608
544
return
609
545
client.delete()
610
546
611
def add_new_client(self, path):
547
def add_new_client(self, path, ifs_and_props):
548
"""Find a client by its object path and remove it.
549
550
This is connected to the InterfacesAdded signal from the
551
Mandos server object.
552
"""
553
if client_interface not in ifs_and_props:
554
# Not a Mandos client object; ignore
555
return
612
556
client_proxy_object = self.bus.get_object(self.busname, path)
613
557
self.add_client(MandosClientWidget(server_proxy_object
614
558
=self.mandos_serv,
619
563
delete_hook
620
564
=self.remove_client,
621
565
logger
622
=self.log_message),
566
=self.log_message,
567
properties
568
= dict(ifs_and_props[
569
client_interface])),
623
570
path=path)
624
571
625
572
def add_client(self, client, path=None):
627
574
if path is None:
628
575
path = client.proxy.object_path
629
576
self.clients_dict[path] = client
630
self.clients.sort(None, lambda c: c.properties["Name"])
577
self.clients.sort(key=lambda c: c.properties["Name"])
631
578
self.refresh()
632
579
633
580
def remove_client(self, client, path=None):
635
582
if path is None:
636
583
path = client.proxy.object_path
637
584
del self.clients_dict[path]
638
if not self.clients_dict:
639
# Work around bug in Urwid 0.9.8.3 - if a SimpleListWalker
640
# is completely emptied, we need to recreate it.
641
self.clients = urwid.SimpleListWalker([])
642
self.rebuild()
643
585
self.refresh()
644
586
645
587
def refresh(self):
649
591
650
592
def run(self):
651
593
"""Start the main loop and exit when it's done."""
594
self.bus = dbus.SystemBus()
595
mandos_dbus_objc = self.bus.get_object(
596
self.busname, "/", follow_name_owner_changes=True)
597
self.mandos_serv = dbus.Interface(mandos_dbus_objc,
598
dbus_interface
599
= server_interface)
600
try:
601
mandos_clients = (self.mandos_serv
602
.GetAllClientsWithProperties())
603
if not mandos_clients:
604
self.log_message_raw(("bold", "Note: Server has no clients."))
605
except dbus.exceptions.DBusException:
606
self.log_message_raw(("bold", "Note: No Mandos server running."))
607
mandos_clients = dbus.Dictionary()
608
609
(self.mandos_serv
610
.connect_to_signal("InterfacesRemoved",
611
self.find_and_remove_client,
612
dbus_interface
613
= dbus.OBJECT_MANAGER_IFACE,
614
byte_arrays=True))
615
(self.mandos_serv
616
.connect_to_signal("InterfacesAdded",
617
self.add_new_client,
618
dbus_interface
619
= dbus.OBJECT_MANAGER_IFACE,
620
byte_arrays=True))
621
(self.mandos_serv
622
.connect_to_signal("ClientNotFound",
623
self.client_not_found,
624
dbus_interface=server_interface,
625
byte_arrays=True))
626
for path, client in mandos_clients.items():
627
client_proxy_object = self.bus.get_object(self.busname,
628
path)
629
self.add_client(MandosClientWidget(server_proxy_object
630
=self.mandos_serv,
631
proxy_object
632
=client_proxy_object,
633
properties=client,
634
update_hook
635
=self.refresh,
636
delete_hook
637
=self.remove_client,
638
logger
639
=self.log_message),
640
path=path)
641
652
642
self.refresh()
653
643
self._input_callback_tag = (gobject.io_add_watch
654
644
(sys.stdin.fileno(),
686
676
elif key == "window resize":
687
677
self.size = self.screen.get_cols_rows()
688
678
self.refresh()
689
elif key == "\f": # Ctrl-L
679
elif key == "ctrl l":
680
self.screen.clear()
690
681
self.refresh()
691
682
elif key == "l" or key == "D":
692
683
self.toggle_log_display()
704
695
"?: Help",
705
696
"l: Log window toggle",
706
697
"TAB: Switch window",
707
"w: Wrap (log)"))))
698
"w: Wrap (log lines)",
699
"v: Toggle verbose log",
700
))))
708
701
self.log_message_raw(("bold",
709
702
" "
710
703
.join(("Clients:",
723
716
else:
724
717
self.topwidget.set_focus(self.logbox)
725
718
self.refresh()
719
elif key == "v":
720
if self.log_level == 0:
721
self.log_level = 1
722
self.log_message("Verbose mode: Off")
723
else:
724
self.log_level = 0
725
self.log_message("Verbose mode: On")
726
726
#elif (key == "end" or key == "meta >" or key == "G"
727
727
# or key == ">"):
728
728
# pass # xxx end-of-buffer
751
751
ui.run()
752
752
except KeyboardInterrupt:
753
753
ui.screen.stop()
754
except Exception, e:
755
ui.log_message(unicode(e))
754
except Exception as e:
755
ui.log_message(str(e))
756
756
ui.screen.stop()
757
757
raise
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0