83
83
    properties and calls a hook function when any of them are
 
86
 
    def __init__(self, proxy_object=None, *args, **kwargs):
 
 
86
    def __init__(self, proxy_object=None, properties=None, **kwargs):
 
87
87
        self.proxy = proxy_object # Mandos Client proxy object
 
89
 
        self.properties = dict()
 
 
88
        self.properties = dict() if properties is None else properties
 
90
89
        self.property_changed_match = (
 
91
90
            self.proxy.connect_to_signal("PropertyChanged",
 
92
 
                                         self.property_changed,
 
 
91
                                         self._property_changed,
 
96
 
        self.properties.update(
 
97
 
            self.proxy.GetAll(client_interface,
 
98
 
                              dbus_interface = dbus.PROPERTIES_IFACE))
 
100
 
        #XXX This breaks good super behaviour
 
101
 
#        super(MandosClientPropertyCache, self).__init__(
 
 
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)
 
104
107
    def property_changed(self, property=None, value=None):
 
105
108
        """This is called whenever we get a PropertyChanged signal
 
 
130
131
        self.logger = logger
 
132
133
        self._update_timer_callback_tag = None
 
133
 
        self._update_timer_callback_lock = 0
 
134
 
        self.last_checker_failed = False
 
136
135
        # The widget shown normally
 
137
136
        self._text_widget = urwid.Text("")
 
138
137
        # The widget shown when we have focus
 
139
138
        self._focus_text_widget = urwid.Text("")
 
140
 
        super(MandosClientWidget, self).__init__(
 
141
 
            update_hook=update_hook, delete_hook=delete_hook,
 
 
139
        super(MandosClientWidget, self).__init__(**kwargs)
 
144
141
        self.opened = False
 
146
 
        last_checked_ok = isoformat_to_datetime(self.properties
 
148
 
        if last_checked_ok is None:
 
149
 
            self.last_checker_failed = True
 
151
 
            self.last_checker_failed = ((datetime.datetime.utcnow()
 
158
 
        if self.last_checker_failed:
 
159
 
            self.using_timer(True)
 
161
 
        if self.need_approval:
 
162
 
            self.using_timer(True)
 
164
143
        self.match_objects = (
 
165
144
            self.proxy.connect_to_signal("CheckerCompleted",
 
166
145
                                         self.checker_completed,
 
 
183
162
                                         client_interface,
 
184
163
                                         byte_arrays=True))
 
185
 
        #self.logger('Created client %s' % (self.properties["Name"]))
 
 
164
        self.logger('Created client {0}'
 
 
165
                    .format(self.properties["Name"]), level=0)
 
187
 
    def property_changed(self, property=None, value=None):
 
188
 
        super(self, MandosClientWidget).property_changed(property,
 
190
 
        if property == "ApprovalPending":
 
191
 
            using_timer(bool(value))
 
193
167
    def using_timer(self, flag):
 
194
168
        """Call this method with True or False when timer should be
 
195
169
        activated or deactivated.
 
197
 
        old = self._update_timer_callback_lock
 
199
 
            self._update_timer_callback_lock += 1
 
201
 
            self._update_timer_callback_lock -= 1
 
202
 
        if old == 0 and self._update_timer_callback_lock:
 
 
171
        if flag and self._update_timer_callback_tag is None:
 
203
172
            # Will update the shown timer value every second
 
204
173
            self._update_timer_callback_tag = (gobject.timeout_add
 
206
175
                                                self.update_timer))
 
207
 
        elif old and self._update_timer_callback_lock == 0:
 
 
176
        elif not (flag or self._update_timer_callback_tag is None):
 
208
177
            gobject.source_remove(self._update_timer_callback_tag)
 
209
178
            self._update_timer_callback_tag = None
 
211
180
    def checker_completed(self, exitstatus, condition, command):
 
212
181
        if exitstatus == 0:
 
213
 
            if self.last_checker_failed:
 
214
 
                self.last_checker_failed = False
 
215
 
                self.using_timer(False)
 
216
 
            #self.logger('Checker for client %s (command "%s")'
 
218
 
            #            % (self.properties["Name"], command))
 
 
182
            self.logger('Checker for client {0} (command "{1}")'
 
 
183
                        ' succeeded'.format(self.properties["Name"],
 
222
 
        if not self.last_checker_failed:
 
223
 
            self.last_checker_failed = True
 
224
 
            self.using_timer(True)
 
225
188
        if os.WIFEXITED(condition):
 
226
 
            self.logger('Checker for client %s (command "%s")'
 
227
 
                        ' failed with exit code %s'
 
228
 
                        % (self.properties["Name"], command,
 
229
 
                           os.WEXITSTATUS(condition)))
 
 
189
            self.logger('Checker for client {0} (command "{1}")'
 
 
190
                        ' failed with exit code {2}'
 
 
191
                        .format(self.properties["Name"], command,
 
 
192
                                os.WEXITSTATUS(condition)))
 
230
193
        elif os.WIFSIGNALED(condition):
 
231
 
            self.logger('Checker for client %s (command "%s")'
 
232
 
                        ' was killed by signal %s'
 
233
 
                        % (self.properties["Name"], command,
 
234
 
                           os.WTERMSIG(condition)))
 
 
194
            self.logger('Checker for client {0} (command "{1}") was'
 
 
195
                        ' killed by signal {2}'
 
 
196
                        .format(self.properties["Name"], command,
 
 
197
                                os.WTERMSIG(condition)))
 
235
198
        elif os.WCOREDUMP(condition):
 
236
 
            self.logger('Checker for client %s (command "%s")'
 
 
199
            self.logger('Checker for client {0} (command "{1}")'
 
238
 
                        % (self.properties["Name"], command))
 
 
201
                        .format(self.properties["Name"], command))
 
240
 
            self.logger('Checker for client %s completed'
 
 
203
            self.logger('Checker for client {0} completed'
 
 
205
                        .format(self.properties["Name"]))
 
244
208
    def checker_started(self, command):
 
245
 
        """Server signals that a checker started. This could be useful
 
246
 
           to log in the future. """
 
247
 
        #self.logger('Client %s started checker "%s"'
 
248
 
        #            % (self.properties["Name"], unicode(command)))
 
 
209
        """Server signals that a checker started."""
 
 
210
        self.logger('Client {0} started checker "{1}"'
 
 
211
                    .format(self.properties["Name"],
 
251
214
    def got_secret(self):
 
252
 
        self.last_checker_failed = False
 
253
 
        self.logger('Client %s received its secret'
 
254
 
                    % self.properties["Name"])
 
 
215
        self.logger('Client {0} received its secret'
 
 
216
                    .format(self.properties["Name"]))
 
256
218
    def need_approval(self, timeout, default):
 
258
 
            message = 'Client %s needs approval within %s seconds'
 
 
220
            message = 'Client {0} needs approval within {1} seconds'
 
260
 
            message = 'Client %s will get its secret in %s seconds'
 
262
 
                    % (self.properties["Name"], timeout/1000))
 
263
 
        self.using_timer(True)
 
 
222
            message = 'Client {0} will get its secret in {1} seconds'
 
 
223
        self.logger(message.format(self.properties["Name"],
 
265
226
    def rejected(self, reason):
 
266
 
        self.logger('Client %s was rejected; reason: %s'
 
267
 
                    % (self.properties["Name"], reason))
 
 
227
        self.logger('Client {0} was rejected; reason: {1}'
 
 
228
                    .format(self.properties["Name"], reason))
 
269
230
    def selectable(self):
 
270
231
        """Make this a "selectable" widget.
 
 
307
268
            last_approval_request = isoformat_to_datetime(
 
308
269
                self.properties["LastApprovalRequest"])
 
309
270
            if last_approval_request is not None:
 
310
 
                timer = timeout - (datetime.datetime.utcnow()
 
311
 
                                   - last_approval_request)
 
 
271
                timer = max(timeout - (datetime.datetime.utcnow()
 
 
272
                                       - last_approval_request),
 
 
273
                            datetime.timedelta())
 
313
275
                timer = datetime.timedelta()
 
314
276
            if self.properties["ApprovedByDefault"]:
 
315
 
                message = "Approval in %s. (d)eny?"
 
 
277
                message = "Approval in {0}. (d)eny?"
 
317
 
                message = "Denial in %s. (a)pprove?"
 
318
 
            message = message % unicode(timer).rsplit(".", 1)[0]
 
319
 
        elif self.last_checker_failed:
 
320
 
            # When checker has failed, print a timer until client expires
 
 
279
                message = "Denial in {0}. (a)pprove?"
 
 
280
            message = message.format(str(timer).rsplit(".", 1)[0])
 
 
281
            self.using_timer(True)
 
 
282
        elif self.properties["LastCheckerStatus"] != 0:
 
 
283
            # When checker has failed, show timer until client expires
 
321
284
            expires = self.properties["Expires"]
 
322
285
            if expires == "":
 
323
286
                timer = datetime.timedelta(0)
 
325
 
                expires = datetime.datetime.strptime(expires,
 
326
 
                                                     '%Y-%m-%dT%H:%M:%S.%f')
 
327
 
                timer = expires - datetime.datetime.utcnow()
 
 
288
                expires = (datetime.datetime.strptime
 
 
289
                           (expires, '%Y-%m-%dT%H:%M:%S.%f'))
 
 
290
                timer = max(expires - datetime.datetime.utcnow(),
 
 
291
                            datetime.timedelta())
 
328
292
            message = ('A checker has failed! Time until client'
 
330
 
                           % unicode(timer).rsplit(".", 1)[0])
 
 
293
                       ' gets disabled: {0}'
 
 
294
                       .format(str(timer).rsplit(".", 1)[0]))
 
 
295
            self.using_timer(True)
 
332
297
            message = "enabled"
 
333
 
        self._text = "%s%s" % (base, message)
 
 
298
            self.using_timer(False)
 
 
299
        self._text = "{0}{1}".format(base, message)
 
335
301
        if not urwid.supports_unicode():
 
336
302
            self._text = self._text.encode("ascii", "replace")
 
337
303
        textlist = [("normal", self._text)]
 
 
414
 
    def property_changed(self, property=None, value=None,
 
 
380
    def property_changed(self, property=None, **kwargs):
 
416
381
        """Call self.update() if old value is not new value.
 
417
382
        This overrides the method from MandosClientPropertyCache"""
 
418
 
        property_name = unicode(property)
 
 
383
        property_name = str(property)
 
419
384
        old_value = self.properties.get(property_name)
 
420
385
        super(MandosClientWidget, self).property_changed(
 
421
 
            property=property, value=value, *args, **kwargs)
 
 
386
            property=property, **kwargs)
 
422
387
        if self.properties.get(property_name) != old_value:
 
 
449
414
                 "default", "default", None),
 
451
 
                 "default", "default", "bold"),
 
 
416
                 "bold", "default", "bold"),
 
452
417
                ("underline-blink",
 
453
 
                 "default", "default", "underline"),
 
 
418
                 "underline,blink", "default", "underline,blink"),
 
455
 
                 "default", "default", "standout"),
 
 
420
                 "standout", "default", "standout"),
 
456
421
                ("bold-underline-blink",
 
457
 
                 "default", "default", ("bold", "underline")),
 
 
422
                 "bold,underline,blink", "default", "bold,underline,blink"),
 
458
423
                ("bold-standout",
 
459
 
                 "default", "default", ("bold", "standout")),
 
 
424
                 "bold,standout", "default", "bold,standout"),
 
460
425
                ("underline-blink-standout",
 
461
 
                 "default", "default", ("underline", "standout")),
 
 
426
                 "underline,blink,standout", "default",
 
 
427
                 "underline,blink,standout"),
 
462
428
                ("bold-underline-blink-standout",
 
463
 
                 "default", "default", ("bold", "underline",
 
 
429
                 "bold,underline,blink,standout", "default",
 
 
430
                 "bold,underline,blink,standout"),
 
467
433
        if urwid.supports_unicode():
 
 
521
489
            self.uilist.append(self.logbox)
 
522
490
        self.topwidget = urwid.Pile(self.uilist)
 
524
 
    def log_message(self, message):
 
 
492
    def log_message(self, message, level=1):
 
 
493
        """Log message formatted with timestamp"""
 
 
494
        if level < self.log_level:
 
525
496
        timestamp = datetime.datetime.now().isoformat()
 
526
 
        self.log_message_raw(timestamp + ": " + message)
 
 
497
        self.log_message_raw("{0}: {1}".format(timestamp, message),
 
528
 
    def log_message_raw(self, markup):
 
 
500
    def log_message_raw(self, markup, level=1):
 
529
501
        """Add a log message to the log buffer."""
 
 
502
        if level < self.log_level:
 
530
504
        self.log.append(urwid.Text(markup, wrap=self.log_wrap))
 
531
505
        if (self.max_log_length
 
532
506
            and len(self.log) > self.max_log_length):