h].SrSSKrSSKrSSKJr SSKJrJrJr SSK J r SSK J r SSK JrJr SrSS jr"S S 5r\"\ 5"S S \55r\"\ R(5"SS55r\"\ 5"SS\55r"SS\5r\"\ R(5"SS55r"SS\R45r\"\ 5"SS\55r\"\ R(5"SS55r\"\ 5"SS\55rg)zD Support for aliases(5) configuration files. @author: Jp Calderone N) implementer)deferprotocolreactor)smtp)IAlias)failurelogczURSS5Vs/sHoDR5PM nn[U5S:waSnX24n[R"Xg-5 gUupUR UR5/5R [[RU RS555 gs snf)a Parse a line from an aliases file. @type result: L{dict} mapping L{bytes} to L{list} of L{bytes} @param result: A dictionary mapping username to aliases to which the results of parsing the line are added. @type line: L{bytes} @param line: A line from an aliases file. @type filename: L{bytes} @param filename: The full or relative path to the aliases file. @type lineNo: L{int} @param lineNo: The position of the line within the aliases file. :z+Invalid format on line %d of alias file %s.,N) splitstriplenr err setdefaultextendmapstr) resultlinefilenamelineNoppartsfmtarguseraliass Y/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/mail/alias.pyhandler#s"!% 3 2 3 21WWY 2E 3 5zQ;    $**,+223syy%++cBR3ST 4sB8cF0nSnUc[U5nSnO [USS5nSnSnUHnUS- nUR5nUR5R S5(aM>UR S 5(dUR S 5(aXg-nMpU(a [ X6X5 UnM U(aUR 5 U(a [ X6X5 UR5Hup[XU5X8'M U$!U(aUR 5 ff=f) a: Load a file containing email aliases. Lines in the file should be formatted like so:: username: alias1, alias2, ..., aliasN Aliases beginning with a C{|} will be treated as programs, will be run, and the message will be written to their stdin. Aliases beginning with a C{:} will be treated as a file containing additional aliases for the username. Aliases beginning with a C{/} will be treated as the full pathname to a file to which the message will be appended. Aliases without a host part will be assumed to be addresses on localhost. If a username is specified multiple times, the aliases for each are joined together as if they had all been on one line. Lines beginning with a space or a tab are continuations of the previous line. Lines beginning with a C{#} are comments. @type domains: L{dict} mapping L{bytes} to L{IDomain} provider @param domains: A mapping of domain name to domain object. @type filename: L{bytes} or L{None} @param filename: The full or relative path to a file from which to load aliases. If omitted, the C{fp} parameter must be specified. @type fp: file-like object or L{None} @param fp: The file from which to load aliases. If specified, the C{filename} parameter is ignored. @rtype: L{dict} mapping L{bytes} to L{AliasGroup} @return: A mapping from username to group of aliases. FTnamez rr #  ) opengetattrrstriplstrip startswithr#closeitems AliasGroup) domainsrfprr/iprevruas r" loadAliasFiler83sRF E z (^2v{3 A DD FA;;=D{{}'',,%%)>)>{65  HHJ vX) q1-  M  HHJ s B DD c.\rSrSrSrSrSrSSjrSrg) AliasBase{z The default base class for aliases. @ivar domains: See L{__init__}. @type original: L{Address} @ivar original: The original address being aliased. cFXl[R"U5Ulg)z @type domains: L{dict} mapping L{bytes} to L{IDomain} provider @param domains: A mapping of domain name to domain object. @type original: L{bytes} @param original: The original address being aliased. N)r2rAddressoriginal)selfr2r>s r"__init__AliasBase.__init__s  X. cHURURR$)z Return the domain associated with original address. @rtype: L{IDomain} provider @return: The domain for the original address. )r2r>domainr?s r"rDAliasBase.domains||DMM0011rBNchUc0n[U5U;agSU[U5'UR5$a Map this alias to its ultimate destination. @type aliasmap: L{dict} mapping L{bytes} to L{AliasBase} @param aliasmap: A mapping of username to alias or group of aliases. @type memo: L{None} or L{dict} of L{AliasBase} @param memo: A record of the aliases already considered in the resolution process. If provided, C{memo} is modified to include this alias. @rtype: L{IMessage } or L{None} @return: A message receiver for the ultimate destination or None for an invalid destination. N)rcreateMessageReceiverr?aliasmapmemos r"resolveAliasBase.resolves9 <D t9 SY))++rB)r2r>N) __name__ __module__ __qualname____firstlineno____doc__r@rDrM__static_attributes__rBr"r:r:{s /2,rBr:c<\rSrSrSrSrS\4SjrSrS Sjr S r g) AddressAliasz{ An alias which translates one email address into another. @type alias : L{Address} @ivar alias: The destination address. ch[R"U/UQ76 [R"U5Ulg)a @type alias: L{Address}, L{User}, L{bytes} or object which can be converted into L{bytes} @param alias: The destination address. @type args: 2-L{tuple} of (0) L{dict} mapping L{bytes} to L{IDomain} provider, (1) L{bytes} @param args: Arguments for L{AliasBase.__init__}. N)r:r@rr=r!)r?r!argss r"r@AddressAlias.__init__s' 4'$'\\%( rBreturnc"SURS3$)z Build a string representation of this L{AddressAlias} instance. @rtype: L{bytes} @return: A string containing the destination address. z
r!rEs r"__str__AddressAlias.__str__s4::,a((rBcfUR5R[UR55$)z Create a message receiver which delivers a message to the destination address. @rtype: L{IMessage } provider @return: A message receiver. )rDexistsrr!rEs r"rI"AddressAlias.createMessageReceivers#{{}##C O44rBNcUc0n[U5U;agSU[U5'UR5R[R"UR SSS5U5"5$![R a Of=fUR RU;a'XR RRX5$grH) rrDrdrUserr! SMTPBadRcptlocalrMrJs r"rMAddressAlias.resolves <D t9 SY ;;='' $**dD$(OQUVX X    ::  x 'JJ,,-55hE EsAA++BBr`rO) rPrQrRrSrTr@rrarIrMrUrVrBr"rXrXs" )))5rBrXc>\rSrSrSrSrSrSrSrS\ 4Sjr S r g ) FileWrapperz A message receiver which delivers a message to a file. @type fp: file-like object @ivar fp: A file used for temporary storage of the message. @type finalname: L{bytes} @ivar finalname: The name of the file in which the message should be stored. cD[R"5UlXlg)zk @type filename: L{bytes} @param filename: The name of the file in which the message should be stored. N)tempfile TemporaryFiler3 finalname)r?rs r"r@FileWrapper.__init__s ((*!rBc@URRUS-5 g)zq Write a received line to the temporary file. @type line: L{bytes} @param line: A received line of the message.  N)r3writer?rs r" lineReceivedFileWrapper.lineReceiveds  dTk"rBcURRSS5 [URS5nU URURR55 URR5 SSS5 [ R"UR5$![a, [ R "[R"55s$f=f!,(df  Ng=f)a+ Handle end of message by writing the message to the file. @rtype: L{Deferred } which successfully results in L{bytes} @return: A deferred which succeeds with the name of the file to which the message has been stored or fails if the message cannot be saved to the file. rr7N) r3seekr*rq BaseExceptionrfailr Failurerureadr/succeed)r?fs r" eomReceivedFileWrapper.eomReceiveds  Q 1T^^S)A GGDGGLLN # GGMMO}}T^^,, 1::goo/0 0 1QsB"AC"3CC C)cFURR5 SUlg)z7 Close the temporary file when the connection is lost. N)r3r/rEs r"connectionLostFileWrapper.connectionLost-s  rBr]c"SURS3$)z Build a string representation of this L{FileWrapper} instance. @rtype: L{bytes} @return: A string containing the file name of the message. z zS An alias which translates an address to a file. @ivar filename: See L{__init__}. c>[R"U/UQ76 Xlg)z @type filename: L{bytes} @param filename: The name of the file in which to store the message. @type args: 2-L{tuple} of (0) L{dict} mapping L{bytes} to L{IDomain} provider, (1) L{bytes} @param args: Arguments for L{AliasBase.__init__}. N)r:r@r)r?rr[s r"r@FileAlias.__init__Fs 4'$' rBr]c"SURS3$)z Build a string representation of this L{FileAlias} instance. @rtype: L{bytes} @return: A string containing the name of the file. zs !))*rBrc\rSrSrSrSrg)ProcessAliasTimeoutiezV An error indicating that a timeout occurred while waiting for a process to complete. rVN)rPrQrRrSrTrUrVrBr"rresrBrc^\rSrSrSrSrSrSr\rSSjr Sr Sr S r S r S rS \4S jrSrg)MessageWrapperila A message receiver which delivers a message to a child process. @type completionTimeout: L{int} or L{float} @ivar completionTimeout: The number of seconds to wait for the child process to exit before reporting the delivery as a failure. @type _timeoutCallID: L{None} or L{IDelayedCall } provider @ivar _timeoutCallID: The call used to time out delivery, started when the connection to the child process is closed. @type done: L{bool} @ivar done: A flag indicating whether the child process has exited (C{True}) or not (C{False}). @type reactor: L{IReactorTime } provider @ivar reactor: A reactor which will be used to schedule timeouts. @ivar protocol: See L{__init__}. @type processName: L{bytes} or L{None} @ivar processName: The process name. @type completion: L{Deferred } @ivar completion: The deferred which will be triggered by the protocol when the child process exits. F<NcX lXl[R"5UlURURlURR UR5 UbX0lgg)aV @type protocol: L{ProcessAliasProtocol} @param protocol: The protocol associated with the child process. @type process: L{bytes} or L{None} @param process: The process name. @type reactor: L{None} or L{IReactorTime } provider @param reactor: A reactor which will be used to schedule timeouts. N) processNamerrDeferred completiononEndaddBoth _processEndedr)r?rprocessrs r"r@MessageWrapper.__init__sU# ..*"oo   2 23  "L rBcrSUlURb"URR5 SUlgU$)a_ Record process termination and cancel the timeout call if it is active. @type result: L{Failure } @param result: The reason the child process terminated. @rtype: L{None} or L{Failure } @return: None, if the process end is expected, or the reason the child process terminated, if the process end is unexpected. TN)done_timeoutCallIDcancel)r?rs r"rMessageWrapper._processEndeds:    *    & & ("&D MrBcxUR(agURRRUS-5 g)zp Write a received line to the child process. @type line: L{bytes} @param line: A received line of the message. Nrt)rr transportrurvs r"rwMessageWrapper.lineReceiveds* 99  %%dTk2rBcUR(dYURRR5 URR UR UR5UlUR$)z Disconnect from the child process and set up a timeout to wait for it to exit. @rtype: L{Deferred } @return: A deferred which will be called back when the child process exits. ) rrrloseConnectionr callLatercompletionTimeout_completionCancelrrrEs r"rMessageWrapper.eomReceivedsUyy MM # # 2 2 4"&,,"8"8&&(>(>#D rBcSUlURRRS5 [ SUR S35nSURlURR[R"U55 g)z Handle the expiration of the timeout for the child process to exit by terminating the child process forcefully and issuing a failure to the L{completion} deferred. NKILLzNo answer after z seconds) rrr signalProcessrrrrerrbackr r})r?excs r"r MessageWrapper._completionCancelsf # --f5!$4T5K5K4LH"UV"   45rBcg)z) Ignore notification of lost connection. NrVrEs r"rMessageWrapper.connectionLostsrBr]c"SURS3$)z Build a string representation of this L{MessageWrapper} instance. @rtype: L{bytes} @return: A string containing the name of the process. z} @ivar onEnd: If set, a deferred on which to errback when the process ends. NcVURbURRU5 gg)zv Call an errback. @type reason: L{Failure } @param reason: The reason the child process terminated. N)rr)r?reasons r" processEnded!ProcessAliasProtocol.processEndeds% :: ! JJ  v & "rBrV)rPrQrRrSrTrrrUrVrBr"rrs E'rBrc<\rSrSrSr\rSrS\4SjrSr Sr Sr g ) ProcessAliasi a An alias which is handled by the execution of a program. @type path: L{list} of L{bytes} @ivar path: The arguments to pass to the process. The first string is the executable's name. @type program: L{bytes} @ivar program: The path of the program to be executed. @type reactor: L{IReactorTime } and L{IReactorProcess } provider @ivar reactor: A reactor which will be used to create and timeout the child process. c[R"U/UQ76 UR5UlURSUlg)a  @type path: L{bytes} @param path: The command to invoke the program consisting of the path to the executable followed by any arguments. @type args: 2-L{tuple} of (0) L{dict} mapping L{bytes} to L{IDomain} provider, (1) L{bytes} @param args: Arguments for L{AliasBase.__init__}. rN)r:r@rpathprogram)r?rr[s r"r@ProcessAlias.__init__s3 4'$'JJL yy| rBr]c"SURS3$)z Build a string representation of this L{ProcessAlias} instance. @rtype: L{bytes} @return: A string containing the command used to invoke the process. z } method on L{reactor} so that it can be customized for test purposes. @type proto: L{IProcessProtocol } provider @param proto: An object which will be notified of all events related to the created process. @type program: L{bytes} @param program: The full path name of the file to execute. @type path: L{list} of L{bytes} @param path: The arguments to pass to the process. The first string should be the executable's name. @rtype: L{IProcessTransport } provider @return: A process transport. )r spawnProcess)r?protorrs r"rProcessAlias.spawnProcess7s0||((>>rBc[5n[XRUR5nUR XRUR 5 U$)z Launch a process and create a message receiver to pass a message to the process. @rtype: L{MessageWrapper} @return: A message receiver which delivers a message to the process. )rrrrrr)r?rms r"rI"ProcessAlias.createMessageReceiverQs= ! " 1llDLL 9 !\\4995rB)rrN) rPrQrRrSrTrr@rrarrIrUrVrBr"rr s)"G $((?4 rBrc>\rSrSrSrSrSrSrSrS\ 4Sjr S r g ) MultiWrapperi_zw A message receiver which delivers a single message to multiple other message receivers. @ivar objs: See L{__init__}. cXlg)z @type objs: L{list} of L{IMessage } provider @param objs: Message receivers to which the incoming message should be directed. Nobjs)r?rs r"r@MultiWrapper.__init__hs  rBcLURHnURU5 M g)zj Pass a received line to the message receivers. @type line: L{bytes} @param line: A line of the message. N)rrw)r?ros r"rwMultiWrapper.lineReceivedpsA NN4 rBc[R"URVs/sHoR5PM sn5$s snf)a Pass the end of message along to the message receivers. @rtype: L{DeferredList } whose successful results are L{bytes} or L{None} @return: A deferred list which triggers when all of the message receivers have finished handling their end of message. )r DeferredListrrr?rs r"rMultiWrapper.eomReceivedzs/!!DII"FIq==?I"FGG"Fs?cJURHnUR5 M g)zA Inform the message receivers that the connection has been lost. N)rrrs r"rMultiWrapper.connectionLostsA   rBr]c@S[[UR5<S3$)z Build a string representation of this L{MultiWrapper} instance. @rtype: L{bytes} @return: A string containing a list of the message receivers. zAqA(>?LLC1%% ##D$<$?LL'' $(>(>? ##L$=$=>'e)?%LGG=d12h\JKLs0G ,F8<F3 F83F88 G 'G43G4c,[UR5$)zi Return the number of aliases in the group. @rtype: L{int} @return: The number of aliases in the group. )rrrEs r"__len__AliasGroup.__len__s4<<  rBr]cZSSR[[UR55-$)z Build a string representation of this L{AliasGroup} instance. @rtype: L{bytes} @return: A string containing the aliases in the group. zz, )rrrrrEs r"raAliasGroup.__str__s##diiC0F&GHHrBcr[URVs/sHoR5PM sn5$s snf)z Create a message receiver for each alias and return a message receiver which will pass on a message to each of those. @rtype: L{MultiWrapper} @return: A message receiver which passes a message on to message receivers for each alias in the group. )rrrI)r?r7s r"rI AliasGroup.createMessageReceivers, M 1446 MNNMs4NcUc0n/nURH#nURURX55 M% [[ SU55$)a) Map each of the aliases in the group to its ultimate destination. @type aliasmap: L{dict} mapping L{bytes} to L{AliasBase} @param aliasmap: A mapping of username to alias or group of aliases. @type memo: L{None} or L{dict} of L{AliasBase} @param memo: A record of the aliases already considered in the resolution process. If provided, C{memo} is modified to include this alias. @rtype: L{MultiWrapper} @return: A message receiver which passes the message on to message receivers for the ultimate destination of each alias in the group. N)rrrMrfilter)r?rKrLrr7s r"rMAliasGroup.resolvesG <D A HHQYYx. /F4O,,rB)rrO)rPrQrRrSrTrrr@rrrarIrMrUrVrBr"r1r1s3 '$?L!II O-rBr1r)rTrrozope.interfacertwisted.internetrrr twisted.mailrtwisted.mail.interfacesrtwisted.pythonr r r#r8r:rXIMessagerlr ExceptionrrProcessProtocolrrrr1rVrBr"rsU  &55*'U6EP3,3,l VC9CCL T]]B1B1B1J V#* #*#*L) T]]D6D6D6N'833', VQ9QQh T]]393939l Vf-f-f-rB