/mandos/trunk

To get this branch, use:
bzr branch http://bzr.recompile.se/loggerhead/mandos/trunk
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
1
#!/usr/bin/python
2
# -*- mode: python; coding: utf-8 -*-
3
4
from __future__ import division, absolute_import, with_statement
5
6
import sys
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
7
import os
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
8
import signal
9
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
10
import datetime
11
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
12
import urwid.curses_display
13
import urwid
14
15
from dbus.mainloop.glib import DBusGMainLoop
16
import gobject
17
18
import dbus
19
20
import UserList
21
411 by Teddy Hogeborn
More consistent terminology: Clients are no longer "invalid" - they
22
import locale
23
24
locale.setlocale(locale.LC_ALL, u'')
25
24.1.153 by Björn Påhlsson
early commit to ease todays coding
26
import logging
27
logging.getLogger('dbus.proxies').setLevel(logging.CRITICAL)
28
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
29
# Some useful constants
30
domain = 'se.bsnet.fukt'
31
server_interface = domain + '.Mandos'
32
client_interface = domain + '.Mandos.Client'
24.1.153 by Björn Påhlsson
early commit to ease todays coding
33
version = "1.0.15"
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
34
35
# Always run in monochrome mode
36
urwid.curses_display.curses.has_colors = lambda : False
37
38
# Urwid doesn't support blinking, but we want it.  Since we have no
39
# use for underline on its own, we make underline also always blink.
40
urwid.curses_display.curses.A_UNDERLINE |= (
41
    urwid.curses_display.curses.A_BLINK)
42
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
43
def isoformat_to_datetime(iso):
44
    "Parse an ISO 8601 date string to a datetime.datetime()"
45
    if not iso:
46
        return None
47
    d, t = iso.split(u"T", 1)
48
    year, month, day = d.split(u"-", 2)
49
    hour, minute, second = t.split(u":", 2)
50
    second, fraction = divmod(float(second), 1)
51
    return datetime.datetime(int(year),
52
                             int(month),
53
                             int(day),
54
                             int(hour),
55
                             int(minute),
56
                             int(second),           # Whole seconds
57
                             int(fraction*1000000)) # Microseconds
58
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
59
class MandosClientPropertyCache(object):
60
    """This wraps a Mandos Client D-Bus proxy object, caches the
61
    properties and calls a hook function when any of them are
62
    changed.
63
    """
411 by Teddy Hogeborn
More consistent terminology: Clients are no longer "invalid" - they
64
    def __init__(self, proxy_object=None, *args, **kwargs):
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
65
        self.proxy = proxy_object # Mandos Client proxy object
66
        
411 by Teddy Hogeborn
More consistent terminology: Clients are no longer "invalid" - they
67
        self.properties = dict()
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
68
        self.proxy.connect_to_signal(u"PropertyChanged",
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
69
                                     self.property_changed,
70
                                     client_interface,
71
                                     byte_arrays=True)
24.1.153 by Björn Påhlsson
early commit to ease todays coding
72
        
411 by Teddy Hogeborn
More consistent terminology: Clients are no longer "invalid" - they
73
        self.properties.update(
74
            self.proxy.GetAll(client_interface,
75
                              dbus_interface = dbus.PROPERTIES_IFACE))
24.1.154 by Björn Påhlsson
merge
76
77
        #XXX This break good super behaviour!
78
#        super(MandosClientPropertyCache, self).__init__(
79
#            *args, **kwargs)
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
80
    
81
    def property_changed(self, property=None, value=None):
82
        """This is called whenever we get a PropertyChanged signal
83
        It updates the changed property in the "properties" dict.
84
        """
85
        # Update properties dict with new value
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
86
        self.properties[property] = value
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
87
88
89
class MandosClientWidget(urwid.FlowWidget, MandosClientPropertyCache):
90
    """A Mandos Client which is visible on the screen.
91
    """
92
    
93
    def __init__(self, server_proxy_object=None, update_hook=None,
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
94
                 delete_hook=None, logger=None, *args, **kwargs):
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
95
        # Called on update
96
        self.update_hook = update_hook
97
        # Called on delete
98
        self.delete_hook = delete_hook
99
        # Mandos Server proxy object
100
        self.server_proxy_object = server_proxy_object
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
101
        # Logger
102
        self.logger = logger
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
103
        
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
104
        self._update_timer_callback_tag = None
105
        self.last_checker_failed = False
106
        
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
107
        # The widget shown normally
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
108
        self._text_widget = urwid.Text(u"")
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
109
        # The widget shown when we have focus
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
110
        self._focus_text_widget = urwid.Text(u"")
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
111
        super(MandosClientWidget, self).__init__(
112
            update_hook=update_hook, delete_hook=delete_hook,
113
            *args, **kwargs)
114
        self.update()
115
        self.opened = False
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
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)
24.1.153 by Björn Påhlsson
early commit to ease todays coding
128
        self.proxy.connect_to_signal(u"NeedApproval",
129
                                     self.need_approval,
130
                                     client_interface,
131
                                     byte_arrays=True)
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
132
        self.proxy.connect_to_signal(u"Rejected",
133
                                     self.rejected,
134
                                     client_interface,
135
                                     byte_arrays=True)
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
136
        last_checked_ok = isoformat_to_datetime(self.properties
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
137
                                                [u"LastCheckedOK"])
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
138
        if last_checked_ok is None:
139
            self.last_checker_failed = True
140
        else:
141
            self.last_checker_failed = ((datetime.datetime.utcnow()
142
                                         - last_checked_ok)
143
                                        > datetime.timedelta
144
                                        (milliseconds=
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
145
                                         self.properties
146
                                         [u"Interval"]))
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
147
        if self.last_checker_failed:
148
            self._update_timer_callback_tag = (gobject.timeout_add
149
                                               (1000,
150
                                                self.update_timer))
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
151
    
152
    def checker_completed(self, exitstatus, condition, command):
153
        if exitstatus == 0:
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
154
            if self.last_checker_failed:
155
                self.last_checker_failed = False
156
                gobject.source_remove(self._update_timer_callback_tag)
157
                self._update_timer_callback_tag = None
424 by Teddy Hogeborn
* mandos-monitor (MandosClientWidget.checker_completed): Do not log a
158
            #self.logger(u'Checker for client %s (command "%s")'
159
            #            u' was successful'
160
            #            % (self.properties[u"Name"], command))
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
161
            self.update()
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
162
            return
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
163
        # Checker failed
164
        if not self.last_checker_failed:
165
            self.last_checker_failed = True
166
            self._update_timer_callback_tag = (gobject.timeout_add
167
                                               (1000,
168
                                                self.update_timer))
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
169
        if os.WIFEXITED(condition):
170
            self.logger(u'Checker for client %s (command "%s")'
171
                        u' failed with exit code %s'
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
172
                        % (self.properties[u"Name"], command,
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
173
                           os.WEXITSTATUS(condition)))
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
174
        elif os.WIFSIGNALED(condition):
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
175
            self.logger(u'Checker for client %s (command "%s")'
176
                        u' was killed by signal %s'
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
177
                        % (self.properties[u"Name"], command,
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
178
                           os.WTERMSIG(condition)))
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
179
        elif os.WCOREDUMP(condition):
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
180
            self.logger(u'Checker for client %s (command "%s")'
181
                        u' dumped core'
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
182
                        % (self.properties[u"Name"], command))
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
183
        else:
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
184
            self.logger(u'Checker for client %s completed'
185
                        u' mysteriously')
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
186
        self.update()
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
187
    
188
    def checker_started(self, command):
24.1.153 by Björn Påhlsson
early commit to ease todays coding
189
        #self.logger(u'Client %s started checker "%s"'
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
190
        #            % (self.properties[u"Name"], unicode(command)))
24.1.153 by Björn Påhlsson
early commit to ease todays coding
191
        pass
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
192
    
193
    def got_secret(self):
24.1.159 by Björn Påhlsson
added approval to mandos-ctl
194
        self.last_checker_failed = False
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
195
        self.logger(u'Client %s received its secret'
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
196
                    % self.properties[u"Name"])
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
197
    
24.1.153 by Björn Påhlsson
early commit to ease todays coding
198
    def need_approval(self, timeout, default):
199
        if not default:
200
            message = u'Client %s needs approval within %s seconds'
201
        else:
202
            message = u'Client %s will get its secret in %s seconds'
203
        self.logger(message
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
204
                    % (self.properties[u"Name"], timeout/1000))
24.1.153 by Björn Påhlsson
early commit to ease todays coding
205
    
206
    def rejected(self, reason):
207
        self.logger(u'Client %s was rejected; reason: %s'
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
208
                    % (self.properties[u"Name"], reason))
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
209
    
210
    def selectable(self):
211
        """Make this a "selectable" widget.
212
        This overrides the method from urwid.FlowWidget."""
213
        return True
214
    
215
    def rows(self, (maxcol,), focus=False):
216
        """How many rows this widget will occupy might depend on
217
        whether we have focus or not.
218
        This overrides the method from urwid.FlowWidget"""
219
        return self.current_widget(focus).rows((maxcol,), focus=focus)
220
    
221
    def current_widget(self, focus=False):
222
        if focus or self.opened:
223
            return self._focus_widget
224
        return self._widget
225
    
226
    def update(self):
227
        "Called when what is visible on the screen should be updated."
228
        # How to add standout mode to a style
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",
235
                          }
24.1.154 by Björn Påhlsson
merge
236
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
237
        # Rebuild focus and non-focus widgets using current properties
24.1.154 by Björn Påhlsson
merge
238
239
        # Base part of a client. Name!
24.1.156 by Björn Påhlsson
merge
240
        base = (u'%(name)s: '
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
241
                      % {u"name": self.properties[u"Name"]})
242
        if not self.properties[u"Enabled"]:
24.1.156 by Björn Påhlsson
merge
243
            message = u"DISABLED"
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
244
        elif self.properties[u"ApprovalPending"]:
245
            if self.properties[u"ApprovedByDefault"]:
24.1.159 by Björn Påhlsson
added approval to mandos-ctl
246
                message = u"Connection established to client. (d)eny?"
247
            else:
248
                message = u"Seeks approval to send secret. (a)pprove?"
24.1.156 by Björn Påhlsson
merge
249
        elif self.last_checker_failed:
250
            timeout = datetime.timedelta(milliseconds
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
251
                                         = self.properties
252
                                         [u"Timeout"])
24.1.156 by Björn Påhlsson
merge
253
            last_ok = isoformat_to_datetime(
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
254
                max((self.properties[u"LastCheckedOK"]
255
                     or self.properties[u"Created"]),
256
                    self.properties[u"LastEnabled"]))
24.1.156 by Björn Påhlsson
merge
257
            timer = timeout - (datetime.datetime.utcnow() - last_ok)
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
258
            message = (u'A checker has failed! Time until client'
259
                       u' gets diabled: %s'
24.1.158 by Björn Påhlsson
mandos-monitor: removed milisecondsseconds from countdown.
260
                           % unicode(timer).rsplit(".", 1)[0])
24.1.154 by Björn Påhlsson
merge
261
        else:
24.1.156 by Björn Påhlsson
merge
262
            message = u"enabled"
263
        self._text = "%s%s" % (base, message)
264
            
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
265
        if not urwid.supports_unicode():
266
            self._text = self._text.encode("ascii", "replace")
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
267
        textlist = [(u"normal", self._text)]
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
268
        self._text_widget.set_text(textlist)
269
        self._focus_text_widget.set_text([(with_standout[text[0]],
270
                                           text[1])
271
                                          if isinstance(text, tuple)
272
                                          else text
273
                                          for text in textlist])
274
        self._widget = self._text_widget
275
        self._focus_widget = urwid.AttrWrap(self._focus_text_widget,
276
                                            "standout")
277
        # Run update hook, if any
278
        if self.update_hook is not None:
279
            self.update_hook()
280
    
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
281
    def update_timer(self):
282
        "called by gobject"
283
        self.update()
284
        return True             # Keep calling this
285
    
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
286
    def delete(self):
417 by Teddy Hogeborn
* mandos (AvahiService.entry_group_state_changed): Better debug log
287
        if self._update_timer_callback_tag is not None:
288
            gobject.source_remove(self._update_timer_callback_tag)
289
            self._update_timer_callback_tag = None
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
290
        if self.delete_hook is not None:
291
            self.delete_hook(self)
292
    
293
    def render(self, (maxcol,), focus=False):
294
        """Render differently if we have focus.
295
        This overrides the method from urwid.FlowWidget"""
296
        return self.current_widget(focus).render((maxcol,),
297
                                                 focus=focus)
298
    
299
    def keypress(self, (maxcol,), key):
300
        """Handle keys.
301
        This overrides the method from urwid.FlowWidget"""
24.1.154 by Björn Påhlsson
merge
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":
307
            self.proxy.Approve(dbus.Boolean(True, variant_level=1),
308
                               dbus_interface = client_interface)
309
        elif key == u"d":
310
            self.proxy.Approve(dbus.Boolean(False, variant_level=1),
311
                                  dbus_interface = client_interface)
408 by Teddy Hogeborn
* debian/rules: Only set BROKEN_PIE if binutils is a specific range of
312
        elif key == u"r" or key == u"_" or key == u"ctrl k":
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
313
            self.server_proxy_object.RemoveClient(self.proxy
314
                                                  .object_path)
315
        elif key == u"s":
24.1.154 by Björn Påhlsson
merge
316
            self.proxy.StartChecker(dbus_interface = client_interface)
407 by Teddy Hogeborn
* mandos-monitor (MandosClientWidget): Change "StopChecker" key to "S"
317
        elif key == u"S":
24.1.154 by Björn Påhlsson
merge
318
            self.proxy.StopChecker(dbus_interface = client_interface)
407 by Teddy Hogeborn
* mandos-monitor (MandosClientWidget): Change "StopChecker" key to "S"
319
        elif key == u"C":
24.1.154 by Björn Påhlsson
merge
320
            self.proxy.CheckedOK(dbus_interface = client_interface)
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
321
        # xxx
322
#         elif key == u"p" or key == "=":
323
#             self.proxy.pause()
324
#         elif key == u"u" or key == ":":
325
#             self.proxy.unpause()
326
#         elif key == u"RET":
327
#             self.open()
24.1.154 by Björn Påhlsson
merge
328
#        elif key == u"+":
329
#            self.proxy.Approve(True)
330
#        elif key == u"-":
331
#            self.proxy.Approve(False)
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
332
        else:
333
            return key
334
    
335
    def property_changed(self, property=None, value=None,
336
                         *args, **kwargs):
337
        """Call self.update() if old value is not new value.
338
        This overrides the method from MandosClientPropertyCache"""
339
        property_name = unicode(property)
340
        old_value = self.properties.get(property_name)
341
        super(MandosClientWidget, self).property_changed(
342
            property=property, value=value, *args, **kwargs)
343
        if self.properties.get(property_name) != old_value:
344
            self.update()
345
346
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
347
class ConstrainedListBox(urwid.ListBox):
348
    """Like a normal urwid.ListBox, but will consume all "up" or
349
    "down" key presses, thus not allowing any containing widgets to
350
    use them as an excuse to shift focus away from this widget.
351
    """
352
    def keypress(self, (maxcol, maxrow), key):
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
353
        ret = super(ConstrainedListBox, self).keypress((maxcol,
354
                                                        maxrow), key)
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
355
        if ret in (u"up", u"down"):
356
            return
357
        return ret
358
359
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
360
class UserInterface(object):
361
    """This is the entire user interface - the whole screen
362
    with boxes, lists of client widgets, etc.
363
    """
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
364
    def __init__(self, max_log_length=1000):
365
        DBusGMainLoop(set_as_default=True)
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
366
        
367
        self.screen = urwid.curses_display.Screen()
368
        
369
        self.screen.register_palette((
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")),
387
                ))
388
        
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
389
        if urwid.supports_unicode():
408 by Teddy Hogeborn
* debian/rules: Only set BROKEN_PIE if binutils is a specific range of
390
            self.divider = u"─" # \u2500
391
            #self.divider = u"━" # \u2501
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
392
        else:
393
            #self.divider = u"-" # \u002d
394
            self.divider = u"_" # \u005f
395
        
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
396
        self.screen.start()
397
        
398
        self.size = self.screen.get_cols_rows()
399
        
400
        self.clients = urwid.SimpleListWalker([])
401
        self.clients_dict = {}
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
402
        
403
        # We will add Text widgets to this list
404
        self.log = []
405
        self.max_log_length = max_log_length
406
        
407
        # We keep a reference to the log widget so we can remove it
408
        # from the ListWalker without it getting destroyed
409
        self.logbox = ConstrainedListBox(self.log)
410
        
411
        # This keeps track of whether self.uilist currently has
412
        # self.logbox in it or not
413
        self.log_visible = True
414
        self.log_wrap = u"any"
415
        
416
        self.rebuild()
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
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"))
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
421
        
422
        self.busname = domain + '.Mandos'
423
        self.main_loop = gobject.MainLoop()
424
        self.bus = dbus.SystemBus()
425
        mandos_dbus_objc = self.bus.get_object(
426
            self.busname, u"/", follow_name_owner_changes=True)
427
        self.mandos_serv = dbus.Interface(mandos_dbus_objc,
428
                                          dbus_interface
429
                                          = server_interface)
430
        try:
431
            mandos_clients = (self.mandos_serv
432
                              .GetAllClientsWithProperties())
433
        except dbus.exceptions.DBusException:
434
            mandos_clients = dbus.Dictionary()
435
        
436
        (self.mandos_serv
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
437
         .connect_to_signal(u"ClientRemoved",
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
438
                            self.find_and_remove_client,
439
                            dbus_interface=server_interface,
440
                            byte_arrays=True))
441
        (self.mandos_serv
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
442
         .connect_to_signal(u"ClientAdded",
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
443
                            self.add_new_client,
444
                            dbus_interface=server_interface,
445
                            byte_arrays=True))
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
446
        (self.mandos_serv
447
         .connect_to_signal(u"ClientNotFound",
448
                            self.client_not_found,
449
                            dbus_interface=server_interface,
450
                            byte_arrays=True))
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
451
        for path, client in mandos_clients.iteritems():
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
452
            client_proxy_object = self.bus.get_object(self.busname,
453
                                                      path)
454
            self.add_client(MandosClientWidget(server_proxy_object
455
                                               =self.mandos_serv,
456
                                               proxy_object
457
                                               =client_proxy_object,
458
                                               properties=client,
459
                                               update_hook
460
                                               =self.refresh,
461
                                               delete_hook
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
462
                                               =self.remove_client,
463
                                               logger
464
                                               =self.log_message),
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
465
                            path=path)
466
    
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
467
    def client_not_found(self, fingerprint, address):
468
        self.log_message((u"Client with address %s and fingerprint %s"
469
                          u" could not be found" % (address,
470
                                                    fingerprint)))
471
    
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
472
    def rebuild(self):
473
        """This rebuilds the User Interface.
474
        Call this when the widget layout needs to change"""
475
        self.uilist = []
476
        #self.uilist.append(urwid.ListBox(self.clients))
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
477
        self.uilist.append(urwid.Frame(ConstrainedListBox(self.
478
                                                          clients),
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
479
                                       #header=urwid.Divider(),
480
                                       header=None,
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
481
                                       footer=
482
                                       urwid.Divider(div_char=
483
                                                     self.divider)))
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
484
        if self.log_visible:
485
            self.uilist.append(self.logbox)
486
            pass
487
        self.topwidget = urwid.Pile(self.uilist)
488
    
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
489
    def log_message(self, message):
490
        timestamp = datetime.datetime.now().isoformat()
491
        self.log_message_raw(timestamp + u": " + message)
492
    
493
    def log_message_raw(self, markup):
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
494
        """Add a log message to the log buffer."""
495
        self.log.append(urwid.Text(markup, wrap=self.log_wrap))
496
        if (self.max_log_length
497
            and len(self.log) > self.max_log_length):
498
            del self.log[0:len(self.log)-self.max_log_length-1]
408 by Teddy Hogeborn
* debian/rules: Only set BROKEN_PIE if binutils is a specific range of
499
        self.logbox.set_focus(len(self.logbox.body.contents),
500
                              coming_from=u"above")
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
501
        self.refresh()
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
502
    
503
    def toggle_log_display(self):
504
        """Toggle visibility of the log buffer."""
505
        self.log_visible = not self.log_visible
506
        self.rebuild()
507
        self.log_message(u"Log visibility changed to: "
508
                         + unicode(self.log_visible))
509
    
510
    def change_log_display(self):
511
        """Change type of log display.
512
        Currently, this toggles wrapping of text lines."""
513
        if self.log_wrap == u"clip":
514
            self.log_wrap = u"any"
515
        else:
516
            self.log_wrap = u"clip"
517
        for textwidget in self.log:
518
            textwidget.set_wrap_mode(self.log_wrap)
519
        self.log_message(u"Wrap mode: " + self.log_wrap)
520
    
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
521
    def find_and_remove_client(self, path, name):
522
        """Find an client from its object path and remove it.
523
        
524
        This is connected to the ClientRemoved signal from the
525
        Mandos server object."""
526
        try:
527
            client = self.clients_dict[path]
528
        except KeyError:
529
            # not found?
530
            return
531
        self.remove_client(client, path)
532
    
411 by Teddy Hogeborn
More consistent terminology: Clients are no longer "invalid" - they
533
    def add_new_client(self, path):
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
534
        client_proxy_object = self.bus.get_object(self.busname, path)
535
        self.add_client(MandosClientWidget(server_proxy_object
536
                                           =self.mandos_serv,
537
                                           proxy_object
538
                                           =client_proxy_object,
539
                                           update_hook
540
                                           =self.refresh,
541
                                           delete_hook
411 by Teddy Hogeborn
More consistent terminology: Clients are no longer "invalid" - they
542
                                           =self.remove_client,
543
                                           logger
544
                                           =self.log_message),
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
545
                        path=path)
546
    
547
    def add_client(self, client, path=None):
548
        self.clients.append(client)
549
        if path is None:
550
            path = client.proxy.object_path
551
        self.clients_dict[path] = client
422 by Teddy Hogeborn
Rename all D-Bus properties to conform to D-Bus naming conventions;
552
        self.clients.sort(None, lambda c: c.properties[u"Name"])
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
553
        self.refresh()
554
    
555
    def remove_client(self, client, path=None):
556
        self.clients.remove(client)
557
        if path is None:
558
            path = client.proxy.object_path
559
        del self.clients_dict[path]
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
560
        if not self.clients_dict:
561
            # Work around bug in Urwid 0.9.8.3 - if a SimpleListWalker
562
            # is completely emptied, we need to recreate it.
563
            self.clients = urwid.SimpleListWalker([])
564
            self.rebuild()
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
565
        self.refresh()
566
    
567
    def refresh(self):
568
        """Redraw the screen"""
569
        canvas = self.topwidget.render(self.size, focus=True)
570
        self.screen.draw_screen(self.size, canvas)
571
    
572
    def run(self):
573
        """Start the main loop and exit when it's done."""
574
        self.refresh()
575
        self._input_callback_tag = (gobject.io_add_watch
576
                                    (sys.stdin.fileno(),
577
                                     gobject.IO_IN,
578
                                     self.process_input))
579
        self.main_loop.run()
580
        # Main loop has finished, we should close everything now
581
        gobject.source_remove(self._input_callback_tag)
582
        self.screen.stop()
583
    
584
    def stop(self):
585
        self.main_loop.quit()
586
    
587
    def process_input(self, source, condition):
588
        keys = self.screen.get_input()
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
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
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
598
                         }
599
        for key in keys:
600
            try:
601
                key = translations[key]
602
            except KeyError:    # :-)
603
                pass
604
            
605
            if key == u"q" or key == u"Q":
606
                self.stop()
607
                break
608
            elif key == u"window resize":
609
                self.size = self.screen.get_cols_rows()
610
                self.refresh()
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
611
            elif key == u"\f":  # Ctrl-L
612
                self.refresh()
613
            elif key == u"l" or key == u"D":
614
                self.toggle_log_display()
615
                self.refresh()
616
            elif key == u"w" or key == u"i":
617
                self.change_log_display()
618
                self.refresh()
408 by Teddy Hogeborn
* debian/rules: Only set BROKEN_PIE if binutils is a specific range of
619
            elif key == u"?" or key == u"f1" or key == u"esc":
407 by Teddy Hogeborn
* mandos-monitor (MandosClientWidget): Change "StopChecker" key to "S"
620
                if not self.log_visible:
621
                    self.log_visible = True
622
                    self.rebuild()
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
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:",
24.1.155 by Björn Påhlsson
mandos server: Added debuglevel that adjust at what level information
633
                                             u"+: Enable",
634
                                             u"-: Disable",
409 by Teddy Hogeborn
* mandos (MandosServer.handle_ipc): Better log message.
635
                                             u"r: Remove",
636
                                             u"s: Start new checker",
637
                                             u"S: Stop checker",
24.1.154 by Björn Påhlsson
merge
638
                                             u"C: Checker OK",
24.1.155 by Björn Påhlsson
mandos server: Added debuglevel that adjust at what level information
639
                                             u"a: Approve",
640
                                             u"d: Deny"))))
405 by Teddy Hogeborn
* mandos-monitor (MandosClientPropertyCache): Remove conversion of
641
                self.refresh()
642
            elif key == u"tab":
643
                if self.topwidget.get_focus() is self.logbox:
644
                    self.topwidget.set_focus(0)
645
                else:
646
                    self.topwidget.set_focus(self.logbox)
647
                self.refresh()
407 by Teddy Hogeborn
* mandos-monitor (MandosClientWidget): Change "StopChecker" key to "S"
648
            #elif (key == u"end" or key == u"meta >" or key == u"G"
649
            #      or key == u">"):
650
            #    pass            # xxx end-of-buffer
651
            #elif (key == u"home" or key == u"meta <" or key == u"g"
652
            #      or key == u"<"):
653
            #    pass            # xxx beginning-of-buffer
654
            #elif key == u"ctrl e" or key == u"$":
655
            #    pass            # xxx move-end-of-line
656
            #elif key == u"ctrl a" or key == u"^":
657
            #    pass            # xxx move-beginning-of-line
658
            #elif key == u"ctrl b" or key == u"meta (" or key == u"h":
659
            #    pass            # xxx left
660
            #elif key == u"ctrl f" or key == u"meta )" or key == u"l":
661
            #    pass            # xxx right
662
            #elif key == u"a":
663
            #    pass            # scroll up log
664
            #elif key == u"z":
665
            #    pass            # scroll down log
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
666
            elif self.topwidget.selectable():
667
                self.topwidget.keypress(self.size, key)
668
                self.refresh()
669
        return True
670
671
ui = UserInterface()
672
try:
673
    ui.run()
24.1.159 by Björn Påhlsson
added approval to mandos-ctl
674
except KeyboardInterrupt:
675
    ui.screen.stop()
411 by Teddy Hogeborn
More consistent terminology: Clients are no longer "invalid" - they
676
except Exception, e:
677
    ui.log_message(unicode(e))
404 by Teddy Hogeborn
* mandos-monitor: New prototype version of interactive server
678
    ui.screen.stop()
679
    raise