Ë
    $Æ%hí  ã                  ó´   — 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y)é    )ÚannotationsNé   )Ú	ReadErroré   )ÚSOCKET_OPTIONÚAsyncNetworkBackendÚAsyncNetworkStreamÚNetworkBackendÚNetworkStreamc                  ó   — e Zd Zdd„Zdd„Zy)ÚMockSSLObjectc                ó   — || _         y ©N©Ú_http2)ÚselfÚhttp2s     úU/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/httpcore/_backends/mock.pyÚ__init__zMockSSLObject.__init__   s	   € Øˆ�ó    c                ó"   — | j                   rdS dS )NÚh2zhttp/1.1r   ©r   s    r   Úselected_alpn_protocolz$MockSSLObject.selected_alpn_protocol   s   € Ø—{’{ˆtÐ2¨
Ð2r   N)r   Úbool©ÚreturnÚstr)Ú__name__Ú
__module__Ú__qualname__r   r   © r   r   r   r      s   „ óô3r   r   c                  ó^   — 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	y)Ú
MockStreamc                ó.   — || _         || _        d| _        y ©NF©Ú_bufferr   Ú_closed©r   Úbufferr   s      r   r   zMockStream.__init__   ó   € ØˆŒØˆŒØˆ�r   Nc                ó€   — | j                   rt        d«      ‚| j                  sy| j                  j                  d«      S ©NzConnection closedr   r   ©r)   r   r(   Úpop©r   Ú	max_bytesÚtimeouts      r   ÚreadzMockStream.read   s4   € Ø�<Š<ÜÐ/Ó0Ð0Ø�|Š|ØØ�|‰|×Ñ Ó"Ð"r   c                 ó   — y r   r"   ©r   r+   r3   s      r   ÚwritezMockStream.write%   ó   € Ør   c                ó   — d| _         y ©NT©r)   r   s    r   ÚclosezMockStream.close(   s	   € Øˆ�r   c                ó   — | S r   r"   ©r   Ússl_contextÚserver_hostnamer3   s       r   Ú	start_tlszMockStream.start_tls+   s	   € ð ˆr   c                ó<   — |dk(  rt        | j                  ¬«      S d S ©NÚ
ssl_object©r   ©r   r   ©r   Úinfos     r   Úget_extra_infozMockStream.get_extra_info3   ó   € Ø37¸<Ò3GŒ} 4§;¡;Ô/ÐQÈTÐQr   c                 ó   — y)Nz<httpcore.MockStream>r"   r   s    r   Ú__repr__zMockStream.__repr__6   s   € Ø&r   ©F©r+   zlist[bytes]r   r   r   ÚNoner   ©r2   Úintr3   úfloat | Noner   Úbytes©r+   rS   r3   rR   r   rO   ©r   rO   ©NN)r?   ússl.SSLContextr@   ú
str | Noner3   rR   r   r   ©rH   r   r   z
typing.Anyr   )
r   r    r!   r   r4   r7   r<   rA   rI   rL   r"   r   r   r$   r$      sT   „ ôô
#ôóð '+Ø $ð	à#ðð $ðð ð	ð
 
óóRô'r   r$   c                  ó`   — e Zd Zddd„Z	 	 	 d	 	 	 	 	 	 	 	 	 	 	 d	d„Z	 	 d
	 	 	 	 	 	 	 dd„Zdd„Zy)ÚMockBackendc                ó    — || _         || _        y r   ©r(   r   r*   s      r   r   zMockBackend.__init__;   ó   € ØˆŒØˆ�r   Nc                óV   — t        t        | j                  «      | j                  ¬«      S ©NrE   ©r$   Úlistr(   r   ©r   ÚhostÚportr3   Úlocal_addressÚsocket_optionss         r   Úconnect_tcpzMockBackend.connect_tcp?   s   € ô œ$˜tŸ|™|Ó,°D·K±KÔ@Ð@r   c                óV   — t        t        | j                  «      | j                  ¬«      S r`   ra   ©r   Úpathr3   rg   s       r   Úconnect_unix_socketzMockBackend.connect_unix_socketI   s   € ô œ$˜tŸ|™|Ó,°D·K±KÔ@Ð@r   c                 ó   — y r   r"   ©r   Úsecondss     r   ÚsleepzMockBackend.sleepQ   r8   r   rM   rN   ©NNN)rd   r   re   rQ   r3   rR   rf   rX   rg   ú%typing.Iterable[SOCKET_OPTION] | Noner   r   rV   )rk   r   r3   rR   rg   rr   r   r   ©ro   Úfloatr   rO   ©r   r    r!   r   rh   rl   rp   r"   r   r   r[   r[   :   s•   „ ôð !%Ø$(Ø@DðAàðAð ðAð ð	Að
 "ðAð >ðAð 
óAð !%Ø@Dð	AàðAð ðAð >ð	Að
 
óAôr   r[   c                  ó^   — 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	y)ÚAsyncMockStreamc                ó.   — || _         || _        d| _        y r&   r'   r*   s      r   r   zAsyncMockStream.__init__V   r,   r   Nc              ƒ  óˆ   K  — | j                   rt        d«      ‚| j                  sy| j                  j                  d«      S ­wr.   r/   r1   s      r   r4   zAsyncMockStream.read[   s8   è ø€ Ø�<Š<ÜÐ/Ó0Ð0Ø�|Š|ØØ�|‰|×Ñ Ó"Ð"ùs   ‚A Ac              ƒ  ó   K  — y ­wr   r"   r6   s      r   r7   zAsyncMockStream.writeb   ó	   è ø€ Øùó   ‚c              ƒ  ó   K  — d| _         y ­wr:   r;   r   s    r   ÚaclosezAsyncMockStream.aclosee   s   è ø€ Øˆ�ùs   ‚	c              ƒ  ó   K  — | S ­wr   r"   r>   s       r   rA   zAsyncMockStream.start_tlsh   s   è ø€ ð ˆùs   ‚c                ó<   — |dk(  rt        | j                  ¬«      S d S rC   rF   rG   s     r   rI   zAsyncMockStream.get_extra_infop   rJ   r   c                 ó   — y)Nz<httpcore.AsyncMockStream>r"   r   s    r   rL   zAsyncMockStream.__repr__s   s   € Ø+r   rM   rN   r   rP   rT   rU   rV   )r?   rW   r@   rX   r3   rR   r   r	   rY   r   )
r   r    r!   r   r4   r7   r~   rA   rI   rL   r"   r   r   rw   rw   U   sT   „ ôô
#ôóð '+Ø $ð	à#ðð $ðð ð	ð
 
óóRô,r   rw   c                  ó`   — e Zd Zddd„Z	 	 	 d	 	 	 	 	 	 	 	 	 	 	 d	d„Z	 	 d
	 	 	 	 	 	 	 dd„Zdd„Zy)ÚAsyncMockBackendc                ó    — || _         || _        y r   r]   r*   s      r   r   zAsyncMockBackend.__init__x   r^   r   Nc              ƒ  ó^   K  — t        t        | j                  «      | j                  ¬«      S ­wr`   ©rw   rb   r(   r   rc   s         r   rh   zAsyncMockBackend.connect_tcp|   s"   è ø€ ô œt D§L¡LÓ1¸¿¹ÔEÐEùó   ‚+-c              ƒ  ó^   K  — t        t        | j                  «      | j                  ¬«      S ­wr`   r†   rj   s       r   rl   z$AsyncMockBackend.connect_unix_socket†   s"   è ø€ ô œt D§L¡LÓ1¸¿¹ÔEÐEùr‡   c              ƒ  ó   K  — y ­wr   r"   rn   s     r   rp   zAsyncMockBackend.sleepŽ   r{   r|   rM   rN   rq   )rd   r   re   rQ   r3   rR   rf   rX   rg   rr   r   r	   rV   )rk   r   r3   rR   rg   rr   r   r	   rs   ru   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$   r[   rw   rƒ   r"   r   r   ú<module>r�      sY   ðÝ "ã 
Û å #÷õ ÷3ñ 3ô'�ô 'ôD�.ô ô6,Ð(ô ,ôDÐ*õ r   