U  W[@sdZddlmZddlmZddlmZddlZz ddlZ Wne k rXddl Z YnXGdddZ Gdd d Z Gd d d e ej ZGd d d e ejZdS)z Support for relaying mail. )smtp)log) UNIXAddressNc@s2eZdZdZd ddZddZddZd d Zd S) DomainQueuerzM An SMTP domain which add messages to a queue intended for relaying. FcCs||_||_dSN)serviceauthed)selfrZ authenticatedr 4/usr/lib/python3/dist-packages/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 3z%DomainQueuer.exists..) willRelaydestprotocolfilterstrorigsplitlenrZ SMTPBadRcpt)r rrrr rr exists s 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)Z transportZgetPeerr isinstancerZhost)r ZaddressrZpeerr r r r7s zDomainQueuer.willRelayc Csb|jj}|\}}|@tdt|jt|jft 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 %r -> %r) rqueueZcreateNewMessagermsgrrrpickledump)r rrZ envelopeFileZ smtpMessager r r rCs  &zDomainQueuer.startMessageN)F)__name__ __module__ __qualname____doc__r rrrr r r r rs   rc@s4eZdZddZddZddZddZd d Zd S) RelayerMixinc Csjg|_g|_|D]T}t|d}t|}W5QRXt|d}|||j||j|qdS)N-H-D)messagesnamesopenr!loadappend)r messagePathsmessagefpZmessageContentsr r r loadMessages]s   zRelayerMixin.loadMessagescCs|js dS|jddS)Nrr*r r r r getMailFromiszRelayerMixin.getMailFromcCs|js dS|jddgS)Nrrr3r4r r r getMailTooszRelayerMixin.getMailTocCs|js dS|jddS)Nrrr3r4r r r getMailDatauszRelayerMixin.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)rSUCCESSosremover+r*)r codeZrespZnumOkZ addressesrr r r sentMail{s  zRelayerMixin.sentMailN)r#r$r%r2r5r6r7r<r r r r r'Ws  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 r2r r/argskwr r r r s zSMTPRelayer.__init__Nr#r$r%r&r r r r r r=sr=c@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 r2r?r r r r szESMTPRelayer.__init__NrBr r r r rCsrC)r&Z twisted.mailrZtwisted.pythonrZtwisted.internet.addressrr9ZcPickler! ImportErrorrr'r>r=rDrCr r r r s    A2