4
4
# Mandos Monitor - Control and monitor the Mandos server
6
# Copyright © 2009-2014 Teddy Hogeborn
7
# Copyright © 2009-2014 Björn Påhlsson
6
# Copyright © 2009-2013 Teddy Hogeborn
7
# Copyright © 2009-2013 Björn Påhlsson
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
162
163
client_interface,
163
164
byte_arrays=True))
164
self.logger('Created client {}'
165
.format(self.properties["Name"]), level=0)
165
#self.logger('Created client {0}'
166
# .format(self.properties["Name"]))
167
168
def using_timer(self, flag):
168
169
"""Call this method with True or False when timer should be
180
181
def checker_completed(self, exitstatus, condition, command):
181
182
if exitstatus == 0:
182
self.logger('Checker for client {} (command "{}")'
183
' succeeded'.format(self.properties["Name"],
188
186
if os.WIFEXITED(condition):
189
self.logger('Checker for client {} (command "{}") failed'
187
self.logger('Checker for client {0} (command "{1}")'
188
' failed with exit code {2}'
191
189
.format(self.properties["Name"], command,
192
190
os.WEXITSTATUS(condition)))
193
191
elif os.WIFSIGNALED(condition):
194
self.logger('Checker for client {} (command "{}") was'
195
' killed by signal {}'
192
self.logger('Checker for client {0} (command "{1}") was'
193
' killed by signal {2}'
196
194
.format(self.properties["Name"], command,
197
195
os.WTERMSIG(condition)))
198
196
elif os.WCOREDUMP(condition):
199
self.logger('Checker for client {} (command "{}") dumped'
200
' core'.format(self.properties["Name"],
197
self.logger('Checker for client {0} (command "{1}")'
199
.format(self.properties["Name"], command))
203
self.logger('Checker for client {} completed'
201
self.logger('Checker for client {0} completed'
205
203
.format(self.properties["Name"]))
208
206
def checker_started(self, command):
209
"""Server signals that a checker started."""
210
self.logger('Client {} started checker "{}"'
211
.format(self.properties["Name"],
207
"""Server signals that a checker started. This could be useful
208
to log in the future. """
209
#self.logger('Client {0} started checker "{1}"'
210
# .format(self.properties["Name"],
214
214
def got_secret(self):
215
self.logger('Client {} received its secret'
215
self.logger('Client {0} received its secret'
216
216
.format(self.properties["Name"]))
218
218
def need_approval(self, timeout, default):
220
message = 'Client {} needs approval within {} seconds'
220
message = 'Client {0} needs approval within {1} seconds'
222
message = 'Client {} will get its secret in {} seconds'
222
message = 'Client {0} will get its secret in {1} seconds'
223
223
self.logger(message.format(self.properties["Name"],
226
226
def rejected(self, reason):
227
self.logger('Client {} was rejected; reason: {}'
227
self.logger('Client {0} was rejected; reason: {1}'
228
228
.format(self.properties["Name"], reason))
230
230
def selectable(self):
275
275
timer = datetime.timedelta()
276
276
if self.properties["ApprovedByDefault"]:
277
message = "Approval in {}. (d)eny?"
277
message = "Approval in {0}. (d)eny?"
279
message = "Denial in {}. (a)pprove?"
279
message = "Denial in {0}. (a)pprove?"
280
280
message = message.format(str(timer).rsplit(".", 1)[0])
281
281
self.using_timer(True)
282
282
elif self.properties["LastCheckerStatus"] != 0:
290
290
timer = max(expires - datetime.datetime.utcnow(),
291
291
datetime.timedelta())
292
292
message = ('A checker has failed! Time until client'
293
' gets disabled: {0}'
294
294
.format(str(timer).rsplit(".", 1)[0]))
295
295
self.using_timer(True)
297
297
message = "enabled"
298
298
self.using_timer(False)
299
self._text = "{}{}".format(base, message)
299
self._text = "{0}{1}".format(base, message)
301
301
if not urwid.supports_unicode():
302
302
self._text = self._text.encode("ascii", "replace")
404
404
"""This is the entire user interface - the whole screen
405
405
with boxes, lists of client widgets, etc.
407
def __init__(self, max_log_length=1000, log_level=1):
407
def __init__(self, max_log_length=1000):
408
408
DBusGMainLoop(set_as_default=True)
410
410
self.screen = urwid.curses_display.Screen()
469
467
self.main_loop = gobject.MainLoop()
471
469
def client_not_found(self, fingerprint, address):
472
self.log_message("Client with address {} and fingerprint {}"
473
" could not be found"
470
self.log_message("Client with address {0} and fingerprint"
471
" {1} could not be found"
474
472
.format(address, fingerprint))
476
474
def rebuild(self):
489
487
self.uilist.append(self.logbox)
490
488
self.topwidget = urwid.Pile(self.uilist)
492
def log_message(self, message, level=1):
490
def log_message(self, message):
493
491
"""Log message formatted with timestamp"""
494
if level < self.log_level:
496
492
timestamp = datetime.datetime.now().isoformat()
497
self.log_message_raw("{}: {}".format(timestamp, message),
493
self.log_message_raw(timestamp + ": " + message)
500
def log_message_raw(self, markup, level=1):
495
def log_message_raw(self, markup):
501
496
"""Add a log message to the log buffer."""
502
if level < self.log_level:
504
497
self.log.append(urwid.Text(markup, wrap=self.log_wrap))
505
498
if (self.max_log_length
506
499
and len(self.log) > self.max_log_length):
513
506
"""Toggle visibility of the log buffer."""
514
507
self.log_visible = not self.log_visible
516
self.log_message("Log visibility changed to: {}"
517
.format(self.log_visible), level=0)
509
#self.log_message("Log visibility changed to: "
510
# + str(self.log_visible))
519
512
def change_log_display(self):
520
513
"""Change type of log display.
525
518
self.log_wrap = "clip"
526
519
for textwidget in self.log:
527
520
textwidget.set_wrap_mode(self.log_wrap)
528
self.log_message("Wrap mode: {}".format(self.log_wrap),
521
#self.log_message("Wrap mode: " + self.log_wrap)
531
523
def find_and_remove_client(self, path, name):
532
524
"""Find a client by its object path and remove it.
added
removed
mandos-monitor
