242
106
    max_renames: integer; maximum number of renames
 
243
107
    rename_count: integer; counter so we only rename after collisions
 
244
108
                  a sensible number of times
 
245
 
    group: D-Bus Entry Group
 
247
 
    bus: dbus.SystemBus()
 
250
110
    def __init__(self, interface = avahi.IF_UNSPEC, name = None,
 
251
 
                 servicetype = None, port = None, TXT = None,
 
252
 
                 domain = "", host = "", max_renames = 32768,
 
253
 
                 protocol = avahi.PROTO_UNSPEC, bus = None):
 
 
111
                 type = None, port = None, TXT = None, domain = "",
 
 
112
                 host = "", max_renames = 32768):
 
254
113
        self.interface = interface
 
256
 
        self.type = servicetype
 
258
 
        self.TXT = TXT if TXT is not None else []
 
259
121
        self.domain = domain
 
261
123
        self.rename_count = 0
 
262
124
        self.max_renames = max_renames
 
263
 
        self.protocol = protocol
 
264
 
        self.group = None       # our entry group
 
267
 
        self.entry_group_state_changed_match = None
 
269
125
    def rename(self):
 
270
126
        """Derived from the Avahi example code"""
 
271
127
        if self.rename_count >= self.max_renames:
 
272
 
            logger.critical("No suitable Zeroconf service name found"
 
273
 
                            " after %i retries, exiting.",
 
 
128
            logger.critical(u"No suitable Zeroconf service name found"
 
 
129
                            u" after %i retries, exiting.",
 
275
131
            raise AvahiServiceError("Too many renames")
 
276
 
        self.name = unicode(self.server
 
277
 
                            .GetAlternativeServiceName(self.name))
 
278
 
        logger.info("Changing Zeroconf service name to %r ...",
 
 
132
        self.name = server.GetAlternativeServiceName(self.name)
 
 
133
        logger.info(u"Changing Zeroconf service name to %r ...",
 
 
135
        syslogger.setFormatter(logging.Formatter\
 
 
136
                               ('Mandos (%s): %%(levelname)s:'
 
 
137
                               ' %%(message)s' % self.name))
 
283
 
        except dbus.exceptions.DBusException as error:
 
284
 
            logger.critical("D-Bus Exception", exc_info=error)
 
287
140
        self.rename_count += 1
 
289
141
    def remove(self):
 
290
142
        """Derived from the Avahi example code"""
 
291
 
        if self.entry_group_state_changed_match is not None:
 
292
 
            self.entry_group_state_changed_match.remove()
 
293
 
            self.entry_group_state_changed_match = None
 
294
 
        if self.group is not None:
 
 
143
        if group is not None:
 
298
146
        """Derived from the Avahi example code"""
 
300
 
        if self.group is None:
 
301
 
            self.group = dbus.Interface(
 
302
 
                self.bus.get_object(avahi.DBUS_NAME,
 
303
 
                                    self.server.EntryGroupNew()),
 
304
 
                avahi.DBUS_INTERFACE_ENTRY_GROUP)
 
305
 
        self.entry_group_state_changed_match = (
 
306
 
            self.group.connect_to_signal(
 
307
 
                'StateChanged', self.entry_group_state_changed))
 
308
 
        logger.debug("Adding Zeroconf service '%s' of type '%s' ...",
 
309
 
                     self.name, self.type)
 
310
 
        self.group.AddService(
 
313
 
            dbus.UInt32(0),     # flags
 
314
 
            self.name, self.type,
 
315
 
            self.domain, self.host,
 
316
 
            dbus.UInt16(self.port),
 
317
 
            avahi.string_array_to_txt_array(self.TXT))
 
320
 
    def entry_group_state_changed(self, state, error):
 
321
 
        """Derived from the Avahi example code"""
 
322
 
        logger.debug("Avahi entry group state change: %i", state)
 
324
 
        if state == avahi.ENTRY_GROUP_ESTABLISHED:
 
325
 
            logger.debug("Zeroconf service established.")
 
326
 
        elif state == avahi.ENTRY_GROUP_COLLISION:
 
327
 
            logger.info("Zeroconf service name collision.")
 
329
 
        elif state == avahi.ENTRY_GROUP_FAILURE:
 
330
 
            logger.critical("Avahi: Error in group state changed %s",
 
332
 
            raise AvahiGroupError("State changed: {0!s}"
 
336
 
        """Derived from the Avahi example code"""
 
337
 
        if self.group is not None:
 
340
 
            except (dbus.exceptions.UnknownMethodException,
 
341
 
                    dbus.exceptions.DBusException):
 
346
 
    def server_state_changed(self, state, error=None):
 
347
 
        """Derived from the Avahi example code"""
 
348
 
        logger.debug("Avahi server state change: %i", state)
 
349
 
        bad_states = { avahi.SERVER_INVALID:
 
350
 
                           "Zeroconf server invalid",
 
351
 
                       avahi.SERVER_REGISTERING: None,
 
352
 
                       avahi.SERVER_COLLISION:
 
353
 
                           "Zeroconf server name collision",
 
354
 
                       avahi.SERVER_FAILURE:
 
355
 
                           "Zeroconf server failure" }
 
356
 
        if state in bad_states:
 
357
 
            if bad_states[state] is not None:
 
359
 
                    logger.error(bad_states[state])
 
361
 
                    logger.error(bad_states[state] + ": %r", error)
 
363
 
        elif state == avahi.SERVER_RUNNING:
 
367
 
                logger.debug("Unknown state: %r", state)
 
369
 
                logger.debug("Unknown state: %r: %r", state, error)
 
372
 
        """Derived from the Avahi example code"""
 
373
 
        if self.server is None:
 
374
 
            self.server = dbus.Interface(
 
375
 
                self.bus.get_object(avahi.DBUS_NAME,
 
376
 
                                    avahi.DBUS_PATH_SERVER,
 
377
 
                                    follow_name_owner_changes=True),
 
378
 
                avahi.DBUS_INTERFACE_SERVER)
 
379
 
        self.server.connect_to_signal("StateChanged",
 
380
 
                                 self.server_state_changed)
 
381
 
        self.server_state_changed(self.server.GetState())
 
384
 
class AvahiServiceToSyslog(AvahiService):
 
386
 
        """Add the new name to the syslog messages"""
 
387
 
        ret = AvahiService.rename(self)
 
388
 
        syslogger.setFormatter(logging.Formatter
 
389
 
                               ('Mandos ({0}) [%(process)d]:'
 
390
 
                                ' %(levelname)s: %(message)s'
 
395
 
def timedelta_to_milliseconds(td):
 
396
 
    "Convert a datetime.timedelta() to milliseconds"
 
397
 
    return ((td.days * 24 * 60 * 60 * 1000)
 
398
 
            + (td.seconds * 1000)
 
399
 
            + (td.microseconds // 1000))
 
 
149
            group = dbus.Interface\
 
 
150
                    (bus.get_object(avahi.DBUS_NAME,
 
 
151
                                    server.EntryGroupNew()),
 
 
152
                     avahi.DBUS_INTERFACE_ENTRY_GROUP)
 
 
153
            group.connect_to_signal('StateChanged',
 
 
154
                                    entry_group_state_changed)
 
 
155
        logger.debug(u"Adding Zeroconf service '%s' of type '%s' ...",
 
 
156
                     service.name, service.type)
 
 
158
                self.interface,         # interface
 
 
159
                avahi.PROTO_INET6,      # protocol
 
 
160
                dbus.UInt32(0),         # flags
 
 
161
                self.name, self.type,
 
 
162
                self.domain, self.host,
 
 
163
                dbus.UInt16(self.port),
 
 
164
                avahi.string_array_to_txt_array(self.TXT))
 
 
167
# From the Avahi example code:
 
 
168
group = None                            # our entry group
 
 
169
# End of Avahi example code
 
402
172
class Client(object):
 
403
173
    """A representation of a client host served by this server.
 
406
 
    approved:   bool(); 'None' if not yet approved/disapproved
 
407
 
    approval_delay: datetime.timedelta(); Time to wait for approval
 
408
 
    approval_duration: datetime.timedelta(); Duration of one approval
 
409
 
    checker:    subprocess.Popen(); a running checker process used
 
410
 
                                    to see if the client lives.
 
411
 
                                    'None' if no process is running.
 
412
 
    checker_callback_tag: a gobject event source tag, or None
 
413
 
    checker_command: string; External command which is run to check
 
414
 
                     if client lives.  %() expansions are done at
 
 
175
    name:      string; from the config file, used in log messages
 
 
176
    fingerprint: string (40 or 32 hexadecimal digits); used to
 
 
177
                 uniquely identify the client
 
 
178
    secret:    bytestring; sent verbatim (over TLS) to client
 
 
179
    host:      string; available for use by the checker command
 
 
180
    created:   datetime.datetime(); object creation, not client host
 
 
181
    last_checked_ok: datetime.datetime() or None if not yet checked OK
 
 
182
    timeout:   datetime.timedelta(); How long from last_checked_ok
 
 
183
                                     until this client is invalid
 
 
184
    interval:  datetime.timedelta(); How often to start a new checker
 
 
185
    stop_hook: If set, called by stop() as stop_hook(self)
 
 
186
    checker:   subprocess.Popen(); a running checker process used
 
 
187
                                   to see if the client lives.
 
 
188
                                   'None' if no process is running.
 
 
189
    checker_initiator_tag: a gobject event source tag, or None
 
 
190
    stop_initiator_tag:    - '' -
 
 
191
    checker_callback_tag:  - '' -
 
 
192
    checker_command: string; External command which is run to check if
 
 
193
                     client lives.  %() expansions are done at
 
415
194
                     runtime with vars(self) as dict, so that for
 
416
195
                     instance %(name)s can be used in the command.
 
417
 
    checker_initiator_tag: a gobject event source tag, or None
 
418
 
    created:    datetime.datetime(); (UTC) object creation
 
419
 
    client_structure: Object describing what attributes a client has
 
420
 
                      and is used for storing the client at exit
 
421
 
    current_checker_command: string; current running checker_command
 
422
 
    disable_initiator_tag: a gobject event source tag, or None
 
424
 
    fingerprint: string (40 or 32 hexadecimal digits); used to
 
425
 
                 uniquely identify the client
 
426
 
    host:       string; available for use by the checker command
 
427
 
    interval:   datetime.timedelta(); How often to start a new checker
 
428
 
    last_approval_request: datetime.datetime(); (UTC) or None
 
429
 
    last_checked_ok: datetime.datetime(); (UTC) or None
 
430
 
    last_checker_status: integer between 0 and 255 reflecting exit
 
431
 
                         status of last checker. -1 reflects crashed
 
432
 
                         checker, -2 means no checker completed yet.
 
433
 
    last_enabled: datetime.datetime(); (UTC) or None
 
434
 
    name:       string; from the config file, used in log messages and
 
436
 
    secret:     bytestring; sent verbatim (over TLS) to client
 
437
 
    timeout:    datetime.timedelta(); How long from last_checked_ok
 
438
 
                                      until this client is disabled
 
439
 
    extended_timeout:   extra long timeout when secret has been sent
 
440
 
    runtime_expansions: Allowed attributes for runtime expansion.
 
441
 
    expires:    datetime.datetime(); time (UTC) when a client will be
 
 
197
    _timeout: Real variable for 'timeout'
 
 
198
    _interval: Real variable for 'interval'
 
 
199
    _timeout_milliseconds: Used when calling gobject.timeout_add()
 
 
200
    _interval_milliseconds: - '' -
 
445
 
    runtime_expansions = ("approval_delay", "approval_duration",
 
446
 
                          "created", "enabled", "expires",
 
447
 
                          "fingerprint", "host", "interval",
 
448
 
                          "last_approval_request", "last_checked_ok",
 
449
 
                          "last_enabled", "name", "timeout")
 
450
 
    client_defaults = { "timeout": "PT5M",
 
451
 
                        "extended_timeout": "PT15M",
 
453
 
                        "checker": "fping -q -- %%(host)s",
 
455
 
                        "approval_delay": "PT0S",
 
456
 
                        "approval_duration": "PT1S",
 
457
 
                        "approved_by_default": "True",
 
461
 
    def timeout_milliseconds(self):
 
462
 
        "Return the 'timeout' attribute in milliseconds"
 
463
 
        return timedelta_to_milliseconds(self.timeout)
 
465
 
    def extended_timeout_milliseconds(self):
 
466
 
        "Return the 'extended_timeout' attribute in milliseconds"
 
467
 
        return timedelta_to_milliseconds(self.extended_timeout)
 
469
 
    def interval_milliseconds(self):
 
470
 
        "Return the 'interval' attribute in milliseconds"
 
471
 
        return timedelta_to_milliseconds(self.interval)
 
473
 
    def approval_delay_milliseconds(self):
 
474
 
        return timedelta_to_milliseconds(self.approval_delay)
 
477
 
    def config_parser(config):
 
478
 
        """Construct a new dict of client settings of this form:
 
479
 
        { client_name: {setting_name: value, ...}, ...}
 
480
 
        with exceptions for any special settings as defined above.
 
481
 
        NOTE: Must be a pure function. Must return the same result
 
482
 
        value given the same arguments.
 
485
 
        for client_name in config.sections():
 
486
 
            section = dict(config.items(client_name))
 
487
 
            client = settings[client_name] = {}
 
489
 
            client["host"] = section["host"]
 
490
 
            # Reformat values from string types to Python types
 
491
 
            client["approved_by_default"] = config.getboolean(
 
492
 
                client_name, "approved_by_default")
 
493
 
            client["enabled"] = config.getboolean(client_name,
 
496
 
            client["fingerprint"] = (section["fingerprint"].upper()
 
498
 
            if "secret" in section:
 
499
 
                client["secret"] = section["secret"].decode("base64")
 
500
 
            elif "secfile" in section:
 
501
 
                with open(os.path.expanduser(os.path.expandvars
 
502
 
                                             (section["secfile"])),
 
504
 
                    client["secret"] = secfile.read()
 
506
 
                raise TypeError("No secret or secfile for section {0}"
 
508
 
            client["timeout"] = string_to_delta(section["timeout"])
 
509
 
            client["extended_timeout"] = string_to_delta(
 
510
 
                section["extended_timeout"])
 
511
 
            client["interval"] = string_to_delta(section["interval"])
 
512
 
            client["approval_delay"] = string_to_delta(
 
513
 
                section["approval_delay"])
 
514
 
            client["approval_duration"] = string_to_delta(
 
515
 
                section["approval_duration"])
 
516
 
            client["checker_command"] = section["checker"]
 
517
 
            client["last_approval_request"] = None
 
518
 
            client["last_checked_ok"] = None
 
519
 
            client["last_checker_status"] = -2
 
523
 
    def __init__(self, settings, name = None):
 
 
202
    def _set_timeout(self, timeout):
 
 
203
        "Setter function for 'timeout' attribute"
 
 
204
        self._timeout = timeout
 
 
205
        self._timeout_milliseconds = ((self.timeout.days
 
 
206
                                       * 24 * 60 * 60 * 1000)
 
 
207
                                      + (self.timeout.seconds * 1000)
 
 
208
                                      + (self.timeout.microseconds
 
 
210
    timeout = property(lambda self: self._timeout,
 
 
213
    def _set_interval(self, interval):
 
 
214
        "Setter function for 'interval' attribute"
 
 
215
        self._interval = interval
 
 
216
        self._interval_milliseconds = ((self.interval.days
 
 
217
                                        * 24 * 60 * 60 * 1000)
 
 
218
                                       + (self.interval.seconds
 
 
220
                                       + (self.interval.microseconds
 
 
222
    interval = property(lambda self: self._interval,
 
 
225
    def __init__(self, name = None, stop_hook=None, config={}):
 
 
226
        """Note: the 'checker' key in 'config' sets the
 
 
227
        'checker_command' attribute and *not* the 'checker'
 
525
 
        # adding all client settings
 
526
 
        for setting, value in settings.iteritems():
 
527
 
            setattr(self, setting, value)
 
530
 
            if not hasattr(self, "last_enabled"):
 
531
 
                self.last_enabled = datetime.datetime.utcnow()
 
532
 
            if not hasattr(self, "expires"):
 
533
 
                self.expires = (datetime.datetime.utcnow()
 
536
 
            self.last_enabled = None
 
539
 
        logger.debug("Creating client %r", self.name)
 
 
230
        logger.debug(u"Creating client %r", self.name)
 
540
231
        # Uppercase and remove spaces from fingerprint for later
 
541
232
        # comparison purposes with return value from the fingerprint()
 
543
 
        logger.debug("  Fingerprint: %s", self.fingerprint)
 
544
 
        self.created = settings.get("created",
 
545
 
                                    datetime.datetime.utcnow())
 
547
 
        # attributes specific for this server instance
 
 
234
        self.fingerprint = config["fingerprint"].upper()\
 
 
236
        logger.debug(u"  Fingerprint: %s", self.fingerprint)
 
 
237
        if "secret" in config:
 
 
238
            self.secret = config["secret"].decode(u"base64")
 
 
239
        elif "secfile" in config:
 
 
240
            sf = open(config["secfile"])
 
 
241
            self.secret = sf.read()
 
 
244
            raise TypeError(u"No secret or secfile for client %s"
 
 
246
        self.host = config.get("host", "")
 
 
247
        self.created = datetime.datetime.now()
 
 
248
        self.last_checked_ok = None
 
 
249
        self.timeout = string_to_delta(config["timeout"])
 
 
250
        self.interval = string_to_delta(config["interval"])
 
 
251
        self.stop_hook = stop_hook
 
548
252
        self.checker = None
 
549
253
        self.checker_initiator_tag = None
 
550
 
        self.disable_initiator_tag = None
 
 
254
        self.stop_initiator_tag = None
 
551
255
        self.checker_callback_tag = None
 
552
 
        self.current_checker_command = None
 
554
 
        self.approvals_pending = 0
 
555
 
        self.changedstate = (multiprocessing_manager
 
556
 
                             .Condition(multiprocessing_manager
 
558
 
        self.client_structure = [attr for attr in
 
559
 
                                 self.__dict__.iterkeys()
 
560
 
                                 if not attr.startswith("_")]
 
561
 
        self.client_structure.append("client_structure")
 
563
 
        for name, t in inspect.getmembers(type(self),
 
567
 
            if not name.startswith("_"):
 
568
 
                self.client_structure.append(name)
 
570
 
    # Send notice to process children that client state has changed
 
571
 
    def send_changedstate(self):
 
572
 
        with self.changedstate:
 
573
 
            self.changedstate.notify_all()
 
 
256
        self.check_command = config["checker"]
 
576
258
        """Start this client's checker and timeout hooks"""
 
577
 
        if getattr(self, "enabled", False):
 
580
 
        self.expires = datetime.datetime.utcnow() + self.timeout
 
582
 
        self.last_enabled = datetime.datetime.utcnow()
 
584
 
        self.send_changedstate()
 
586
 
    def disable(self, quiet=True):
 
587
 
        """Disable this client."""
 
588
 
        if not getattr(self, "enabled", False):
 
591
 
            logger.info("Disabling client %s", self.name)
 
592
 
        if getattr(self, "disable_initiator_tag", None) is not None:
 
593
 
            gobject.source_remove(self.disable_initiator_tag)
 
594
 
            self.disable_initiator_tag = None
 
596
 
        if getattr(self, "checker_initiator_tag", None) is not None:
 
597
 
            gobject.source_remove(self.checker_initiator_tag)
 
598
 
            self.checker_initiator_tag = None
 
602
 
            self.send_changedstate()
 
603
 
        # Do not run this again if called by a gobject.timeout_add
 
609
 
    def init_checker(self):
 
610
259
        # Schedule a new checker to be started an 'interval' from now,
 
611
260
        # and every interval from then on.
 
612
 
        if self.checker_initiator_tag is not None:
 
613
 
            gobject.source_remove(self.checker_initiator_tag)
 
614
 
        self.checker_initiator_tag = (gobject.timeout_add
 
615
 
                                      (self.interval_milliseconds(),
 
617
 
        # Schedule a disable() when 'timeout' has passed
 
618
 
        if self.disable_initiator_tag is not None:
 
619
 
            gobject.source_remove(self.disable_initiator_tag)
 
620
 
        self.disable_initiator_tag = (gobject.timeout_add
 
621
 
                                   (self.timeout_milliseconds(),
 
 
261
        self.checker_initiator_tag = gobject.timeout_add\
 
 
262
                                     (self._interval_milliseconds,
 
623
264
        # Also start a new checker *right now*.
 
624
265
        self.start_checker()
 
626
 
    def checker_callback(self, pid, condition, command):
 
 
266
        # Schedule a stop() when 'timeout' has passed
 
 
267
        self.stop_initiator_tag = gobject.timeout_add\
 
 
268
                                  (self._timeout_milliseconds,
 
 
272
        The possibility that a client might be restarted is left open,
 
 
273
        but not currently used."""
 
 
274
        # If this client doesn't have a secret, it is already stopped.
 
 
275
        if hasattr(self, "secret") and self.secret:
 
 
276
            logger.info(u"Stopping client %s", self.name)
 
 
280
        if getattr(self, "stop_initiator_tag", False):
 
 
281
            gobject.source_remove(self.stop_initiator_tag)
 
 
282
            self.stop_initiator_tag = None
 
 
283
        if getattr(self, "checker_initiator_tag", False):
 
 
284
            gobject.source_remove(self.checker_initiator_tag)
 
 
285
            self.checker_initiator_tag = None
 
 
289
        # Do not run this again if called by a gobject.timeout_add
 
 
292
        self.stop_hook = None
 
 
294
    def checker_callback(self, pid, condition):
 
627
295
        """The checker has completed, so take appropriate actions."""
 
 
296
        now = datetime.datetime.now()
 
628
297
        self.checker_callback_tag = None
 
629
298
        self.checker = None
 
630
 
        if os.WIFEXITED(condition):
 
631
 
            self.last_checker_status = os.WEXITSTATUS(condition)
 
632
 
            if self.last_checker_status == 0:
 
633
 
                logger.info("Checker for %(name)s succeeded",
 
637
 
                logger.info("Checker for %(name)s failed",
 
640
 
            self.last_checker_status = -1
 
641
 
            logger.warning("Checker for %(name)s crashed?",
 
 
299
        if os.WIFEXITED(condition) \
 
 
300
               and (os.WEXITSTATUS(condition) == 0):
 
 
301
            logger.info(u"Checker for %(name)s succeeded",
 
 
303
            self.last_checked_ok = now
 
 
304
            gobject.source_remove(self.stop_initiator_tag)
 
 
305
            self.stop_initiator_tag = gobject.timeout_add\
 
 
306
                                      (self._timeout_milliseconds,
 
 
308
        elif not os.WIFEXITED(condition):
 
 
309
            logger.warning(u"Checker for %(name)s crashed?",
 
644
 
    def checked_ok(self):
 
645
 
        """Assert that the client has been seen, alive and well."""
 
646
 
        self.last_checked_ok = datetime.datetime.utcnow()
 
647
 
        self.last_checker_status = 0
 
650
 
    def bump_timeout(self, timeout=None):
 
651
 
        """Bump up the timeout for this client."""
 
653
 
            timeout = self.timeout
 
654
 
        if self.disable_initiator_tag is not None:
 
655
 
            gobject.source_remove(self.disable_initiator_tag)
 
656
 
            self.disable_initiator_tag = None
 
657
 
        if getattr(self, "enabled", False):
 
658
 
            self.disable_initiator_tag = (gobject.timeout_add
 
659
 
                                          (timedelta_to_milliseconds
 
660
 
                                           (timeout), self.disable))
 
661
 
            self.expires = datetime.datetime.utcnow() + timeout
 
663
 
    def need_approval(self):
 
664
 
        self.last_approval_request = datetime.datetime.utcnow()
 
 
312
            logger.info(u"Checker for %(name)s failed",
 
666
314
    def start_checker(self):
 
667
315
        """Start a new checker subprocess if one is not running.
 
669
316
        If a checker already exists, leave it running and do
 
671
318
        # The reason for not killing a running checker is that if we
 
672
 
        # did that, and if a checker (for some reason) started running
 
673
 
        # slowly and taking more than 'interval' time, then the client
 
674
 
        # would inevitably timeout, since no checker would get a
 
675
 
        # chance to run to completion.  If we instead leave running
 
 
319
        # did that, then if a checker (for some reason) started
 
 
320
        # running slowly and taking more than 'interval' time, the
 
 
321
        # client would inevitably timeout, since no checker would get
 
 
322
        # a chance to run to completion.  If we instead leave running
 
676
323
        # checkers alone, the checker would have to take more time
 
677
 
        # than 'timeout' for the client to be disabled, which is as it
 
680
 
        # If a checker exists, make sure it is not a zombie
 
682
 
            pid, status = os.waitpid(self.checker.pid, os.WNOHANG)
 
683
 
        except (AttributeError, OSError) as error:
 
684
 
            if (isinstance(error, OSError)
 
685
 
                and error.errno != errno.ECHILD):
 
689
 
                logger.warning("Checker was a zombie")
 
690
 
                gobject.source_remove(self.checker_callback_tag)
 
691
 
                self.checker_callback(pid, status,
 
692
 
                                      self.current_checker_command)
 
693
 
        # Start a new checker if needed
 
 
324
        # than 'timeout' for the client to be declared invalid, which
 
 
325
        # is as it should be.
 
694
326
        if self.checker is None:
 
695
 
            # Escape attributes for the shell
 
696
 
            escaped_attrs = dict(
 
697
 
                (attr, re.escape(unicode(getattr(self, attr))))
 
699
 
                self.runtime_expansions)
 
701
 
                command = self.checker_command % escaped_attrs
 
702
 
            except TypeError as error:
 
703
 
                logger.error('Could not format string "%s"',
 
704
 
                             self.checker_command, exc_info=error)
 
705
 
                return True # Try again later
 
706
 
            self.current_checker_command = command
 
708
 
                logger.info("Starting checker %r for %s",
 
 
328
                # In case check_command has exactly one % operator
 
 
329
                command = self.check_command % self.host
 
 
331
                # Escape attributes for the shell
 
 
332
                escaped_attrs = dict((key, re.escape(str(val)))
 
 
334
                                     vars(self).iteritems())
 
 
336
                    command = self.check_command % escaped_attrs
 
 
337
                except TypeError, error:
 
 
338
                    logger.error(u'Could not format string "%s":'
 
 
339
                                 u' %s', self.check_command, error)
 
 
340
                    return True # Try again later
 
 
342
                logger.info(u"Starting checker %r for %s",
 
709
343
                            command, self.name)
 
710
344
                # We don't need to redirect stdout and stderr, since
 
711
345
                # in normal mode, that is already done by daemon(),
 
 
737
363
            self.checker_callback_tag = None
 
738
364
        if getattr(self, "checker", None) is None:
 
740
 
        logger.debug("Stopping checker for %(name)s", vars(self))
 
 
366
        logger.debug(u"Stopping checker for %(name)s", vars(self))
 
742
 
            self.checker.terminate()
 
 
368
            os.kill(self.checker.pid, signal.SIGTERM)
 
744
370
            #if self.checker.poll() is None:
 
745
 
            #    self.checker.kill()
 
746
 
        except OSError as error:
 
 
371
            #    os.kill(self.checker.pid, signal.SIGKILL)
 
 
372
        except OSError, error:
 
747
373
            if error.errno != errno.ESRCH: # No such process
 
749
375
        self.checker = None
 
752
 
def dbus_service_property(dbus_interface, signature="v",
 
753
 
                          access="readwrite", byte_arrays=False):
 
754
 
    """Decorators for marking methods of a DBusObjectWithProperties to
 
755
 
    become properties on the D-Bus.
 
757
 
    The decorated method will be called with no arguments by "Get"
 
758
 
    and with one argument by "Set".
 
760
 
    The parameters, where they are supported, are the same as
 
761
 
    dbus.service.method, except there is only "signature", since the
 
762
 
    type from Get() and the type sent to Set() is the same.
 
764
 
    # Encoding deeply encoded byte arrays is not supported yet by the
 
765
 
    # "Set" method, so we fail early here:
 
766
 
    if byte_arrays and signature != "ay":
 
767
 
        raise ValueError("Byte arrays not supported for non-'ay'"
 
768
 
                         " signature {0!r}".format(signature))
 
770
 
        func._dbus_is_property = True
 
771
 
        func._dbus_interface = dbus_interface
 
772
 
        func._dbus_signature = signature
 
773
 
        func._dbus_access = access
 
774
 
        func._dbus_name = func.__name__
 
775
 
        if func._dbus_name.endswith("_dbus_property"):
 
776
 
            func._dbus_name = func._dbus_name[:-14]
 
777
 
        func._dbus_get_args_options = {'byte_arrays': byte_arrays }
 
782
 
def dbus_interface_annotations(dbus_interface):
 
783
 
    """Decorator for marking functions returning interface annotations
 
787
 
    @dbus_interface_annotations("org.example.Interface")
 
788
 
    def _foo(self):  # Function name does not matter
 
789
 
        return {"org.freedesktop.DBus.Deprecated": "true",
 
790
 
                "org.freedesktop.DBus.Property.EmitsChangedSignal":
 
794
 
        func._dbus_is_interface = True
 
795
 
        func._dbus_interface = dbus_interface
 
796
 
        func._dbus_name = dbus_interface
 
801
 
def dbus_annotations(annotations):
 
802
 
    """Decorator to annotate D-Bus methods, signals or properties
 
805
 
    @dbus_service_property("org.example.Interface", signature="b",
 
807
 
    @dbus_annotations({{"org.freedesktop.DBus.Deprecated": "true",
 
808
 
                        "org.freedesktop.DBus.Property."
 
809
 
                        "EmitsChangedSignal": "false"})
 
810
 
    def Property_dbus_property(self):
 
811
 
        return dbus.Boolean(False)
 
814
 
        func._dbus_annotations = annotations
 
819
 
class DBusPropertyException(dbus.exceptions.DBusException):
 
820
 
    """A base class for D-Bus property-related exceptions
 
822
 
    def __unicode__(self):
 
823
 
        return unicode(str(self))
 
826
 
class DBusPropertyAccessException(DBusPropertyException):
 
827
 
    """A property's access permissions disallows an operation.
 
832
 
class DBusPropertyNotFound(DBusPropertyException):
 
833
 
    """An attempt was made to access a non-existing property.
 
838
 
class DBusObjectWithProperties(dbus.service.Object):
 
839
 
    """A D-Bus object with properties.
 
841
 
    Classes inheriting from this can use the dbus_service_property
 
842
 
    decorator to expose methods as D-Bus properties.  It exposes the
 
843
 
    standard Get(), Set(), and GetAll() methods on the D-Bus.
 
847
 
    def _is_dbus_thing(thing):
 
848
 
        """Returns a function testing if an attribute is a D-Bus thing
 
850
 
        If called like _is_dbus_thing("method") it returns a function
 
851
 
        suitable for use as predicate to inspect.getmembers().
 
853
 
        return lambda obj: getattr(obj, "_dbus_is_{0}".format(thing),
 
856
 
    def _get_all_dbus_things(self, thing):
 
857
 
        """Returns a generator of (name, attribute) pairs
 
859
 
        return ((getattr(athing.__get__(self), "_dbus_name",
 
861
 
                 athing.__get__(self))
 
862
 
                for cls in self.__class__.__mro__
 
864
 
                inspect.getmembers(cls,
 
865
 
                                   self._is_dbus_thing(thing)))
 
867
 
    def _get_dbus_property(self, interface_name, property_name):
 
868
 
        """Returns a bound method if one exists which is a D-Bus
 
869
 
        property with the specified name and interface.
 
871
 
        for cls in  self.__class__.__mro__:
 
872
 
            for name, value in (inspect.getmembers
 
874
 
                                 self._is_dbus_thing("property"))):
 
875
 
                if (value._dbus_name == property_name
 
876
 
                    and value._dbus_interface == interface_name):
 
877
 
                    return value.__get__(self)
 
880
 
        raise DBusPropertyNotFound(self.dbus_object_path + ":"
 
881
 
                                   + interface_name + "."
 
884
 
    @dbus.service.method(dbus.PROPERTIES_IFACE, in_signature="ss",
 
886
 
    def Get(self, interface_name, property_name):
 
887
 
        """Standard D-Bus property Get() method, see D-Bus standard.
 
889
 
        prop = self._get_dbus_property(interface_name, property_name)
 
890
 
        if prop._dbus_access == "write":
 
891
 
            raise DBusPropertyAccessException(property_name)
 
893
 
        if not hasattr(value, "variant_level"):
 
895
 
        return type(value)(value, variant_level=value.variant_level+1)
 
897
 
    @dbus.service.method(dbus.PROPERTIES_IFACE, in_signature="ssv")
 
898
 
    def Set(self, interface_name, property_name, value):
 
899
 
        """Standard D-Bus property Set() method, see D-Bus standard.
 
901
 
        prop = self._get_dbus_property(interface_name, property_name)
 
902
 
        if prop._dbus_access == "read":
 
903
 
            raise DBusPropertyAccessException(property_name)
 
904
 
        if prop._dbus_get_args_options["byte_arrays"]:
 
905
 
            # The byte_arrays option is not supported yet on
 
906
 
            # signatures other than "ay".
 
907
 
            if prop._dbus_signature != "ay":
 
909
 
            value = dbus.ByteArray(b''.join(chr(byte)
 
913
 
    @dbus.service.method(dbus.PROPERTIES_IFACE, in_signature="s",
 
914
 
                         out_signature="a{sv}")
 
915
 
    def GetAll(self, interface_name):
 
916
 
        """Standard D-Bus property GetAll() method, see D-Bus
 
919
 
        Note: Will not include properties with access="write".
 
922
 
        for name, prop in self._get_all_dbus_things("property"):
 
924
 
                and interface_name != prop._dbus_interface):
 
925
 
                # Interface non-empty but did not match
 
927
 
            # Ignore write-only properties
 
928
 
            if prop._dbus_access == "write":
 
931
 
            if not hasattr(value, "variant_level"):
 
932
 
                properties[name] = value
 
934
 
            properties[name] = type(value)(value, variant_level=
 
935
 
                                           value.variant_level+1)
 
936
 
        return dbus.Dictionary(properties, signature="sv")
 
938
 
    @dbus.service.method(dbus.INTROSPECTABLE_IFACE,
 
940
 
                         path_keyword='object_path',
 
941
 
                         connection_keyword='connection')
 
942
 
    def Introspect(self, object_path, connection):
 
943
 
        """Overloading of standard D-Bus method.
 
945
 
        Inserts property tags and interface annotation tags.
 
947
 
        xmlstring = dbus.service.Object.Introspect(self, object_path,
 
950
 
            document = xml.dom.minidom.parseString(xmlstring)
 
951
 
            def make_tag(document, name, prop):
 
952
 
                e = document.createElement("property")
 
953
 
                e.setAttribute("name", name)
 
954
 
                e.setAttribute("type", prop._dbus_signature)
 
955
 
                e.setAttribute("access", prop._dbus_access)
 
957
 
            for if_tag in document.getElementsByTagName("interface"):
 
959
 
                for tag in (make_tag(document, name, prop)
 
961
 
                            in self._get_all_dbus_things("property")
 
962
 
                            if prop._dbus_interface
 
963
 
                            == if_tag.getAttribute("name")):
 
964
 
                    if_tag.appendChild(tag)
 
965
 
                # Add annotation tags
 
966
 
                for typ in ("method", "signal", "property"):
 
967
 
                    for tag in if_tag.getElementsByTagName(typ):
 
969
 
                        for name, prop in (self.
 
970
 
                                           _get_all_dbus_things(typ)):
 
971
 
                            if (name == tag.getAttribute("name")
 
972
 
                                and prop._dbus_interface
 
973
 
                                == if_tag.getAttribute("name")):
 
974
 
                                annots.update(getattr
 
978
 
                        for name, value in annots.iteritems():
 
979
 
                            ann_tag = document.createElement(
 
981
 
                            ann_tag.setAttribute("name", name)
 
982
 
                            ann_tag.setAttribute("value", value)
 
983
 
                            tag.appendChild(ann_tag)
 
984
 
                # Add interface annotation tags
 
985
 
                for annotation, value in dict(
 
986
 
                    itertools.chain.from_iterable(
 
987
 
                        annotations().iteritems()
 
988
 
                        for name, annotations in
 
989
 
                        self._get_all_dbus_things("interface")
 
990
 
                        if name == if_tag.getAttribute("name")
 
992
 
                    ann_tag = document.createElement("annotation")
 
993
 
                    ann_tag.setAttribute("name", annotation)
 
994
 
                    ann_tag.setAttribute("value", value)
 
995
 
                    if_tag.appendChild(ann_tag)
 
996
 
                # Add the names to the return values for the
 
997
 
                # "org.freedesktop.DBus.Properties" methods
 
998
 
                if (if_tag.getAttribute("name")
 
999
 
                    == "org.freedesktop.DBus.Properties"):
 
1000
 
                    for cn in if_tag.getElementsByTagName("method"):
 
1001
 
                        if cn.getAttribute("name") == "Get":
 
1002
 
                            for arg in cn.getElementsByTagName("arg"):
 
1003
 
                                if (arg.getAttribute("direction")
 
1005
 
                                    arg.setAttribute("name", "value")
 
1006
 
                        elif cn.getAttribute("name") == "GetAll":
 
1007
 
                            for arg in cn.getElementsByTagName("arg"):
 
1008
 
                                if (arg.getAttribute("direction")
 
1010
 
                                    arg.setAttribute("name", "props")
 
1011
 
            xmlstring = document.toxml("utf-8")
 
1013
 
        except (AttributeError, xml.dom.DOMException,
 
1014
 
                xml.parsers.expat.ExpatError) as error:
 
1015
 
            logger.error("Failed to override Introspection method",
 
1020
 
def datetime_to_dbus(dt, variant_level=0):
 
1021
 
    """Convert a UTC datetime.datetime() to a D-Bus type."""
 
1023
 
        return dbus.String("", variant_level = variant_level)
 
1024
 
    return dbus.String(dt.isoformat(),
 
1025
 
                       variant_level=variant_level)
 
1028
 
def alternate_dbus_interfaces(alt_interface_names, deprecate=True):
 
1029
 
    """A class decorator; applied to a subclass of
 
1030
 
    dbus.service.Object, it will add alternate D-Bus attributes with
 
1031
 
    interface names according to the "alt_interface_names" mapping.
 
1034
 
    @alternate_dbus_interfaces({"org.example.Interface":
 
1035
 
                                    "net.example.AlternateInterface"})
 
1036
 
    class SampleDBusObject(dbus.service.Object):
 
1037
 
        @dbus.service.method("org.example.Interface")
 
1038
 
        def SampleDBusMethod():
 
1041
 
    The above "SampleDBusMethod" on "SampleDBusObject" will be
 
1042
 
    reachable via two interfaces: "org.example.Interface" and
 
1043
 
    "net.example.AlternateInterface", the latter of which will have
 
1044
 
    its D-Bus annotation "org.freedesktop.DBus.Deprecated" set to
 
1045
 
    "true", unless "deprecate" is passed with a False value.
 
1047
 
    This works for methods and signals, and also for D-Bus properties
 
1048
 
    (from DBusObjectWithProperties) and interfaces (from the
 
1049
 
    dbus_interface_annotations decorator).
 
1052
 
        for orig_interface_name, alt_interface_name in (
 
1053
 
            alt_interface_names.iteritems()):
 
1055
 
            interface_names = set()
 
1056
 
            # Go though all attributes of the class
 
1057
 
            for attrname, attribute in inspect.getmembers(cls):
 
1058
 
                # Ignore non-D-Bus attributes, and D-Bus attributes
 
1059
 
                # with the wrong interface name
 
1060
 
                if (not hasattr(attribute, "_dbus_interface")
 
1061
 
                    or not attribute._dbus_interface
 
1062
 
                    .startswith(orig_interface_name)):
 
1064
 
                # Create an alternate D-Bus interface name based on
 
1066
 
                alt_interface = (attribute._dbus_interface
 
1067
 
                                 .replace(orig_interface_name,
 
1068
 
                                          alt_interface_name))
 
1069
 
                interface_names.add(alt_interface)
 
1070
 
                # Is this a D-Bus signal?
 
1071
 
                if getattr(attribute, "_dbus_is_signal", False):
 
1072
 
                    # Extract the original non-method function by
 
1074
 
                    nonmethod_func = (dict(
 
1075
 
                            zip(attribute.func_code.co_freevars,
 
1076
 
                                attribute.__closure__))["func"]
 
1078
 
                    # Create a new, but exactly alike, function
 
1079
 
                    # object, and decorate it to be a new D-Bus signal
 
1080
 
                    # with the alternate D-Bus interface name
 
1081
 
                    new_function = (dbus.service.signal
 
1083
 
                                     attribute._dbus_signature)
 
1084
 
                                    (types.FunctionType(
 
1085
 
                                nonmethod_func.func_code,
 
1086
 
                                nonmethod_func.func_globals,
 
1087
 
                                nonmethod_func.func_name,
 
1088
 
                                nonmethod_func.func_defaults,
 
1089
 
                                nonmethod_func.func_closure)))
 
1090
 
                    # Copy annotations, if any
 
1092
 
                        new_function._dbus_annotations = (
 
1093
 
                            dict(attribute._dbus_annotations))
 
1094
 
                    except AttributeError:
 
1096
 
                    # Define a creator of a function to call both the
 
1097
 
                    # original and alternate functions, so both the
 
1098
 
                    # original and alternate signals gets sent when
 
1099
 
                    # the function is called
 
1100
 
                    def fixscope(func1, func2):
 
1101
 
                        """This function is a scope container to pass
 
1102
 
                        func1 and func2 to the "call_both" function
 
1103
 
                        outside of its arguments"""
 
1104
 
                        def call_both(*args, **kwargs):
 
1105
 
                            """This function will emit two D-Bus
 
1106
 
                            signals by calling func1 and func2"""
 
1107
 
                            func1(*args, **kwargs)
 
1108
 
                            func2(*args, **kwargs)
 
1110
 
                    # Create the "call_both" function and add it to
 
1112
 
                    attr[attrname] = fixscope(attribute, new_function)
 
1113
 
                # Is this a D-Bus method?
 
1114
 
                elif getattr(attribute, "_dbus_is_method", False):
 
1115
 
                    # Create a new, but exactly alike, function
 
1116
 
                    # object.  Decorate it to be a new D-Bus method
 
1117
 
                    # with the alternate D-Bus interface name.  Add it
 
1119
 
                    attr[attrname] = (dbus.service.method
 
1121
 
                                       attribute._dbus_in_signature,
 
1122
 
                                       attribute._dbus_out_signature)
 
1124
 
                                       (attribute.func_code,
 
1125
 
                                        attribute.func_globals,
 
1126
 
                                        attribute.func_name,
 
1127
 
                                        attribute.func_defaults,
 
1128
 
                                        attribute.func_closure)))
 
1129
 
                    # Copy annotations, if any
 
1131
 
                        attr[attrname]._dbus_annotations = (
 
1132
 
                            dict(attribute._dbus_annotations))
 
1133
 
                    except AttributeError:
 
1135
 
                # Is this a D-Bus property?
 
1136
 
                elif getattr(attribute, "_dbus_is_property", False):
 
1137
 
                    # Create a new, but exactly alike, function
 
1138
 
                    # object, and decorate it to be a new D-Bus
 
1139
 
                    # property with the alternate D-Bus interface
 
1140
 
                    # name.  Add it to the class.
 
1141
 
                    attr[attrname] = (dbus_service_property
 
1143
 
                                       attribute._dbus_signature,
 
1144
 
                                       attribute._dbus_access,
 
1146
 
                                       ._dbus_get_args_options
 
1149
 
                                       (attribute.func_code,
 
1150
 
                                        attribute.func_globals,
 
1151
 
                                        attribute.func_name,
 
1152
 
                                        attribute.func_defaults,
 
1153
 
                                        attribute.func_closure)))
 
1154
 
                    # Copy annotations, if any
 
1156
 
                        attr[attrname]._dbus_annotations = (
 
1157
 
                            dict(attribute._dbus_annotations))
 
1158
 
                    except AttributeError:
 
1160
 
                # Is this a D-Bus interface?
 
1161
 
                elif getattr(attribute, "_dbus_is_interface", False):
 
1162
 
                    # Create a new, but exactly alike, function
 
1163
 
                    # object.  Decorate it to be a new D-Bus interface
 
1164
 
                    # with the alternate D-Bus interface name.  Add it
 
1166
 
                    attr[attrname] = (dbus_interface_annotations
 
1169
 
                                       (attribute.func_code,
 
1170
 
                                        attribute.func_globals,
 
1171
 
                                        attribute.func_name,
 
1172
 
                                        attribute.func_defaults,
 
1173
 
                                        attribute.func_closure)))
 
1175
 
                # Deprecate all alternate interfaces
 
1176
 
                iname="_AlternateDBusNames_interface_annotation{0}"
 
1177
 
                for interface_name in interface_names:
 
1178
 
                    @dbus_interface_annotations(interface_name)
 
1180
 
                        return { "org.freedesktop.DBus.Deprecated":
 
1182
 
                    # Find an unused name
 
1183
 
                    for aname in (iname.format(i)
 
1184
 
                                  for i in itertools.count()):
 
1185
 
                        if aname not in attr:
 
1189
 
                # Replace the class with a new subclass of it with
 
1190
 
                # methods, signals, etc. as created above.
 
1191
 
                cls = type(b"{0}Alternate".format(cls.__name__),
 
1197
 
@alternate_dbus_interfaces({"se.recompile.Mandos":
 
1198
 
                                "se.bsnet.fukt.Mandos"})
 
1199
 
class ClientDBus(Client, DBusObjectWithProperties):
 
1200
 
    """A Client class using D-Bus
 
1203
 
    dbus_object_path: dbus.ObjectPath
 
1204
 
    bus: dbus.SystemBus()
 
1207
 
    runtime_expansions = (Client.runtime_expansions
 
1208
 
                          + ("dbus_object_path",))
 
1210
 
    # dbus.service.Object doesn't use super(), so we can't either.
 
1212
 
    def __init__(self, bus = None, *args, **kwargs):
 
1214
 
        Client.__init__(self, *args, **kwargs)
 
1215
 
        # Only now, when this client is initialized, can it show up on
 
1217
 
        client_object_name = unicode(self.name).translate(
 
1218
 
            {ord("."): ord("_"),
 
1219
 
             ord("-"): ord("_")})
 
1220
 
        self.dbus_object_path = (dbus.ObjectPath
 
1221
 
                                 ("/clients/" + client_object_name))
 
1222
 
        DBusObjectWithProperties.__init__(self, self.bus,
 
1223
 
                                          self.dbus_object_path)
 
1225
 
    def notifychangeproperty(transform_func,
 
1226
 
                             dbus_name, type_func=lambda x: x,
 
1228
 
        """ Modify a variable so that it's a property which announces
 
1229
 
        its changes to DBus.
 
1231
 
        transform_fun: Function that takes a value and a variant_level
 
1232
 
                       and transforms it to a D-Bus type.
 
1233
 
        dbus_name: D-Bus name of the variable
 
1234
 
        type_func: Function that transform the value before sending it
 
1235
 
                   to the D-Bus.  Default: no transform
 
1236
 
        variant_level: D-Bus variant level.  Default: 1
 
1238
 
        attrname = "_{0}".format(dbus_name)
 
1239
 
        def setter(self, value):
 
1240
 
            if hasattr(self, "dbus_object_path"):
 
1241
 
                if (not hasattr(self, attrname) or
 
1242
 
                    type_func(getattr(self, attrname, None))
 
1243
 
                    != type_func(value)):
 
1244
 
                    dbus_value = transform_func(type_func(value),
 
1247
 
                    self.PropertyChanged(dbus.String(dbus_name),
 
1249
 
            setattr(self, attrname, value)
 
1251
 
        return property(lambda self: getattr(self, attrname), setter)
 
1253
 
    expires = notifychangeproperty(datetime_to_dbus, "Expires")
 
1254
 
    approvals_pending = notifychangeproperty(dbus.Boolean,
 
1257
 
    enabled = notifychangeproperty(dbus.Boolean, "Enabled")
 
1258
 
    last_enabled = notifychangeproperty(datetime_to_dbus,
 
1260
 
    checker = notifychangeproperty(dbus.Boolean, "CheckerRunning",
 
1261
 
                                   type_func = lambda checker:
 
1262
 
                                       checker is not None)
 
1263
 
    last_checked_ok = notifychangeproperty(datetime_to_dbus,
 
1265
 
    last_checker_status = notifychangeproperty(dbus.Int16,
 
1266
 
                                               "LastCheckerStatus")
 
1267
 
    last_approval_request = notifychangeproperty(
 
1268
 
        datetime_to_dbus, "LastApprovalRequest")
 
1269
 
    approved_by_default = notifychangeproperty(dbus.Boolean,
 
1270
 
                                               "ApprovedByDefault")
 
1271
 
    approval_delay = notifychangeproperty(dbus.UInt64,
 
1274
 
                                          timedelta_to_milliseconds)
 
1275
 
    approval_duration = notifychangeproperty(
 
1276
 
        dbus.UInt64, "ApprovalDuration",
 
1277
 
        type_func = timedelta_to_milliseconds)
 
1278
 
    host = notifychangeproperty(dbus.String, "Host")
 
1279
 
    timeout = notifychangeproperty(dbus.UInt64, "Timeout",
 
1281
 
                                   timedelta_to_milliseconds)
 
1282
 
    extended_timeout = notifychangeproperty(
 
1283
 
        dbus.UInt64, "ExtendedTimeout",
 
1284
 
        type_func = timedelta_to_milliseconds)
 
1285
 
    interval = notifychangeproperty(dbus.UInt64,
 
1288
 
                                    timedelta_to_milliseconds)
 
1289
 
    checker_command = notifychangeproperty(dbus.String, "Checker")
 
1291
 
    del notifychangeproperty
 
1293
 
    def __del__(self, *args, **kwargs):
 
1295
 
            self.remove_from_connection()
 
1298
 
        if hasattr(DBusObjectWithProperties, "__del__"):
 
1299
 
            DBusObjectWithProperties.__del__(self, *args, **kwargs)
 
1300
 
        Client.__del__(self, *args, **kwargs)
 
1302
 
    def checker_callback(self, pid, condition, command,
 
1304
 
        self.checker_callback_tag = None
 
1306
 
        if os.WIFEXITED(condition):
 
1307
 
            exitstatus = os.WEXITSTATUS(condition)
 
1309
 
            self.CheckerCompleted(dbus.Int16(exitstatus),
 
1310
 
                                  dbus.Int64(condition),
 
1311
 
                                  dbus.String(command))
 
1314
 
            self.CheckerCompleted(dbus.Int16(-1),
 
1315
 
                                  dbus.Int64(condition),
 
1316
 
                                  dbus.String(command))
 
1318
 
        return Client.checker_callback(self, pid, condition, command,
 
1321
 
    def start_checker(self, *args, **kwargs):
 
1322
 
        old_checker = self.checker
 
1323
 
        if self.checker is not None:
 
1324
 
            old_checker_pid = self.checker.pid
 
1326
 
            old_checker_pid = None
 
1327
 
        r = Client.start_checker(self, *args, **kwargs)
 
1328
 
        # Only if new checker process was started
 
1329
 
        if (self.checker is not None
 
1330
 
            and old_checker_pid != self.checker.pid):
 
1332
 
            self.CheckerStarted(self.current_checker_command)
 
1335
 
    def _reset_approved(self):
 
1336
 
        self.approved = None
 
1339
 
    def approve(self, value=True):
 
1340
 
        self.approved = value
 
1341
 
        gobject.timeout_add(timedelta_to_milliseconds
 
1342
 
                            (self.approval_duration),
 
1343
 
                            self._reset_approved)
 
1344
 
        self.send_changedstate()
 
1346
 
    ## D-Bus methods, signals & properties
 
1347
 
    _interface = "se.recompile.Mandos.Client"
 
1351
 
    @dbus_interface_annotations(_interface)
 
1353
 
        return { "org.freedesktop.DBus.Property.EmitsChangedSignal":
 
1358
 
    # CheckerCompleted - signal
 
1359
 
    @dbus.service.signal(_interface, signature="nxs")
 
1360
 
    def CheckerCompleted(self, exitcode, waitstatus, command):
 
1364
 
    # CheckerStarted - signal
 
1365
 
    @dbus.service.signal(_interface, signature="s")
 
1366
 
    def CheckerStarted(self, command):
 
1370
 
    # PropertyChanged - signal
 
1371
 
    @dbus.service.signal(_interface, signature="sv")
 
1372
 
    def PropertyChanged(self, property, value):
 
1376
 
    # GotSecret - signal
 
1377
 
    @dbus.service.signal(_interface)
 
1378
 
    def GotSecret(self):
 
1380
 
        Is sent after a successful transfer of secret from the Mandos
 
1381
 
        server to mandos-client
 
1386
 
    @dbus.service.signal(_interface, signature="s")
 
1387
 
    def Rejected(self, reason):
 
1391
 
    # NeedApproval - signal
 
1392
 
    @dbus.service.signal(_interface, signature="tb")
 
1393
 
    def NeedApproval(self, timeout, default):
 
1395
 
        return self.need_approval()
 
1400
 
    @dbus.service.method(_interface, in_signature="b")
 
1401
 
    def Approve(self, value):
 
1404
 
    # CheckedOK - method
 
1405
 
    @dbus.service.method(_interface)
 
1406
 
    def CheckedOK(self):
 
1410
 
    @dbus.service.method(_interface)
 
1415
 
    # StartChecker - method
 
1416
 
    @dbus.service.method(_interface)
 
1417
 
    def StartChecker(self):
 
1419
 
        self.start_checker()
 
1422
 
    @dbus.service.method(_interface)
 
1427
 
    # StopChecker - method
 
1428
 
    @dbus.service.method(_interface)
 
1429
 
    def StopChecker(self):
 
1434
 
    # ApprovalPending - property
 
1435
 
    @dbus_service_property(_interface, signature="b", access="read")
 
1436
 
    def ApprovalPending_dbus_property(self):
 
1437
 
        return dbus.Boolean(bool(self.approvals_pending))
 
1439
 
    # ApprovedByDefault - property
 
1440
 
    @dbus_service_property(_interface, signature="b",
 
1442
 
    def ApprovedByDefault_dbus_property(self, value=None):
 
1443
 
        if value is None:       # get
 
1444
 
            return dbus.Boolean(self.approved_by_default)
 
1445
 
        self.approved_by_default = bool(value)
 
1447
 
    # ApprovalDelay - property
 
1448
 
    @dbus_service_property(_interface, signature="t",
 
1450
 
    def ApprovalDelay_dbus_property(self, value=None):
 
1451
 
        if value is None:       # get
 
1452
 
            return dbus.UInt64(self.approval_delay_milliseconds())
 
1453
 
        self.approval_delay = datetime.timedelta(0, 0, 0, value)
 
1455
 
    # ApprovalDuration - property
 
1456
 
    @dbus_service_property(_interface, signature="t",
 
1458
 
    def ApprovalDuration_dbus_property(self, value=None):
 
1459
 
        if value is None:       # get
 
1460
 
            return dbus.UInt64(timedelta_to_milliseconds(
 
1461
 
                    self.approval_duration))
 
1462
 
        self.approval_duration = datetime.timedelta(0, 0, 0, value)
 
1465
 
    @dbus_service_property(_interface, signature="s", access="read")
 
1466
 
    def Name_dbus_property(self):
 
1467
 
        return dbus.String(self.name)
 
1469
 
    # Fingerprint - property
 
1470
 
    @dbus_service_property(_interface, signature="s", access="read")
 
1471
 
    def Fingerprint_dbus_property(self):
 
1472
 
        return dbus.String(self.fingerprint)
 
1475
 
    @dbus_service_property(_interface, signature="s",
 
1477
 
    def Host_dbus_property(self, value=None):
 
1478
 
        if value is None:       # get
 
1479
 
            return dbus.String(self.host)
 
1480
 
        self.host = unicode(value)
 
1482
 
    # Created - property
 
1483
 
    @dbus_service_property(_interface, signature="s", access="read")
 
1484
 
    def Created_dbus_property(self):
 
1485
 
        return datetime_to_dbus(self.created)
 
1487
 
    # LastEnabled - property
 
1488
 
    @dbus_service_property(_interface, signature="s", access="read")
 
1489
 
    def LastEnabled_dbus_property(self):
 
1490
 
        return datetime_to_dbus(self.last_enabled)
 
1492
 
    # Enabled - property
 
1493
 
    @dbus_service_property(_interface, signature="b",
 
1495
 
    def Enabled_dbus_property(self, value=None):
 
1496
 
        if value is None:       # get
 
1497
 
            return dbus.Boolean(self.enabled)
 
1503
 
    # LastCheckedOK - property
 
1504
 
    @dbus_service_property(_interface, signature="s",
 
1506
 
    def LastCheckedOK_dbus_property(self, value=None):
 
1507
 
        if value is not None:
 
1510
 
        return datetime_to_dbus(self.last_checked_ok)
 
1512
 
    # LastCheckerStatus - property
 
1513
 
    @dbus_service_property(_interface, signature="n",
 
1515
 
    def LastCheckerStatus_dbus_property(self):
 
1516
 
        return dbus.Int16(self.last_checker_status)
 
1518
 
    # Expires - property
 
1519
 
    @dbus_service_property(_interface, signature="s", access="read")
 
1520
 
    def Expires_dbus_property(self):
 
1521
 
        return datetime_to_dbus(self.expires)
 
1523
 
    # LastApprovalRequest - property
 
1524
 
    @dbus_service_property(_interface, signature="s", access="read")
 
1525
 
    def LastApprovalRequest_dbus_property(self):
 
1526
 
        return datetime_to_dbus(self.last_approval_request)
 
1528
 
    # Timeout - property
 
1529
 
    @dbus_service_property(_interface, signature="t",
 
1531
 
    def Timeout_dbus_property(self, value=None):
 
1532
 
        if value is None:       # get
 
1533
 
            return dbus.UInt64(self.timeout_milliseconds())
 
1534
 
        old_timeout = self.timeout
 
1535
 
        self.timeout = datetime.timedelta(0, 0, 0, value)
 
1536
 
        # Reschedule disabling
 
1538
 
            now = datetime.datetime.utcnow()
 
1539
 
            self.expires += self.timeout - old_timeout
 
1540
 
            if self.expires <= now:
 
1541
 
                # The timeout has passed
 
1544
 
                if (getattr(self, "disable_initiator_tag", None)
 
1547
 
                gobject.source_remove(self.disable_initiator_tag)
 
1548
 
                self.disable_initiator_tag = (
 
1549
 
                    gobject.timeout_add(
 
1550
 
                        timedelta_to_milliseconds(self.expires - now),
 
1553
 
    # ExtendedTimeout - property
 
1554
 
    @dbus_service_property(_interface, signature="t",
 
1556
 
    def ExtendedTimeout_dbus_property(self, value=None):
 
1557
 
        if value is None:       # get
 
1558
 
            return dbus.UInt64(self.extended_timeout_milliseconds())
 
1559
 
        self.extended_timeout = datetime.timedelta(0, 0, 0, value)
 
1561
 
    # Interval - property
 
1562
 
    @dbus_service_property(_interface, signature="t",
 
1564
 
    def Interval_dbus_property(self, value=None):
 
1565
 
        if value is None:       # get
 
1566
 
            return dbus.UInt64(self.interval_milliseconds())
 
1567
 
        self.interval = datetime.timedelta(0, 0, 0, value)
 
1568
 
        if getattr(self, "checker_initiator_tag", None) is None:
 
1571
 
            # Reschedule checker run
 
1572
 
            gobject.source_remove(self.checker_initiator_tag)
 
1573
 
            self.checker_initiator_tag = (gobject.timeout_add
 
1574
 
                                          (value, self.start_checker))
 
1575
 
            self.start_checker()    # Start one now, too
 
1577
 
    # Checker - property
 
1578
 
    @dbus_service_property(_interface, signature="s",
 
1580
 
    def Checker_dbus_property(self, value=None):
 
1581
 
        if value is None:       # get
 
1582
 
            return dbus.String(self.checker_command)
 
1583
 
        self.checker_command = unicode(value)
 
1585
 
    # CheckerRunning - property
 
1586
 
    @dbus_service_property(_interface, signature="b",
 
1588
 
    def CheckerRunning_dbus_property(self, value=None):
 
1589
 
        if value is None:       # get
 
1590
 
            return dbus.Boolean(self.checker is not None)
 
1592
 
            self.start_checker()
 
1596
 
    # ObjectPath - property
 
1597
 
    @dbus_service_property(_interface, signature="o", access="read")
 
1598
 
    def ObjectPath_dbus_property(self):
 
1599
 
        return self.dbus_object_path # is already a dbus.ObjectPath
 
1602
 
    @dbus_service_property(_interface, signature="ay",
 
1603
 
                           access="write", byte_arrays=True)
 
1604
 
    def Secret_dbus_property(self, value):
 
1605
 
        self.secret = str(value)
 
1610
 
class ProxyClient(object):
 
1611
 
    def __init__(self, child_pipe, fpr, address):
 
1612
 
        self._pipe = child_pipe
 
1613
 
        self._pipe.send(('init', fpr, address))
 
1614
 
        if not self._pipe.recv():
 
1617
 
    def __getattribute__(self, name):
 
1619
 
            return super(ProxyClient, self).__getattribute__(name)
 
1620
 
        self._pipe.send(('getattr', name))
 
1621
 
        data = self._pipe.recv()
 
1622
 
        if data[0] == 'data':
 
1624
 
        if data[0] == 'function':
 
1625
 
            def func(*args, **kwargs):
 
1626
 
                self._pipe.send(('funcall', name, args, kwargs))
 
1627
 
                return self._pipe.recv()[1]
 
1630
 
    def __setattr__(self, name, value):
 
1632
 
            return super(ProxyClient, self).__setattr__(name, value)
 
1633
 
        self._pipe.send(('setattr', name, value))
 
1636
 
class ClientHandler(socketserver.BaseRequestHandler, object):
 
1637
 
    """A class to handle client connections.
 
1639
 
    Instantiated once for each connection to handle it.
 
 
376
    def still_valid(self):
 
 
377
        """Has the timeout not yet passed for this client?"""
 
 
378
        now = datetime.datetime.now()
 
 
379
        if self.last_checked_ok is None:
 
 
380
            return now < (self.created + self.timeout)
 
 
382
            return now < (self.last_checked_ok + self.timeout)
 
 
385
def peer_certificate(session):
 
 
386
    "Return the peer's OpenPGP certificate as a bytestring"
 
 
387
    # If not an OpenPGP certificate...
 
 
388
    if gnutls.library.functions.gnutls_certificate_type_get\
 
 
389
            (session._c_object) \
 
 
390
           != gnutls.library.constants.GNUTLS_CRT_OPENPGP:
 
 
391
        # ...do the normal thing
 
 
392
        return session.peer_certificate
 
 
393
    list_size = ctypes.c_uint()
 
 
394
    cert_list = gnutls.library.functions.gnutls_certificate_get_peers\
 
 
395
        (session._c_object, ctypes.byref(list_size))
 
 
396
    if list_size.value == 0:
 
 
399
    return ctypes.string_at(cert.data, cert.size)
 
 
402
def fingerprint(openpgp):
 
 
403
    "Convert an OpenPGP bytestring to a hexdigit fingerprint string"
 
 
404
    # New GnuTLS "datum" with the OpenPGP public key
 
 
405
    datum = gnutls.library.types.gnutls_datum_t\
 
 
406
        (ctypes.cast(ctypes.c_char_p(openpgp),
 
 
407
                     ctypes.POINTER(ctypes.c_ubyte)),
 
 
408
         ctypes.c_uint(len(openpgp)))
 
 
409
    # New empty GnuTLS certificate
 
 
410
    crt = gnutls.library.types.gnutls_openpgp_crt_t()
 
 
411
    gnutls.library.functions.gnutls_openpgp_crt_init\
 
 
413
    # Import the OpenPGP public key into the certificate
 
 
414
    gnutls.library.functions.gnutls_openpgp_crt_import\
 
 
415
                    (crt, ctypes.byref(datum),
 
 
416
                     gnutls.library.constants.GNUTLS_OPENPGP_FMT_RAW)
 
 
417
    # Verify the self signature in the key
 
 
418
    crtverify = ctypes.c_uint();
 
 
419
    gnutls.library.functions.gnutls_openpgp_crt_verify_self\
 
 
420
        (crt, 0, ctypes.byref(crtverify))
 
 
421
    if crtverify.value != 0:
 
 
422
        gnutls.library.functions.gnutls_openpgp_crt_deinit(crt)
 
 
423
        raise gnutls.errors.CertificateSecurityError("Verify failed")
 
 
424
    # New buffer for the fingerprint
 
 
425
    buffer = ctypes.create_string_buffer(20)
 
 
426
    buffer_length = ctypes.c_size_t()
 
 
427
    # Get the fingerprint from the certificate into the buffer
 
 
428
    gnutls.library.functions.gnutls_openpgp_crt_get_fingerprint\
 
 
429
        (crt, ctypes.byref(buffer), ctypes.byref(buffer_length))
 
 
430
    # Deinit the certificate
 
 
431
    gnutls.library.functions.gnutls_openpgp_crt_deinit(crt)
 
 
432
    # Convert the buffer to a Python bytestring
 
 
433
    fpr = ctypes.string_at(buffer, buffer_length.value)
 
 
434
    # Convert the bytestring to hexadecimal notation
 
 
435
    hex_fpr = u''.join(u"%02X" % ord(char) for char in fpr)
 
 
439
class tcp_handler(SocketServer.BaseRequestHandler, object):
 
 
440
    """A TCP request handler class.
 
 
441
    Instantiated by IPv6_TCPServer for each request to handle it.
 
1640
442
    Note: This will run in its own forked process."""
 
1642
444
    def handle(self):
 
1643
 
        with contextlib.closing(self.server.child_pipe) as child_pipe:
 
1644
 
            logger.info("TCP connection from: %s",
 
1645
 
                        unicode(self.client_address))
 
1646
 
            logger.debug("Pipe FD: %d",
 
1647
 
                         self.server.child_pipe.fileno())
 
1649
 
            session = (gnutls.connection
 
1650
 
                       .ClientSession(self.request,
 
1652
 
                                      .X509Credentials()))
 
1654
 
            # Note: gnutls.connection.X509Credentials is really a
 
1655
 
            # generic GnuTLS certificate credentials object so long as
 
1656
 
            # no X.509 keys are added to it.  Therefore, we can use it
 
1657
 
            # here despite using OpenPGP certificates.
 
1659
 
            #priority = ':'.join(("NONE", "+VERS-TLS1.1",
 
1660
 
            #                      "+AES-256-CBC", "+SHA1",
 
1661
 
            #                      "+COMP-NULL", "+CTYPE-OPENPGP",
 
1663
 
            # Use a fallback default, since this MUST be set.
 
1664
 
            priority = self.server.gnutls_priority
 
1665
 
            if priority is None:
 
1667
 
            (gnutls.library.functions
 
1668
 
             .gnutls_priority_set_direct(session._c_object,
 
1671
 
            # Start communication using the Mandos protocol
 
1672
 
            # Get protocol number
 
1673
 
            line = self.request.makefile().readline()
 
1674
 
            logger.debug("Protocol version: %r", line)
 
1676
 
                if int(line.strip().split()[0]) > 1:
 
1678
 
            except (ValueError, IndexError, RuntimeError) as error:
 
1679
 
                logger.error("Unknown protocol version: %s", error)
 
1682
 
            # Start GnuTLS connection
 
1685
 
            except gnutls.errors.GNUTLSError as error:
 
1686
 
                logger.warning("Handshake failed: %s", error)
 
1687
 
                # Do not run session.bye() here: the session is not
 
1688
 
                # established.  Just abandon the request.
 
1690
 
            logger.debug("Handshake succeeded")
 
1692
 
            approval_required = False
 
1695
 
                    fpr = self.fingerprint(self.peer_certificate
 
1698
 
                        gnutls.errors.GNUTLSError) as error:
 
1699
 
                    logger.warning("Bad certificate: %s", error)
 
1701
 
                logger.debug("Fingerprint: %s", fpr)
 
1704
 
                    client = ProxyClient(child_pipe, fpr,
 
1705
 
                                         self.client_address)
 
1709
 
                if client.approval_delay:
 
1710
 
                    delay = client.approval_delay
 
1711
 
                    client.approvals_pending += 1
 
1712
 
                    approval_required = True
 
1715
 
                    if not client.enabled:
 
1716
 
                        logger.info("Client %s is disabled",
 
1718
 
                        if self.server.use_dbus:
 
1720
 
                            client.Rejected("Disabled")
 
1723
 
                    if client.approved or not client.approval_delay:
 
1724
 
                        #We are approved or approval is disabled
 
1726
 
                    elif client.approved is None:
 
1727
 
                        logger.info("Client %s needs approval",
 
1729
 
                        if self.server.use_dbus:
 
1731
 
                            client.NeedApproval(
 
1732
 
                                client.approval_delay_milliseconds(),
 
1733
 
                                client.approved_by_default)
 
1735
 
                        logger.warning("Client %s was not approved",
 
1737
 
                        if self.server.use_dbus:
 
1739
 
                            client.Rejected("Denied")
 
1742
 
                    #wait until timeout or approved
 
1743
 
                    time = datetime.datetime.now()
 
1744
 
                    client.changedstate.acquire()
 
1745
 
                    client.changedstate.wait(
 
1746
 
                        float(timedelta_to_milliseconds(delay)
 
1748
 
                    client.changedstate.release()
 
1749
 
                    time2 = datetime.datetime.now()
 
1750
 
                    if (time2 - time) >= delay:
 
1751
 
                        if not client.approved_by_default:
 
1752
 
                            logger.warning("Client %s timed out while"
 
1753
 
                                           " waiting for approval",
 
1755
 
                            if self.server.use_dbus:
 
1757
 
                                client.Rejected("Approval timed out")
 
1762
 
                        delay -= time2 - time
 
1765
 
                while sent_size < len(client.secret):
 
1767
 
                        sent = session.send(client.secret[sent_size:])
 
1768
 
                    except gnutls.errors.GNUTLSError as error:
 
1769
 
                        logger.warning("gnutls send failed",
 
1772
 
                    logger.debug("Sent: %d, remaining: %d",
 
1773
 
                                 sent, len(client.secret)
 
1774
 
                                 - (sent_size + sent))
 
1777
 
                logger.info("Sending secret to %s", client.name)
 
1778
 
                # bump the timeout using extended_timeout
 
1779
 
                client.bump_timeout(client.extended_timeout)
 
1780
 
                if self.server.use_dbus:
 
1785
 
                if approval_required:
 
1786
 
                    client.approvals_pending -= 1
 
1789
 
                except gnutls.errors.GNUTLSError as error:
 
1790
 
                    logger.warning("GnuTLS bye failed",
 
1794
 
    def peer_certificate(session):
 
1795
 
        "Return the peer's OpenPGP certificate as a bytestring"
 
1796
 
        # If not an OpenPGP certificate...
 
1797
 
        if (gnutls.library.functions
 
1798
 
            .gnutls_certificate_type_get(session._c_object)
 
1799
 
            != gnutls.library.constants.GNUTLS_CRT_OPENPGP):
 
1800
 
            # ...do the normal thing
 
1801
 
            return session.peer_certificate
 
1802
 
        list_size = ctypes.c_uint(1)
 
1803
 
        cert_list = (gnutls.library.functions
 
1804
 
                     .gnutls_certificate_get_peers
 
1805
 
                     (session._c_object, ctypes.byref(list_size)))
 
1806
 
        if not bool(cert_list) and list_size.value != 0:
 
1807
 
            raise gnutls.errors.GNUTLSError("error getting peer"
 
1809
 
        if list_size.value == 0:
 
1812
 
        return ctypes.string_at(cert.data, cert.size)
 
1815
 
    def fingerprint(openpgp):
 
1816
 
        "Convert an OpenPGP bytestring to a hexdigit fingerprint"
 
1817
 
        # New GnuTLS "datum" with the OpenPGP public key
 
1818
 
        datum = (gnutls.library.types
 
1819
 
                 .gnutls_datum_t(ctypes.cast(ctypes.c_char_p(openpgp),
 
1822
 
                                 ctypes.c_uint(len(openpgp))))
 
1823
 
        # New empty GnuTLS certificate
 
1824
 
        crt = gnutls.library.types.gnutls_openpgp_crt_t()
 
1825
 
        (gnutls.library.functions
 
1826
 
         .gnutls_openpgp_crt_init(ctypes.byref(crt)))
 
1827
 
        # Import the OpenPGP public key into the certificate
 
1828
 
        (gnutls.library.functions
 
1829
 
         .gnutls_openpgp_crt_import(crt, ctypes.byref(datum),
 
1830
 
                                    gnutls.library.constants
 
1831
 
                                    .GNUTLS_OPENPGP_FMT_RAW))
 
1832
 
        # Verify the self signature in the key
 
1833
 
        crtverify = ctypes.c_uint()
 
1834
 
        (gnutls.library.functions
 
1835
 
         .gnutls_openpgp_crt_verify_self(crt, 0,
 
1836
 
                                         ctypes.byref(crtverify)))
 
1837
 
        if crtverify.value != 0:
 
1838
 
            gnutls.library.functions.gnutls_openpgp_crt_deinit(crt)
 
1839
 
            raise (gnutls.errors.CertificateSecurityError
 
1841
 
        # New buffer for the fingerprint
 
1842
 
        buf = ctypes.create_string_buffer(20)
 
1843
 
        buf_len = ctypes.c_size_t()
 
1844
 
        # Get the fingerprint from the certificate into the buffer
 
1845
 
        (gnutls.library.functions
 
1846
 
         .gnutls_openpgp_crt_get_fingerprint(crt, ctypes.byref(buf),
 
1847
 
                                             ctypes.byref(buf_len)))
 
1848
 
        # Deinit the certificate
 
1849
 
        gnutls.library.functions.gnutls_openpgp_crt_deinit(crt)
 
1850
 
        # Convert the buffer to a Python bytestring
 
1851
 
        fpr = ctypes.string_at(buf, buf_len.value)
 
1852
 
        # Convert the bytestring to hexadecimal notation
 
1853
 
        hex_fpr = binascii.hexlify(fpr).upper()
 
1857
 
class MultiprocessingMixIn(object):
 
1858
 
    """Like socketserver.ThreadingMixIn, but with multiprocessing"""
 
1859
 
    def sub_process_main(self, request, address):
 
1861
 
            self.finish_request(request, address)
 
1863
 
            self.handle_error(request, address)
 
1864
 
        self.close_request(request)
 
1866
 
    def process_request(self, request, address):
 
1867
 
        """Start a new process to process the request."""
 
1868
 
        proc = multiprocessing.Process(target = self.sub_process_main,
 
1869
 
                                       args = (request, address))
 
1874
 
class MultiprocessingMixInWithPipe(MultiprocessingMixIn, object):
 
1875
 
    """ adds a pipe to the MixIn """
 
1876
 
    def process_request(self, request, client_address):
 
1877
 
        """Overrides and wraps the original process_request().
 
1879
 
        This function creates a new pipe in self.pipe
 
1881
 
        parent_pipe, self.child_pipe = multiprocessing.Pipe()
 
1883
 
        proc = MultiprocessingMixIn.process_request(self, request,
 
1885
 
        self.child_pipe.close()
 
1886
 
        self.add_pipe(parent_pipe, proc)
 
1888
 
    def add_pipe(self, parent_pipe, proc):
 
1889
 
        """Dummy function; override as necessary"""
 
1890
 
        raise NotImplementedError
 
1893
 
class IPv6_TCPServer(MultiprocessingMixInWithPipe,
 
1894
 
                     socketserver.TCPServer, object):
 
1895
 
    """IPv6-capable TCP server.  Accepts 'None' as address and/or port
 
 
445
        logger.info(u"TCP connection from: %s",
 
 
446
                     unicode(self.client_address))
 
 
447
        session = gnutls.connection.ClientSession\
 
 
448
                  (self.request, gnutls.connection.X509Credentials())
 
 
450
        line = self.request.makefile().readline()
 
 
451
        logger.debug(u"Protocol version: %r", line)
 
 
453
            if int(line.strip().split()[0]) > 1:
 
 
455
        except (ValueError, IndexError, RuntimeError), error:
 
 
456
            logger.error(u"Unknown protocol version: %s", error)
 
 
459
        # Note: gnutls.connection.X509Credentials is really a generic
 
 
460
        # GnuTLS certificate credentials object so long as no X.509
 
 
461
        # keys are added to it.  Therefore, we can use it here despite
 
 
462
        # using OpenPGP certificates.
 
 
464
        #priority = ':'.join(("NONE", "+VERS-TLS1.1", "+AES-256-CBC",
 
 
465
        #                "+SHA1", "+COMP-NULL", "+CTYPE-OPENPGP",
 
 
467
        priority = "NORMAL"             # Fallback default, since this
 
 
469
        if self.server.settings["priority"]:
 
 
470
            priority = self.server.settings["priority"]
 
 
471
        gnutls.library.functions.gnutls_priority_set_direct\
 
 
472
            (session._c_object, priority, None);
 
 
476
        except gnutls.errors.GNUTLSError, error:
 
 
477
            logger.warning(u"Handshake failed: %s", error)
 
 
478
            # Do not run session.bye() here: the session is not
 
 
479
            # established.  Just abandon the request.
 
 
482
            fpr = fingerprint(peer_certificate(session))
 
 
483
        except (TypeError, gnutls.errors.GNUTLSError), error:
 
 
484
            logger.warning(u"Bad certificate: %s", error)
 
 
487
        logger.debug(u"Fingerprint: %s", fpr)
 
 
489
        for c in self.server.clients:
 
 
490
            if c.fingerprint == fpr:
 
 
494
            logger.warning(u"Client not found for fingerprint: %s",
 
 
498
        # Have to check if client.still_valid(), since it is possible
 
 
499
        # that the client timed out while establishing the GnuTLS
 
 
501
        if not client.still_valid():
 
 
502
            logger.warning(u"Client %(name)s is invalid",
 
 
507
        while sent_size < len(client.secret):
 
 
508
            sent = session.send(client.secret[sent_size:])
 
 
509
            logger.debug(u"Sent: %d, remaining: %d",
 
 
510
                         sent, len(client.secret)
 
 
511
                         - (sent_size + sent))
 
 
516
class IPv6_TCPServer(SocketServer.ForkingTCPServer, object):
 
 
517
    """IPv6 TCP server.  Accepts 'None' as address and/or port.
 
 
519
        settings:       Server settings
 
 
520
        clients:        Set() of Client objects
 
1898
521
        enabled:        Boolean; whether this server is activated yet
 
1899
 
        interface:      None or a network interface name (string)
 
1900
 
        use_ipv6:       Boolean; to use IPv6 or not
 
1902
 
    def __init__(self, server_address, RequestHandlerClass,
 
1903
 
                 interface=None, use_ipv6=True, socketfd=None):
 
1904
 
        """If socketfd is set, use that file descriptor instead of
 
1905
 
        creating a new one with socket.socket().
 
1907
 
        self.interface = interface
 
1909
 
            self.address_family = socket.AF_INET6
 
1910
 
        if socketfd is not None:
 
1911
 
            # Save the file descriptor
 
1912
 
            self.socketfd = socketfd
 
1913
 
            # Save the original socket.socket() function
 
1914
 
            self.socket_socket = socket.socket
 
1915
 
            # To implement --socket, we monkey patch socket.socket.
 
1917
 
            # (When socketserver.TCPServer is a new-style class, we
 
1918
 
            # could make self.socket into a property instead of monkey
 
1919
 
            # patching socket.socket.)
 
1921
 
            # Create a one-time-only replacement for socket.socket()
 
1922
 
            @functools.wraps(socket.socket)
 
1923
 
            def socket_wrapper(*args, **kwargs):
 
1924
 
                # Restore original function so subsequent calls are
 
1926
 
                socket.socket = self.socket_socket
 
1927
 
                del self.socket_socket
 
1928
 
                # This time only, return a new socket object from the
 
1929
 
                # saved file descriptor.
 
1930
 
                return socket.fromfd(self.socketfd, *args, **kwargs)
 
1931
 
            # Replace socket.socket() function with wrapper
 
1932
 
            socket.socket = socket_wrapper
 
1933
 
        # The socketserver.TCPServer.__init__ will call
 
1934
 
        # socket.socket(), which might be our replacement,
 
1935
 
        # socket_wrapper(), if socketfd was set.
 
1936
 
        socketserver.TCPServer.__init__(self, server_address,
 
1937
 
                                        RequestHandlerClass)
 
 
523
    address_family = socket.AF_INET6
 
 
524
    def __init__(self, *args, **kwargs):
 
 
525
        if "settings" in kwargs:
 
 
526
            self.settings = kwargs["settings"]
 
 
527
            del kwargs["settings"]
 
 
528
        if "clients" in kwargs:
 
 
529
            self.clients = kwargs["clients"]
 
 
530
            del kwargs["clients"]
 
 
532
        return super(type(self), self).__init__(*args, **kwargs)
 
1939
533
    def server_bind(self):
 
1940
534
        """This overrides the normal server_bind() function
 
1941
535
        to bind to an interface if one was specified, and also NOT to
 
1942
536
        bind to an address or port if they were not specified."""
 
1943
 
        if self.interface is not None:
 
1944
 
            if SO_BINDTODEVICE is None:
 
1945
 
                logger.error("SO_BINDTODEVICE does not exist;"
 
1946
 
                             " cannot bind to interface %s",
 
1950
 
                    self.socket.setsockopt(socket.SOL_SOCKET,
 
1952
 
                                           str(self.interface + '\0'))
 
1953
 
                except socket.error as error:
 
1954
 
                    if error.errno == errno.EPERM:
 
1955
 
                        logger.error("No permission to bind to"
 
1956
 
                                     " interface %s", self.interface)
 
1957
 
                    elif error.errno == errno.ENOPROTOOPT:
 
1958
 
                        logger.error("SO_BINDTODEVICE not available;"
 
1959
 
                                     " cannot bind to interface %s",
 
1961
 
                    elif error.errno == errno.ENODEV:
 
1962
 
                        logger.error("Interface %s does not exist,"
 
1963
 
                                     " cannot bind", self.interface)
 
 
537
        if self.settings["interface"]:
 
 
538
            # 25 is from /usr/include/asm-i486/socket.h
 
 
539
            SO_BINDTODEVICE = getattr(socket, "SO_BINDTODEVICE", 25)
 
 
541
                self.socket.setsockopt(socket.SOL_SOCKET,
 
 
543
                                       self.settings["interface"])
 
 
544
            except socket.error, error:
 
 
545
                if error[0] == errno.EPERM:
 
 
546
                    logger.error(u"No permission to"
 
 
547
                                 u" bind to interface %s",
 
 
548
                                 self.settings["interface"])
 
1966
551
        # Only bind(2) the socket if we really need to.
 
1967
552
        if self.server_address[0] or self.server_address[1]:
 
1968
553
            if not self.server_address[0]:
 
1969
 
                if self.address_family == socket.AF_INET6:
 
1970
 
                    any_address = "::" # in6addr_any
 
1972
 
                    any_address = socket.INADDR_ANY
 
1973
 
                self.server_address = (any_address,
 
 
555
                self.server_address = (in6addr_any,
 
1974
556
                                       self.server_address[1])
 
1975
557
            elif not self.server_address[1]:
 
1976
558
                self.server_address = (self.server_address[0],
 
1978
 
#                 if self.interface:
 
 
560
#                 if self.settings["interface"]:
 
1979
561
#                     self.server_address = (self.server_address[0],
 
1982
564
#                                            if_nametoindex
 
1984
 
            return socketserver.TCPServer.server_bind(self)
 
1987
 
class MandosServer(IPv6_TCPServer):
 
1991
 
        clients:        set of Client objects
 
1992
 
        gnutls_priority GnuTLS priority string
 
1993
 
        use_dbus:       Boolean; to emit D-Bus signals or not
 
1995
 
    Assumes a gobject.MainLoop event loop.
 
1997
 
    def __init__(self, server_address, RequestHandlerClass,
 
1998
 
                 interface=None, use_ipv6=True, clients=None,
 
1999
 
                 gnutls_priority=None, use_dbus=True, socketfd=None):
 
2000
 
        self.enabled = False
 
2001
 
        self.clients = clients
 
2002
 
        if self.clients is None:
 
2004
 
        self.use_dbus = use_dbus
 
2005
 
        self.gnutls_priority = gnutls_priority
 
2006
 
        IPv6_TCPServer.__init__(self, server_address,
 
2007
 
                                RequestHandlerClass,
 
2008
 
                                interface = interface,
 
2009
 
                                use_ipv6 = use_ipv6,
 
2010
 
                                socketfd = socketfd)
 
 
567
            return super(type(self), self).server_bind()
 
2011
568
    def server_activate(self):
 
2012
569
        if self.enabled:
 
2013
 
            return socketserver.TCPServer.server_activate(self)
 
 
570
            return super(type(self), self).server_activate()
 
2015
571
    def enable(self):
 
2016
572
        self.enabled = True
 
2018
 
    def add_pipe(self, parent_pipe, proc):
 
2019
 
        # Call "handle_ipc" for both data and EOF events
 
2020
 
        gobject.io_add_watch(parent_pipe.fileno(),
 
2021
 
                             gobject.IO_IN | gobject.IO_HUP,
 
2022
 
                             functools.partial(self.handle_ipc,
 
2027
 
    def handle_ipc(self, source, condition, parent_pipe=None,
 
2028
 
                   proc = None, client_object=None):
 
2029
 
        # error, or the other end of multiprocessing.Pipe has closed
 
2030
 
        if condition & (gobject.IO_ERR | gobject.IO_HUP):
 
2031
 
            # Wait for other process to exit
 
2035
 
        # Read a request from the child
 
2036
 
        request = parent_pipe.recv()
 
2037
 
        command = request[0]
 
2039
 
        if command == 'init':
 
2041
 
            address = request[2]
 
2043
 
            for c in self.clients.itervalues():
 
2044
 
                if c.fingerprint == fpr:
 
2048
 
                logger.info("Client not found for fingerprint: %s, ad"
 
2049
 
                            "dress: %s", fpr, address)
 
2052
 
                    mandos_dbus_service.ClientNotFound(fpr,
 
2054
 
                parent_pipe.send(False)
 
2057
 
            gobject.io_add_watch(parent_pipe.fileno(),
 
2058
 
                                 gobject.IO_IN | gobject.IO_HUP,
 
2059
 
                                 functools.partial(self.handle_ipc,
 
2065
 
            parent_pipe.send(True)
 
2066
 
            # remove the old hook in favor of the new above hook on
 
2069
 
        if command == 'funcall':
 
2070
 
            funcname = request[1]
 
2074
 
            parent_pipe.send(('data', getattr(client_object,
 
2078
 
        if command == 'getattr':
 
2079
 
            attrname = request[1]
 
2080
 
            if callable(client_object.__getattribute__(attrname)):
 
2081
 
                parent_pipe.send(('function',))
 
2083
 
                parent_pipe.send(('data', client_object
 
2084
 
                                  .__getattribute__(attrname)))
 
2086
 
        if command == 'setattr':
 
2087
 
            attrname = request[1]
 
2089
 
            setattr(client_object, attrname, value)
 
2094
 
def rfc3339_duration_to_delta(duration):
 
2095
 
    """Parse an RFC 3339 "duration" and return a datetime.timedelta
 
2097
 
    >>> rfc3339_duration_to_delta("P7D")
 
2098
 
    datetime.timedelta(7)
 
2099
 
    >>> rfc3339_duration_to_delta("PT60S")
 
2100
 
    datetime.timedelta(0, 60)
 
2101
 
    >>> rfc3339_duration_to_delta("PT60M")
 
2102
 
    datetime.timedelta(0, 3600)
 
2103
 
    >>> rfc3339_duration_to_delta("PT24H")
 
2104
 
    datetime.timedelta(1)
 
2105
 
    >>> rfc3339_duration_to_delta("P1W")
 
2106
 
    datetime.timedelta(7)
 
2107
 
    >>> rfc3339_duration_to_delta("PT5M30S")
 
2108
 
    datetime.timedelta(0, 330)
 
2109
 
    >>> rfc3339_duration_to_delta("P1DT3M20S")
 
2110
 
    datetime.timedelta(1, 200)
 
2113
 
    # Parsing an RFC 3339 duration with regular expressions is not
 
2114
 
    # possible - there would have to be multiple places for the same
 
2115
 
    # values, like seconds.  The current code, while more esoteric, is
 
2116
 
    # cleaner without depending on a parsing library.  If Python had a
 
2117
 
    # built-in library for parsing we would use it, but we'd like to
 
2118
 
    # avoid excessive use of external libraries.
 
2120
 
    # New type for defining tokens, syntax, and semantics all-in-one
 
2121
 
    Token = collections.namedtuple("Token",
 
2122
 
                                   ("regexp", # To match token; if
 
2123
 
                                              # "value" is not None,
 
2124
 
                                              # must have a "group"
 
2126
 
                                    "value",  # datetime.timedelta or
 
2128
 
                                    "followers")) # Tokens valid after
 
2130
 
    # RFC 3339 "duration" tokens, syntax, and semantics; taken from
 
2131
 
    # the "duration" ABNF definition in RFC 3339, Appendix A.
 
2132
 
    token_end = Token(re.compile(r"$"), None, frozenset())
 
2133
 
    token_second = Token(re.compile(r"(\d+)S"),
 
2134
 
                         datetime.timedelta(seconds=1),
 
2135
 
                         frozenset((token_end,)))
 
2136
 
    token_minute = Token(re.compile(r"(\d+)M"),
 
2137
 
                         datetime.timedelta(minutes=1),
 
2138
 
                         frozenset((token_second, token_end)))
 
2139
 
    token_hour = Token(re.compile(r"(\d+)H"),
 
2140
 
                       datetime.timedelta(hours=1),
 
2141
 
                       frozenset((token_minute, token_end)))
 
2142
 
    token_time = Token(re.compile(r"T"),
 
2144
 
                       frozenset((token_hour, token_minute,
 
2146
 
    token_day = Token(re.compile(r"(\d+)D"),
 
2147
 
                      datetime.timedelta(days=1),
 
2148
 
                      frozenset((token_time, token_end)))
 
2149
 
    token_month = Token(re.compile(r"(\d+)M"),
 
2150
 
                        datetime.timedelta(weeks=4),
 
2151
 
                        frozenset((token_day, token_end)))
 
2152
 
    token_year = Token(re.compile(r"(\d+)Y"),
 
2153
 
                       datetime.timedelta(weeks=52),
 
2154
 
                       frozenset((token_month, token_end)))
 
2155
 
    token_week = Token(re.compile(r"(\d+)W"),
 
2156
 
                       datetime.timedelta(weeks=1),
 
2157
 
                       frozenset((token_end,)))
 
2158
 
    token_duration = Token(re.compile(r"P"), None,
 
2159
 
                           frozenset((token_year, token_month,
 
2160
 
                                      token_day, token_time,
 
2162
 
    # Define starting values
 
2163
 
    value = datetime.timedelta() # Value so far
 
2165
 
    followers = frozenset(token_duration,) # Following valid tokens
 
2166
 
    s = duration                # String left to parse
 
2167
 
    # Loop until end token is found
 
2168
 
    while found_token is not token_end:
 
2169
 
        # Search for any currently valid tokens
 
2170
 
        for token in followers:
 
2171
 
            match = token.regexp.match(s)
 
2172
 
            if match is not None:
 
2174
 
                if token.value is not None:
 
2175
 
                    # Value found, parse digits
 
2176
 
                    factor = int(match.group(1), 10)
 
2177
 
                    # Add to value so far
 
2178
 
                    value += factor * token.value
 
2179
 
                # Strip token from string
 
2180
 
                s = token.regexp.sub("", s, 1)
 
2183
 
                # Set valid next tokens
 
2184
 
                followers = found_token.followers
 
2187
 
            # No currently valid tokens were found
 
2188
 
            raise ValueError("Invalid RFC 3339 duration")
 
2193
575
def string_to_delta(interval):
 
2194
576
    """Parse a string and return a datetime.timedelta
 
2196
578
    >>> string_to_delta('7d')
 
2197
579
    datetime.timedelta(7)
 
2198
580
    >>> string_to_delta('60s')
 
 
2323
722
                        "SECURE256:!CTYPE-X.509:+CTYPE-OPENPGP",
 
2324
723
                        "servicename": "Mandos",
 
2330
 
                        "statedir": "/var/lib/mandos",
 
2331
 
                        "foreground": "False",
 
2334
726
    # Parse config file for server-global settings
 
2335
 
    server_config = configparser.SafeConfigParser(server_defaults)
 
 
727
    server_config = ConfigParser.SafeConfigParser(server_defaults)
 
2336
728
    del server_defaults
 
2337
 
    server_config.read(os.path.join(options.configdir,
 
 
729
    server_config.read(os.path.join(options.configdir, "mandos.conf"))
 
2339
730
    # Convert the SafeConfigParser object to a dict
 
2340
731
    server_settings = server_config.defaults()
 
2341
 
    # Use the appropriate methods on the non-string config options
 
2342
 
    for option in ("debug", "use_dbus", "use_ipv6", "foreground"):
 
2343
 
        server_settings[option] = server_config.getboolean("DEFAULT",
 
2345
 
    if server_settings["port"]:
 
2346
 
        server_settings["port"] = server_config.getint("DEFAULT",
 
2348
 
    if server_settings["socket"]:
 
2349
 
        server_settings["socket"] = server_config.getint("DEFAULT",
 
2351
 
        # Later, stdin will, and stdout and stderr might, be dup'ed
 
2352
 
        # over with an opened os.devnull.  But we don't want this to
 
2353
 
        # happen with a supplied network socket.
 
2354
 
        if 0 <= server_settings["socket"] <= 2:
 
2355
 
            server_settings["socket"] = os.dup(server_settings
 
 
732
    # Use getboolean on the boolean config option
 
 
733
    server_settings["debug"] = server_config.getboolean\
 
2357
735
    del server_config
 
2359
737
    # Override the settings from the config file with command line
 
2360
738
    # options, if set.
 
2361
739
    for option in ("interface", "address", "port", "debug",
 
2362
 
                   "priority", "servicename", "configdir",
 
2363
 
                   "use_dbus", "use_ipv6", "debuglevel", "restore",
 
2364
 
                   "statedir", "socket", "foreground"):
 
 
740
                   "priority", "servicename", "configdir"):
 
2365
741
        value = getattr(options, option)
 
2366
742
        if value is not None:
 
2367
743
            server_settings[option] = value
 
2369
 
    # Force all strings to be unicode
 
2370
 
    for option in server_settings.keys():
 
2371
 
        if type(server_settings[option]) is str:
 
2372
 
            server_settings[option] = unicode(server_settings[option])
 
2373
 
    # Debug implies foreground
 
2374
 
    if server_settings["debug"]:
 
2375
 
        server_settings["foreground"] = True
 
2376
745
    # Now we have our good server settings in "server_settings"
 
2378
 
    ##################################################################
 
2381
747
    debug = server_settings["debug"]
 
2382
 
    debuglevel = server_settings["debuglevel"]
 
2383
 
    use_dbus = server_settings["use_dbus"]
 
2384
 
    use_ipv6 = server_settings["use_ipv6"]
 
2385
 
    stored_state_path = os.path.join(server_settings["statedir"],
 
2387
 
    foreground = server_settings["foreground"]
 
2390
 
        initlogger(debug, logging.DEBUG)
 
2395
 
            level = getattr(logging, debuglevel.upper())
 
2396
 
            initlogger(debug, level)
 
 
750
        syslogger.setLevel(logging.WARNING)
 
 
751
        console.setLevel(logging.WARNING)
 
2398
753
    if server_settings["servicename"] != "Mandos":
 
2399
 
        syslogger.setFormatter(logging.Formatter
 
2400
 
                               ('Mandos ({0}) [%(process)d]:'
 
2401
 
                                ' %(levelname)s: %(message)s'
 
2402
 
                                .format(server_settings
 
 
754
        syslogger.setFormatter(logging.Formatter\
 
 
755
                               ('Mandos (%s): %%(levelname)s:'
 
 
757
                                % server_settings["servicename"]))
 
2405
759
    # Parse config file with clients
 
2406
 
    client_config = configparser.SafeConfigParser(Client
 
 
760
    client_defaults = { "timeout": "1h",
 
 
762
                        "checker": "fping -q -- %(host)s",
 
 
765
    client_config = ConfigParser.SafeConfigParser(client_defaults)
 
2408
766
    client_config.read(os.path.join(server_settings["configdir"],
 
2409
767
                                    "clients.conf"))
 
2411
 
    global mandos_dbus_service
 
2412
 
    mandos_dbus_service = None
 
2414
 
    tcp_server = MandosServer((server_settings["address"],
 
2415
 
                               server_settings["port"]),
 
2417
 
                              interface=(server_settings["interface"]
 
2421
 
                              server_settings["priority"],
 
2423
 
                              socketfd=(server_settings["socket"]
 
2426
 
        pidfilename = "/var/run/mandos.pid"
 
2429
 
            pidfile = open(pidfilename, "w")
 
2430
 
        except IOError as e:
 
2431
 
            logger.error("Could not open file %r", pidfilename,
 
2434
 
    for name in ("_mandos", "mandos", "nobody"):
 
2436
 
            uid = pwd.getpwnam(name).pw_uid
 
2437
 
            gid = pwd.getpwnam(name).pw_gid
 
 
770
    tcp_server = IPv6_TCPServer((server_settings["address"],
 
 
771
                                 server_settings["port"]),
 
 
773
                                settings=server_settings,
 
 
775
    pidfilename = "/var/run/mandos.pid"
 
 
777
        pidfile = open(pidfilename, "w")
 
 
778
    except IOError, error:
 
 
779
        logger.error("Could not open file %r", pidfilename)
 
 
784
        uid = pwd.getpwnam("mandos").pw_uid
 
 
787
            uid = pwd.getpwnam("nobody").pw_uid
 
 
791
        gid = pwd.getpwnam("mandos").pw_gid
 
 
794
            gid = pwd.getpwnam("nogroup").pw_gid
 
2447
 
    except OSError as error:
 
2448
 
        if error.errno != errno.EPERM:
 
 
800
    except OSError, error:
 
 
801
        if error[0] != errno.EPERM:
 
2452
 
        # Enable all possible GnuTLS debugging
 
2454
 
        # "Use a log level over 10 to enable all debugging options."
 
2456
 
        gnutls.library.functions.gnutls_global_set_log_level(11)
 
2458
 
        @gnutls.library.types.gnutls_log_func
 
2459
 
        def debug_gnutls(level, string):
 
2460
 
            logger.debug("GnuTLS: %s", string[:-1])
 
2462
 
        (gnutls.library.functions
 
2463
 
         .gnutls_global_set_log_function(debug_gnutls))
 
2465
 
        # Redirect stdin so all checkers get /dev/null
 
2466
 
        null = os.open(os.devnull, os.O_NOCTTY | os.O_RDWR)
 
2467
 
        os.dup2(null, sys.stdin.fileno())
 
2471
 
    # Need to fork before connecting to D-Bus
 
2473
 
        # Close all input and output, do double fork, etc.
 
2476
 
    # multiprocessing will use threads, so before we use gobject we
 
2477
 
    # need to inform gobject that threads will be used.
 
2478
 
    gobject.threads_init()
 
 
805
    service = AvahiService(name = server_settings["servicename"],
 
 
806
                           type = "_mandos._tcp", );
 
 
807
    if server_settings["interface"]:
 
 
808
        service.interface = if_nametoindex\
 
 
809
                            (server_settings["interface"])
 
2480
811
    global main_loop
 
2481
814
    # From the Avahi example code
 
2482
 
    DBusGMainLoop(set_as_default=True)
 
 
815
    DBusGMainLoop(set_as_default=True )
 
2483
816
    main_loop = gobject.MainLoop()
 
2484
817
    bus = dbus.SystemBus()
 
 
818
    server = dbus.Interface(bus.get_object(avahi.DBUS_NAME,
 
 
819
                                           avahi.DBUS_PATH_SERVER),
 
 
820
                            avahi.DBUS_INTERFACE_SERVER)
 
2485
821
    # End of Avahi example code
 
2488
 
            bus_name = dbus.service.BusName("se.recompile.Mandos",
 
2489
 
                                            bus, do_not_queue=True)
 
2490
 
            old_bus_name = (dbus.service.BusName
 
2491
 
                            ("se.bsnet.fukt.Mandos", bus,
 
2493
 
        except dbus.exceptions.NameExistsException as e:
 
2494
 
            logger.error("Disabling D-Bus:", exc_info=e)
 
2496
 
            server_settings["use_dbus"] = False
 
2497
 
            tcp_server.use_dbus = False
 
2498
 
    protocol = avahi.PROTO_INET6 if use_ipv6 else avahi.PROTO_INET
 
2499
 
    service = AvahiServiceToSyslog(name =
 
2500
 
                                   server_settings["servicename"],
 
2501
 
                                   servicetype = "_mandos._tcp",
 
2502
 
                                   protocol = protocol, bus = bus)
 
2503
 
    if server_settings["interface"]:
 
2504
 
        service.interface = (if_nametoindex
 
2505
 
                             (str(server_settings["interface"])))
 
2507
 
    global multiprocessing_manager
 
2508
 
    multiprocessing_manager = multiprocessing.Manager()
 
2510
 
    client_class = Client
 
2512
 
        client_class = functools.partial(ClientDBus, bus = bus)
 
2514
 
    client_settings = Client.config_parser(client_config)
 
2515
 
    old_client_settings = {}
 
2518
 
    # Get client data and settings from last running state.
 
2519
 
    if server_settings["restore"]:
 
2521
 
            with open(stored_state_path, "rb") as stored_state:
 
2522
 
                clients_data, old_client_settings = (pickle.load
 
2524
 
            os.remove(stored_state_path)
 
2525
 
        except IOError as e:
 
2526
 
            if e.errno == errno.ENOENT:
 
2527
 
                logger.warning("Could not load persistent state: {0}"
 
2528
 
                                .format(os.strerror(e.errno)))
 
2530
 
                logger.critical("Could not load persistent state:",
 
2533
 
        except EOFError as e:
 
2534
 
            logger.warning("Could not load persistent state: "
 
2535
 
                           "EOFError:", exc_info=e)
 
2537
 
    with PGPEngine() as pgp:
 
2538
 
        for client_name, client in clients_data.iteritems():
 
2539
 
            # Decide which value to use after restoring saved state.
 
2540
 
            # We have three different values: Old config file,
 
2541
 
            # new config file, and saved state.
 
2542
 
            # New config value takes precedence if it differs from old
 
2543
 
            # config value, otherwise use saved state.
 
2544
 
            for name, value in client_settings[client_name].items():
 
2546
 
                    # For each value in new config, check if it
 
2547
 
                    # differs from the old config value (Except for
 
2548
 
                    # the "secret" attribute)
 
2549
 
                    if (name != "secret" and
 
2550
 
                        value != old_client_settings[client_name]
 
2552
 
                        client[name] = value
 
2556
 
            # Clients who has passed its expire date can still be
 
2557
 
            # enabled if its last checker was successful.  Clients
 
2558
 
            # whose checker succeeded before we stored its state is
 
2559
 
            # assumed to have successfully run all checkers during
 
2561
 
            if client["enabled"]:
 
2562
 
                if datetime.datetime.utcnow() >= client["expires"]:
 
2563
 
                    if not client["last_checked_ok"]:
 
2565
 
                            "disabling client {0} - Client never "
 
2566
 
                            "performed a successful checker"
 
2567
 
                            .format(client_name))
 
2568
 
                        client["enabled"] = False
 
2569
 
                    elif client["last_checker_status"] != 0:
 
2571
 
                            "disabling client {0} - Client "
 
2572
 
                            "last checker failed with error code {1}"
 
2573
 
                            .format(client_name,
 
2574
 
                                    client["last_checker_status"]))
 
2575
 
                        client["enabled"] = False
 
2577
 
                        client["expires"] = (datetime.datetime
 
2579
 
                                             + client["timeout"])
 
2580
 
                        logger.debug("Last checker succeeded,"
 
2581
 
                                     " keeping {0} enabled"
 
2582
 
                                     .format(client_name))
 
2584
 
                client["secret"] = (
 
2585
 
                    pgp.decrypt(client["encrypted_secret"],
 
2586
 
                                client_settings[client_name]
 
2589
 
                # If decryption fails, we use secret from new settings
 
2590
 
                logger.debug("Failed to decrypt {0} old secret"
 
2591
 
                             .format(client_name))
 
2592
 
                client["secret"] = (
 
2593
 
                    client_settings[client_name]["secret"])
 
2595
 
    # Add/remove clients based on new changes made to config
 
2596
 
    for client_name in (set(old_client_settings)
 
2597
 
                        - set(client_settings)):
 
2598
 
        del clients_data[client_name]
 
2599
 
    for client_name in (set(client_settings)
 
2600
 
                        - set(old_client_settings)):
 
2601
 
        clients_data[client_name] = client_settings[client_name]
 
2603
 
    # Create all client objects
 
2604
 
    for client_name, client in clients_data.iteritems():
 
2605
 
        tcp_server.clients[client_name] = client_class(
 
2606
 
            name = client_name, settings = client)
 
2608
 
    if not tcp_server.clients:
 
2609
 
        logger.warning("No clients defined")
 
2612
 
        if pidfile is not None:
 
2616
 
                    pidfile.write(str(pid) + "\n".encode("utf-8"))
 
2618
 
                logger.error("Could not write to file %r with PID %d",
 
 
823
    def remove_from_clients(client):
 
 
824
        clients.remove(client)
 
 
826
            logger.critical(u"No clients left, exiting")
 
 
829
    clients.update(Set(Client(name = section,
 
 
830
                              stop_hook = remove_from_clients,
 
 
832
                              = dict(client_config.items(section)))
 
 
833
                       for section in client_config.sections()))
 
 
835
        logger.critical(u"No clients defined")
 
 
839
        # Redirect stdin so all checkers get /dev/null
 
 
840
        null = os.open(os.path.devnull, os.O_NOCTTY | os.O_RDWR)
 
 
841
        os.dup2(null, sys.stdin.fileno())
 
 
846
        logger.removeHandler(console)
 
 
847
        # Close all input and output, do double fork, etc.
 
 
852
        pidfile.write(str(pid) + "\n")
 
2623
 
    signal.signal(signal.SIGHUP, lambda signum, frame: sys.exit())
 
2624
 
    signal.signal(signal.SIGTERM, lambda signum, frame: sys.exit())
 
2627
 
        @alternate_dbus_interfaces({"se.recompile.Mandos":
 
2628
 
                                        "se.bsnet.fukt.Mandos"})
 
2629
 
        class MandosDBusService(DBusObjectWithProperties):
 
2630
 
            """A D-Bus proxy object"""
 
2632
 
                dbus.service.Object.__init__(self, bus, "/")
 
2633
 
            _interface = "se.recompile.Mandos"
 
2635
 
            @dbus_interface_annotations(_interface)
 
2637
 
                return { "org.freedesktop.DBus.Property"
 
2638
 
                         ".EmitsChangedSignal":
 
2641
 
            @dbus.service.signal(_interface, signature="o")
 
2642
 
            def ClientAdded(self, objpath):
 
2646
 
            @dbus.service.signal(_interface, signature="ss")
 
2647
 
            def ClientNotFound(self, fingerprint, address):
 
2651
 
            @dbus.service.signal(_interface, signature="os")
 
2652
 
            def ClientRemoved(self, objpath, name):
 
2656
 
            @dbus.service.method(_interface, out_signature="ao")
 
2657
 
            def GetAllClients(self):
 
2659
 
                return dbus.Array(c.dbus_object_path
 
2661
 
                                  tcp_server.clients.itervalues())
 
2663
 
            @dbus.service.method(_interface,
 
2664
 
                                 out_signature="a{oa{sv}}")
 
2665
 
            def GetAllClientsWithProperties(self):
 
2667
 
                return dbus.Dictionary(
 
2668
 
                    ((c.dbus_object_path, c.GetAll(""))
 
2669
 
                     for c in tcp_server.clients.itervalues()),
 
2672
 
            @dbus.service.method(_interface, in_signature="o")
 
2673
 
            def RemoveClient(self, object_path):
 
2675
 
                for c in tcp_server.clients.itervalues():
 
2676
 
                    if c.dbus_object_path == object_path:
 
2677
 
                        del tcp_server.clients[c.name]
 
2678
 
                        c.remove_from_connection()
 
2679
 
                        # Don't signal anything except ClientRemoved
 
2680
 
                        c.disable(quiet=True)
 
2682
 
                        self.ClientRemoved(object_path, c.name)
 
2684
 
                raise KeyError(object_path)
 
2688
 
        mandos_dbus_service = MandosDBusService()
 
 
856
        logger.error(u"Could not write to file %r with PID %d",
 
 
859
        # "pidfile" was never created
 
2691
864
        "Cleanup function; run on exit"
 
2694
 
        multiprocessing.active_children()
 
2695
 
        if not (tcp_server.clients or client_settings):
 
2698
 
        # Store client before exiting. Secrets are encrypted with key
 
2699
 
        # based on what config file has. If config file is
 
2700
 
        # removed/edited, old secret will thus be unrecovable.
 
2702
 
        with PGPEngine() as pgp:
 
2703
 
            for client in tcp_server.clients.itervalues():
 
2704
 
                key = client_settings[client.name]["secret"]
 
2705
 
                client.encrypted_secret = pgp.encrypt(client.secret,
 
2709
 
                # A list of attributes that can not be pickled
 
2711
 
                exclude = set(("bus", "changedstate", "secret",
 
2713
 
                for name, typ in (inspect.getmembers
 
2714
 
                                  (dbus.service.Object)):
 
2717
 
                client_dict["encrypted_secret"] = (client
 
2719
 
                for attr in client.client_structure:
 
2720
 
                    if attr not in exclude:
 
2721
 
                        client_dict[attr] = getattr(client, attr)
 
2723
 
                clients[client.name] = client_dict
 
2724
 
                del client_settings[client.name]["secret"]
 
2727
 
            with (tempfile.NamedTemporaryFile
 
2728
 
                  (mode='wb', suffix=".pickle", prefix='clients-',
 
2729
 
                   dir=os.path.dirname(stored_state_path),
 
2730
 
                   delete=False)) as stored_state:
 
2731
 
                pickle.dump((clients, client_settings), stored_state)
 
2732
 
                tempname=stored_state.name
 
2733
 
            os.rename(tempname, stored_state_path)
 
2734
 
        except (IOError, OSError) as e:
 
2740
 
            if e.errno in (errno.ENOENT, errno.EACCES, errno.EEXIST):
 
2741
 
                logger.warning("Could not save persistent state: {0}"
 
2742
 
                               .format(os.strerror(e.errno)))
 
2744
 
                logger.warning("Could not save persistent state:",
 
2748
 
        # Delete all clients, and settings from config
 
2749
 
        while tcp_server.clients:
 
2750
 
            name, client = tcp_server.clients.popitem()
 
2752
 
                client.remove_from_connection()
 
2753
 
            # Don't signal anything except ClientRemoved
 
2754
 
            client.disable(quiet=True)
 
2757
 
                mandos_dbus_service.ClientRemoved(client
 
2760
 
        client_settings.clear()
 
 
866
        # From the Avahi example code
 
 
867
        if not group is None:
 
 
870
        # End of Avahi example code
 
 
873
            client = clients.pop()
 
 
874
            client.stop_hook = None
 
2762
877
    atexit.register(cleanup)
 
2764
 
    for client in tcp_server.clients.itervalues():
 
2767
 
            mandos_dbus_service.ClientAdded(client.dbus_object_path)
 
2768
 
        # Need to initiate checking of clients
 
2770
 
            client.init_checker()
 
 
880
        signal.signal(signal.SIGINT, signal.SIG_IGN)
 
 
881
    signal.signal(signal.SIGHUP, lambda signum, frame: sys.exit())
 
 
882
    signal.signal(signal.SIGTERM, lambda signum, frame: sys.exit())
 
 
884
    for client in clients:
 
2772
887
    tcp_server.enable()
 
2773
888
    tcp_server.server_activate()
 
2775
890
    # Find out what port we got
 
2776
891
    service.port = tcp_server.socket.getsockname()[1]
 
2778
 
        logger.info("Now listening on address %r, port %d,"
 
2779
 
                    " flowinfo %d, scope_id %d",
 
2780
 
                    *tcp_server.socket.getsockname())
 
2782
 
        logger.info("Now listening on address %r, port %d",
 
2783
 
                    *tcp_server.socket.getsockname())
 
 
892
    logger.info(u"Now listening on address %r, port %d, flowinfo %d,"
 
 
893
                u" scope_id %d" % tcp_server.socket.getsockname())
 
2785
895
    #service.interface = tcp_server.socket.getsockname()[3]
 
2788
898
        # From the Avahi example code
 
 
899
        server.connect_to_signal("StateChanged", server_state_changed)
 
2791
 
        except dbus.exceptions.DBusException as error:
 
2792
 
            logger.critical("D-Bus Exception", exc_info=error)
 
 
901
            server_state_changed(server.GetState())
 
 
902
        except dbus.exceptions.DBusException, error:
 
 
903
            logger.critical(u"DBusException: %s", error)
 
2795
905
        # End of Avahi example code
 
2797
907
        gobject.io_add_watch(tcp_server.fileno(), gobject.IO_IN,
 
2798
908
                             lambda *args, **kwargs:
 
2799
 
                             (tcp_server.handle_request
 
2800
 
                              (*args[2:], **kwargs) or True))
 
 
909
                             tcp_server.handle_request\
 
 
910
                             (*args[2:], **kwargs) or True)
 
2802
 
        logger.debug("Starting main loop")
 
 
912
        logger.debug(u"Starting main loop")
 
 
913
        main_loop_started = True
 
2804
 
    except AvahiError as error:
 
2805
 
        logger.critical("Avahi Error", exc_info=error)
 
 
915
    except AvahiError, error:
 
 
916
        logger.critical(u"AvahiError: %s" + unicode(error))
 
2808
918
    except KeyboardInterrupt:
 
2810
 
            print("", file=sys.stderr)
 
2811
 
        logger.debug("Server received KeyboardInterrupt")
 
2812
 
    logger.debug("Server exiting")
 
2813
 
    # Must run before the D-Bus bus name gets deregistered
 
2816
922
if __name__ == '__main__':