~mmlmtp/mailman/mm3lmtp

DASH    = '-'

CRLF    = '\r\n'

# These error codes are now obsolete. The LMTP protocol now uses enhanced error codes 

 

# Enhanced error codes

EERR_200 = '2.0.0'

 

class Channel(asynchat.async_chat):

    """An LMTP channel."""

    # It is a complete working LMTP channel, based on smtpd in Python

    

    COMMAND = 0

    # The LHLO boolean determines if the LHLO command has been used or not during a session

    # False = LHLO has not been used

    # True = LHLO has been used

    LHLO = False

 

    def __init__(self, server, conn, addr):

        self._fqdn = socket.getfqdn()

        self._peer = conn.getpeername()

        self.set_terminator('\r\n')

 

 

    # smtp_HELO pushs an error if the HELO command is used

    def smtp_HELO(self, arg):

        return

 

    # smtp_EHLO pushs an error if the EHLO command is used

    def smtp_EHLO(self, arg):

        return

 

    def smtp_LHLO(self, arg):

        """HELO is not a valid LMTP command."""

        if not arg:

            return

        if self._greeting:

        else:

            self.LHLO = True

            self._greeting = arg

 

    def smtp_MAIL(self, arg):

        if self.LHLO == False:

            return

        address = self._getaddr('FROM:', arg) if arg else None

        if not address:

            return

        if self._mailfrom:

            return

        self._mailfrom = address

 

 

    def smtp_RCPT(self, arg):

        if not self._mailfrom:

            return

        address = self._getaddr('TO:', arg) if arg else None

        if not address:

            return

        # Call rcpttocheck to check if list address is a known address.

        if self.rcpttocheck(address) == 'EERR_511':

            return

        # get subaddress

        listname = self.listname(address)

        # Check if sender is authorised to post to list 

        if not subaddress in SUBADDRESS_NAMES:

            if self.listmembercheck(self._mailfrom, address) == 'EERR_572':

                return   

        if subaddress in SUBADDRESS_NAMES:

            if self.listmembercheck(self._mailfrom, listname) == 'EERR_572':

                    self.push('550 '+EERR_572+', the subaddresses -leave and -unsubscribe can not be used by unauthorised senders')

                    return

        self._rcpttos.append(address)

 

    def smtp_DATA(self, arg):

        if not self._rcpttos:

            return

        if arg:

            self.push('501 '+EERR_554+' Syntax: DATA')

 

    def smtp_RSET(self, arg):

        if arg:

            return

        # Resets the sender, recipients, and data, but not the greeting

        self._mailfrom = None

        self._rcpttos = []

        self._data = ''

        self._state = self.COMMAND

 

    def smtp_NOOP(self, arg):

        if arg:

        else:

            self.push('250 '+EERR_200+' Ok')

 

        self._line = []

        if self._state == self.COMMAND:

            if not line:

                return

            method = None

            i = line.find(' ')

                arg = line[i+1:].strip()

            method = getattr(self, 'smtp_' + command, None)

            if not method:

                return

            method(arg)

            return

        else:

            if self._state != self.DATA:

                return

            # Remove extraneous carriage returns and de-transparency according

            # to RFC 821, Section 4.5.2.

        except Exception, e:

            elog.exception('LMTP message parsing')

            config.db.abort()

        # 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