53
60
domain = 'se.recompile'
 
54
61
server_interface = domain + '.Mandos'
 
55
62
client_interface = domain + '.Mandos.Client'
 
58
 
# Always run in monochrome mode
 
59
 
urwid.curses_display.curses.has_colors = lambda : False
 
61
 
# Urwid doesn't support blinking, but we want it.  Since we have no
 
62
 
# use for underline on its own, we make underline also always blink.
 
63
 
urwid.curses_display.curses.A_UNDERLINE |= (
 
64
 
    urwid.curses_display.curses.A_BLINK)
 
 
66
    dbus.OBJECT_MANAGER_IFACE
 
 
67
except AttributeError:
 
 
68
    dbus.OBJECT_MANAGER_IFACE = "org.freedesktop.DBus.ObjectManager"
 
66
70
def isoformat_to_datetime(iso):
 
67
71
    "Parse an ISO 8601 date string to a datetime.datetime()"
 
 
84
88
    properties and calls a hook function when any of them are
 
87
 
    def __init__(self, proxy_object=None, *args, **kwargs):
 
 
91
    def __init__(self, proxy_object=None, properties=None, **kwargs):
 
88
92
        self.proxy = proxy_object # Mandos Client proxy object
 
90
 
        self.properties = dict()
 
 
93
        self.properties = dict() if properties is None else properties
 
91
94
        self.property_changed_match = (
 
92
 
            self.proxy.connect_to_signal("PropertyChanged",
 
93
 
                                         self.property_changed,
 
 
95
            self.proxy.connect_to_signal("PropertiesChanged",
 
 
96
                                         self.properties_changed,
 
 
97
                                         dbus.PROPERTIES_IFACE,
 
97
 
        self.properties.update(
 
98
 
            self.proxy.GetAll(client_interface,
 
99
 
                              dbus_interface = dbus.PROPERTIES_IFACE))
 
101
 
        #XXX This breaks good super behaviour
 
102
 
#        super(MandosClientPropertyCache, self).__init__(
 
 
100
        if properties is None:
 
 
101
            self.properties.update(
 
 
102
                self.proxy.GetAll(client_interface,
 
 
104
                                  = dbus.PROPERTIES_IFACE))
 
 
106
        super(MandosClientPropertyCache, self).__init__(**kwargs)
 
105
 
    def property_changed(self, property=None, value=None):
 
106
 
        """This is called whenever we get a PropertyChanged signal
 
107
 
        It updates the changed property in the "properties" dict.
 
 
108
    def properties_changed(self, interface, properties, invalidated):
 
 
109
        """This is called whenever we get a PropertiesChanged signal
 
 
110
        It updates the changed properties in the "properties" dict.
 
109
112
        # Update properties dict with new value
 
110
 
        self.properties[property] = value
 
 
113
        if interface == client_interface:
 
 
114
            self.properties.update(properties)
 
112
 
    def delete(self, *args, **kwargs):
 
113
117
        self.property_changed_match.remove()
 
114
 
        super(MandosClientPropertyCache, self).__init__(
 
118
120
class MandosClientWidget(urwid.FlowWidget, MandosClientPropertyCache):
 
 
131
133
        self.logger = logger
 
133
135
        self._update_timer_callback_tag = None
 
134
 
        self._update_timer_callback_lock = 0
 
136
137
        # The widget shown normally
 
137
138
        self._text_widget = urwid.Text("")
 
138
139
        # The widget shown when we have focus
 
139
140
        self._focus_text_widget = urwid.Text("")
 
140
 
        super(MandosClientWidget, self).__init__(
 
141
 
            update_hook=update_hook, delete_hook=delete_hook,
 
 
141
        super(MandosClientWidget, self).__init__(**kwargs)
 
144
143
        self.opened = False
 
146
 
        last_checked_ok = isoformat_to_datetime(self.properties
 
149
 
        if self.properties ["LastCheckerStatus"] != 0:
 
150
 
            self.using_timer(True)
 
152
 
        if self.need_approval:
 
153
 
            self.using_timer(True)
 
155
145
        self.match_objects = (
 
156
146
            self.proxy.connect_to_signal("CheckerCompleted",
 
157
147
                                         self.checker_completed,
 
 
174
164
                                         client_interface,
 
175
165
                                         byte_arrays=True))
 
176
 
        #self.logger('Created client {0}'
 
177
 
        #            .format(self.properties["Name"]))
 
179
 
    def property_changed(self, property=None, value=None):
 
180
 
        super(self, MandosClientWidget).property_changed(property,
 
182
 
        if property == "ApprovalPending":
 
183
 
            using_timer(bool(value))
 
184
 
        if property == "LastCheckerStatus":
 
185
 
            using_timer(value != 0)
 
186
 
            #self.logger('Checker for client {0} (command "{1}") was '
 
187
 
            #            ' successful'.format(self.properties["Name"],
 
 
166
        self.logger('Created client {}'
 
 
167
                    .format(self.properties["Name"]), level=0)
 
190
169
    def using_timer(self, flag):
 
191
170
        """Call this method with True or False when timer should be
 
192
171
        activated or deactivated.
 
194
 
        old = self._update_timer_callback_lock
 
196
 
            self._update_timer_callback_lock += 1
 
198
 
            self._update_timer_callback_lock -= 1
 
199
 
        if old == 0 and self._update_timer_callback_lock:
 
 
173
        if flag and self._update_timer_callback_tag is None:
 
200
174
            # Will update the shown timer value every second
 
201
175
            self._update_timer_callback_tag = (gobject.timeout_add
 
203
177
                                                self.update_timer))
 
204
 
        elif old and self._update_timer_callback_lock == 0:
 
 
178
        elif not (flag or self._update_timer_callback_tag is None):
 
205
179
            gobject.source_remove(self._update_timer_callback_tag)
 
206
180
            self._update_timer_callback_tag = None
 
208
182
    def checker_completed(self, exitstatus, condition, command):
 
209
183
        if exitstatus == 0:
 
 
184
            self.logger('Checker for client {} (command "{}")'
 
 
185
                        ' succeeded'.format(self.properties["Name"],
 
213
190
        if os.WIFEXITED(condition):
 
214
 
            self.logger('Checker for client {0} (command "{1}")'
 
215
 
                        ' failed with exit code {2}'
 
 
191
            self.logger('Checker for client {} (command "{}") failed'
 
216
193
                        .format(self.properties["Name"], command,
 
217
194
                                os.WEXITSTATUS(condition)))
 
218
195
        elif os.WIFSIGNALED(condition):
 
219
 
            self.logger('Checker for client {0} (command "{1}") was'
 
220
 
                        ' killed by signal {2}'
 
 
196
            self.logger('Checker for client {} (command "{}") was'
 
 
197
                        ' killed by signal {}'
 
221
198
                        .format(self.properties["Name"], command,
 
222
199
                                os.WTERMSIG(condition)))
 
223
 
        elif os.WCOREDUMP(condition):
 
224
 
            self.logger('Checker for client {0} (command "{1}")'
 
226
 
                        .format(self.properties["Name"], command))
 
228
 
            self.logger('Checker for client {0} completed'
 
230
 
                        .format(self.properties["Name"]))
 
233
202
    def checker_started(self, command):
 
234
 
        """Server signals that a checker started. This could be useful
 
235
 
           to log in the future. """
 
236
 
        #self.logger('Client {0} started checker "{1}"'
 
237
 
        #            .format(self.properties["Name"],
 
 
203
        """Server signals that a checker started."""
 
 
204
        self.logger('Client {} started checker "{}"'
 
 
205
                    .format(self.properties["Name"],
 
241
208
    def got_secret(self):
 
242
 
        self.logger('Client {0} received its secret'
 
 
209
        self.logger('Client {} received its secret'
 
243
210
                    .format(self.properties["Name"]))
 
245
212
    def need_approval(self, timeout, default):
 
247
 
            message = 'Client {0} needs approval within {1} seconds'
 
 
214
            message = 'Client {} needs approval within {} seconds'
 
249
 
            message = 'Client {0} will get its secret in {1} seconds'
 
 
216
            message = 'Client {} will get its secret in {} seconds'
 
250
217
        self.logger(message.format(self.properties["Name"],
 
252
 
        self.using_timer(True)
 
254
220
    def rejected(self, reason):
 
255
 
        self.logger('Client {0} was rejected; reason: {1}'
 
 
221
        self.logger('Client {} was rejected; reason: {}'
 
256
222
                    .format(self.properties["Name"], reason))
 
258
224
    def selectable(self):
 
 
295
262
            last_approval_request = isoformat_to_datetime(
 
296
263
                self.properties["LastApprovalRequest"])
 
297
264
            if last_approval_request is not None:
 
298
 
                timer = timeout - (datetime.datetime.utcnow()
 
299
 
                                   - last_approval_request)
 
 
265
                timer = max(timeout - (datetime.datetime.utcnow()
 
 
266
                                       - last_approval_request),
 
 
267
                            datetime.timedelta())
 
301
269
                timer = datetime.timedelta()
 
302
270
            if self.properties["ApprovedByDefault"]:
 
303
 
                message = "Approval in {0}. (d)eny?"
 
 
271
                message = "Approval in {}. (d)eny?"
 
305
 
                message = "Denial in {0}. (a)pprove?"
 
306
 
            message = message.format(unicode(timer).rsplit(".", 1)[0])
 
 
273
                message = "Denial in {}. (a)pprove?"
 
 
274
            message = message.format(str(timer).rsplit(".", 1)[0])
 
 
275
            self.using_timer(True)
 
307
276
        elif self.properties["LastCheckerStatus"] != 0:
 
308
277
            # When checker has failed, show timer until client expires
 
309
278
            expires = self.properties["Expires"]
 
 
313
282
                expires = (datetime.datetime.strptime
 
314
283
                           (expires, '%Y-%m-%dT%H:%M:%S.%f'))
 
315
 
                timer = expires - datetime.datetime.utcnow()
 
 
284
                timer = max(expires - datetime.datetime.utcnow(),
 
 
285
                            datetime.timedelta())
 
316
286
            message = ('A checker has failed! Time until client'
 
317
 
                       ' gets disabled: {0}'
 
318
 
                       .format(unicode(timer).rsplit(".", 1)[0]))
 
 
288
                       .format(str(timer).rsplit(".", 1)[0]))
 
 
289
            self.using_timer(True)
 
320
291
            message = "enabled"
 
321
 
        self._text = "{0}{1}".format(base, message)
 
 
292
            self.using_timer(False)
 
 
293
        self._text = "{}{}".format(base, message)
 
323
295
        if not urwid.supports_unicode():
 
324
296
            self._text = self._text.encode("ascii", "replace")
 
325
297
        textlist = [("normal", self._text)]
 
 
364
336
        This overrides the method from urwid.FlowWidget"""
 
366
 
            self.proxy.Enable(dbus_interface = client_interface,
 
 
338
            self.proxy.Set(client_interface, "Enabled",
 
 
339
                           dbus.Boolean(True), ignore_reply = True,
 
 
340
                           dbus_interface = dbus.PROPERTIES_IFACE)
 
369
 
            self.proxy.Disable(dbus_interface = client_interface,
 
 
342
            self.proxy.Set(client_interface, "Enabled", False,
 
 
344
                           dbus_interface = dbus.PROPERTIES_IFACE)
 
372
346
            self.proxy.Approve(dbus.Boolean(True, variant_level=1),
 
373
347
                               dbus_interface = client_interface,
 
 
382
356
                                                  ignore_reply=True)
 
384
 
            self.proxy.StartChecker(dbus_interface = client_interface,
 
 
358
            self.proxy.Set(client_interface, "CheckerRunning",
 
 
359
                           dbus.Boolean(True), ignore_reply = True,
 
 
360
                           dbus_interface = dbus.PROPERTIES_IFACE)
 
387
 
            self.proxy.StopChecker(dbus_interface = client_interface,
 
 
362
            self.proxy.Set(client_interface, "CheckerRunning",
 
 
363
                           dbus.Boolean(False), ignore_reply = True,
 
 
364
                           dbus_interface = dbus.PROPERTIES_IFACE)
 
390
366
            self.proxy.CheckedOK(dbus_interface = client_interface,
 
391
367
                                 ignore_reply=True)
 
 
402
 
    def property_changed(self, property=None, value=None,
 
404
 
        """Call self.update() if old value is not new value.
 
 
378
    def properties_changed(self, interface, properties, invalidated):
 
 
379
        """Call self.update() if any properties changed.
 
405
380
        This overrides the method from MandosClientPropertyCache"""
 
406
 
        property_name = unicode(property)
 
407
 
        old_value = self.properties.get(property_name)
 
408
 
        super(MandosClientWidget, self).property_changed(
 
409
 
            property=property, value=value, *args, **kwargs)
 
410
 
        if self.properties.get(property_name) != old_value:
 
 
381
        old_values = { key: self.properties.get(key)
 
 
382
                       for key in properties.keys() }
 
 
383
        super(MandosClientWidget, self).properties_changed(
 
 
384
            interface, properties, invalidated)
 
 
385
        if any(old_values[key] != self.properties.get(key)
 
 
386
               for key in old_values):
 
 
437
413
                 "default", "default", None),
 
439
 
                 "default", "default", "bold"),
 
 
415
                 "bold", "default", "bold"),
 
440
416
                ("underline-blink",
 
441
 
                 "default", "default", "underline"),
 
 
417
                 "underline,blink", "default", "underline,blink"),
 
443
 
                 "default", "default", "standout"),
 
 
419
                 "standout", "default", "standout"),
 
444
420
                ("bold-underline-blink",
 
445
 
                 "default", "default", ("bold", "underline")),
 
 
421
                 "bold,underline,blink", "default", "bold,underline,blink"),
 
446
422
                ("bold-standout",
 
447
 
                 "default", "default", ("bold", "standout")),
 
 
423
                 "bold,standout", "default", "bold,standout"),
 
448
424
                ("underline-blink-standout",
 
449
 
                 "default", "default", ("underline", "standout")),
 
 
425
                 "underline,blink,standout", "default",
 
 
426
                 "underline,blink,standout"),
 
450
427
                ("bold-underline-blink-standout",
 
451
 
                 "default", "default", ("bold", "underline",
 
 
428
                 "bold,underline,blink,standout", "default",
 
 
429
                 "bold,underline,blink,standout"),
 
455
432
        if urwid.supports_unicode():
 
 
509
488
            self.uilist.append(self.logbox)
 
510
489
        self.topwidget = urwid.Pile(self.uilist)
 
512
 
    def log_message(self, message):
 
 
491
    def log_message(self, message, level=1):
 
 
492
        """Log message formatted with timestamp"""
 
 
493
        if level < self.log_level:
 
513
495
        timestamp = datetime.datetime.now().isoformat()
 
514
 
        self.log_message_raw(timestamp + ": " + message)
 
 
496
        self.log_message_raw("{}: {}".format(timestamp, message),
 
516
 
    def log_message_raw(self, markup):
 
 
499
    def log_message_raw(self, markup, level=1):
 
517
500
        """Add a log message to the log buffer."""
 
 
501
        if level < self.log_level:
 
518
503
        self.log.append(urwid.Text(markup, wrap=self.log_wrap))
 
519
504
        if (self.max_log_length
 
520
505
            and len(self.log) > self.max_log_length):
 
 
539
524
            self.log_wrap = "clip"
 
540
525
        for textwidget in self.log:
 
541
526
            textwidget.set_wrap_mode(self.log_wrap)
 
542
 
        #self.log_message("Wrap mode: " + self.log_wrap)
 
 
527
        self.log_message("Wrap mode: {}".format(self.log_wrap),
 
544
 
    def find_and_remove_client(self, path, name):
 
 
530
    def find_and_remove_client(self, path, interfaces):
 
545
531
        """Find a client by its object path and remove it.
 
547
 
        This is connected to the ClientRemoved signal from the
 
 
533
        This is connected to the InterfacesRemoved signal from the
 
548
534
        Mandos server object."""
 
 
535
        if client_interface not in interfaces:
 
 
536
            # Not a Mandos client object; ignore
 
550
539
            client = self.clients_dict[path]
 
553
 
            self.log_message("Unknown client {0!r} ({1!r}) removed"
 
 
542
            self.log_message("Unknown client {!r} removed"
 
558
 
    def add_new_client(self, path):
 
 
547
    def add_new_client(self, path, ifs_and_props):
 
 
548
        """Find a client by its object path and remove it.
 
 
550
        This is connected to the InterfacesAdded signal from the
 
 
551
        Mandos server object.
 
 
553
        if client_interface not in ifs_and_props:
 
 
554
            # Not a Mandos client object; ignore
 
559
556
        client_proxy_object = self.bus.get_object(self.busname, path)
 
560
557
        self.add_client(MandosClientWidget(server_proxy_object
 
561
558
                                           =self.mandos_serv,
 
 
606
601
            mandos_clients = (self.mandos_serv
 
607
602
                              .GetAllClientsWithProperties())
 
 
603
            if not mandos_clients:
 
 
604
                self.log_message_raw(("bold", "Note: Server has no clients."))
 
608
605
        except dbus.exceptions.DBusException:
 
 
606
            self.log_message_raw(("bold", "Note: No Mandos server running."))
 
609
607
            mandos_clients = dbus.Dictionary()
 
611
609
        (self.mandos_serv
 
612
 
         .connect_to_signal("ClientRemoved",
 
 
610
         .connect_to_signal("InterfacesRemoved",
 
613
611
                            self.find_and_remove_client,
 
614
 
                            dbus_interface=server_interface,
 
 
613
                            = dbus.OBJECT_MANAGER_IFACE,
 
615
614
                            byte_arrays=True))
 
616
615
        (self.mandos_serv
 
617
 
         .connect_to_signal("ClientAdded",
 
 
616
         .connect_to_signal("InterfacesAdded",
 
618
617
                            self.add_new_client,
 
619
 
                            dbus_interface=server_interface,
 
 
619
                            = dbus.OBJECT_MANAGER_IFACE,
 
620
620
                            byte_arrays=True))
 
621
621
        (self.mandos_serv
 
622
622
         .connect_to_signal("ClientNotFound",
 
623
623
                            self.client_not_found,
 
624
624
                            dbus_interface=server_interface,
 
625
625
                            byte_arrays=True))
 
626
 
        for path, client in mandos_clients.iteritems():
 
 
626
        for path, client in mandos_clients.items():
 
627
627
            client_proxy_object = self.bus.get_object(self.busname,
 
629
629
            self.add_client(MandosClientWidget(server_proxy_object