diff options
Diffstat (limited to 'mailman/queue/lmtp.py')
| -rw-r--r-- | mailman/queue/lmtp.py | 218 |
1 files changed, 0 insertions, 218 deletions
diff --git a/mailman/queue/lmtp.py b/mailman/queue/lmtp.py deleted file mode 100644 index 3ac8796ca..000000000 --- a/mailman/queue/lmtp.py +++ /dev/null @@ -1,218 +0,0 @@ -# Copyright (C) 2006-2009 by the Free Software Foundation, Inc. -# -# This file is part of GNU Mailman. -# -# GNU Mailman 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, either version 3 of the License, or (at your option) -# any later version. -# -# GNU Mailman 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 General Public License for -# more details. -# -# You should have received a copy of the GNU General Public License along with -# GNU Mailman. If not, see <http://www.gnu.org/licenses/>. - -"""Mailman LMTP runner (server). - -Most mail servers can be configured to deliver local messages via 'LMTP'[1]. -This module is actually an LMTP server rather than a standard queue runner. - -The LMTP runner opens a local TCP port and waits for the mail server to -connect to it. The messages it receives over LMTP are very minimally parsed -for sanity and if they look okay, they are accepted and injected into -Mailman's incoming queue for normal processing. If they don't look good, or -are destined for a bogus sub-address, they are rejected right away, hopefully -so that the peer mail server can provide better diagnostics. - -[1] RFC 2033 Local Mail Transport Protocol - http://www.faqs.org/rfcs/rfc2033.html -""" - -import email -import smtpd -import logging -import asyncore - -from email.utils import parseaddr - -from mailman.Message import Message -from mailman.config import config -from mailman.database.transaction import txn -from mailman.queue import Runner - -elog = logging.getLogger('mailman.error') -qlog = logging.getLogger('mailman.qrunner') - - -# We only care about the listname and the sub-addresses as in listname@ or -# listname-request@ -SUBADDRESS_NAMES = ( - 'bounces', 'confirm', 'join', ' leave', - 'owner', 'request', 'subscribe', 'unsubscribe', - ) - -DASH = '-' -CRLF = '\r\n' -ERR_451 = '451 Requested action aborted: error in processing' -ERR_501 = '501 Message has defects' -ERR_502 = '502 Error: command HELO not implemented' -ERR_550 = '550 Requested action not taken: mailbox unavailable' - -# XXX Blech -smtpd.__version__ = 'Python LMTP queue runner 1.0' - - - -def split_recipient(address): - """Split an address into listname, subaddress and domain parts. - - For example: - - >>> split_recipient('mylist@example.com') - ('mylist', None, 'example.com') - - >>> split_recipient('mylist-request@example.com') - ('mylist', 'request', 'example.com') - - :param address: The destination address. - :return: A 3-tuple of the form (list-shortname, subaddress, domain). - subaddress may be None if this is the list's posting address. - """ - localpart, domain = address.split('@', 1) - localpart = localpart.split(config.mta.verp_delimiter, 1)[0] - parts = localpart.split(DASH) - if parts[-1] in SUBADDRESS_NAMES: - listname = DASH.join(parts[:-1]) - subaddress = parts[-1] - else: - listname = localpart - subaddress = None - return listname, subaddress, domain - - - -class Channel(smtpd.SMTPChannel): - """An LMTP channel.""" - - def __init__(self, server, conn, addr): - smtpd.SMTPChannel.__init__(self, server, conn, addr) - # Stash this here since the subclass uses private attributes. :( - self._server = server - - def smtp_LHLO(self, arg): - """The LMTP greeting, used instead of HELO/EHLO.""" - smtpd.SMTPChannel.smtp_HELO(self, arg) - - def smtp_HELO(self, arg): - """HELO is not a valid LMTP command.""" - self.push(ERR_502) - - - -class LMTPRunner(Runner, smtpd.SMTPServer): - # Only __init__ is called on startup. Asyncore is responsible for later - # connections from the MTA. slice and numslices are ignored and are - # necessary only to satisfy the API. - def __init__(self, slice=None, numslices=1): - localaddr = config.mta.lmtp_host, int(config.mta.lmtp_port) - # Do not call Runner's constructor because there's no QDIR to create - smtpd.SMTPServer.__init__(self, localaddr, remoteaddr=None) - qlog.debug('LMTP server listening on %s:%s', - localaddr[0], localaddr[1]) - - def handle_accept(self): - conn, addr = self.accept() - channel = Channel(self, conn, addr) - qlog.debug('LMTP accept from %s', addr) - - @txn - def process_message(self, peer, mailfrom, rcpttos, data): - try: - # Refresh the list of list names every time we process a message - # since the set of mailing lists could have changed. - listnames = set(config.db.list_manager.names) - qlog.debug('listnames: %s', listnames) - # Parse the message data. If there are any defects in the - # message, reject it right away; it's probably spam. - msg = email.message_from_string(data, Message) - msg.original_size = len(data) - if msg.defects: - return ERR_501 - msg['X-MailFrom'] = mailfrom - except Exception, e: - elog.exception('LMTP message parsing') - config.db.abort() - return CRLF.join(ERR_451 for to in rcpttos) - # RFC 2033 requires us to return a status code for every recipient. - status = [] - # Now for each address in the recipients, parse the address to first - # see if it's destined for a valid mailing list. If so, then queue - # the message to the appropriate place and record a 250 status for - # that recipient. If not, record a failure status for that recipient. - for to in rcpttos: - try: - to = parseaddr(to)[1].lower() - listname, subaddress, domain = split_recipient(to) - qlog.debug('to: %s, list: %s, sub: %s, dom: %s', - to, listname, subaddress, domain) - listname += '@' + domain - if listname not in listnames: - status.append(ERR_550) - continue - # The recipient is a valid mailing list; see if it's a valid - # sub-address, and if so, enqueue it. - queue = None - msgdata = dict(listname=listname, - original_size=msg.original_size) - if subaddress in ('bounces', 'admin'): - queue = 'bounce' - elif subaddress == 'confirm': - msgdata['toconfirm'] = True - queue = 'command' - elif subaddress in ('join', 'subscribe'): - msgdata['tojoin'] = True - queue = 'command' - elif subaddress in ('leave', 'unsubscribe'): - msgdata['toleave'] = True - queue = 'command' - elif subaddress == 'owner': - msgdata.update(dict( - toowner=True, - envsender=config.mailman.site_owner, - )) - queue = 'in' - elif subaddress is None: - msgdata['tolist'] = True - queue = 'in' - elif subaddress == 'request': - msgdata['torequest'] = True - queue = 'command' - else: - elog.error('Unknown sub-address: %s', subaddress) - status.append(ERR_550) - continue - # If we found a valid subaddress, enqueue the message and add - # a success status for this recipient. - if queue is not None: - config.switchboards[queue].enqueue(msg, msgdata) - status.append('250 Ok') - except Exception, e: - elog.exception('Queue detection: %s', msg['message-id']) - config.db.abort() - status.append(ERR_550) - # All done; returning this big status string should give the expected - # response to the LMTP client. - return CRLF.join(status) - - def run(self): - """See `IRunner`.""" - asyncore.loop() - - def stop(self): - """See `IRunner`.""" - asyncore.socket_map.clear() - asyncore.close_all() - self.close() |