U P|j@sdZddlZddlZddlmZddlmZddlmZGdddZ Gdd d Z Gd d d e ej Z Gd d d e ej ZdS)z Support for relaying mail. N) UNIXAddress)smtp)logc@s2eZdZdZd ddZddZddZd d Zd S) DomainQueuerzM An SMTP domain which add messages to a queue intended for relaying. FcCs||_||_dSN)serviceauthed)selfr authenticatedr 6/tmp/pip-unpacked-wheel-audpp6lv/twisted/mail/relay.py__init__szDomainQueuer.__init__cstjjrftdtjdd}tdtjdd}t|dkrft|dkrffddSt dS)a Check whether mail can be relayed to a user. @type user: L{User} @param user: A user. @rtype: no-argument callable which returns L{IMessage } provider @return: A function which takes no arguments and returns a message receiver for the user. @raise SMTPBadRcpt: When mail cannot be relayed to the user. N@cs Sr) startMessager r userr r -z%DomainQueuer.exists..) willRelaydestprotocolfilterstrorigsplitlenrZ SMTPBadRcpt)r rrrr rr existss zDomainQueuer.existscCs$|j}|jp"t|tp"|jdkS)z Check whether we agree to relay. The default is to relay for all connections over UNIX sockets and all connections from localhost. z 127.0.0.1) transportZgetPeerr isinstancerhost)r addressrZpeerr r r r0s zDomainQueuer.willRelayc Csf|jj}|\}}|Dtdt|jdt|jt t|jt|jg|W5QRX|S)z Create an envelope and a message receiver for the relay queue. @type user: L{User} @param user: A user. @rtype: L{IMessage } @return: A message receiver. zQueueing mail z -> ) rqueueZcreateNewMessagermsgrrrpickledump)r rr#Z envelopeFileZ smtpMessager r r r:s  "&zDomainQueuer.startMessageN)F)__name__ __module__ __qualname____doc__r rrrr r r r rs   rc@s4eZdZddZddZddZddZd d Zd S) RelayerMixinc Cslg|_g|_|D]V}t|dd}t|}W5QRXt|d}|||j||j|qdS)N-Hrb-D)messagesnamesopenr%loadappend)r messagePathsmessagefpZmessageContentsr r r loadMessagesQs   zRelayerMixin.loadMessagescCs|js dS|jddS)Nrr/r r r r getMailFrom\szRelayerMixin.getMailFromcCs|js dS|jddgS)Nrrr8r9r r r getMailToaszRelayerMixin.getMailTocCs|js dS|jddS)Nrrr8r9r r r getMailDatafszRelayerMixin.getMailDatacCsF|tjkr2t|jddt|jdd|jd=|jd=dS)zSince we only use one recipient per envelope, this will be called with 0 or 1 addresses. We probably want to do something with the error message if we failed. rr.r,N)rSUCCESSosremover0r/)r coderespZnumOk addressesrr r r sentMailks  zRelayerMixin.sentMailN)r'r(r)r7r:r;r<rCr r r r r+Ls  r+c@seZdZdZddZdS) SMTPRelayerz) A base class for SMTP relayers. cOs"tjj|f||||dS)a @type messagePaths: L{list} of L{bytes} @param messagePaths: The base filename for each message to be relayed. @type args: 1-L{tuple} of (0) L{bytes} or 2-L{tuple} of (0) L{bytes}, (1) L{int} @param args: Positional arguments for L{SMTPClient.__init__} @type kw: L{dict} @param kw: Keyword arguments for L{SMTPClient.__init__} N)r SMTPClientr r7r r4argskwr r r r }s zSMTPRelayer.__init__Nr'r(r)r*r r r r r rDxsrDc@seZdZdZddZdS) ESMTPRelayerz* A base class for ESMTP relayers. cOs"tjj|f||||dS)a @type messagePaths: L{list} of L{bytes} @param messagePaths: The base filename for each message to be relayed. @type args: 3-L{tuple} of (0) L{bytes}, (1) L{None} or L{ClientContextFactory }, (2) L{bytes} or 4-L{tuple} of (0) L{bytes}, (1) L{None} or L{ClientContextFactory }, (2) L{bytes}, (3) L{int} @param args: Positional arguments for L{ESMTPClient.__init__} @type kw: L{dict} @param kw: Keyword arguments for L{ESMTPClient.__init__} N)r ESMTPClientr r7rFr r r r szESMTPRelayer.__init__NrIr r r r rJsrJ)r*r>r%Ztwisted.internet.addressrZ twisted.mailrZtwisted.pythonrrr+rErDrKrJr r r r s   ;,