Ë
    oj  ã                  óV  — d Z ddlmZ ddlZddlmZ ddlmZmZ ddl	m
ZmZ ddlmZmZ ddlmZmZ dd	lmZ d
„ Z
d„ Z G d„ dej,                  ej.                  «      Zesej2                  dk\  reeeeef   f   ZneZ G d„ deej:                  «      Z G d„ dej:                  «      Zy)z1
Postfix mail transport agent related protocols.
é    )ÚannotationsN)ÚUserDict)ÚTYPE_CHECKINGÚUnion)ÚquoteÚunquote)ÚdeferÚprotocol)ÚbasicÚpolicies)Úlogc                ó^   — t        | «      }t        |t        «      r|j                  d«      }|S ©NÚascii)Ú_quoteÚ
isinstanceÚstrÚencode©ÚsÚquoteds     ú;/usr/lib/python3/dist-packages/twisted/protocols/postfix.pyr   r      s(   € Ü�A‹Y€FÜ�&œ#ÔØ—‘˜wÓ'ˆØ€Mó    c                ó|   — t        | t        «      r| j                  d«      } t        | «      }|j	                  d«      S r   )r   ÚbytesÚdecodeÚ_unquoter   r   s     r   r   r      s2   € Ü�!”UÔØ�H‰H�WÓˆÜ�a‹[€FØ�=‰=˜Ó!Ð!r   c                  óD   — e Zd ZdZdZdZd„ Zdd„Zd„ Zd„ Z	d„ Z
d	„ Zd
„ Zy)ÚPostfixTCPMapServera  
    Postfix mail transport agent TCP map protocol implementation.

    Receive requests for data matching given key via lineReceived,
    asks it's factory for the data with self.factory.get(key), and
    returns the data to the requester. None means no entry found.

    You can use postfix's postmap to test the map service::

    /usr/sbin/postmap -q KEY tcp:localhost:4242

    iX  ó   
c                ó:   — | j                  | j                  «       y ©N)Ú
setTimeoutÚtimeout)Úselfs    r   ÚconnectionMadez"PostfixTCPMapServer.connectionMade5   s   € Ø�‰˜Ÿ™Õ%r   c                ób   — | j                  t        |«      j                  d«      dz   |z   «       y)z8
        Send an SMTP-like code with a message.
        r   ó    N)ÚsendLiner   r   )r%   ÚcodeÚmessages      r   ÚsendCodezPostfixTCPMapServer.sendCode8   s)   € ð 	�‰”c˜$“i×&Ñ& wÓ/°$Ñ6¸Ñ@ÕAr   c                óº  — | j                  «        	 |j                  d d«      \  }}	 t        | d|j	                  d«      z   «      }	  ||«       y # t        $ r |}d }Y Œ8w xY w# t
        $ rM t        t        j                  «       d   «      j                  d«      }| j                  dd|z   dz   |z   «       Y y w xY w# t        $ r | j                  dd«       Y y w xY w)Né   Údo_r   é�  s   Command s	    failed: s   unknown command)ÚresetTimeoutÚsplitÚ
ValueErrorÚgetattrr   ÚBaseExceptionr   ÚsysÚexc_infor   r,   ÚAttributeError)r%   ÚlineÚrequestÚparamsÚfÚexcInfos         r   ÚlineReceivedz PostfixTCPMapServer.lineReceived>   sÝ   € Ø×ÑÔð	Ø"Ÿj™j¨¨qÓ1‰OˆG�Vð		SÜ˜˜e g§n¡n°WÓ&=Ñ=Ó>ˆAðSÙ�&•	øô ò 	ØˆGØŠFð	ûô !ò SÜœcŸl™l›n¨QÑ/Ó0×7Ñ7¸Ó@�Ø—‘˜c ;°Ñ#8¸<Ñ#GÈ'Ñ#QÖRðSûô ò 	3Ø�M‰M˜#Ð1Ö2ð	3ús5   ’A ¨B< ÁA# ÁA ÁA Á#AB9Â8B9Â<CÃCc                ó  — |€| j                  dd«       y t        j                  | j                  j                  |«      }|j                  | j                  | j                  «       |j                  t        j                  «       y )Nr0   s!   Command 'get' takes 1 parameters.)r,   r	   ÚmaybeDeferredÚfactoryÚgetÚaddCallbacksÚ_cbGotÚ_cbNotÚ
addErrbackr   Úerr)r%   ÚkeyÚds      r   Údo_getzPostfixTCPMapServer.do_getP   sX   € Øˆ;Ø�M‰M˜#ÐCÕDä×#Ñ# D§L¡L×$4Ñ$4°cÓ:ˆAØ�N‰N˜4Ÿ;™;¨¯©Ô4Ø�L‰LœŸ™Õ!r   c                óf   — |j                  «       j                  d«      }| j                  d|«       y )Nr   r0   )ÚgetErrorMessager   r,   )r%   ÚfailÚmsgs      r   rE   zPostfixTCPMapServer._cbNotX   s)   € Ø×"Ñ"Ó$×+Ñ+¨GÓ4ˆØ�‰�c˜3Õr   c                ób   — |€| j                  d«       y | j                  dt        |«      «       y )Néô  éÈ   )r,   r   )r%   Úvalues     r   rD   zPostfixTCPMapServer._cbGot\   s%   € Øˆ=Ø�M‰M˜#Õà�M‰M˜#œu U›|Õ,r   c                óÀ   — |€| j                  dd«       y 	 |j                  d d«      \  }}| j                  dd«       y # t        $ r | j                  dd«       Y y w xY w)Nr0   s!   Command 'put' takes 2 parameters.r.   rP   s   put is not implemented yet.)r,   r2   r3   )r%   ÚkeyAndValuerH   rR   s       r   Údo_putzPostfixTCPMapServer.do_putb   sf   € ØÐØ�M‰M˜#ÐCÕDðCØ(×.Ñ.¨t°QÓ7‘
��Uð —‘˜cÐ#AÕBøô ò IØ—‘˜cÐ#GÖHðIús   —? ¿AÁAN)r   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__r$   Ú	delimiterr&   r,   r>   rJ   rE   rD   rU   © r   r   r   r   $   s9   „ ñð €GØ€Iò&óBòSò$"ò ò-ó	Cr   r   )é   é	   c                  ó   — e Zd ZdZeZy)ÚPostfixTCPMapDictServerFactoryúB
    An in-memory dictionary factory for PostfixTCPMapServer.
    N)rV   rW   rX   rY   r   r
   r[   r   r   r_   r_   t   s   „ ñð #�Hr   r_   c                  ó"   — e Zd ZdZeZdd„Zd„ Zy)Ú'PostfixTCPMapDeferringDictServerFactoryr`   Nc                óN   — i | _         |�| j                   j                  |«       y y r"   )ÚdataÚupdate)r%   rd   s     r   Ú__init__z0PostfixTCPMapDeferringDictServerFactory.__init__ƒ   s&   € ØˆŒ	ØÐØ�I‰I×Ñ˜TÕ"ð r   c                ó^   — t        j                  | j                  j                  |«      «      S r"   )r	   Úsucceedrd   rB   )r%   rH   s     r   rB   z+PostfixTCPMapDeferringDictServerFactory.getˆ   s   € Ü�}‰}˜TŸY™YŸ]™]¨3Ó/Ó0Ð0r   r"   )rV   rW   rX   rY   r   r
   rf   rB   r[   r   r   rb   rb   |   s   „ ñð #€Hó#ó
1r   rb   ) rY   Ú
__future__r   r6   Úcollectionsr   Útypingr   r   Úurllib.parser   r   r   r   Útwisted.internetr	   r
   Útwisted.protocolsr   r   Útwisted.pythonr   ÚLineReceiverÚTimeoutMixinr   Úversion_infor   r   Ú_PostfixTCPMapDictÚServerFactoryr_   rb   r[   r   r   ú<module>ru      s¥   ðñ
õ #ã 
Ý  ß 'ß =ç ,ß -Ý ò
ò"ôGC˜%×,Ñ,¨h×.CÑ.Cô GCñT �C×$Ñ$¨Ò.Ø! %¨¨s°E¨zÑ):Ð":Ñ;Ñà!Ðô#Ð%7¸×9OÑ9Oô #ô1¨h×.DÑ.Dõ 1r   