§
    ÏÁ³gl  ã                  óž   — d dl mZ d dlZd dlZd dlZddlmZmZmZm	Z	m
Z
mZmZmZ ddlmZmZmZ  G d„ de¦  «        Z G d	„ d
e¦  «        ZdS )é    )ÚannotationsNé   )ÚConnectErrorÚConnectTimeoutÚExceptionMappingÚ	ReadErrorÚReadTimeoutÚ
WriteErrorÚWriteTimeoutÚmap_exceptionsé   )ÚSOCKET_OPTIONÚAsyncNetworkBackendÚAsyncNetworkStreamc                  óP   — e Zd Z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 )%Ú
TrioStreamÚstreamútrio.abc.StreamÚreturnÚNonec                ó   — || _         d S ©N)Ú_stream©Úselfr   s     úU/var/www/html/mpstechhub/venv/lib/python3.11/site-packages/httpcore/_backends/trio.pyÚ__init__zTrioStream.__init__   s   € ØˆŒˆˆó    NÚ	max_bytesÚintÚtimeoutúfloat | NoneÚbytesc              ƒ  ó¢  K  — |€t          d¦  «        n|}t          j        t          t          j        t
          t          j        t
          i}t          |¦  «        5  t          j        |¦  «        5  | j	         
                    |¬¦  «        ƒ d {V —†}|cd d d ¦  «         cd d d ¦  «         S # 1 swxY w Y   	 d d d ¦  «         d S # 1 swxY w Y   d S )NÚinf)r   )ÚfloatÚtrioÚTooSlowErrorr	   ÚBrokenResourceErrorr   ÚClosedResourceErrorr   Ú
fail_afterr   Úreceive_some)r   r   r!   Útimeout_or_infÚexc_mapÚdatas         r   ÚreadzTrioStream.read   sk  è è € Ø)0¨�˜u™œ˜¸gˆåÔ�{ÝÔ$¥iÝÔ$¥ið%
ˆõ
 ˜GÑ$Ô$ð 	ð 	Ý” Ñ0Ô0ð ð Ø$(¤L×$=Ò$=È	Ð$=Ñ$RÔ$RÐRÐRÐRÐRÐRÐR�Øðð ð ð ñ ô ð ð	ð 	ð 	ð 	ñ 	ô 	ð 	ð 	ðð ð ð øøøð ð ð ð ð ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	s6   ÁCÁ/#B+ÂCÂ+B/	Â/CÂ2B/	Â3CÃCÃCÚbufferc              ƒ  óŒ  K  — |sd S |€t          d¦  «        n|}t          j        t          t          j        t
          t          j        t
          i}t          |¦  «        5  t          j        |¦  «        5  | j	         
                    |¬¦  «        ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         d S # 1 swxY w Y   d S )Nr%   )r/   )r&   r'   r(   r   r)   r
   r*   r   r+   r   Úsend_all)r   r1   r!   r-   r.   s        r   ÚwritezTrioStream.write%   sI  è è € Øð 	ØˆFà)0¨�˜u™œ˜¸gˆåÔ�|ÝÔ$¥jÝÔ$¥jð%
ˆõ
 ˜GÑ$Ô$ð 	9ð 	9Ý” Ñ0Ô0ð 9ð 9Ø”l×+Ò+°Ð+Ñ8Ô8Ð8Ð8Ð8Ð8Ð8Ð8Ð8ð9ð 9ð 9ñ 9ô 9ð 9ð 9ð 9ð 9ð 9ð 9øøøð 9ð 9ð 9ð 9ð	9ð 	9ð 	9ñ 	9ô 	9ð 	9ð 	9ð 	9ð 	9ð 	9ð 	9ð 	9øøøð 	9ð 	9ð 	9ð 	9ð 	9ð 	9s6   ÁB9Á3"B!ÂB9Â!B%	Â%B9Â(B%	Â)B9Â9B=Ã B=c              ƒ  óH   K  — | j                              ¦   «         ƒ d {V —† d S r   )r   Úaclose)r   s    r   r6   zTrioStream.aclose3   s2   è è € ØŒl×!Ò!Ñ#Ô#Ð#Ð#Ð#Ð#Ð#Ð#Ð#Ð#Ð#r   Ússl_contextússl.SSLContextÚserver_hostnameú
str | Noner   c              ƒ  ó  K  — |€t          d¦  «        n|}t          j        t          t          j        t
          i}t          j        | j        ||dd¬¦  «        }t          |¦  «        5  	 t          j	        |¦  «        5  | 
                    ¦   «         ƒ d {V —† d d d ¦  «         n# 1 swxY w Y   n.# t          $ r!}|                      ¦   «         ƒ d {V —† |‚d }~ww xY wd d d ¦  «         n# 1 swxY w Y   t          |¦  «        S )Nr%   TF)r7   r9   Úhttps_compatibleÚserver_side)r&   r'   r(   r   r)   r   Ú	SSLStreamr   r   r+   Údo_handshakeÚ	Exceptionr6   r   )r   r7   r9   r!   r-   r.   Ú
ssl_streamÚexcs           r   Ú	start_tlszTrioStream.start_tls6   s£  è è € ð *1¨�˜u™œ˜¸gˆåÔ�~ÝÔ$¥lð%
ˆõ ”^ØŒLØ#Ø+Ø!Øð
ñ 
ô 
ˆ
õ ˜GÑ$Ô$ð 	ð 	ðÝ”_ ^Ñ4Ô4ð 4ð 4Ø$×1Ò1Ñ3Ô3Ð3Ð3Ð3Ð3Ð3Ð3Ð3ð4ð 4ð 4ñ 4ô 4ð 4ð 4ð 4ð 4ð 4ð 4øøøð 4ð 4ð 4ð 4øøåð ð ð Ø—k’k‘m”mÐ#Ð#Ð#Ð#Ð#Ð#Ð#Ø�	øøøøðøøøð		ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	õ ˜*Ñ%Ô%Ð%sZ   Á'C*Á)B0Á=B$ÂB0Â$B(	Â(B0Â+B(	Â,B0Â/C*Â0
CÂ:CÃCÃC*Ã*C.Ã1C.ÚinfoÚstrú
typing.Anyc                ó`  — |dk    r+t          | j        t          j        ¦  «        r| j        j        S |dk    r+|                      ¦   «         j                             ¦   «         S |dk    r+|                      ¦   «         j                             ¦   «         S |dk    re| j        }t          |t          j        ¦  «        r!|j	        }t          |t          j        ¦  «        °!t          |t          j
        ¦  «        sJ ‚|j        S |dk    r)|                      d¦  «        }|                     ¦   «         S d S )NÚ
ssl_objectÚclient_addrÚserver_addrÚsocketÚis_readable)Ú
isinstancer   r'   r>   Ú_ssl_objectÚ_get_socket_streamrK   ÚgetsocknameÚgetpeernameÚtransport_streamÚSocketStreamÚget_extra_inforL   )r   rD   r   rK   s       r   rT   zTrioStream.get_extra_infoQ   s  € Ø�<ÒÐ¥J¨t¬|½T¼^Ñ$LÔ$LÐð ”<Ô+Ð+Ø�=Ò Ð Ø×*Ò*Ñ,Ô,Ô3×?Ò?ÑAÔAÐAØ�=Ò Ð Ø×*Ò*Ñ,Ô,Ô3×?Ò?ÑAÔAÐAØ�8ÒÐØ”\ˆFÝ˜V¥T¤^Ñ4Ô4ð 1ØÔ0�õ ˜V¥T¤^Ñ4Ô4ð 1å˜f¥dÔ&7Ñ8Ô8Ð8Ð8Ð8Ø”=Ð Ø�=Ò Ð Ø×(Ò(¨Ñ2Ô2ˆFØ×%Ò%Ñ'Ô'Ð'Øˆtr   útrio.SocketStreamc                óÂ   — | j         }t          |t          j        ¦  «        r!|j        }t          |t          j        ¦  «        °!t          |t          j        ¦  «        sJ ‚|S r   )r   rM   r'   r>   rR   rS   r   s     r   rO   zTrioStream._get_socket_streame   sY   € Ø”ˆÝ˜¥¤Ñ0Ô0ð 	-ØÔ,ˆFõ ˜¥¤Ñ0Ô0ð 	-å˜&¥$Ô"3Ñ4Ô4Ð4Ð4Ð4Øˆr   )r   r   r   r   r   )r   r    r!   r"   r   r#   )r1   r#   r!   r"   r   r   )r   r   ©NN)r7   r8   r9   r:   r!   r"   r   r   )rD   rE   r   rF   )r   rU   )
Ú__name__Ú
__module__Ú__qualname__r   r0   r4   r6   rC   rT   rO   © r   r   r   r      s·   € € € € € ðð ð ð ð
ð 
ð 
ð 
ð 
ð9ð 9ð 9ð 9ð 9ð$ð $ð $ð $ð '+Ø $ð	&ð &ð &ð &ð &ð6ð ð ð ð(ð ð ð ð ð r   r   c                  ó4   — e Zd Z	 	 	 ddd„Z	 	 ddd„Zdd„ZdS )ÚTrioBackendNÚhostrE   Úportr    r!   r"   Úlocal_addressr:   Úsocket_optionsú%typing.Iterable[SOCKET_OPTION] | Noner   r   c              ƒ  ó²  K  — |€g }|€t          d¦  «        n|}t          j        t          t          j        t
          t          t
          i}t          |¦  «        5  t          j        |¦  «        5  t          j	        |||¬¦  «        ƒ d {V —†}|D ]}	 |j
        |	Ž  Œ	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   t          |¦  «        S )Nr%   )r^   r_   r`   )r&   r'   r(   r   r)   r   ÚOSErrorr   r+   Úopen_tcp_streamÚ
setsockoptr   )
r   r^   r_   r!   r`   ra   r-   r.   r   Úoptions
             r   Úconnect_tcpzTrioBackend.connect_tcpn   s�  è è € ð Ð!ØˆNØ)0¨�˜u™œ˜¸gˆåÔ�~ÝÔ$¥lÝ•\ð%
ˆõ
 ˜GÑ$Ô$ð 	/ð 	/Ý” Ñ0Ô0ð /ð /Ý04Ô0DØ D¸ð1ñ 1ô 1ð +ð +ð +ð +ð +ð +�ð -ð /ð /�FØ%�FÔ% vÐ.Ð.Ð.ð/ð	/ð /ð /ñ /ô /ð /ð /ð /ð /ð /ð /øøøð /ð /ð /ð /ð	/ð 	/ð 	/ñ 	/ô 	/ð 	/ð 	/ð 	/ð 	/ð 	/ð 	/øøøð 	/ð 	/ð 	/ð 	/õ ˜&Ñ!Ô!Ð!s6   ÁB?Á.-B(ÂB?Â(B,	Â,B?Â/B,	Â0B?Â?CÃCÚpathc              ƒ  ó¬  K  — |€g }|€t          d¦  «        n|}t          j        t          t          j        t
          t          t
          i}t          |¦  «        5  t          j        |¦  «        5  t          j	        |¦  «        ƒ d {V —†}|D ]} |j
        |Ž  Œ	 d d d ¦  «         n# 1 swxY w Y   d d d ¦  «         n# 1 swxY w Y   t          |¦  «        S )Nr%   )r&   r'   r(   r   r)   r   rd   r   r+   Úopen_unix_socketrf   r   )r   ri   r!   ra   r-   r.   r   rg   s           r   Úconnect_unix_socketzTrioBackend.connect_unix_socket‰   se  è è € ð Ð!ØˆNØ)0¨�˜u™œ˜¸gˆåÔ�~ÝÔ$¥lÝ•\ð%
ˆõ
 ˜GÑ$Ô$ð 	/ð 	/Ý” Ñ0Ô0ð /ð /Ý04Ô0EÀdÑ0KÔ0KÐ*KÐ*KÐ*KÐ*KÐ*KÐ*K�Ø,ð /ð /�FØ%�FÔ% vÐ.Ð.Ð.ð/ð/ð /ð /ñ /ô /ð /ð /ð /ð /ð /ð /øøøð /ð /ð /ð /ð	/ð 	/ð 	/ñ 	/ô 	/ð 	/ð 	/ð 	/ð 	/ð 	/ð 	/øøøð 	/ð 	/ð 	/ð 	/õ
 ˜&Ñ!Ô!Ð!s6   ÁB<Á.*B%ÂB<Â%B)	Â)B<Â,B)	Â-B<Â<C ÃC Úsecondsr&   r   c              ƒ  ó>   K  — t          j        |¦  «        ƒ d {V —† d S r   )r'   Úsleep)r   rm   s     r   ro   zTrioBackend.sleepž   s.   è è € ÝŒj˜Ñ!Ô!Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ð!r   )NNN)r^   rE   r_   r    r!   r"   r`   r:   ra   rb   r   r   rW   )ri   rE   r!   r"   ra   rb   r   r   )rm   r&   r   r   )rX   rY   rZ   rh   rl   ro   r[   r   r   r]   r]   m   sm   € € € € € ð
 !%Ø$(Ø@Dð"ð "ð "ð "ð "ð< !%Ø@Dð	"ð "ð "ð "ð "ð*"ð "ð "ð "ð "ð "r   r]   )Ú
__future__r   ÚsslÚtypingr'   Ú_exceptionsr   r   r   r   r	   r
   r   r   Úbaser   r   r   r   r]   r[   r   r   ú<module>ru      s   ðØ "Ð "Ð "Ð "Ð "Ð "à 
€
€
€
Ø €€€à €€€ð	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	ð IÐ HÐ HÐ HÐ HÐ HÐ HÐ HÐ HÐ HðUð Uð Uð Uð UÐ#ñ Uô Uð Uðp2"ð 2"ð 2"ð 2"ð 2"Ð%ñ 2"ô 2"ð 2"ð 2"ð 2"r   