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