
    h                        S SK Jr  S SKrS SKrSSKJr  SSKJrJrJ	r	J
r
Jr   " S S5      r " S	 S
\5      r " S S\
5      r " S S\	5      r " S S\5      rg)    )annotationsN   )	ReadError   )SOCKET_OPTIONAsyncNetworkBackendAsyncNetworkStreamNetworkBackendNetworkStreamc                  (    \ rS rSrSS jrSS jrSrg)MockSSLObject   c                    Xl         g N_http2)selfhttp2s     I/var/www/html/env/lib/python3.13/site-packages/httpcore/_backends/mock.py__init__MockSSLObject.__init__   s        c                ,    U R                   (       a  S$ S$ )Nh2zhttp/1.1r   r   s    r   selected_alpn_protocol$MockSSLObject.selected_alpn_protocol   s    {{t2
2r   r   N)r   boolreturnstr)__name__
__module____qualname____firstlineno__r   r   __static_attributes__ r   r   r   r      s    3r   r   c                  |    \ rS rSrSSS jjrSSS jjrSSS jjrSS jr  S       SS jjrSS jr	SS	 jr
S
rg)
MockStream   c                *    Xl         X l        SU l        g NF_bufferr   _closedr   bufferr   s      r   r   MockStream.__init__       r   Nc                    U R                   (       a  [        S5      eU R                  (       d  gU R                  R                  S5      $ NzConnection closedr   r   r/   r   r.   popr   	max_bytestimeouts      r   readMockStream.read   s4    <</00||||""r   c                    g r   r'   r   r1   r:   s      r   writeMockStream.write%       r   c                    SU l         g NTr/   r   s    r   closeMockStream.close(   s	    r   c                    U $ r   r'   r   ssl_contextserver_hostnamer:   s       r   	start_tlsMockStream.start_tls+   s	     r   c                8    US:X  a  [        U R                  S9$ S $ N
ssl_objectr   r   r   r   infos     r   get_extra_infoMockStream.get_extra_info3       37<3G}4;;/QTQr   c                    g)Nz<httpcore.MockStream>r'   r   s    r   __repr__MockStream.__repr__6   s    &r   r.   r/   r   Fr1   zlist[bytes]r   r   r    Noner   r9   intr:   float | Noner    bytesr1   ra   r:   r`   r    r]   r    r]   NN)rI   ssl.SSLContextrJ   
str | Noner:   r`   r    r   rS   r!   r    z
typing.Anyr   )r"   r#   r$   r%   r   r;   r?   rE   rK   rT   rX   r&   r'   r   r   r)   r)      sT    
# '+ $	# $ 	
 
R'r   r)   c                  v    \ rS rSrSS	S jjr   S
           SS jjr  S       SS jjrSS jrSrg)MockBackend:   c                    Xl         X l        g r   r.   r   r0   s      r   r   MockBackend.__init__;       r   Nc                P    [        [        U R                  5      U R                  S9$ NrP   r)   listr.   r   r   hostportr:   local_addresssocket_optionss         r   connect_tcpMockBackend.connect_tcp?   s     $t||,DKK@@r   c                P    [        [        U R                  5      U R                  S9$ rp   rq   r   pathr:   rw   s       r   connect_unix_socketMockBackend.connect_unix_socketI   s     $t||,DKK@@r   c                    g r   r'   r   secondss     r   sleepMockBackend.sleepQ   rA   r   rl   r[   r\   NNN)rt   r!   ru   r_   r:   r`   rv   rf   rw   %typing.Iterable[SOCKET_OPTION] | Noner    r   rd   )r|   r!   r:   r`   rw   r   r    r   r   floatr    r]   	r"   r#   r$   r%   r   rx   r}   r   r&   r'   r   r   ri   ri   :   s     !%$(@DAA A 	A
 "A >A 
A !%@D	AA A >	A
 
Ar   ri   c                  |    \ rS rSrSSS jjrSSS jjrSSS jjrSS jr  S       SS jjrSS jr	SS	 jr
S
rg)AsyncMockStreamU   c                *    Xl         X l        SU l        g r,   r-   r0   s      r   r   AsyncMockStream.__init__V   r3   r   Nc                   #    U R                   (       a  [        S5      eU R                  (       d  gU R                  R                  S5      $ 7fr5   r6   r8   s      r   r;   AsyncMockStream.read[   s7     <</00||||""s   A
Ac                   #    g 7fr   r'   r>   s      r   r?   AsyncMockStream.writeb           c                   #    SU l         g 7frC   rD   r   s    r   acloseAsyncMockStream.aclosee   s     s   	c                   #    U $ 7fr   r'   rH   s       r   rK   AsyncMockStream.start_tlsh   s      s   c                8    US:X  a  [        U R                  S9$ S $ rN   rQ   rR   s     r   rT   AsyncMockStream.get_extra_infop   rV   r   c                    g)Nz<httpcore.AsyncMockStream>r'   r   s    r   rX   AsyncMockStream.__repr__s   s    +r   rZ   r[   r\   r   r^   rb   rc   rd   )rI   re   rJ   rf   r:   r`   r    r	   rg   r   )r"   r#   r$   r%   r   r;   r?   r   rK   rT   rX   r&   r'   r   r   r   r   U   sT    
# '+ $	# $ 	
 
R,r   r   c                  v    \ rS rSrSS	S jjr   S
           SS jjr  S       SS jjrSS jrSrg)AsyncMockBackendw   c                    Xl         X l        g r   rl   r0   s      r   r   AsyncMockBackend.__init__x   rn   r   Nc                X   #    [        [        U R                  5      U R                  S9$ 7frp   r   rr   r.   r   rs   s         r   rx   AsyncMockBackend.connect_tcp|   s!      tDLL1EE   (*c                X   #    [        [        U R                  5      U R                  S9$ 7frp   r   r{   s       r   r}   $AsyncMockBackend.connect_unix_socket   s!      tDLL1EEr   c                   #    g 7fr   r'   r   s     r   r   AsyncMockBackend.sleep   r   r   rl   r[   r\   r   )rt   r!   ru   r_   r:   r`   rv   rf   rw   r   r    r	   rd   )r|   r!   r:   r`   rw   r   r    r	   r   r   r'   r   r   r   r   w   s     !%$(@DFF F 	F
 "F >F 
F !%@D	FF F >	F
 
Fr   r   )
__future__r   ssltyping_exceptionsr   baser   r   r	   r
   r   r   r)   ri   r   r   r'   r   r   <module>r      sY    " 
  # 3 3' 'D. 6,( ,D* r   