
    h                    b   S r SSKJr  SSKrSSKJr  SSKJrJr  SSK	J
rJr  SSKJrJr  SSKJrJr  SS	KJr  S
 r
S r " S S\R,                  \R.                  5      r\(       d  \R2                  S:  a  \\\\\4   4   rO\r " S S\\R:                  5      r " S S\R:                  5      rg)z1
Postfix mail transport agent related protocols.
    )annotationsN)UserDict)TYPE_CHECKINGUnion)quoteunquote)deferprotocol)basicpolicies)logc                h    [        U 5      n[        U[        5      (       a  UR                  S5      nU$ Nascii)_quote
isinstancestrencodesquoteds     `/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/protocols/postfix.pyr   r      s+    AYF&#w'M    c                    [        U [        5      (       a  U R                  S5      n [        U 5      nUR	                  S5      $ r   )r   bytesdecode_unquoter   r   s     r   r   r      s5    !UHHWa[F==!!r   c                  N    \ rS rSrSrSrSrS rSS jrS r	S r
S	 rS
 rS rSrg)PostfixTCPMapServer$   ac  
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                :    U R                  U R                  5        g N)
setTimeouttimeout)selfs    r   connectionMade"PostfixTCPMapServer.connectionMade5   s    %r   c                b    U R                  [        U5      R                  S5      S-   U-   5        g)z(
Send an SMTP-like code with a message.
r       N)sendLiner   r   )r&   codemessages      r   sendCodePostfixTCPMapServer.sendCode8   s)     	c$i&&w/$6@Ar   c                   U R                  5          UR                  S S5      u  p# [        U SUR	                  S5      -   5      n U" U5        g ! [         a    UnS n N9f = f! [
         aN    [        [        R                  " 5       S   5      R                  S5      nU R                  SSU-   S-   U-   5         g f = f! [         a    U R                  SS5         g f = f)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   lineReceived PostfixTCPMapServer.lineReceived>   s    	"jjq1OG		SegnnW&==>AS&	  	GF	 ! ScllnQ/077@c;#8<#G'#QRS  	3MM#12	3s5   A B> A# A A #AB;:B;>CCc                   Uc  U R                  SS5        g [        R                  " U R                  R                  U5      nUR                  U R                  U R                  5        UR                  [        R                  5        g )Nr3   s!   Command 'get' takes 1 parameters.)r.   r	   maybeDeferredfactorygetaddCallbacks_cbGot_cbNot
addErrbackr   err)r&   keyds      r   do_getPostfixTCPMapServer.do_getP   sX    ;MM#CD##DLL$4$4c:ANN4;;4LL!r   c                f    UR                  5       R                  S5      nU R                  SU5        g )Nr   r3   )getErrorMessager   r.   )r&   failmsgs      r   rI   PostfixTCPMapServer._cbNotX   s)    ""$++G4c3r   c                d    Uc  U R                  S5        g U R                  S[        U5      5        g )N     )r.   r   )r&   values     r   rH   PostfixTCPMapServer._cbGot\   s%    =MM#MM#uU|,r   c                    Uc  U R                  SS5        g  UR                  S S5      u  p#U R                  SS5        g ! [         a    U R                  SS5         g f = f)Nr3   s!   Command 'put' takes 2 parameters.r1   rV   s   put is not implemented yet.)r.   r5   r6   )r&   keyAndValuerL   rX   s       r   do_putPostfixTCPMapServer.do_putb   sd    MM#CDC(..tQ7
 c#AB  Ic#GHIs   ? AA N)r   )__name__
__module____qualname____firstlineno____doc__r%   	delimiterr'   r.   rA   rN   rI   rH   r\   __static_attributes__r^   r   r   r   r   $   s9     GI&BS$" -	Cr   r   )   	   c                      \ rS rSrSr\rSrg)PostfixTCPMapDictServerFactoryt   :
An in-memory dictionary factory for PostfixTCPMapServer.
r^   N)r_   r`   ra   rb   rc   r   r
   re   r^   r   r   ri   ri   t   s     #Hr   ri   c                  ,    \ rS rSrSr\rSS jrS rSr	g)'PostfixTCPMapDeferringDictServerFactory|   rk   Nc                P    0 U l         Ub  U R                   R                  U5        g g r#   )dataupdate)r&   rp   s     r   __init__0PostfixTCPMapDeferringDictServerFactory.__init__   s&    	IIT" r   c                `    [         R                  " U R                  R                  U5      5      $ r#   )r	   succeedrp   rF   )r&   rL   s     r   rF   +PostfixTCPMapDeferringDictServerFactory.get   s    }}TYY]]3/00r   )rp   r#   )
r_   r`   ra   rb   rc   r   r
   rr   rF   re   r^   r   r   rm   rm   |   s     #H#
1r   rm   ) rc   
__future__r   r9   collectionsr   typingr   r   urllib.parser   r   r   r   twisted.internetr	   r
   twisted.protocolsr   r   twisted.pythonr   LineReceiverTimeoutMixinr   version_infor   r   _PostfixTCPMapDictServerFactoryri   rm   r^   r   r   <module>r      s   
 # 
   ' = , - 
"GC%,,h.C.C GCT C$$.!%sEz):":;!#%79O9O #1h.D.D 1r   