83
82
    properties and calls a hook function when any of them are
 
86
 
    def __init__(self, proxy_object=None, properties=None, **kwargs):
 
 
85
    def __init__(self, proxy_object=None, *args, **kwargs):
 
87
86
        self.proxy = proxy_object # Mandos Client proxy object
 
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)
 
 
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__(
 
107
102
    def property_changed(self, property=None, value=None):
 
108
103
        """This is called whenever we get a PropertyChanged signal
 
 
131
123
        self.logger = logger
 
133
125
        self._update_timer_callback_tag = None
 
 
126
        self._update_timer_callback_lock = 0
 
 
127
        self.last_checker_failed = False
 
135
129
        # The widget shown normally
 
136
130
        self._text_widget = urwid.Text("")
 
137
131
        # The widget shown when we have focus
 
138
132
        self._focus_text_widget = urwid.Text("")
 
139
 
        super(MandosClientWidget, self).__init__(**kwargs)
 
 
133
        super(MandosClientWidget, self).__init__(
 
 
134
            update_hook=update_hook, delete_hook=delete_hook,
 
141
137
        self.opened = False
 
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"]))
 
 
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",
 
 
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))
 
167
184
    def using_timer(self, flag):
 
168
185
        """Call this method with True or False when timer should be
 
169
186
        activated or deactivated.
 
171
 
        if flag and self._update_timer_callback_tag is None:
 
172
 
            # Will update the shown timer value every second
 
 
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:
 
173
194
            self._update_timer_callback_tag = (gobject.timeout_add
 
175
196
                                                self.update_timer))
 
176
 
        elif not (flag or self._update_timer_callback_tag is None):
 
 
197
        elif old and self._update_timer_callback_lock == 0:
 
177
198
            gobject.source_remove(self._update_timer_callback_tag)
 
178
199
            self._update_timer_callback_tag = None
 
180
201
    def checker_completed(self, exitstatus, condition, command):
 
181
202
        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)
 
185
215
        if os.WIFEXITED(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)))
 
 
216
            self.logger('Checker for client %s (command "%s")'
 
 
217
                        ' failed with exit code %s'
 
 
218
                        % (self.properties["Name"], command,
 
 
219
                           os.WEXITSTATUS(condition)))
 
190
220
        elif os.WIFSIGNALED(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)))
 
 
221
            self.logger('Checker for client %s (command "%s")'
 
 
222
                        ' was killed by signal %s'
 
 
223
                        % (self.properties["Name"], command,
 
 
224
                           os.WTERMSIG(condition)))
 
195
225
        elif os.WCOREDUMP(condition):
 
196
 
            self.logger('Checker for client {0} (command "{1}")'
 
 
226
            self.logger('Checker for client %s (command "%s")'
 
198
 
                        .format(self.properties["Name"], command))
 
 
228
                        % (self.properties["Name"], command))
 
200
 
            self.logger('Checker for client {0} completed'
 
202
 
                        .format(self.properties["Name"]))
 
 
230
            self.logger('Checker for client %s completed'
 
205
234
    def checker_started(self, 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"],
 
 
235
        #self.logger('Client %s started checker "%s"'
 
 
236
        #            % (self.properties["Name"], unicode(command)))
 
213
239
    def got_secret(self):
 
214
 
        self.logger('Client {0} received its secret'
 
215
 
                    .format(self.properties["Name"]))
 
 
240
        self.last_checker_failed = False
 
 
241
        self.logger('Client %s received its secret'
 
 
242
                    % self.properties["Name"])
 
217
244
    def need_approval(self, timeout, default):
 
219
 
            message = 'Client {0} needs approval within {1} seconds'
 
 
246
            message = 'Client %s needs approval within %s seconds'
 
221
 
            message = 'Client {0} will get its secret in {1} seconds'
 
222
 
        self.logger(message.format(self.properties["Name"],
 
 
248
            message = 'Client %s will get its secret in %s seconds'
 
 
250
                    % (self.properties["Name"], timeout/1000))
 
 
251
        self.using_timer(True)
 
225
253
    def rejected(self, reason):
 
226
 
        self.logger('Client {0} was rejected; reason: {1}'
 
227
 
                    .format(self.properties["Name"], reason))
 
 
254
        self.logger('Client %s was rejected; reason: %s'
 
 
255
                    % (self.properties["Name"], reason))
 
229
257
    def selectable(self):
 
230
258
        """Make this a "selectable" widget.
 
 
267
295
            last_approval_request = isoformat_to_datetime(
 
268
296
                self.properties["LastApprovalRequest"])
 
269
297
            if last_approval_request is not None:
 
270
 
                timer = max(timeout - (datetime.datetime.utcnow()
 
271
 
                                       - last_approval_request),
 
272
 
                            datetime.timedelta())
 
 
298
                timer = timeout - (datetime.datetime.utcnow()
 
 
299
                                   - last_approval_request)
 
274
301
                timer = datetime.timedelta()
 
275
302
            if self.properties["ApprovedByDefault"]:
 
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())
 
 
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)
 
291
316
            message = ('A checker has failed! Time until client'
 
292
 
                       ' gets disabled: {0}'
 
293
 
                       .format(str(timer).rsplit(".", 1)[0]))
 
294
 
            self.using_timer(True)
 
 
318
                           % unicode(timer).rsplit(".", 1)[0])
 
296
320
            message = "enabled"
 
297
 
            self.using_timer(False)
 
298
 
        self._text = "{0}{1}".format(base, message)
 
 
321
        self._text = "%s%s" % (base, message)
 
300
323
        if not urwid.supports_unicode():
 
301
324
            self._text = self._text.encode("ascii", "replace")
 
302
325
        textlist = [("normal", self._text)]
 
 
341
359
        This overrides the method from urwid.FlowWidget"""
 
343
 
            self.proxy.Enable(dbus_interface = client_interface,
 
 
361
            self.proxy.Enable(dbus_interface = client_interface)
 
346
 
            self.proxy.Disable(dbus_interface = client_interface,
 
 
363
            self.proxy.Disable(dbus_interface = client_interface)
 
349
365
            self.proxy.Approve(dbus.Boolean(True, variant_level=1),
 
350
 
                               dbus_interface = client_interface,
 
 
366
                               dbus_interface = client_interface)
 
353
368
            self.proxy.Approve(dbus.Boolean(False, variant_level=1),
 
354
 
                                  dbus_interface = client_interface,
 
 
369
                                  dbus_interface = client_interface)
 
356
370
        elif key == "R" or key == "_" or key == "ctrl k":
 
357
371
            self.server_proxy_object.RemoveClient(self.proxy
 
361
 
            self.proxy.StartChecker(dbus_interface = client_interface,
 
 
374
            self.proxy.StartChecker(dbus_interface = client_interface)
 
364
 
            self.proxy.StopChecker(dbus_interface = client_interface,
 
 
376
            self.proxy.StopChecker(dbus_interface = client_interface)
 
367
 
            self.proxy.CheckedOK(dbus_interface = client_interface,
 
 
378
            self.proxy.CheckedOK(dbus_interface = client_interface)
 
370
380
#         elif key == "p" or key == "=":
 
371
381
#             self.proxy.pause()
 
 
413
424
                 "default", "default", None),
 
415
 
                 "bold", "default", "bold"),
 
 
426
                 "default", "default", "bold"),
 
416
427
                ("underline-blink",
 
417
 
                 "underline,blink", "default", "underline,blink"),
 
 
428
                 "default", "default", "underline"),
 
419
 
                 "standout", "default", "standout"),
 
 
430
                 "default", "default", "standout"),
 
420
431
                ("bold-underline-blink",
 
421
 
                 "bold,underline,blink", "default", "bold,underline,blink"),
 
 
432
                 "default", "default", ("bold", "underline")),
 
422
433
                ("bold-standout",
 
423
 
                 "bold,standout", "default", "bold,standout"),
 
 
434
                 "default", "default", ("bold", "standout")),
 
424
435
                ("underline-blink-standout",
 
425
 
                 "underline,blink,standout", "default",
 
426
 
                 "underline,blink,standout"),
 
 
436
                 "default", "default", ("underline", "standout")),
 
427
437
                ("bold-underline-blink-standout",
 
428
 
                 "bold,underline,blink,standout", "default",
 
429
 
                 "bold,underline,blink,standout"),
 
 
438
                 "default", "default", ("bold", "underline",
 
432
442
        if urwid.supports_unicode():
 
 
465
475
        self.busname = domain + '.Mandos'
 
466
476
        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,
 
468
520
    def client_not_found(self, fingerprint, address):
 
469
 
        self.log_message("Client with address {0} and fingerprint"
 
470
 
                         " {1} could not be found"
 
471
 
                         .format(address, fingerprint))
 
 
521
        self.log_message(("Client with address %s and fingerprint %s"
 
 
522
                          " could not be found" % (address,
 
473
525
    def rebuild(self):
 
474
526
        """This rebuilds the User Interface.
 
 
571
626
        """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,
 
619
628
        self._input_callback_tag = (gobject.io_add_watch
 
620
629
                                    (sys.stdin.fileno(),