← Back
Editing: relay.cpython-38.pyc
U W[� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlZz ddlZ W n e k rX ddl Z Y nX G dd� d�Z G dd � d �Z G d d � d e ej �ZG d d � d e ej�ZdS )z Support for relaying mail. � )�smtp)�log)� UNIXAddressNc @ s2 e Zd ZdZd dd�Zdd� Zdd� Zd d � Zd S ) � DomainQueuerzM An SMTP domain which add messages to a queue intended for relaying. Fc C s || _ || _d S �N)�service�authed)�selfr Z authenticated� r �4/usr/lib/python3/dist-packages/twisted/mail/relay.py�__init__ s zDomainQueuer.__init__c st � � �j�j�rftdt�j��dd��}tdt�j��dd��}t|�dkrft|�dkrf� �fdd�S t� ���dS )a� 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 <smtp.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 s � � ��S r )� startMessager �r �userr r �<lambda>3 � z%DomainQueuer.exists.<locals>.<lambda>) � willRelay�dest�protocol�filter�str�orig�split�lenr Z SMTPBadRcpt)r r r r r r r �exists s zDomainQueuer.existsc C s$ |j �� }| jp"t|t�p"|jdkS )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)Z transportZgetPeerr � isinstancer Zhost)r Zaddressr Zpeerr r r r 7 s �zDomainQueuer.willRelayc C sb | j j}|�� \}}|�@ t�dt|j�t|j�f � t� t|j�t|j�g|� W 5 Q R X |S )z� Create an envelope and a message receiver for the relay queue. @type user: L{User} @param user: A user. @rtype: L{IMessage <smtp.IMessage>} @return: A message receiver. zQueueing mail %r -> %r) r �queueZcreateNewMessager �msgr r r �pickle�dump)r r r Z envelopeFileZ smtpMessager r r r C s �&zDomainQueuer.startMessageN)F)�__name__� __module__� __qualname__�__doc__r r r r r r r r r s r c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) � RelayerMixinc C sj g | _ g | _|D ]T}t|d ��}t�|�}W 5 Q R X t|d �}|�|� | j �|� | j�|� qd S )N�-H�-D)�messages�names�openr! �load�append)r � messagePaths�message�fpZmessageContentsr r r � loadMessages] s zRelayerMixin.loadMessagesc C s | j s d S | j d d S )Nr �r* �r r r r � getMailFromi s zRelayerMixin.getMailFromc C s | j s d S | j d d gS )Nr r r3 r4 r r r � getMailToo s zRelayerMixin.getMailToc C s | j s d S | j d d S )Nr r r3 r4 r r r � getMailDatau s zRelayerMixin.getMailDatac C sF |t jkr2t�| jd d � t�| jd d � | jd= | jd= dS )z�Since 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. r r) r( N)r �SUCCESS�os�remover+ r* )r �codeZrespZnumOkZ addressesr r r r �sentMail{ s zRelayerMixin.sentMailN)r# r$ r% r2 r5 r6 r7 r< r r r r r' W s r' c @ s e Zd ZdZdd� ZdS )� SMTPRelayerz) A base class for SMTP relayers. c O s" t jj| f|�|� | �|� dS )a� @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 � SMTPClientr r2 �r r/ �args�kwr r r r � s zSMTPRelayer.__init__N�r# r$ r% r& r r r r r r= � s r= c @ s e Zd ZdZdd� ZdS )� ESMTPRelayerz* A base class for ESMTP relayers. c O s" t jj| f|�|� | �|� dS )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 <twisted.internet.ssl.ClientContextFactory>}, (2) L{bytes} or 4-L{tuple} of (0) L{bytes}, (1) L{None} or L{ClientContextFactory <twisted.internet.ssl.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 � ESMTPClientr r2 r? r r r r � s zESMTPRelayer.__init__NrB r r r r rC � s rC )r& Z twisted.mailr Ztwisted.pythonr Ztwisted.internet.addressr r9 ZcPickler! � ImportErrorr r' r> r= rD rC r r r r �<module> s A2
Save File
Cancel