§
    ÏÁ³gí  ã                  óÔ   — d dl mZ d dlZd dlZddlmZ ddlmZmZm	Z	m
Z
mZ  G d„ d¦  «        Z G d	„ d
e¦  «        Z G d„ de
¦  «        Z G d„ de	¦  «        Z G d„ de¦  «        ZdS )é    )ÚannotationsNé   )Ú	ReadErroré   )ÚSOCKET_OPTIONÚAsyncNetworkBackendÚAsyncNetworkStreamÚNetworkBackendÚNetworkStreamc                  ó   — e Zd Zdd„Zd	d„ZdS )
ÚMockSSLObjectÚhttp2Úboolc                ó   — || _         d S ©N©Ú_http2)Úselfr   s     úU/var/www/html/mpstechhub/venv/lib/python3.11/site-packages/httpcore/_backends/mock.pyÚ__init__zMockSSLObject.__init__   s   € ØˆŒˆˆó    ÚreturnÚstrc                ó   — | j         rdndS )NÚh2zhttp/1.1r   ©r   s    r   Úselected_alpn_protocolz$MockSSLObject.selected_alpn_protocol   s   € Ø”{Ð2ˆtˆt¨
Ð2r   N)r   r   ©r   r   )Ú__name__Ú
__module__Ú__qualname__r   r   © r   r   r   r      s<   € € € € € ðð ð ð ð3ð 3ð 3ð 3ð 3ð 3r   r   c                  óR   — e Zd Zddd„Zdd d„Zdd!d„Zd"d„Z	 	 d#d$d„Zd%d„Zd&d„Z	d	S )'Ú
MockStreamFÚbufferúlist[bytes]r   r   r   ÚNonec                ó0   — || _         || _        d| _        d S ©NF©Ú_bufferr   Ú_closed©r   r%   r   s      r   r   zMockStream.__init__   ó   € ØˆŒØˆŒØˆŒˆˆr   NÚ	max_bytesÚintÚtimeoutúfloat | NoneÚbytesc                ót   — | j         rt          d¦  «        ‚| j        sdS | j                             d¦  «        S ©NzConnection closedr   r   ©r,   r   r+   Úpop©r   r/   r1   s      r   ÚreadzMockStream.read   s@   € ØŒ<ð 	1ÝÐ/Ñ0Ô0Ð0ØŒ|ð 	Ø�3ØŒ|×Ò Ñ"Ô"Ð"r   c                ó   — d S r   r"   ©r   r%   r1   s      r   ÚwritezMockStream.write%   ó   € Øˆr   c                ó   — d| _         d S ©NT©r,   r   s    r   ÚclosezMockStream.close(   s   € ØˆŒˆˆr   Ússl_contextússl.SSLContextÚserver_hostnameú
str | Noner   c                ó   — | S r   r"   ©r   rB   rD   r1   s       r   Ú	start_tlszMockStream.start_tls+   s	   € ð ˆr   Úinfor   ú
typing.Anyc                ó<   — |dk    rt          | j        ¬¦  «        nd S ©NÚ
ssl_object©r   ©r   r   ©r   rI   s     r   Úget_extra_infozMockStream.get_extra_info3   ó$   € Ø37¸<Ò3GÐ3G�} 4¤;Ð/Ñ/Ô/Ð/ÈTÐQr   c                ó   — dS )Nz<httpcore.MockStream>r"   r   s    r   Ú__repr__zMockStream.__repr__6   s   € Ø&Ð&r   ©F©r%   r&   r   r   r   r'   r   ©r/   r0   r1   r2   r   r3   ©r%   r3   r1   r2   r   r'   ©r   r'   ©NN)rB   rC   rD   rE   r1   r2   r   r   ©rI   r   r   rJ   r   )
r   r    r!   r   r9   r<   rA   rH   rQ   rT   r"   r   r   r$   r$      sÀ   € € € € € ðð ð ð ð ð
#ð #ð #ð #ð #ðð ð ð ð ðð ð ð ð '+Ø $ð	ð ð ð ð ðRð Rð Rð Rð'ð 'ð 'ð 'ð 'ð 'r   r$   c                  ó>   — e Zd Zddd„Z	 	 	 ddd„Z	 	 dd d„Zd!d„Zd	S )"ÚMockBackendFr%   r&   r   r   r   r'   c                ó"   — || _         || _        d S r   ©r+   r   r-   s      r   r   zMockBackend.__init__;   ó   € ØˆŒØˆŒˆˆr   NÚhostr   Úportr0   r1   r2   Úlocal_addressrE   Úsocket_optionsú%typing.Iterable[SOCKET_OPTION] | Noner   c                óR   — t          t          | j        ¦  «        | j        ¬¦  «        S ©NrN   ©r$   Úlistr+   r   ©r   ra   rb   r1   rc   rd   s         r   Úconnect_tcpzMockBackend.connect_tcp?   s#   € õ �$˜tœ|Ñ,Ô,°D´KÐ@Ñ@Ô@Ð@r   Úpathc                óR   — t          t          | j        ¦  «        | j        ¬¦  «        S rg   rh   ©r   rl   r1   rd   s       r   Úconnect_unix_socketzMockBackend.connect_unix_socketI   s#   € õ �$˜tœ|Ñ,Ô,°D´KÐ@Ñ@Ô@Ð@r   ÚsecondsÚfloatc                ó   — d S r   r"   ©r   rp   s     r   ÚsleepzMockBackend.sleepQ   r=   r   rU   rV   ©NNN)ra   r   rb   r0   r1   r2   rc   rE   rd   re   r   r   rZ   )rl   r   r1   r2   rd   re   r   r   ©rp   rq   r   r'   ©r   r    r!   r   rk   ro   rt   r"   r   r   r]   r]   :   s�   € € € € € ðð ð ð ð ð !%Ø$(Ø@DðAð Að Að Að Að !%Ø@Dð	Að Að Að Að Aðð ð ð ð ð r   r]   c                  óR   — e Zd Zddd„Zdd d„Zdd!d„Zd"d„Z	 	 d#d$d„Zd%d„Zd&d„Z	d	S )'ÚAsyncMockStreamFr%   r&   r   r   r   r'   c                ó0   — || _         || _        d| _        d S r)   r*   r-   s      r   r   zAsyncMockStream.__init__V   r.   r   Nr/   r0   r1   r2   r3   c              ƒ  óx   K  — | j         rt          d¦  «        ‚| j        sdS | j                             d¦  «        S r5   r6   r8   s      r   r9   zAsyncMockStream.read[   sD   è è € ØŒ<ð 	1ÝÐ/Ñ0Ô0Ð0ØŒ|ð 	Ø�3ØŒ|×Ò Ñ"Ô"Ð"r   c              ƒ  ó
   K  — d S r   r"   r;   s      r   r<   zAsyncMockStream.writeb   ó   è è € Øˆr   c              ƒ  ó   K  — d| _         d S r?   r@   r   s    r   ÚaclosezAsyncMockStream.aclosee   s   è è € ØˆŒˆˆr   rB   rC   rD   rE   r	   c              ƒ  ó
   K  — | S r   r"   rG   s       r   rH   zAsyncMockStream.start_tlsh   s   è è € ð ˆr   rI   r   rJ   c                ó<   — |dk    rt          | j        ¬¦  «        nd S rL   rO   rP   s     r   rQ   zAsyncMockStream.get_extra_infop   rR   r   c                ó   — dS )Nz<httpcore.AsyncMockStream>r"   r   s    r   rT   zAsyncMockStream.__repr__s   s   € Ø+Ð+r   rU   rV   r   rW   rX   rY   rZ   )rB   rC   rD   rE   r1   r2   r   r	   r[   r   )
r   r    r!   r   r9   r<   r   rH   rQ   rT   r"   r   r   ry   ry   U   sÀ   € € € € € ðð ð ð ð ð
#ð #ð #ð #ð #ðð ð ð ð ðð ð ð ð '+Ø $ð	ð ð ð ð ðRð Rð Rð Rð,ð ,ð ,ð ,ð ,ð ,r   ry   c                  ó>   — e Zd Zddd„Z	 	 	 ddd„Z	 	 dd d„Zd!d„Zd	S )"ÚAsyncMockBackendFr%   r&   r   r   r   r'   c                ó"   — || _         || _        d S r   r_   r-   s      r   r   zAsyncMockBackend.__init__x   r`   r   Nra   r   rb   r0   r1   r2   rc   rE   rd   re   r	   c              ƒ  óV   K  — t          t          | j        ¦  «        | j        ¬¦  «        S rg   ©ry   ri   r+   r   rj   s         r   rk   zAsyncMockBackend.connect_tcp|   s'   è è € õ �t D¤LÑ1Ô1¸¼ÐEÑEÔEÐEr   rl   c              ƒ  óV   K  — t          t          | j        ¦  «        | j        ¬¦  «        S rg   r‡   rn   s       r   ro   z$AsyncMockBackend.connect_unix_socket†   s'   è è € õ �t D¤LÑ1Ô1¸¼ÐEÑEÔEÐEr   rp   rq   c              ƒ  ó
   K  — d S r   r"   rs   s     r   rt   zAsyncMockBackend.sleepŽ   r}   r   rU   rV   ru   )ra   r   rb   r0   r1   r2   rc   rE   rd   re   r   r	   rZ   )rl   r   r1   r2   rd   re   r   r	   rv   rw   r"   r   r   r„   r„   w   s�   € € € € € ðð ð ð ð ð !%Ø$(Ø@Dð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$   r]   ry   r„   r"   r   r   ú<module>r�      s_  ðØ "Ð "Ð "Ð "Ð "Ð "à 
€
€
€
Ø €€€à #Ð #Ð #Ð #Ð #Ð #ðð ð ð ð ð ð ð ð ð ð ð ð ð ð3ð 3ð 3ð 3ð 3ñ 3ô 3ð 3ð'ð 'ð 'ð 'ð '�ñ 'ô 'ð 'ðDð ð ð ð �.ñ ô ð ð6,ð ,ð ,ð ,ð ,Ð(ñ ,ô ,ð ,ðDð ð ð ð Ð*ñ ô ð ð ð r   