2
2
# -*- mode: python; coding: utf-8 -*-
 
4
 
# Mandos Monitor - Control and monitor the Mandos server
 
6
 
# Copyright © 2009-2011 Teddy Hogeborn
 
7
 
# Copyright © 2009-2011 Björn Påhlsson
 
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.
 
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.
 
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/>.
 
22
 
# Contact the authors at <mandos@fukt.bsnet.se>.
 
25
 
from __future__ import division, absolute_import, print_function, unicode_literals
 
 
4
from __future__ import division, absolute_import, with_statement
 
 
123
102
        self.logger = logger
 
125
104
        self._update_timer_callback_tag = None
 
126
 
        self._update_timer_callback_lock = 0
 
127
105
        self.last_checker_failed = False
 
129
107
        # The widget shown normally
 
130
 
        self._text_widget = urwid.Text("")
 
 
108
        self._text_widget = urwid.Text(u"")
 
131
109
        # The widget shown when we have focus
 
132
 
        self._focus_text_widget = urwid.Text("")
 
 
110
        self._focus_text_widget = urwid.Text(u"")
 
133
111
        super(MandosClientWidget, self).__init__(
 
134
112
            update_hook=update_hook, delete_hook=delete_hook,
 
137
115
        self.opened = False
 
 
116
        self.proxy.connect_to_signal(u"CheckerCompleted",
 
 
117
                                     self.checker_completed,
 
 
120
        self.proxy.connect_to_signal(u"CheckerStarted",
 
 
121
                                     self.checker_started,
 
 
124
        self.proxy.connect_to_signal(u"GotSecret",
 
 
128
        self.proxy.connect_to_signal(u"NeedApproval",
 
 
132
        self.proxy.connect_to_signal(u"Rejected",
 
139
136
        last_checked_ok = isoformat_to_datetime(self.properties
 
141
138
        if last_checked_ok is None:
 
142
139
            self.last_checker_failed = True
 
 
145
142
                                         - last_checked_ok)
 
146
143
                                        > datetime.timedelta
 
 
145
                                         self.properties["interval"]))
 
151
146
        if self.last_checker_failed:
 
152
 
            self.using_timer(True)
 
154
 
        if self.need_approval:
 
155
 
            self.using_timer(True)
 
157
 
        self.proxy.connect_to_signal("CheckerCompleted",
 
158
 
                                     self.checker_completed,
 
161
 
        self.proxy.connect_to_signal("CheckerStarted",
 
162
 
                                     self.checker_started,
 
165
 
        self.proxy.connect_to_signal("GotSecret",
 
169
 
        self.proxy.connect_to_signal("NeedApproval",
 
173
 
        self.proxy.connect_to_signal("Rejected",
 
178
 
    def property_changed(self, property=None, value=None):
 
179
 
        super(self, MandosClientWidget).property_changed(property,
 
181
 
        if property == "ApprovalPending":
 
182
 
            using_timer(bool(value))
 
184
 
    def using_timer(self, flag):
 
185
 
        """Call this method with True or False when timer should be
 
186
 
        activated or deactivated.
 
188
 
        old = self._update_timer_callback_lock
 
190
 
            self._update_timer_callback_lock += 1
 
192
 
            self._update_timer_callback_lock -= 1
 
193
 
        if old == 0 and self._update_timer_callback_lock:
 
194
147
            self._update_timer_callback_tag = (gobject.timeout_add
 
196
149
                                                self.update_timer))
 
197
 
        elif old and self._update_timer_callback_lock == 0:
 
198
 
            gobject.source_remove(self._update_timer_callback_tag)
 
199
 
            self._update_timer_callback_tag = None
 
201
151
    def checker_completed(self, exitstatus, condition, command):
 
202
152
        if exitstatus == 0:
 
203
153
            if self.last_checker_failed:
 
204
154
                self.last_checker_failed = False
 
205
 
                self.using_timer(False)
 
206
 
            #self.logger('Checker for client %s (command "%s")'
 
208
 
            #            % (self.properties["Name"], command))
 
 
155
                gobject.source_remove(self._update_timer_callback_tag)
 
 
156
                self._update_timer_callback_tag = None
 
 
157
            self.logger(u'Checker for client %s (command "%s")'
 
 
159
                        % (self.properties[u"name"], command))
 
212
163
        if not self.last_checker_failed:
 
213
164
            self.last_checker_failed = True
 
214
 
            self.using_timer(True)
 
 
165
            self._update_timer_callback_tag = (gobject.timeout_add
 
215
168
        if os.WIFEXITED(condition):
 
216
 
            self.logger('Checker for client %s (command "%s")'
 
217
 
                        ' failed with exit code %s'
 
218
 
                        % (self.properties["Name"], command,
 
 
169
            self.logger(u'Checker for client %s (command "%s")'
 
 
170
                        u' failed with exit code %s'
 
 
171
                        % (self.properties[u"name"], command,
 
219
172
                           os.WEXITSTATUS(condition)))
 
220
173
        elif os.WIFSIGNALED(condition):
 
221
 
            self.logger('Checker for client %s (command "%s")'
 
222
 
                        ' was killed by signal %s'
 
223
 
                        % (self.properties["Name"], command,
 
 
174
            self.logger(u'Checker for client %s (command "%s")'
 
 
175
                        u' was killed by signal %s'
 
 
176
                        % (self.properties[u"name"], command,
 
224
177
                           os.WTERMSIG(condition)))
 
225
178
        elif os.WCOREDUMP(condition):
 
226
 
            self.logger('Checker for client %s (command "%s")'
 
228
 
                        % (self.properties["Name"], command))
 
 
179
            self.logger(u'Checker for client %s (command "%s")'
 
 
181
                        % (self.properties[u"name"], command))
 
230
 
            self.logger('Checker for client %s completed'
 
 
183
            self.logger(u'Checker for client %s completed mysteriously')
 
234
186
    def checker_started(self, command):
 
235
 
        #self.logger('Client %s started checker "%s"'
 
236
 
        #            % (self.properties["Name"], unicode(command)))
 
 
187
        #self.logger(u'Client %s started checker "%s"'
 
 
188
        #            % (self.properties[u"name"], unicode(command)))
 
239
191
    def got_secret(self):
 
240
 
        self.last_checker_failed = False
 
241
 
        self.logger('Client %s received its secret'
 
242
 
                    % self.properties["Name"])
 
 
192
        self.logger(u'Client %s received its secret'
 
 
193
                    % self.properties[u"name"])
 
244
195
    def need_approval(self, timeout, default):
 
246
 
            message = 'Client %s needs approval within %s seconds'
 
 
197
            message = u'Client %s needs approval within %s seconds'
 
248
 
            message = 'Client %s will get its secret in %s seconds'
 
 
199
            message = u'Client %s will get its secret in %s seconds'
 
249
200
        self.logger(message
 
250
 
                    % (self.properties["Name"], timeout/1000))
 
251
 
        self.using_timer(True)
 
 
201
                    % (self.properties[u"name"], timeout/1000))
 
253
203
    def rejected(self, reason):
 
254
 
        self.logger('Client %s was rejected; reason: %s'
 
255
 
                    % (self.properties["Name"], reason))
 
 
204
        self.logger(u'Client %s was rejected; reason: %s'
 
 
205
                    % (self.properties[u"name"], reason))
 
257
207
    def selectable(self):
 
258
208
        """Make this a "selectable" widget.
 
259
209
        This overrides the method from urwid.FlowWidget."""
 
262
 
    def rows(self, maxcolrow, focus=False):
 
 
212
    def rows(self, (maxcol,), focus=False):
 
263
213
        """How many rows this widget will occupy might depend on
 
264
214
        whether we have focus or not.
 
265
215
        This overrides the method from urwid.FlowWidget"""
 
266
 
        return self.current_widget(focus).rows(maxcolrow, focus=focus)
 
 
216
        return self.current_widget(focus).rows((maxcol,), focus=focus)
 
268
218
    def current_widget(self, focus=False):
 
269
219
        if focus or self.opened:
 
 
273
223
    def update(self):
 
274
224
        "Called when what is visible on the screen should be updated."
 
275
225
        # How to add standout mode to a style
 
276
 
        with_standout = { "normal": "standout",
 
277
 
                          "bold": "bold-standout",
 
279
 
                              "underline-blink-standout",
 
280
 
                          "bold-underline-blink":
 
281
 
                              "bold-underline-blink-standout",
 
 
226
        with_standout = { u"normal": u"standout",
 
 
227
                          u"bold": u"bold-standout",
 
 
229
                              u"underline-blink-standout",
 
 
230
                          u"bold-underline-blink":
 
 
231
                              u"bold-underline-blink-standout",
 
284
234
        # Rebuild focus and non-focus widgets using current properties
 
286
236
        # Base part of a client. Name!
 
288
 
                      % {"name": self.properties["Name"]})
 
289
 
        if not self.properties["Enabled"]:
 
291
 
        elif self.properties["ApprovalPending"]:
 
292
 
            timeout = datetime.timedelta(milliseconds
 
295
 
            last_approval_request = isoformat_to_datetime(
 
296
 
                self.properties["LastApprovalRequest"])
 
297
 
            if last_approval_request is not None:
 
298
 
                timer = timeout - (datetime.datetime.utcnow()
 
299
 
                                   - last_approval_request)
 
301
 
                timer = datetime.timedelta()
 
302
 
            if self.properties["ApprovedByDefault"]:
 
303
 
                message = "Approval in %s. (d)eny?"
 
305
 
                message = "Denial in %s. (a)pprove?"
 
306
 
            message = message % unicode(timer).rsplit(".", 1)[0]
 
 
237
        base = (u'%(name)s: '
 
 
238
                      % {u"name": self.properties[u"name"]})
 
 
239
        if not self.properties[u"enabled"]:
 
 
240
            message = u"DISABLED"
 
307
241
        elif self.last_checker_failed:
 
308
242
            timeout = datetime.timedelta(milliseconds
 
 
243
                                         = self.properties[u"timeout"])
 
311
244
            last_ok = isoformat_to_datetime(
 
312
 
                max((self.properties["LastCheckedOK"]
 
313
 
                     or self.properties["Created"]),
 
314
 
                    self.properties["LastEnabled"]))
 
 
245
                max((self.properties["last_checked_ok"]
 
 
246
                     or self.properties["created"]),
 
 
247
                    self.properties[u"last_enabled"]))
 
315
248
            timer = timeout - (datetime.datetime.utcnow() - last_ok)
 
316
 
            message = ('A checker has failed! Time until client'
 
318
 
                           % unicode(timer).rsplit(".", 1)[0])
 
 
250
            message = (u'A checker has failed! Time until client gets diabled: %s'
 
 
252
        elif self.properties[u"approved_pending"]:
 
 
253
            if self.properties[u"approved_by_default"]:
 
 
254
                message = u"Connection established to client. (d)eny?"
 
 
256
                message = u"Seeks approval to send secret. (a)pprove?"
 
321
259
        self._text = "%s%s" % (base, message)
 
323
261
        if not urwid.supports_unicode():
 
324
262
            self._text = self._text.encode("ascii", "replace")
 
325
 
        textlist = [("normal", self._text)]
 
 
263
        textlist = [(u"normal", self._text)]
 
326
264
        self._text_widget.set_text(textlist)
 
327
265
        self._focus_text_widget.set_text([(with_standout[text[0]],
 
 
348
286
        if self.delete_hook is not None:
 
349
287
            self.delete_hook(self)
 
351
 
    def render(self, maxcolrow, focus=False):
 
 
289
    def render(self, (maxcol,), focus=False):
 
352
290
        """Render differently if we have focus.
 
353
291
        This overrides the method from urwid.FlowWidget"""
 
354
 
        return self.current_widget(focus).render(maxcolrow,
 
 
292
        return self.current_widget(focus).render((maxcol,),
 
357
 
    def keypress(self, maxcolrow, key):
 
 
295
    def keypress(self, (maxcol,), key):
 
359
297
        This overrides the method from urwid.FlowWidget"""
 
361
299
            self.proxy.Enable(dbus_interface = client_interface)
 
363
301
            self.proxy.Disable(dbus_interface = client_interface)
 
365
303
            self.proxy.Approve(dbus.Boolean(True, variant_level=1),
 
366
304
                               dbus_interface = client_interface)
 
368
306
            self.proxy.Approve(dbus.Boolean(False, variant_level=1),
 
369
307
                                  dbus_interface = client_interface)
 
370
 
        elif key == "R" or key == "_" or key == "ctrl k":
 
 
308
        elif key == u"r" or key == u"_" or key == u"ctrl k":
 
371
309
            self.server_proxy_object.RemoveClient(self.proxy
 
374
312
            self.proxy.StartChecker(dbus_interface = client_interface)
 
376
314
            self.proxy.StopChecker(dbus_interface = client_interface)
 
378
316
            self.proxy.CheckedOK(dbus_interface = client_interface)
 
380
 
#         elif key == "p" or key == "=":
 
 
318
#         elif key == u"p" or key == "=":
 
381
319
#             self.proxy.pause()
 
382
 
#         elif key == "u" or key == ":":
 
 
320
#         elif key == u"u" or key == ":":
 
383
321
#             self.proxy.unpause()
 
 
322
#         elif key == u"RET":
 
 
325
#            self.proxy.Approve(True)
 
 
327
#            self.proxy.Approve(False)
 
 
420
362
        self.screen = urwid.curses_display.Screen()
 
422
364
        self.screen.register_palette((
 
424
 
                 "default", "default", None),
 
426
 
                 "default", "default", "bold"),
 
428
 
                 "default", "default", "underline"),
 
430
 
                 "default", "default", "standout"),
 
431
 
                ("bold-underline-blink",
 
432
 
                 "default", "default", ("bold", "underline")),
 
434
 
                 "default", "default", ("bold", "standout")),
 
435
 
                ("underline-blink-standout",
 
436
 
                 "default", "default", ("underline", "standout")),
 
437
 
                ("bold-underline-blink-standout",
 
438
 
                 "default", "default", ("bold", "underline",
 
 
366
                 u"default", u"default", None),
 
 
368
                 u"default", u"default", u"bold"),
 
 
370
                 u"default", u"default", u"underline"),
 
 
372
                 u"default", u"default", u"standout"),
 
 
373
                (u"bold-underline-blink",
 
 
374
                 u"default", u"default", (u"bold", u"underline")),
 
 
376
                 u"default", u"default", (u"bold", u"standout")),
 
 
377
                (u"underline-blink-standout",
 
 
378
                 u"default", u"default", (u"underline", u"standout")),
 
 
379
                (u"bold-underline-blink-standout",
 
 
380
                 u"default", u"default", (u"bold", u"underline",
 
442
384
        if urwid.supports_unicode():
 
443
 
            self.divider = "─" # \u2500
 
444
 
            #self.divider = "━" # \u2501
 
 
385
            self.divider = u"─" # \u2500
 
 
386
            #self.divider = u"━" # \u2501
 
446
 
            #self.divider = "-" # \u002d
 
447
 
            self.divider = "_" # \u005f
 
 
388
            #self.divider = u"-" # \u002d
 
 
389
            self.divider = u"_" # \u005f
 
449
391
        self.screen.start()
 
 
464
406
        # This keeps track of whether self.uilist currently has
 
465
407
        # self.logbox in it or not
 
466
408
        self.log_visible = True
 
467
 
        self.log_wrap = "any"
 
 
409
        self.log_wrap = u"any"
 
470
 
        self.log_message_raw(("bold",
 
471
 
                              "Mandos Monitor version " + version))
 
472
 
        self.log_message_raw(("bold",
 
 
412
        self.log_message_raw((u"bold",
 
 
413
                              u"Mandos Monitor version " + version))
 
 
414
        self.log_message_raw((u"bold",
 
475
417
        self.busname = domain + '.Mandos'
 
476
418
        self.main_loop = gobject.MainLoop()
 
477
419
        self.bus = dbus.SystemBus()
 
478
420
        mandos_dbus_objc = self.bus.get_object(
 
479
 
            self.busname, "/", follow_name_owner_changes=True)
 
 
421
            self.busname, u"/", follow_name_owner_changes=True)
 
480
422
        self.mandos_serv = dbus.Interface(mandos_dbus_objc,
 
482
424
                                          = server_interface)
 
 
550
489
            and len(self.log) > self.max_log_length):
 
551
490
            del self.log[0:len(self.log)-self.max_log_length-1]
 
552
491
        self.logbox.set_focus(len(self.logbox.body.contents),
 
 
492
                              coming_from=u"above")
 
556
495
    def toggle_log_display(self):
 
557
496
        """Toggle visibility of the log buffer."""
 
558
497
        self.log_visible = not self.log_visible
 
560
 
        #self.log_message("Log visibility changed to: "
 
561
 
        #                 + unicode(self.log_visible))
 
 
499
        self.log_message(u"Log visibility changed to: "
 
 
500
                         + unicode(self.log_visible))
 
563
502
    def change_log_display(self):
 
564
503
        """Change type of log display.
 
565
504
        Currently, this toggles wrapping of text lines."""
 
566
 
        if self.log_wrap == "clip":
 
567
 
            self.log_wrap = "any"
 
 
505
        if self.log_wrap == u"clip":
 
 
506
            self.log_wrap = u"any"
 
569
 
            self.log_wrap = "clip"
 
 
508
            self.log_wrap = u"clip"
 
570
509
        for textwidget in self.log:
 
571
510
            textwidget.set_wrap_mode(self.log_wrap)
 
572
 
        #self.log_message("Wrap mode: " + self.log_wrap)
 
 
511
        self.log_message(u"Wrap mode: " + self.log_wrap)
 
574
513
    def find_and_remove_client(self, path, name):
 
575
514
        """Find an client from its object path and remove it.
 
 
655
594
            except KeyError:    # :-)
 
658
 
            if key == "q" or key == "Q":
 
 
597
            if key == u"q" or key == u"Q":
 
661
 
            elif key == "window resize":
 
 
600
            elif key == u"window resize":
 
662
601
                self.size = self.screen.get_cols_rows()
 
664
 
            elif key == "\f":  # Ctrl-L
 
 
603
            elif key == u"\f":  # Ctrl-L
 
666
 
            elif key == "l" or key == "D":
 
 
605
            elif key == u"l" or key == u"D":
 
667
606
                self.toggle_log_display()
 
669
 
            elif key == "w" or key == "i":
 
 
608
            elif key == u"w" or key == u"i":
 
670
609
                self.change_log_display()
 
672
 
            elif key == "?" or key == "f1" or key == "esc":
 
 
611
            elif key == u"?" or key == u"f1" or key == u"esc":
 
673
612
                if not self.log_visible:
 
674
613
                    self.log_visible = True
 
676
 
                self.log_message_raw(("bold",
 
680
 
                                            "l: Log window toggle",
 
681
 
                                            "TAB: Switch window",
 
683
 
                self.log_message_raw(("bold",
 
689
 
                                             "s: Start new checker",
 
 
615
                self.log_message_raw((u"bold",
 
 
619
                                            u"l: Log window toggle",
 
 
620
                                            u"TAB: Switch window",
 
 
622
                self.log_message_raw((u"bold",
 
 
628
                                             u"s: Start new checker",
 
696
635
                if self.topwidget.get_focus() is self.logbox:
 
697
636
                    self.topwidget.set_focus(0)
 
699
638
                    self.topwidget.set_focus(self.logbox)
 
701
 
            #elif (key == "end" or key == "meta >" or key == "G"
 
 
640
            #elif (key == u"end" or key == u"meta >" or key == u"G"
 
703
642
            #    pass            # xxx end-of-buffer
 
704
 
            #elif (key == "home" or key == "meta <" or key == "g"
 
 
643
            #elif (key == u"home" or key == u"meta <" or key == u"g"
 
706
645
            #    pass            # xxx beginning-of-buffer
 
707
 
            #elif key == "ctrl e" or key == "$":
 
 
646
            #elif key == u"ctrl e" or key == u"$":
 
708
647
            #    pass            # xxx move-end-of-line
 
709
 
            #elif key == "ctrl a" or key == "^":
 
 
648
            #elif key == u"ctrl a" or key == u"^":
 
710
649
            #    pass            # xxx move-beginning-of-line
 
711
 
            #elif key == "ctrl b" or key == "meta (" or key == "h":
 
 
650
            #elif key == u"ctrl b" or key == u"meta (" or key == u"h":
 
712
651
            #    pass            # xxx left
 
713
 
            #elif key == "ctrl f" or key == "meta )" or key == "l":
 
 
652
            #elif key == u"ctrl f" or key == u"meta )" or key == u"l":
 
714
653
            #    pass            # xxx right
 
716
655
            #    pass            # scroll up log
 
718
657
            #    pass            # scroll down log
 
719
658
            elif self.topwidget.selectable():
 
720
659
                self.topwidget.keypress(self.size, key)