/usr/lib/python3/dist-packages/twisted/mail/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/mail/__pycache__/alias.cpython-310.pyc (25460B)
o
b] @ sJ d Z ddlZddlZddlmZ ddlmZmZmZ ddl m
Z
ddl m Z ddl
mZmZ dd Zd d
d ZG d d
d
Zee G dd deZee
jG dd dZee G dd deZG dd deZee
jG dd dZG dd dejZee G dd deZ ee
jG d d d Z ee G d d d eZ dS )!zD
Support for aliases(5) configuration files.
@author: Jp Calderone
N) implementer)deferprotocolreactor)smtp)IAlias)failurelogc C sp dd | ddD }t|dkr d}||f}t|| dS |\}}| | g ttj| d dS ) 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.
c S g | ]}| qS strip).0pr r 4/usr/lib/python3/dist-packages/twisted/mail/alias.py
) zhandle..: z+Invalid format on line %d of alias file %s.,N) splitlenr err
setdefaultr
extendmapstr) resultlinefilenamelineNopartsfmtarguseraliasr r r handle s (r' c
C s i }d}|du rt |}d}nt|dd}d}d}z7|D ],}|d7 }| }| d r.q |d
s8|d r=|| }q |rFt|||| |}q W |rP| n|rX| w w |rbt|||| | D ] \}} t| | |||< qf|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 r r # ) opengetattrrstriplstrip
startswithr' closeitems
AliasGroup)
domainsr fpr r2 iprevr uar r r
loadAliasFile3 s> )
r; c @ s* e Zd ZdZdd Zdd Zd ddZdS )
AliasBasez
The default base class for aliases.
@ivar domains: See L{__init__}.
@type original: L{Address}
@ivar original: The original address being aliased.
c C s || _ t|| _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)r5 r Addressoriginal)selfr5 r> r r r __init__ s zAliasBase.__init__c C s | j | jj S )z
Return the domain associated with original address.
@rtype: L{IDomain} provider
@return: The domain for the original address.
)r5 r> domainr? r r r rA zAliasBase.domainNc C s0 |du ri }t | |v rdS d|t | < | S aY
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)r createMessageReceiverr? aliasmapmemor r r resolve s zAliasBase.resolveN)__name__
__module__ __qualname____doc__r@ rA rI r r r r r< { s
r< c @ s8 e Zd ZdZdd ZdefddZdd Zd d
d Zd S )
AddressAliasz
An alias which translates one email address into another.
@type alias : L{Address}
@ivar alias: The destination address.
c G s" t j| g|R t|| _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< r@ r r= r& )r? r& argsr r r r@ s
zAddressAlias.__init__returnc C d| j dS )z
Build a string representation of this L{AddressAlias} instance.
@rtype: L{bytes}
@return: A string containing the destination address.
z )r& rB r r r __str__ rC zAddressAlias.__str__c C s | t| jS )z
Create a message receiver which delivers a message to
the destination address.
@rtype: L{IMessage } provider
@return: A message receiver.
)rA existsr r& rB r r r rE s z"AddressAlias.createMessageReceiverNc C s |du ri }t | |v rdS d|t | < z| t| jddd| W S tjy/ Y nw | jj|v r@|| jj ||S dS rD ) r rA rU r Userr& SMTPBadRcptlocalrI rF r r r rI s " zAddressAlias.resolverJ ) rK rL rM rN r@ r rT rE rI r r r r rO s
rO c @ > e Zd ZdZdd Zdd Zdd Zdd Zd
efd d Z d
S ) 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.
c C s t | _|| _dS )z
@type filename: L{bytes}
@param filename: The name of the file in which the message should be
stored.
N)tempfile
TemporaryFiler6 finalname)r? r r r r r@ s
zFileWrapper.__init__c C s | j |d dS )z
Write a received line to the temporary file.
@type line: L{bytes}
@param line: A received line of the message.
N)r6 writer? r r r r lineReceived zFileWrapper.lineReceivedc C s | j dd zt| jd}W n ty tt Y S w | | | j
| j W d n1 s:w Y t | 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.
r r: N)
r6 seekr- r]
BaseExceptionr failr Failurer_ readr2 succeed)r? fr r r eomReceived s
zFileWrapper.eomReceivedc C s | j d| _ dS )zG
Close the temporary file when the connection is lost.
N)r6 r2 rB r r r connectionLost- s
zFileWrapper.connectionLostrQ c C rR )z
Build a string representation of this L{FileWrapper} instance.
@rtype: L{bytes}
@return: A string containing the file name of the message.
z
s
rm c @ s e Zd ZdZdS )ProcessAliasTimeoutzb
An error indicating that a timeout occurred while waiting for a process
to complete.
N)rK rL rM rN r r r r rp e s rp c @ s` e Zd ZdZdZdZdZeZdddZdd Z d d
Z
d d Z d
d Z dd Z
defddZdS )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 C sD || _ || _t | _| j| j_| j| j |dur || _dS dS )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) processNamer r Deferred
completiononEndaddBoth
_processEndedr )r? r processr r r r r@ s
zMessageWrapper.__init__c C s( d| _ | jdur| j d| _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)r? r r r r rx s
z MessageWrapper._processEndedc C s | j rdS | jj|d dS )z
Write a received line to the child process.
@type line: L{bytes}
@param line: A received line of the message.
Nr^ )rz r transportr_ r` r r r ra s zMessageWrapper.lineReceivedc C s, | j s| 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.
)
rz r r} loseConnectionr callLatercompletionTimeout_completionCancelr{ ru rB r r r rj s zMessageWrapper.eomReceivedc C sD d| _ | jjd td| j d}d| j_| jt
| 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) r{ r r}
signalProcessrp r rv ru errbackr rf )r? excr r r r s
z MessageWrapper._completionCancelc C s dS )z9
Ignore notification of lost connection.
Nr rB r r r rk s z MessageWrapper.connectionLostrQ c C rR )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.
Nc C s | j dur
| j | dS dS )z
Call an errback.
@type reason: L{Failure }
@param reason: The reason the child process terminated.
N)rv r )r? reasonr r r processEnded s
z!ProcessAliasProtocol.processEnded)rK rL rM rN rv r r r r r r s r c @ s: e Zd ZdZeZdd ZdefddZdd Zd d
Z d S ) 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.
c G s, t j| 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__}.
r N)r< r@ r pathprogram)r? r rP r r r r@ s
zProcessAlias.__init__rQ c C rR )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? protor r r r r r 7 s zProcessAlias.spawnProcessc C s, t }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.
)r rq r r r r )r? r mr r r rE Q s z"ProcessAlias.createMessageReceiverN)
rK rL rM rN r r@ r rT r rE r r r r r
s r c @ rY ) MultiWrapperz
A message receiver which delivers a single message to multiple other
message receivers.
@ivar objs: See L{__init__}.
c C s
|| _ dS )z
@type objs: L{list} of L{IMessage } provider
@param objs: Message receivers to which the incoming message should be
directed.
N)objs)r? r r r r r@ h s
zMultiWrapper.__init__c C s | j D ]}|| qdS )z
Pass a received line to the message receivers.
@type line: L{bytes}
@param line: A line of the message.
N)r ra )r? r or r r ra p s
zMultiWrapper.lineReceivedc C s t dd | jD S )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.
c S r
r )rj )r r r r r r r z,MultiWrapper.eomReceived..)r DeferredListr rB r r r rj z s zMultiWrapper.eomReceivedc C s | j D ]}| qdS )zQ
Inform the message receivers that the connection has been lost.
N)r rk )r? r r r r rk s
zMultiWrapper.connectionLostrQ c C s dt t| 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.r |/z Directory delivery not supported)r< r@ aliasespopr
r1 r- rd r r joinr r appendprocessAliasFactoryosr isdirrm rO )r? r3 rP addrri r r r r@ s,
$
zAliasGroup.__init__c C rn )z
Return the number of aliases in the group.
@rtype: L{int}
@return: The number of aliases in the group.
)r r rB r r r __len__ ro zAliasGroup.__len__rQ c C s dd tt| j S )z
Build a string representation of this L{AliasGroup} instance.
@rtype: L{bytes}
@return: A string containing the aliases in the group.
zz, )r r r r rB r r r rT s zAliasGroup.__str__c C s t dd | jD S )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.
c S r
r )rE )r r: r r r r r z4AliasGroup.createMessageReceiver..)r r rB r r r rE s z AliasGroup.createMessageReceiverNc C s< |du ri }g }| j D ] }|||| q ttd|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)r r rI r filter)r? rG rH rr: r r r rI s
zAliasGroup.resolverJ ) rK rL rM rN r r r@ r r rT rE rI r r r r r4 s & r4 r ) rN r r[ zope.interfacer twisted.internetr r r twisted.mailr twisted.mail.interfacesr twisted.pythonr r r' r; r< rO IMessagerZ rm Exceptionrp rq ProcessProtocolr r r r4 r r r r s8
H6FE& T6