\d]dZddlZddlZddlmZddlmZmZmZddl m Z ddl m Z ddl mZmZdZdd ZGd d Zee Gd d eZee jGddZee GddeZGddeZee jGddZGddejZee GddeZee jGddZee GddeZdS)zD Support for aliases(5) configuration files. @author: Jp Calderone N) implementer)deferprotocolreactor)smtp)IAlias)failurelogcd|ddD}t|dkrd}||f}tj||zdS|\}}||gttj|ddS)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. c6g|]}|Sstrip).0ps 2lib/python3.11/site-packages/twisted/mail/alias.py zhandle..)s 3 3 31QWWYY 3 3 3:z+Invalid format on line %d of alias file %s.,N) splitlenr err setdefaultrextendmapstr) resultlinefilenamelineNopartsfmtarguseraliass rhandler)s" 4 3 3 2 2 3 3 3E 5zzQ;x  c  e$**,,++223sy%++cBRBR3S3STTTTTrcfi}d}|t|}d}nt|dd}d}d} |D]}|dz }|}|d rC|d s|d r||z}s|rt |||||} |r|n#|r|wwxYw|rt |||||D]\}} t| ||||<|S) 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. FNTnamez rr#  ) opengetattrrstriplstrip startswithr)closeitems AliasGroup) domainsr"fpr r5iprevr!uas r loadAliasFiler>3ssRF E z (^^2v{33 A D  D FA;;==D{{}}'',, %% )>)> d{6641555    HHJJJ   HHJJJJ  *vtXq))),,....Aq'1--q Ms B CC,c&eZdZdZdZdZddZdS) AliasBasez The default base class for aliases. @ivar domains: See L{__init__}. @type original: L{Address} @ivar original: The original address being aliased. cF||_tj||_dS)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)r8rAddressoriginal)selfr8rCs r__init__zAliasBase.__init__s   X.. rc0|j|jjS)z Return the domain associated with original address. @rtype: L{IDomain} provider @return: The domain for the original address. )r8rCdomainrDs rrGzAliasBase.domains|DM011rNc||i}t||vrdSd|t|<|SaY 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)rcreateMessageReceiverrDaliasmapmemos rresolvezAliasBase.resolvesE <D t99  4SYY))+++rN)__name__ __module__ __qualname____doc__rErGrOr rrr@r@{sP / / /222,,,,,,rr@c2eZdZdZdZdefdZdZddZdS) AddressAliasz An alias which translates one email address into another. @type alias : L{Address} @ivar alias: The destination address. c\tj|g|Rtj||_dS)aQ @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@rErrBr()rDr(argss rrEzAddressAlias.__init__s2 4'$''''\%(( rreturncd|jdS)z Build a string representation of this L{AddressAlias} instance. @rtype: L{bytes} @return: A string containing the destination address. z
)r(rHs r__str__zAddressAlias.__str__s)4:((((rct|t|jS)z Create a message receiver which delivers a message to the destination address. @rtype: L{IMessage } provider @return: A message receiver. )rGexistsrr(rHs rrKz"AddressAlias.createMessageReceivers({{}}##C OO444rNc |i}t||vrdSd|t|< |tj|jddd|S#tj$rYnwxYw|jj|vr&||jj||SdSrJ) rrGr^rUserr( SMTPBadRcptlocalrOrLs rrOzAddressAlias.resolves <D t99  4SYY V4;;=='' $*dD$(O(OQUVVXX X    D  : x ' 'DJ,-55hEE EtsA A55BBrP) rQrRrSrTrErr\rKrOr rrrVrVsk ) ) ))))))555rrVc6eZdZdZdZdZdZdZdefdZ dS) FileWrappera 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. cDtj|_||_dS)z @type filename: L{bytes} @param filename: The name of the file in which the message should be stored. N)tempfile TemporaryFiler9 finalname)rDr"s rrEzFileWrapper.__init__s (**!rc@|j|dzdS)z Write a received line to the temporary file. @type line: L{bytes} @param line: A received line of the message.  N)r9writerDr!s r lineReceivedzFileWrapper.lineReceiveds"  dTk"""""rc|jdd t|jd}n5#t$r(t jtjcYSwxYw|5| |j |j dddn #1swxYwYt j |jS)ac 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. rr=N) r9seekr0rh BaseExceptionrfailr Failurerkreadr5succeed)rDfs r eomReceivedzFileWrapper.eomReceiveds  Q 1T^S))AA 1 1 1:go//00 0 0 0 1   GGDGLLNN # # # GMMOOO               }T^,,,s"3/A%$A%*AB<<CCcF|jd|_dS)zG Close the temporary file when the connection is lost. N)r9r5rHs rconnectionLostzFileWrapper.connectionLost-s  rrYcd|jdS)z Build a string representation of this L{FileWrapper} instance. @rtype: L{bytes} @return: A string containing the file name of the message. z sW ! ! !)))))*****rr|ceZdZdZdS)ProcessAliasTimeoutzb An error indicating that a timeout occurred while waiting for a process to complete. N)rQrRrSrTr rrrresrrcTeZdZdZdZdZdZeZd dZdZ dZ dZ d Z d Z d efd ZdS)MessageWrapperaF 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<Nc||_||_tj|_|j|j_|j|j| ||_dSdS)a @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)rDrprocessrs rrEzMessageWrapper.__init__s`#  .**"o   2333  "DLLL  rcfd|_|j"|jd|_dS|S)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)rDr s rrzMessageWrapper._processEndeds@   *   & & ( ( ("&D   Mrc\|jrdS|jj|dzdS)z Write a received line to the child process. @type line: L{bytes} @param line: A received line of the message. Nrj)rr transportrkrls rrmzMessageWrapper.lineReceiveds6 9  F %%dTk22222rc|jsH|jj|j|j|j|_|j S)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_completionCancelrrrHs rrvzMessageWrapper.eomReceivedsTy  M # 2 2 4 4 4"&,"8"8&(>##D rcd|_|jjdt d|jd}d|j_|jtj |dS)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 rr)rDexcs rrz MessageWrapper._completionCancelsq # --f555!"UT5K"U"U"UVV"   4 455555rcdS)z9 Ignore notification of lost connection. Nr rHs rrxzMessageWrapper.connectionLostsrrYcd|jdS)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. NcL|j|j|dSdS)z Call an errback. @type reason: L{Failure } @param reason: The reason the child process terminated. N)rr)rDreasons r processEndedz!ProcessAliasProtocol.processEndeds0 : ! J  v & & & & & " !r)rQrRrSrTrrr rrrrs4 E'''''rrc4eZdZdZeZdZdefdZdZdZ dS) ProcessAliasa6 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. ctj|g|R||_|jd|_dS)aX @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@rErpathprogram)rDrrXs rrEzProcessAlias.__init__s= 4'$''''JJLL y| rrYcd|jdS)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)rDprotorrs rrzProcessAlias.spawnProcess7s0|((>>>rct}t||j|j}|||j|j|S)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)rDrms rrKz"ProcessAlias.createMessageReceiverQsE ! " " 1dlDL 9 9 !T\49555rN) rQrRrSrTrrErr\rrKr rrrr sm"G $ $ $(((((???4     rrc6eZdZdZdZdZdZdZdefdZ dS) MultiWrapperz A message receiver which delivers a single message to multiple other message receivers. @ivar objs: See L{__init__}. c||_dS)z @type objs: L{list} of L{IMessage } provider @param objs: Message receivers to which the incoming message should be directed. N)objs)rDrs rrEzMultiWrapper.__init__hs  rcD|jD]}||dS)z Pass a received line to the message receivers. @type line: L{bytes} @param line: A line of the message. N)rrm)rDr!os rrmzMultiWrapper.lineReceivedps4 ! !A NN4  ! !rcHtjd|jDS)aG 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. c6g|]}|Sr )rv)rrs rrz,MultiWrapper.eomReceived..s "F"F"Fq1==??"F"F"Fr)r DeferredListrrHs rrvzMultiWrapper.eomReceivedzs&!"F"FDI"F"F"FGGGrcB|jD]}|dS)zQ Inform the message receivers that the connection has been lost. N)rrx)rDrs rrxzMultiWrapper.connectionLosts4  A        rrYc>dtt|jdS)z Build a string representation of this L{MultiWrapper} instance. @rtype: L{bytes} @return: A string containing a list of the message receivers. z.s (>(>(>q(>(>(>rrzInvalid filename in alias file |/z Directory delivery not supported)r@rEaliasespoprr4r0joinrrrpr rappendprocessAliasFactoryosrisdirr|rV)rDr6rXaddrrus rrEzAliasGroup.__init__s_ 4'$''''  ?99;;$$&&Ds## ?2T!""XA@@"xx(>(>A(>(>(>??@@@@@@@@@@@@@@@LLC1111 %LLLGJd122hJJKKKKKL %% ? ##$????L'' $(>(>(>(>???? ##L$=$=$=$=>>>' ? ? ? ? ?s$C2 BB"%B")C?>C?c*t|jS)z Return the number of aliases in the group. @rtype: L{int} @return: The number of aliases in the group. )rrrHs r__len__zAliasGroup.__len__s4<   rrYcbddtt|jzS)z Build a string representation of this L{AliasGroup} instance. @rtype: L{bytes} @return: A string containing the aliases in the group. zz, )rrrrrHs rr\zAliasGroup.__str__s'#diiC0F0F&G&GHHrc>td|jDS)a, 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. c6g|]}|Sr )rK)rr=s rrz4AliasGroup.createMessageReceiver..s$MMM1Q4466MMMr)rrrHs rrKz AliasGroup.createMessageReceivers#MM MMMNNNrNc|i}g}|jD]+}||||,tt d|S)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)rrrOrfilter)rDrMrNrr=s rrOzAliasGroup.resolves] <D  0 0A HHQYYx.. / / / /F4OO,,,rrP) rQrRrSrTrrrErrr\rKrOr rrr7r7s  '$?$?$?L!!!IIIII O O O------rr7r)rTrrfzope.interfacertwisted.internetrrr twisted.mailrtwisted.mail.interfacesrtwisted.pythonr r r)r>r@rVIMessagerdr| ExceptionrrProcessProtocolrrrr7r rrrs;  &&&&&&5555555555******''''''''UUU6EEEEP3,3,3,3,3,3,3,3,l VCCCCC9CCCL T]B1B1B1B1B1B1B1B1J V#*#*#*#*#* #*#*#*L) T]D6D6D6D6D6D6D6D6N'''''83''', VQQQQQ9QQQh T]3939393939393939l Vf-f-f-f-f-f-f-f-f-f-r