82
83
    properties and calls a hook function when any of them are
 
85
 
    def __init__(self, proxy_object=None, *args, **kwargs):
 
 
86
    def __init__(self, proxy_object=None, properties=None, **kwargs):
 
86
87
        self.proxy = proxy_object # Mandos Client proxy object
 
88
 
        self.properties = dict()
 
89
 
        self.proxy.connect_to_signal("PropertyChanged",
 
90
 
                                     self.property_changed,
 
94
 
        self.properties.update(
 
95
 
            self.proxy.GetAll(client_interface,
 
96
 
                              dbus_interface = dbus.PROPERTIES_IFACE))
 
98
 
        #XXX This break good super behaviour!
 
99
 
#        super(MandosClientPropertyCache, self).__init__(
 
 
88
        self.properties = dict() if properties is None else properties
 
 
89
        self.property_changed_match = (
 
 
90
            self.proxy.connect_to_signal("PropertyChanged",
 
 
91
                                         self._property_changed,
 
 
95
        if properties is None:
 
 
96
            self.properties.update(
 
 
97
                self.proxy.GetAll(client_interface,
 
 
99
                                  = dbus.PROPERTIES_IFACE))
 
 
101
        super(MandosClientPropertyCache, self).__init__(**kwargs)
 
 
103
    def _property_changed(self, property, value):
 
 
104
        """Helper which takes positional arguments"""
 
 
105
        return self.property_changed(property=property, value=value)
 
102
107
    def property_changed(self, property=None, value=None):
 
103
108
        """This is called whenever we get a PropertyChanged signal
 
 
123
131
        self.logger = logger
 
125
133
        self._update_timer_callback_tag = None
 
126
 
        self._update_timer_callback_lock = 0
 
127
 
        self.last_checker_failed = False
 
129
135
        # The widget shown normally
 
130
136
        self._text_widget = urwid.Text("")
 
131
137
        # The widget shown when we have focus
 
132
138
        self._focus_text_widget = urwid.Text("")
 
133
 
        super(MandosClientWidget, self).__init__(
 
134
 
            update_hook=update_hook, delete_hook=delete_hook,
 
 
139
        super(MandosClientWidget, self).__init__(**kwargs)
 
137
141
        self.opened = False
 
139
 
        last_checked_ok = isoformat_to_datetime(self.properties
 
141
 
        if last_checked_ok is None:
 
142
 
            self.last_checker_failed = True
 
144
 
            self.last_checker_failed = ((datetime.datetime.utcnow()
 
151
 
        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",
 
 
143
        self.match_objects = (
 
 
144
            self.proxy.connect_to_signal("CheckerCompleted",
 
 
145
                                         self.checker_completed,
 
 
148
            self.proxy.connect_to_signal("CheckerStarted",
 
 
149
                                         self.checker_started,
 
 
152
            self.proxy.connect_to_signal("GotSecret",
 
 
156
            self.proxy.connect_to_signal("NeedApproval",
 
 
160
            self.proxy.connect_to_signal("Rejected",
 
 
164
        #self.logger('Created client {0}'
 
 
165
        #            .format(self.properties["Name"]))
 
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
167
    def using_timer(self, flag):
 
185
168
        """Call this method with True or False when timer should be
 
186
169
        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:
 
 
171
        if flag and self._update_timer_callback_tag is None:
 
 
172
            # Will update the shown timer value every second
 
194
173
            self._update_timer_callback_tag = (gobject.timeout_add
 
196
175
                                                self.update_timer))
 
197
 
        elif old and self._update_timer_callback_lock == 0:
 
 
176
        elif not (flag or self._update_timer_callback_tag is None):
 
198
177
            gobject.source_remove(self._update_timer_callback_tag)
 
199
178
            self._update_timer_callback_tag = None
 
201
180
    def checker_completed(self, exitstatus, condition, command):
 
202
181
        if exitstatus == 0:
 
203
 
            if self.last_checker_failed:
 
204
 
                self.last_checker_failed = False
 
205
 
                self.using_timer(False)
 
206
 
            #self.logger('Checker for client %s (command "%s")'
 
208
 
            #            % (self.properties["Name"], command))
 
212
 
        if not self.last_checker_failed:
 
213
 
            self.last_checker_failed = True
 
214
 
            self.using_timer(True)
 
215
185
        if os.WIFEXITED(condition):
 
216
 
            self.logger('Checker for client %s (command "%s")'
 
217
 
                        ' failed with exit code %s'
 
218
 
                        % (self.properties["Name"], command,
 
219
 
                           os.WEXITSTATUS(condition)))
 
 
186
            self.logger('Checker for client {0} (command "{1}")'
 
 
187
                        ' failed with exit code {2}'
 
 
188
                        .format(self.properties["Name"], command,
 
 
189
                                os.WEXITSTATUS(condition)))
 
220
190
        elif os.WIFSIGNALED(condition):
 
221
 
            self.logger('Checker for client %s (command "%s")'
 
222
 
                        ' was killed by signal %s'
 
223
 
                        % (self.properties["Name"], command,
 
224
 
                           os.WTERMSIG(condition)))
 
 
191
            self.logger('Checker for client {0} (command "{1}") was'
 
 
192
                        ' killed by signal {2}'
 
 
193
                        .format(self.properties["Name"], command,
 
 
194
                                os.WTERMSIG(condition)))
 
225
195
        elif os.WCOREDUMP(condition):
 
226
 
            self.logger('Checker for client %s (command "%s")'
 
 
196
            self.logger('Checker for client {0} (command "{1}")'
 
228
 
                        % (self.properties["Name"], command))
 
 
198
                        .format(self.properties["Name"], command))
 
230
 
            self.logger('Checker for client %s completed'
 
 
200
            self.logger('Checker for client {0} completed'
 
 
202
                        .format(self.properties["Name"]))
 
234
205
    def checker_started(self, command):
 
235
 
        #self.logger('Client %s started checker "%s"'
 
236
 
        #            % (self.properties["Name"], unicode(command)))
 
 
206
        """Server signals that a checker started. This could be useful
 
 
207
           to log in the future. """
 
 
208
        #self.logger('Client {0} started checker "{1}"'
 
 
209
        #            .format(self.properties["Name"],
 
239
213
    def got_secret(self):
 
240
 
        self.last_checker_failed = False
 
241
 
        self.logger('Client %s received its secret'
 
242
 
                    % self.properties["Name"])
 
 
214
        self.logger('Client {0} received its secret'
 
 
215
                    .format(self.properties["Name"]))
 
244
217
    def need_approval(self, timeout, default):
 
246
 
            message = 'Client %s needs approval within %s seconds'
 
 
219
            message = 'Client {0} needs approval within {1} seconds'
 
248
 
            message = 'Client %s will get its secret in %s seconds'
 
250
 
                    % (self.properties["Name"], timeout/1000))
 
251
 
        self.using_timer(True)
 
 
221
            message = 'Client {0} will get its secret in {1} seconds'
 
 
222
        self.logger(message.format(self.properties["Name"],
 
253
225
    def rejected(self, reason):
 
254
 
        self.logger('Client %s was rejected; reason: %s'
 
255
 
                    % (self.properties["Name"], reason))
 
 
226
        self.logger('Client {0} was rejected; reason: {1}'
 
 
227
                    .format(self.properties["Name"], reason))
 
257
229
    def selectable(self):
 
258
230
        """Make this a "selectable" widget.
 
 
295
267
            last_approval_request = isoformat_to_datetime(
 
296
268
                self.properties["LastApprovalRequest"])
 
297
269
            if last_approval_request is not None:
 
298
 
                timer = timeout - (datetime.datetime.utcnow()
 
299
 
                                   - last_approval_request)
 
 
270
                timer = max(timeout - (datetime.datetime.utcnow()
 
 
271
                                       - last_approval_request),
 
 
272
                            datetime.timedelta())
 
301
274
                timer = datetime.timedelta()
 
302
275
            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]
 
307
 
        elif self.last_checker_failed:
 
308
 
            timeout = datetime.timedelta(milliseconds
 
311
 
            last_ok = isoformat_to_datetime(
 
312
 
                max((self.properties["LastCheckedOK"]
 
313
 
                     or self.properties["Created"]),
 
314
 
                    self.properties["LastEnabled"]))
 
315
 
            timer = timeout - (datetime.datetime.utcnow() - last_ok)
 
 
276
                message = "Approval in {0}. (d)eny?"
 
 
278
                message = "Denial in {0}. (a)pprove?"
 
 
279
            message = message.format(str(timer).rsplit(".", 1)[0])
 
 
280
            self.using_timer(True)
 
 
281
        elif self.properties["LastCheckerStatus"] != 0:
 
 
282
            # When checker has failed, show timer until client expires
 
 
283
            expires = self.properties["Expires"]
 
 
285
                timer = datetime.timedelta(0)
 
 
287
                expires = (datetime.datetime.strptime
 
 
288
                           (expires, '%Y-%m-%dT%H:%M:%S.%f'))
 
 
289
                timer = max(expires - datetime.datetime.utcnow(),
 
 
290
                            datetime.timedelta())
 
316
291
            message = ('A checker has failed! Time until client'
 
318
 
                           % unicode(timer).rsplit(".", 1)[0])
 
 
292
                       ' gets disabled: {0}'
 
 
293
                       .format(str(timer).rsplit(".", 1)[0]))
 
 
294
            self.using_timer(True)
 
320
296
            message = "enabled"
 
321
 
        self._text = "%s%s" % (base, message)
 
 
297
            self.using_timer(False)
 
 
298
        self._text = "{0}{1}".format(base, message)
 
323
300
        if not urwid.supports_unicode():
 
324
301
            self._text = self._text.encode("ascii", "replace")
 
325
302
        textlist = [("normal", self._text)]
 
 
359
341
        This overrides the method from urwid.FlowWidget"""
 
361
 
            self.proxy.Enable(dbus_interface = client_interface)
 
 
343
            self.proxy.Enable(dbus_interface = client_interface,
 
363
 
            self.proxy.Disable(dbus_interface = client_interface)
 
 
346
            self.proxy.Disable(dbus_interface = client_interface,
 
365
349
            self.proxy.Approve(dbus.Boolean(True, variant_level=1),
 
366
 
                               dbus_interface = client_interface)
 
 
350
                               dbus_interface = client_interface,
 
368
353
            self.proxy.Approve(dbus.Boolean(False, variant_level=1),
 
369
 
                                  dbus_interface = client_interface)
 
 
354
                                  dbus_interface = client_interface,
 
370
356
        elif key == "R" or key == "_" or key == "ctrl k":
 
371
357
            self.server_proxy_object.RemoveClient(self.proxy
 
374
 
            self.proxy.StartChecker(dbus_interface = client_interface)
 
 
361
            self.proxy.StartChecker(dbus_interface = client_interface,
 
376
 
            self.proxy.StopChecker(dbus_interface = client_interface)
 
 
364
            self.proxy.StopChecker(dbus_interface = client_interface,
 
378
 
            self.proxy.CheckedOK(dbus_interface = client_interface)
 
 
367
            self.proxy.CheckedOK(dbus_interface = client_interface,
 
380
370
#         elif key == "p" or key == "=":
 
381
371
#             self.proxy.pause()
 
 
424
413
                 "default", "default", None),
 
426
 
                 "default", "default", "bold"),
 
 
415
                 "bold", "default", "bold"),
 
427
416
                ("underline-blink",
 
428
 
                 "default", "default", "underline"),
 
 
417
                 "underline,blink", "default", "underline,blink"),
 
430
 
                 "default", "default", "standout"),
 
 
419
                 "standout", "default", "standout"),
 
431
420
                ("bold-underline-blink",
 
432
 
                 "default", "default", ("bold", "underline")),
 
 
421
                 "bold,underline,blink", "default", "bold,underline,blink"),
 
433
422
                ("bold-standout",
 
434
 
                 "default", "default", ("bold", "standout")),
 
 
423
                 "bold,standout", "default", "bold,standout"),
 
435
424
                ("underline-blink-standout",
 
436
 
                 "default", "default", ("underline", "standout")),
 
 
425
                 "underline,blink,standout", "default",
 
 
426
                 "underline,blink,standout"),
 
437
427
                ("bold-underline-blink-standout",
 
438
 
                 "default", "default", ("bold", "underline",
 
 
428
                 "bold,underline,blink,standout", "default",
 
 
429
                 "bold,underline,blink,standout"),
 
442
432
        if urwid.supports_unicode():
 
 
475
465
        self.busname = domain + '.Mandos'
 
476
466
        self.main_loop = gobject.MainLoop()
 
477
 
        self.bus = dbus.SystemBus()
 
478
 
        mandos_dbus_objc = self.bus.get_object(
 
479
 
            self.busname, "/", follow_name_owner_changes=True)
 
480
 
        self.mandos_serv = dbus.Interface(mandos_dbus_objc,
 
484
 
            mandos_clients = (self.mandos_serv
 
485
 
                              .GetAllClientsWithProperties())
 
486
 
        except dbus.exceptions.DBusException:
 
487
 
            mandos_clients = dbus.Dictionary()
 
490
 
         .connect_to_signal("ClientRemoved",
 
491
 
                            self.find_and_remove_client,
 
492
 
                            dbus_interface=server_interface,
 
495
 
         .connect_to_signal("ClientAdded",
 
497
 
                            dbus_interface=server_interface,
 
500
 
         .connect_to_signal("ClientNotFound",
 
501
 
                            self.client_not_found,
 
502
 
                            dbus_interface=server_interface,
 
504
 
        for path, client in mandos_clients.iteritems():
 
505
 
            client_proxy_object = self.bus.get_object(self.busname,
 
507
 
            self.add_client(MandosClientWidget(server_proxy_object
 
510
 
                                               =client_proxy_object,
 
520
468
    def client_not_found(self, fingerprint, address):
 
521
 
        self.log_message(("Client with address %s and fingerprint %s"
 
522
 
                          " could not be found" % (address,
 
 
469
        self.log_message("Client with address {0} and fingerprint"
 
 
470
                         " {1} could not be found"
 
 
471
                         .format(address, fingerprint))
 
525
473
    def rebuild(self):
 
526
474
        """This rebuilds the User Interface.
 
 
626
571
        """Start the main loop and exit when it's done."""
 
 
572
        self.bus = dbus.SystemBus()
 
 
573
        mandos_dbus_objc = self.bus.get_object(
 
 
574
            self.busname, "/", follow_name_owner_changes=True)
 
 
575
        self.mandos_serv = dbus.Interface(mandos_dbus_objc,
 
 
579
            mandos_clients = (self.mandos_serv
 
 
580
                              .GetAllClientsWithProperties())
 
 
581
            if not mandos_clients:
 
 
582
                self.log_message_raw(("bold", "Note: Server has no clients."))
 
 
583
        except dbus.exceptions.DBusException:
 
 
584
            self.log_message_raw(("bold", "Note: No Mandos server running."))
 
 
585
            mandos_clients = dbus.Dictionary()
 
 
588
         .connect_to_signal("ClientRemoved",
 
 
589
                            self.find_and_remove_client,
 
 
590
                            dbus_interface=server_interface,
 
 
593
         .connect_to_signal("ClientAdded",
 
 
595
                            dbus_interface=server_interface,
 
 
598
         .connect_to_signal("ClientNotFound",
 
 
599
                            self.client_not_found,
 
 
600
                            dbus_interface=server_interface,
 
 
602
        for path, client in mandos_clients.items():
 
 
603
            client_proxy_object = self.bus.get_object(self.busname,
 
 
605
            self.add_client(MandosClientWidget(server_proxy_object
 
 
608
                                               =client_proxy_object,
 
628
619
        self._input_callback_tag = (gobject.io_add_watch
 
629
620
                                    (sys.stdin.fileno(),