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