\ddZddlZddlZddlmZddlmZddlmZGddZ Gdd Z Gd d e ej Z Gd d e ej ZdS)z Support for relaying mail. N) UNIXAddress)smtp)logc,eZdZdZddZdZdZdZdS) DomainQueuerzM An SMTP domain which add messages to a queue intended for relaying. Fc"||_||_dSN)serviceauthed)selfr authenticateds 2lib/python3.11/site-packages/twisted/mail/relay.py__init__zDomainQueuer.__init__s # cjjrtdt jdd}tdt jdd}t|dkrt|dkrfdStj )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@c.Sr ) startMessage)r usersrz%DomainQueuer.exists..-st0066r) willRelaydestprotocolfilterstrorigsplitlenr SMTPBadRcpt)r rrrs`` rexistszDomainQueuer.existss >>$)T] 3 3 7$DI 4 4S! < <==D$DI 4 4S! < <==D4yyA~~#d))q..666666t$$$rc|j}|jpt|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) transportgetPeerr isinstancerhost)r addressrpeers rrzDomainQueuer.willRelay0s;!))++{Wj{;;WtyK?WWrc r|jj}|\}}|5tjdt |jdt |jtj t |jt |jg|dddn #1swxYwY|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 -> N) r queuecreateNewMessagermsgrrrpickledump)r rr+ envelopeFile smtpMessages rrzDomainQueuer.startMessage:s "$)$:$:$<$<! k  H H GMS^^MM3ty>>MM N N N KTYTY8, G G G H H H H H H H H H H H H H H HsA:B,,B03B0N)F)__name__ __module__ __qualname____doc__rr"rrrrrrsb$$$$%%%,XXXrrc,eZdZdZdZdZdZdZdS) RelayerMixinc`g|_g|_|D]}t|dzd5}tj|}dddn #1swxYwYt|dz}|||j||j|dS)N-Hrb-D)messagesnamesopenr.loadappend)r messagePathsmessagefpmessageContentss r loadMessageszRelayerMixin.loadMessagesRs  # ' 'Ggnd++ 2r"(+b// 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2gn%%B  " "2 & & & M  1 1 1 J  g & & & &  ' 'sAA A c:|jsdS|jddS)Nrr=r s r getMailFromzRelayerMixin.getMailFrom]#} 4}Q""rc<|jsdS|jddgS)NrrrHrIs r getMailTozRelayerMixin.getMailTobs&} 4 a #$$rc:|jsdS|jddS)NrrrHrIs r getMailDatazRelayerMixin.getMailDatagrKrc|tjvrDtj|jddztj|jddz|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 coderespnumOk addressesrs rsentMailzRelayerMixin.sentMaills^ 4<   Idjmd* + + + Idjmd* + + + M!  JqMMMrN)r2r3r4rFrJrMrOrXr6rrr8r8Ls_ ' ' '### %%% ###     rr8ceZdZdZdZdS) SMTPRelayerz) A base class for SMTP relayers. cdtjj|g|Ri|||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 SMTPClientrrFr rBargskws rrzSMTPRelayer.__init__~sA  3333333 ,'''''rNr2r3r4r5rr6rrrZrZys- ( ( ( ( (rrZceZdZdZdZdS) ESMTPRelayerz* A base class for ESMTP relayers. cdtjj|g|Ri|||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 ESMTPClientrrFr]s rrzESMTPRelayer.__init__sB" !$4444444 ,'''''rNr`r6rrrbrbs-(((((rrb)r5rRr.twisted.internet.addressr twisted.mailrtwisted.pythonrrr8r\rZrdrbr6rrrhs  00000088888888v********Z(((((,(((*(((((<!1(((((r