hSrSSKrSSKrSSKJr SSKJr SSKJr "SS5r "SS 5r "S S \ \R5r "S S \ \R5rg)z Support for relaying mail. N) UNIXAddress)smtp)logc4\rSrSrSrS SjrSrSrSrSr g) DomainQueuerzE An SMTP domain which add messages to a queue intended for relaying. cXlX lgN)serviceauthed)selfr authenticateds Y/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/mail/relay.py__init__DomainQueuer.__init__s  # c^^TRTRTR5(a[S[ TR 5R SS55n[S[ TR5R SS55n[U5S:Xa[U5S:XaUU4Sj$[R"T5e)aI 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&>TRT5$r ) startMessage)r usersr%DomainQueuer.exists..-st006r) willRelaydestprotocolfilterstrorigsplitlenr SMTPBadRcpt)r rr!rs`` rexistsDomainQueuer.existss >>$))T]] 3 3$DII 4 4S! <=D$DII 4 4S! <=D4yA~#d)q.66t$$rcURR5nUR=(d& [U[5=(d UR S:H$)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 rrDomainQueuer.willRelay0s<!!))+{{Wj{;WtyyK?WWrc URRnUR5up4U [R"S[ UR 5<S[ UR5<35 [R"[ UR 5[ UR5/U5 SSS5 U$!,(df  U$=f)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 queuecreateNewMessagermsgr r!rpickledump)r rr0 envelopeFile smtpMessages rrDomainQueuer.startMessage:s ""$)$:$:$<!  GGnS^$6d3tyy>:LM N KKTYYTYY8, G\s BB99 C)r r N)F) __name__ __module__ __qualname____firstlineno____doc__rr%rr__static_attributes__rrrrs$%,Xrrc2\rSrSrSrSrSrSrSrSr g) RelayerMixinLcZ/Ul/UlUHn[US-S5n[R"U5nSSS5 [US-5nWR U5 URR U5 URR U5 M g!,(df  Nh=f)N-Hrb-D)messagesnamesopenr3loadappend)r messagePathsmessagefpmessageContentss r loadMessagesRelayerMixin.loadMessagesQs  #Ggnd+r"(++b/,gn%B  " "2 & MM  1 JJ  g & $++s B B* cJUR(dgURSS$)NrrFr s r getMailFromRelayerMixin.getMailFrom\ }}}}Q""rcLUR(dgURSS/$)NrrrRrSs r getMailToRelayerMixin.getMailToas#}} a #$$rcJUR(dgURSS$)NrrrRrSs r getMailDataRelayerMixin.getMailDatafrVrcU[R;aL[R"URSS-5 [R"URSS-5 UR S URS g)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. rrErCN)rSUCCESSosremoverGrF)r coderespnumOk addressesrs rsentMailRelayerMixin.sentMailksY 4<<  IIdjjmd* + IIdjjmd* + MM!  JJqMr)rFrGN) r8r9r:r;rOrTrXr[rer=r>rrr@r@Ls '# % # rr@c\rSrSrSrSrSrg) SMTPRelayerxz! A base class for SMTP relayers. cn[RR"U/UQ70UD6 URU5 g)aN @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 SMTPClientrrOr rKargskws rrSMTPRelayer.__init__}s.   333 ,'rr>Nr8r9r:r;r<rr=r>rrrhrhxs  (rrhc\rSrSrSrSrSrg) ESMTPRelayerz" A base class for ESMTP relayers. cn[RR"U/UQ70UD6 URU5 g)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 ESMTPClientrrOrls rrESMTPRelayer.__init__s0" !!$444 ,'rr>Nrpr>rrrrrrs (rrr)r<r_r3twisted.internet.addressr twisted.mailrtwisted.pythonrrr@rkrhrurrr>rrrzsW  088v))X(,(*(<!1!1(r