diff options
| -rw-r--r-- | configure.ac | 1 | ||||
| -rwxr-xr-x | saslauthd.py | 42 | ||||
| -rw-r--r-- | saslauthd/Makefile.am | 2 | ||||
| -rw-r--r-- | saslauthd/__init__.py | 133 |
4 files changed, 178 insertions, 0 deletions
diff --git a/configure.ac b/configure.ac index 3b4bb20..ea9bb48 100644 --- a/configure.ac +++ b/configure.ac @@ -26,6 +26,7 @@ kolabd/Makefile po/Makefile.in pykolab/constants.py pykolab/Makefile +saslauthd/Makefile ]) AC_OUTPUT diff --git a/saslauthd.py b/saslauthd.py new file mode 100755 index 0000000..40194c2 --- /dev/null +++ b/saslauthd.py @@ -0,0 +1,42 @@ +#!/usr/bin/python +# +# Copyright 2010-2011 Kolab Systems AG (http://www.kolabsys.com) +# +# Jeroen van Meeuwen (Kolab Systems) <vanmeeuwen a kolabsys.com> +# +# This program is free software; you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation; version 3 or, at your option, any later version +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU Library General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program; if not, write to the Free Software +# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. +# + +import logging +import os +import sys + +# For development purposes +sys.path.extend(['.', '..']) + +from pykolab.translate import _ + +try: + import pykolab.logger +except ImportError, e: + print >> sys.stderr, _("Cannot load pykolab/logger.py:") + print >> sys.stderr, "%s" % e + sys.exit(1) + +import saslauthd + +if __name__ == "__main__": + saslauthd = saslauthd.SASLAuthDaemon() + saslauthd.run() + diff --git a/saslauthd/Makefile.am b/saslauthd/Makefile.am new file mode 100644 index 0000000..5f4fa80 --- /dev/null +++ b/saslauthd/Makefile.am @@ -0,0 +1,2 @@ +saslauthddir = $(datadir)/$(PACKAGE)/saslauthd +saslauthd_PYTHON = $(wildcard *.py) diff --git a/saslauthd/__init__.py b/saslauthd/__init__.py new file mode 100644 index 0000000..d9f3025 --- /dev/null +++ b/saslauthd/__init__.py @@ -0,0 +1,133 @@ +# Copyright 2010-2011 Kolab Systems AG (http://www.kolabsys.com) +# +# Jeroen van Meeuwen (Kolab Systems) <vanmeeuwen a kolabsys.com> +# +# This program is free software; you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation; version 3 or, at your option, any later version +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU Library General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program; if not, write to the Free Software +# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. +# + +from optparse import OptionParser +from ConfigParser import SafeConfigParser + +import os +import shutil +import time +import traceback + +from pykolab.auth import Auth +from pykolab.conf import Conf +from pykolab.constants import * +from pykolab.translate import _ + +class SASLAuthDaemon(object): + def __init__(self): + """ + self.args == Arguments passed on the CLI + self.cli_options == Parser results (again, CLI) + self.parser == The actual Parser (from OptionParser) + self.plugins == Our Kolab Plugins + """ + + self.conf = Conf() + + daemon_group = self.conf.parser.add_option_group(_("Daemon Options")) + + daemon_group.add_option( "--fork", + dest = "fork_mode", + action = "store_true", + default = False, + help = _("Fork to the background.")) + + self.conf.finalize_conf() + + self.log = self.conf.log + + def run(self): + """Run Forest, RUN!""" + + exitcode = 0 + + try: + pid = 1 + if self.conf.fork_mode: + self.thread_count += 1 + pid = os.fork() + + if pid == 0: + self.log.remove_stdout_handler() + + self.do_saslauthd() + + except SystemExit, e: + exitcode = e + except KeyboardInterrupt: + exitcode = 1 + self.log.info(_("Interrupted by user")) + except AttributeError, e: + exitcode = 1 + traceback.print_exc() + print >> sys.stderr, _("Traceback occurred, please report a bug at http://issues.kolab.org") + except TypeError, e: + exitcode = 1 + traceback.print_exc() + self.log.error(_("Type Error: %s") % e) + except: + exitcode = 2 + traceback.print_exc() + print >> sys.stderr, _("Traceback occurred, please report a bug at http://issues.kolab.org") + sys.exit(exitcode) + + def do_saslauthd(self): + import binascii + import socket + import struct + + s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) + + # TODO: The saslauthd socket path could be a setting. + try: + os.remove('/var/run/saslauthd/mux') + except: + # TODO: Do the "could not remove, could not start dance" + pass + + s.bind('/var/run/saslauthd/mux') + os.chmod('/var/run/saslauthd/mux', 0777) + + s.listen(5) + + while 1: + (clientsocket, address) = s.accept() + received = clientsocket.recv(4096) + + login = [] + + start = 0 + end = 2 + + while end < len(received): + (length,) = struct.unpack("!H", received[start:end]) + start += 2 + end += length + (value,) = struct.unpack("!%ds" %(length), received[start:end]) + start += length + end = start + 2 + login.append(value) + + auth = Auth(self.conf) + if auth.authenticate(login): + clientsocket.send(struct.pack("!H2s", 2, "OK")) + else: + clientsocket.send(struct.pack("!H2s", 2, "NO")) + + clientsocket.close() |