Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/mail/__pycache__/alias.cpython-39.pyc
Ðазад
a k�h�] � @ sJ d Z ddlZddlZddlmZ ddlmZmZmZ ddl m Z ddl m Z ddl mZmZ dd � Zd d d �ZG d d � d �Zee �G dd� de��Zee j�G dd� d��Zee �G dd� de��ZG dd� de�Zee j�G dd� d��ZG dd� dej�Zee �G dd� de��Z ee j�G d d � d ��Z ee �G d d � d e��Z dS )!zD Support for aliases(5) configuration files. @author: Jp Calderone � N)� implementer)�defer�protocol�reactor)�smtp)�IAlias)�failure�logc C sn dd� |� dd�D �}t|�dkr>d}||f}t�|| � n,|\}}| �|�� 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 s g | ] }|� � �qS � ��strip)�.0�pr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/mail/alias.py� <listcomp>) � zhandle.<locals>.<listcomp>�:� � z+Invalid format on line %d of alias file %s.�,N) �split�lenr �err� setdefaultr �extend�map�str) �result�line�filenameZlineNo�parts�fmt�arg�user�aliasr r r �handle s r% c C s� i }d}|du r t |�}d}n t|dd�}d}d}zp|D ]Z}|d7 }|�� }|�� �d �r^q8q8|�d �sr|�d �r||| }q8|r�t||||� |}q8W |r�|�� n|r�|�� 0 |r�t||||� |�� D ]\}} t| | |�||< q�|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. FNT�namez <unknown>r � r �#� � ) �open�getattr�rstrip�lstrip� startswithr% �close�items� AliasGroup) �domainsr �fpr r0 �i�prevr �u�ar r r � loadAliasFile3 s8 ) � r9 c @ s* e Zd ZdZdd� Zdd� Zd dd�ZdS ) � 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)r3 r �Address�original)�selfr3 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. )r3 r< �domain�r= r r r r? � s zAliasBase.domainNc C s0 |du r i }t | �|v r dS 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 <smtp.IMessage>} or L{None} @return: A message receiver for the ultimate destination or None for an invalid destination. N)r �createMessageReceiver�r= �aliasmap�memor r r �resolve� s zAliasBase.resolve)N)�__name__� __module__� __qualname__�__doc__r> r? rF r r r r r: { s r: c @ s8 e Zd ZdZdd� Zed�dd�Zdd� 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 s d| j � d�S )z� Build a string representation of this L{AddressAlias} instance. @rtype: L{bytes} @return: A string containing the destination address. z <Address �>)r$ r@ r r r �__str__� s zAddressAlias.__str__c C s | � � �t| j��S )z� Create a message receiver which delivers a message to the destination address. @rtype: L{IMessage <smtp.IMessage>} provider @return: A message receiver. )r? �existsr r$ r@ r r r rB � s z"AddressAlias.createMessageReceiverNc C s� |du r i }t | �|v r dS d|t | �< z"| �� �t�| jddd�|�� W S tjy^ Y n0 | jj|v r�|| jj �||�S dS rA ) r r? rQ r ZUserr$ Z SMTPBadRcpt�localrF rC r r r rF � s " zAddressAlias.resolve)N) rG rH rI rJ r> r rP rB rF r r r r rK � s rK c @ s> e Zd ZdZdd� Zdd� Zdd� Zdd � Zed �d 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� TemporaryFiler4 � 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)r4 �write�r= r r r r � lineReceived s zFileWrapper.lineReceivedc C s� | j �dd� zt| jd�}W n ty> t�t�� � Y S 0 |�* |� | j � � � | j � � W d � n1 st0 Y t� | j�S )ac Handle end of message by writing the message to the file. @rtype: L{Deferred <defer.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 r8 N) r4 �seekr+ rV � BaseExceptionr Zfailr �FailurerX �readr0 Zsucceed)r= �fr r r � eomReceived s (zFileWrapper.eomReceivedc C s | j �� d| _ dS )zG Close the temporary file when the connection is lost. N)r4 r0 r@ r r r �connectionLost- s zFileWrapper.connectionLostrM c C s d| j � d�S )z� Build a string representation of this L{FileWrapper} instance. @rtype: L{bytes} @return: A string containing the file name of the message. z <FileWrapper rO )rV r@ r r r rP 4 s zFileWrapper.__str__N� rG rH rI rJ r> rZ r` ra r rP r r r r rS � s rS c @ s. e Zd ZdZdd� Zed�dd�Zdd� Zd S ) � FileAliasz_ An alias which translates an address to a file. @ivar filename: See L{__init__}. c G s t j| g|�R � || _dS )a" @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= r rL r r r r> F s zFileAlias.__init__rM c C s d| j � d�S )z� Build a string representation of this L{FileAlias} instance. @rtype: L{bytes} @return: A string containing the name of the file. z<File rO )r r@ r r r rP R s zFileAlias.__str__c C s t | j�S )z� Create a message receiver which delivers a message to the file. @rtype: L{FileWrapper} @return: A message receiver which writes a message to the file. )rS r r@ r r r rB [ s z FileAlias.createMessageReceiverN)rG rH rI rJ r> r rP rB r r r r rc > s rc c @ s e Zd ZdZdS )�ProcessAliasTimeoutzb An error indicating that a timeout occurred while waiting for a process to complete. N)rG rH rI rJ r r r r rd e s rd c @ s` e Zd ZdZdZdZdZeZddd�Zdd� Z d d � Z d d � Z d d� Z dd� Z ed�dd�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 <twisted.internet.interfaces.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 <twisted.internet.interfaces.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 <defer.Deferred>} @ivar completion: The deferred which will be triggered by the protocol when the child process exits. F�< Nc C s@ || _ || _t�� | _| j| j_| j�| j� |dur<|| _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 <twisted.internet.interfaces.IReactorTime>} provider @param reactor: A reactor which will be used to schedule timeouts. N) � processNamer r ZDeferred� completion�onEndZaddBoth� _processEndedr )r= r �processr r r r r> � s zMessageWrapper.__init__c C s* d| _ | jdur"| j�� d| _n|S dS )a� Record process termination and cancel the timeout call if it is active. @type result: L{Failure <failure.Failure>} @param result: The reason the child process terminated. @rtype: L{None} or L{Failure <failure.Failure>} @return: None, if the process end is expected, or the reason the child process terminated, if the process end is unexpected. TN)�done�_timeoutCallID�cancel)r= r r r r rj � s z MessageWrapper._processEndedc C s | j r dS | jj�|d � dS )z� Write a received line to the child process. @type line: L{bytes} @param line: A received line of the message. NrW )rl r � transportrX rY r r r rZ � 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 <defer.Deferred>} @return: A deferred which will be called back when the child process exits. ) rl r ro ZloseConnectionr Z callLater�completionTimeout�_completionCancelrm rh r@ r r r r` � s �zMessageWrapper.eomReceivedc C sD d| _ | jj�d� td| j� d��}d| j_| j�t � |�� 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. NZKILLzNo answer after z seconds) rm r ro Z signalProcessrd rp ri rh �errbackr r] )r= �excr r r rq � s z MessageWrapper._completionCancelc C s dS )z9 Ignore notification of lost connection. Nr r@ r r r ra � s z MessageWrapper.connectionLostrM c C s d| j � d�S )z� Build a string representation of this L{MessageWrapper} instance. @rtype: L{bytes} @return: A string containing the name of the process. z<ProcessWrapper rO )rg r@ r r r rP � s zMessageWrapper.__str__)NN)rG rH rI rJ rl rp rm r r> rj rZ r` rq ra r rP r r r r re l s re c @ s e Zd ZdZdZdd� ZdS )�ProcessAliasProtocolz� A process protocol which errbacks a deferred when the associated process ends. @type onEnd: L{None} or L{Deferred <defer.Deferred>} @ivar onEnd: If set, a deferred on which to errback when the process ends. Nc C s | j dur| j �|� dS )z� Call an errback. @type reason: L{Failure <failure.Failure>} @param reason: The reason the child process terminated. N)ri rr )r= �reasonr r r � processEnded� s z!ProcessAliasProtocol.processEnded)rG rH rI rJ ri rv r r r r rt � s rt c @ s: e Zd ZdZeZdd� Zed�dd�Zdd� 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 <twisted.internet.interfaces.IReactorTime>} and L{IReactorProcess <twisted.internet.interfaces.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 �path�program)r= rx rL r r r r> s zProcessAlias.__init__rM c C s d| j � d�S )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 <Process rO )rx r@ r r r rP . s zProcessAlias.__str__c C s | j �|||�S )aP Spawn a process. This wraps the L{spawnProcess <twisted.internet.interfaces.IReactorProcess.spawnProcess>} method on L{reactor} so that it can be customized for test purposes. @type proto: L{IProcessProtocol <twisted.internet.interfaces.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 <twisted.internet.interfaces.IProcessTransport>} provider @return: A process transport. )r � spawnProcess)r= �protory rx r r r rz 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. )rt re ry r rz rx )r= r �mr r r rB Q s z"ProcessAlias.createMessageReceiverN) rG rH rI rJ r r> r rP rz rB r r r r rw s rw c @ s> e Zd ZdZdd� Zdd� Zdd� Zdd � Zed �d d �Z d S )� 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 <smtp.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~ rZ )r= r �or r r rZ p s zMultiWrapper.lineReceivedc C s t �dd� | jD ��S )aG Pass the end of message along to the message receivers. @rtype: L{DeferredList <defer.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 s g | ] }|� � �qS r )r` )r r r r r r � r z,MultiWrapper.eomReceived.<locals>.<listcomp>)r Z DeferredListr~ r@ r r r r` z s zMultiWrapper.eomReceivedc C s | j D ] }|�� qdS )zQ Inform the message receivers that the connection has been lost. N)r~ ra )r= r r r r ra � s zMultiWrapper.connectionLostrM c C s dt t| j��d�S )z� Build a string representation of this L{MultiWrapper} instance. @rtype: L{bytes} @return: A string containing a list of the message receivers. z<GroupWrapper rO )r r r~ r@ r r r rP � s zMultiWrapper.__str__Nrb r r r r r} _ s r} c @ sD e Zd ZdZeZdd� Zdd� Zed�dd�Z d d � Z dd d �Z d S )r2 aL An alias which points to multiple destination aliases. @type processAliasFactory: no-argument callable which returns L{ProcessAlias} @ivar processAliasFactory: A factory for process aliases. @type aliases: L{list} of L{AliasBase} which implements L{IAlias} @ivar aliases: The destination aliases. c G sJ t j| g|�R � g | _|�rF|�� �� }|�d�r�zt|dd� �}W n* tyr t� d|dd� ��� Y nJ0 |�$ d� dd� |D ��}W d � n1 s�0 Y |� |� d�� q|�d �r�| j� | j|dd� g|�R � � q|�d ��r,tj�|��rt� d � n| j� t|g|�R � � q| j� t|g|�R � � qdS ) a� Create a group of aliases. Parse a list of alias strings and, for each, create an appropriate alias object. @type items: L{list} of L{bytes} @param items: Aliases. @type args: n-L{tuple} of (0) L{dict} mapping L{bytes} to L{IDomain} provider, (1) L{bytes} @param args: Arguments for L{AliasBase.__init__}. r r Nz Invalid filename in alias file r) c S s g | ] }|� � �qS r r )r �lr r r r � r z'AliasGroup.__init__.<locals>.<listcomp>r �|�/z Directory delivery not supported)r: r> �aliases�popr r/ r+ r\ r r �joinr r �append�processAliasFactory�osrx �isdirrc rK )r= r1 rL �addrr_ r r r r> � s& 2 $ zAliasGroup.__init__c C s t | j�S )z� Return the number of aliases in the group. @rtype: L{int} @return: The number of aliases in the group. )r r� r@ r r r �__len__� s zAliasGroup.__len__rM 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. z<AliasGroup [%s]>z, )r� r r r� r@ r r r rP � 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 s g | ] }|� � �qS r )rB )r r8 r r r r � r z4AliasGroup.createMessageReceiver.<locals>.<listcomp>)r} r� r@ r r r rB � s z AliasGroup.createMessageReceiverNc C s< |du r i }g }| j D ]}|�|�||�� qttd|��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� rF r} �filter)r= rD rE �rr8 r r r rF � s zAliasGroup.resolve)N) rG rH rI rJ rw r� r> r� r rP rB rF r r r r r2 � s & r2 )NN) rJ r� rT Zzope.interfacer Ztwisted.internetr r r Z twisted.mailr Ztwisted.mail.interfacesr Ztwisted.pythonr r r% r9 r: rK ZIMessagerS rc � Exceptionrd re ZProcessProtocolrt rw r} r2 r r r r �<module> s6 H6FE& T6
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка