summaryrefslogtreecommitdiff
path: root/leap/mx
diff options
context:
space:
mode:
Diffstat (limited to 'leap/mx')
-rw-r--r--leap/mx/alias_resolver.py172
1 files changed, 0 insertions, 172 deletions
diff --git a/leap/mx/alias_resolver.py b/leap/mx/alias_resolver.py
deleted file mode 100644
index 5010f63..0000000
--- a/leap/mx/alias_resolver.py
+++ /dev/null
@@ -1,172 +0,0 @@
-#!/usr/bin/env python
-# -*- encoding: utf-8 -*-
-'''
-alias_resolver.py
-=================
-Classes for resolving postfix aliases.
-
-@authors: Isis Agora Lovecruft
-@version: 0.0.1-beta
-@license: see included LICENSE file
-@copyright: copyright 2013 Isis Agora Lovecruft
-'''
-
-import os
-
-try:
- from paisley import client
-except ImportError:
- print "This software requires paisley. Please see the README file"
- print "for instructions on getting required dependencies."
-
-try:
- from twisted.internet import address, defer, reactor
- from twisted.mail import maildir, alias
- from twisted.protocols import postfix
-except ImportError:
- print "This software requires paisley. Please see the README file"
- print "for instructions on getting required dependencies."
-
-from leap.mx import net, log ## xxx implement log
-
-
-class ConnectedCouchDB(client.CouchDB):
- """
- Connect to a CouchDB instance.
-
- ## xxx will we need to open CouchDB documents and views?
- """
- def __init__(self, host, port, dbName=None,
- username=None, password=None, *args, **kwargs):
- """
- Connect to a CouchDB instance.
-
- @param host: A hostname string for the CouchDB server.
- @param port: The port of the CouchDB server, as an integer.
- @param dbName: (optional) The default database to connect to.
- @param username: (optional) The username for authorization.
- @param password: (optional) The password for authorization.
- @returns: A :class:`twisted.internet.defer.Deferred` representing the
- the client connection to the CouchDB instance.
- """
- super(client.CouchDB, self).__init__(host, port,
- dbName=dbName,
- username=username,
- password=password,
- *args, **kwargs)
-
- def query(self, uri):
- """
- Query a CouchDB instance that we are connected to.
- """
- try:
- self.checkURI(uri) ## xxx write checkURI()
- ## xxx we might be able to use self._parseURI()
- except SchemeNotSupported, sns: ## xxx where in paisley is this?
- log.exception(sns) ## xxx need log.exception()
-
- d = self.get(uri)
- @d.addCallback
- def parse_answer(answer):
- return answer
-
- return answer
-
- @defer.inlineCallbacks
- def listUsersAndEmails(self, limit=1000, reverse=False):
- """
- List all users and email addresses, up to the given limit.
- """
- query = "/users/_design/User/_view/by_email_or_alias/?reduce=false"
- answer = yield self.query(query, limit=limit, reverse=reverse)
-
- if answer:
- parsed = yield self.parseResult(answer)
- if parsed:
- log.msg("%s" % parsed)
- else:
- log.msg("No answer from database, perhaps there are no users.")
- else:
- log.msg("Problem querying CouchDB instance...")
- log.debug("Host: %s" % host)
- log.debug("Port: %d" % port)
-
-class PostfixAliasResolver(postfix.PostfixTCPMapServer):
- """
- Resolve postfix aliases, similarly to using "$ postmap -q <alias>".
-
- This class starts a simple LineReceiver server which listens for a string
- specifying an alias to look up, :param:`key`, and which will be used to
- query the local Postfix server. You can test it with:
-
- $ ./alias_resolver.py &
- $ /usr/bin/postmap -q <key> tcp:localhost:4242
-
- """
- def __init__(self, *args, **kwargs):
- """
- Create a local LineReceiver server which listens for Postfix aliases
- to resolve.
- """
- super(postfix.PostfixTCPMapServer, self).__init__(*args, **kwargs)
-
-
-class PostfixAliasResolverFactory(postfix.PostfixTCPMapDeferringDictServerFactory):
- """
- A Factory for creating PostfixAliasResolver servers, which handles inputs
- and outputs, and keeps an in-memory mapping of Postfix aliases in the form
- of a dict.
-
- xxx fill me in
-
- """
- protocol = PostfixAliasResolver
-
- def __init__(self, addr='127.0.0.1', port=4242, timeout=120, data=None):
- """
- Create a Factory which returns :class:`PostfixAliasResolver` servers.
-
- @param addr:
- (optional) A string giving the IP address of the Postfix server.
- Default: '127.0.0.1'
- @param port:
- (optional) An integer that specifies the port number of the
- Postfix server. Default: 4242
- @param timeout:
- (optional) An integer specifying the number of seconds to wait
- until we should time out. Default: 120
- @param data:
- (optional) A dict to use to initialise or update the alias
- mapping.
- """
- super(postfix.PostfixTCPMapDeferringDictServerFactory,
- self).__init__(data=data)
- self.timeout = timeout
- ## xxx get config value, should be something like verbose = no
- self.noisy = False
-
- try:
- assert isinstance(port, int), "Port number must be an integer"
- assert isinstance(timeout, int), "Timeout must be an integer"
- except AssertionError, ae:
- raise SystemExit(ae.message)
-
- if net.checkIPaddress(addr):
- self.addr = address._IPAddress('TCP', addr, int(port))
- else:
- log.debug("Using default address for Postfix: 127.0.0.1:%s" % port)
- self.addr = address._IPAddress('TCP', '127.0.0.1', int(port))
-
- def buildProtocol(self):
- """
- Create an instance of the :class:`PostfixAliasResolver` server.
- """
- proto = self.protocol()
- proto.timeout = self.timeout
- proto.factory = self
- return proto
-
-
-if __name__ == "__main__":
-
- print "To test alias_resolver.py, please use /test/test_alias_resolver.py"