§
     @gê3  ã                  ó  — d Z ddlmZ ddlZddlZddlmZ ddlZddlm	Z	m
Z
mZmZ ddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZ ddlmZmZ dd	lm Z m!Z!m"Z"m#Z#m$Z$ dd
l%m&Z& ddl'm(Z(m)Z)  ej*        dd¬¦  «        Z+ ej*        dd¬¦  «        Z,ej-        ej.        e/e/e/f         ej.        e/e/ej-        e0e1f         f         ej.        e/e/de/f         f         Z2ej3        dd„¦   «         Z4ej        eej        eej        eej        eej        eej        eej        eej        eej        eej        eej        eej        eej        eej        eiZ5 G d„ de#¦  «        Z6 G d„ de)¦  «        Z7 G d„ de ¦  «        Z8 G d„ de(¦  «        Z9dS )a   
Custom transports, with nicely configured defaults.

The following additional keyword arguments are currently supported by httpcore...

* uds: str
* local_address: str
* retries: int

Example usages...

# Disable HTTP/2 on a single specific domain.
mounts = {
    "all://": httpx.HTTPTransport(http2=True),
    "all://*example.org": httpx.HTTPTransport()
}

# Using advanced httpcore configuration, with connection retries.
transport = httpx.HTTPTransport(retries=1)
client = httpx.Client(transport=transport)

# Using advanced httpcore configuration, with unix domain sockets.
transport = httpx.HTTPTransport(uds="socket.uds")
client = httpx.Client(transport=transport)
é    )ÚannotationsN)ÚTracebackTypeé   )ÚDEFAULT_LIMITSÚLimitsÚProxyÚcreate_ssl_context)ÚConnectErrorÚConnectTimeoutÚLocalProtocolErrorÚNetworkErrorÚPoolTimeoutÚProtocolErrorÚ
ProxyErrorÚ	ReadErrorÚReadTimeoutÚRemoteProtocolErrorÚTimeoutExceptionÚUnsupportedProtocolÚ
WriteErrorÚWriteTimeout)ÚRequestÚResponse)ÚAsyncByteStreamÚ	CertTypesÚ
ProxyTypesÚSyncByteStreamÚVerifyTypes)ÚURLé   )ÚAsyncBaseTransportÚBaseTransportÚTÚHTTPTransport)ÚboundÚAÚAsyncHTTPTransportÚreturnútyping.Iterator[None]c               #  ó   K  — 	 d V — d S # t           $ ri} d }t                               ¦   «         D ]*\  }}t          | |¦  «        sŒ|�t	          ||¦  «        r|}Œ+|€‚ t          | ¦  «        } ||¦  «        | ‚d } ~ ww xY w©N)Ú	ExceptionÚHTTPCORE_EXC_MAPÚitemsÚ
isinstanceÚ
issubclassÚstr)ÚexcÚ
mapped_excÚfrom_excÚto_excÚmessages        úM/var/www/piapp/venv/lib/python3.11/site-packages/httpx/_transports/default.pyÚmap_httpcore_exceptionsr8   B   s´   è è € ð+ØˆˆˆˆˆøÝð +ð +ð +Øˆ
å 0× 6Ò 6Ñ 8Ô 8ð 	$ð 	$ÑˆH�fÝ˜c 8Ñ,Ô,ð Øð Ð!¥Z°¸
Ñ%CÔ%CÐ!Ø#�
øàÐØå�c‘(”(ˆØˆj˜Ñ!Ô! sÐ*øøøøð!+øøøs   „
 Š
A=”A$A8Á8A=c                  ó&   — e Zd Zd
d„Zdd„Zdd„Zd	S )ÚResponseStreamÚhttpcore_streamútyping.Iterable[bytes]r(   ÚNonec                ó   — || _         d S r+   ©Ú_httpcore_stream©Úselfr;   s     r7   Ú__init__zResponseStream.__init__l   ó   € Ø /ˆÔÐÐó    útyping.Iterator[bytes]c              #  óv   K  — t          ¦   «         5  | j        D ]}|V — Œ	 d d d ¦  «         d S # 1 swxY w Y   d S r+   ©r8   r@   ©rB   Úparts     r7   Ú__iter__zResponseStream.__iter__o   s˜   è è € Ý$Ñ&Ô&ð 	ð 	ØÔ-ð ð �Ø�
�
�
�
ðð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	s   ‘.®2µ2c                óf   — t          | j        d¦  «        r| j                             ¦   «          d S d S )NÚclose)Úhasattrr@   rM   ©rB   s    r7   rM   zResponseStream.closet   s<   € Ý�4Ô(¨'Ñ2Ô2ð 	*ØÔ!×'Ò'Ñ)Ô)Ð)Ð)Ð)ð	*ð 	*rE   N)r;   r<   r(   r=   )r(   rF   ©r(   r=   )Ú__name__Ú
__module__Ú__qualname__rC   rK   rM   © rE   r7   r:   r:   k   sP   € € € € € ð0ð 0ð 0ð 0ðð ð ð ð
*ð *ð *ð *ð *ð *rE   r:   c                  óV   — e Zd Zddddeddddddfd*d„Zd+d„Z	 	 	 d,d-d$„Zd.d(„Zd/d)„ZdS )0r$   TNFr   Úverifyr   ÚcertúCertTypes | NoneÚhttp1ÚboolÚhttp2Úlimitsr   Ú	trust_envÚproxyúProxyTypes | NoneÚudsú
str | NoneÚlocal_addressÚretriesÚintÚsocket_optionsú%typing.Iterable[SOCKET_OPTION] | Noner(   r=   c                ó¤  — t          |||¬¦  «        }t          |t          t          f¦  «        rt	          |¬¦  «        n|}|€4t          j        ||j        |j        |j	        ||||	|
|¬¦
  «
        | _
        d S |j        j        dv r‡t          j        t          j        |j        j        |j        j        |j        j        |j        j        ¬¦  «        |j        |j        j        ||j        |j        |j        |j	        |||¬¦  «        | _
        d S |j        j        dk    r™	 dd l}n# t.          $ r t/          d	¦  «        d ‚w xY wt          j        t          j        |j        j        |j        j        |j        j        |j        j        ¬¦  «        |j        ||j        |j        |j	        ||¬
¦  «        | _
        d S t3          d|j        j        ›d�¦  «        ‚)N©rV   rW   r]   ©Úurl©
Ússl_contextÚmax_connectionsÚmax_keepalive_connectionsÚkeepalive_expiryrY   r[   r`   rb   rc   re   ©ÚhttpÚhttps©ÚschemeÚhostÚportÚtarget)Ú	proxy_urlÚ
proxy_authÚproxy_headersrl   Úproxy_ssl_contextrm   rn   ro   rY   r[   re   Úsocks5r   ú{Using SOCKS proxy, but the 'socksio' package is not installed. Make sure to install httpx using `pip install httpx[socks]`.©rx   ry   rl   rm   rn   ro   rY   r[   zDProxy protocol must be either 'http', 'https', or 'socks5', but got ú.)r	   r/   r1   r   r   ÚhttpcoreÚConnectionPoolrm   rn   ro   Ú_poolrj   rt   Ú	HTTPProxyÚ
raw_schemeÚraw_hostrv   Úraw_pathÚraw_authÚheadersÚrawrl   ÚsocksioÚImportErrorÚ
SOCKSProxyÚ
ValueError©rB   rV   rW   rY   r[   r\   r]   r^   r`   rb   rc   re   rl   rŠ   s                 r7   rC   zHTTPTransport.__init__z   s  € õ )°¸TÈYÐWÑWÔWˆÝ$.¨uµs½C°jÑ$AÔ$AÐL•˜%Ð Ñ Ô Ð Àuˆàˆ=Ý!Ô0Ø'Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØØØ+ØØ-ðñ ô ˆDŒJˆJˆJð ŒYÔÐ!2Ð2Ð2Ý!Ô+Ý"œ,Ø œ9Ô/ØœÔ+ØœœØ œ9Ô-ð	ñ ô ð !œ>Ø#œmÔ/Ø'Ø"'Ô"3Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØØ-ð!ñ ô ˆDŒJˆJˆJð$ ŒYÔ Ò)Ð)ðØ����øÝð ð ð Ý!ðSñô ð ððøøøõ "Ô,Ý"œ,Ø œ9Ô/ØœÔ+ØœœØ œ9Ô-ð	ñ ô ð !œ>Ø'Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØðñ ô ˆDŒJˆJˆJõ  ð2Ø!œIÔ,ð2ð 2ð 2ñô ð s   ÄD" Ä"D=rB   r#   c                ó8   — | j                              ¦   «          | S r+   )r‚   Ú	__enter__rO   s    r7   r�   zHTTPTransport.__enter__É   s   € ØŒ
×ÒÑÔÐØˆrE   Úexc_typeútype[BaseException] | NoneÚ	exc_valueúBaseException | NoneÚ	tracebackúTracebackType | Nonec                óŒ   — t          ¦   «         5  | j                             |||¦  «         d d d ¦  «         d S # 1 swxY w Y   d S r+   )r8   r‚   Ú__exit__©rB   r‘   r“   r•   s       r7   r˜   zHTTPTransport.__exit__Í   s¢   € õ %Ñ&Ô&ð 	@ð 	@ØŒJ×Ò ¨)°YÑ?Ô?Ð?ð	@ð 	@ð 	@ñ 	@ô 	@ð 	@ð 	@ð 	@ð 	@ð 	@ð 	@ð 	@øøøð 	@ð 	@ð 	@ð 	@ð 	@ð 	@s   �9¹=Á =Úrequestr   r   c           	     óD  — t          |j        t          ¦  «        sJ ‚t          j        |j        t          j        |j        j        |j        j	        |j        j
        |j        j        ¬¦  «        |j        j        |j        |j        ¬¦  «        }t          ¦   «         5  | j                             |¦  «        }d d d ¦  «         n# 1 swxY w Y   t          |j        t$          j        ¦  «        sJ ‚t)          |j        |j        t-          |j        ¦  «        |j        ¬¦  «        S ©Nrs   )Úmethodrj   rˆ   ÚcontentÚ
extensions)Ústatus_coderˆ   ÚstreamrŸ   )r/   r¡   r   r€   r   r�   r   rj   r„   r…   rv   r†   rˆ   r‰   rŸ   r8   r‚   Úhandle_requestÚtypingÚIterabler   Ústatusr:   ©rB   rš   ÚreqÚresps       r7   r¢   zHTTPTransport.handle_requestÖ   sH  € õ ˜'œ.­.Ñ9Ô9Ð9Ð9Ð9åÔØ”>Ý”Ø”{Ô-Ø”[Ô)Ø”[Ô%Ø”{Ô+ð	ñ ô ð ”OÔ'Ø”NØÔ)ð
ñ 
ô 
ˆõ %Ñ&Ô&ð 	2ð 	2Ø”:×,Ò,¨SÑ1Ô1ˆDð	2ð 	2ð 	2ñ 	2ô 	2ð 	2ð 	2ð 	2ð 	2ð 	2ð 	2øøøð 	2ð 	2ð 	2ð 	2õ ˜$œ+¥v¤Ñ7Ô7Ð7Ð7Ð7åØœØ”LÝ! $¤+Ñ.Ô.Ø”ð	
ñ 
ô 
ð 	
s   ÂCÃCÃ	Cc                ó8   — | j                              ¦   «          d S r+   )r‚   rM   rO   s    r7   rM   zHTTPTransport.closeô   s   € ØŒ
×ÒÑÔÐÐÐrE   ©rV   r   rW   rX   rY   rZ   r[   rZ   r\   r   r]   rZ   r^   r_   r`   ra   rb   ra   rc   rd   re   rf   r(   r=   )rB   r#   r(   r#   ©NNN©r‘   r’   r“   r”   r•   r–   r(   r=   ©rš   r   r(   r   rP   )	rQ   rR   rS   r   rC   r�   r˜   r¢   rM   rT   rE   r7   r$   r$   y   s»   € € € € € ð #Ø!%ØØØ'ØØ#'ØØ$(ØØ@DðMð Mð Mð Mð Mð^ð ð ð ð 04Ø*.Ø*.ð	@ð @ð @ð @ð @ð
ð 
ð 
ð 
ð<ð ð ð ð ð rE   c                  ó&   — e Zd Zd
d„Zdd„Zdd„Zd	S )ÚAsyncResponseStreamr;   útyping.AsyncIterable[bytes]r(   r=   c                ó   — || _         d S r+   r?   rA   s     r7   rC   zAsyncResponseStream.__init__ù   rD   rE   útyping.AsyncIterator[bytes]c               ó„   K  — t          ¦   «         5  | j        2 3 d {V —†}|W V — Œ6 	 d d d ¦  «         d S # 1 swxY w Y   d S r+   rH   rI   s     r7   Ú	__aiter__zAsyncResponseStream.__aiter__ü   s¶   è è € Ý$Ñ&Ô&ð 	ð 	Ø"Ô3ð ð ð ð ð ð ð �dØ�
�
�
�
�
ð 4Ð3ð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	s   ‘5™&Ÿ5µ9¼9c              ƒ  óv   K  — t          | j        d¦  «        r!| j                             ¦   «         ƒ d {V —† d S d S )NÚaclose)rN   r@   r¶   rO   s    r7   r¶   zAsyncResponseStream.aclose  sR   è è € Ý�4Ô(¨(Ñ3Ô3ð 	1ØÔ'×.Ò.Ñ0Ô0Ð0Ð0Ð0Ð0Ð0Ð0Ð0Ð0Ð0ð	1ð 	1rE   N)r;   r°   r(   r=   )r(   r²   rP   )rQ   rR   rS   rC   r´   r¶   rT   rE   r7   r¯   r¯   ø   sP   € € € € € ð0ð 0ð 0ð 0ðð ð ð ð
1ð 1ð 1ð 1ð 1ð 1rE   r¯   c                  óV   — e Zd Zddddeddddddfd*d„Zd+d„Z	 	 	 d,d-d$„Zd.d(„Zd/d)„ZdS )0r'   TNFr   rV   r   rW   rX   rY   rZ   r[   r\   r   r]   r^   r_   r`   ra   rb   rc   rd   re   rf   r(   r=   c                ó|  — t          |||¬¦  «        }t          |t          t          f¦  «        rt	          |¬¦  «        n|}|€4t          j        ||j        |j        |j	        ||||	|
|¬¦
  «
        | _
        d S |j        j        dv r�t          j        t          j        |j        j        |j        j        |j        j        |j        j        ¬¦  «        |j        |j        j        ||j        |j        |j	        |||¬¦
  «
        | _
        d S |j        j        dk    r™	 dd l}n# t,          $ r t-          d	¦  «        d ‚w xY wt          j        t          j        |j        j        |j        j        |j        j        |j        j        ¬¦  «        |j        ||j        |j        |j	        ||¬
¦  «        | _
        d S t1          d¦  «        ‚)Nrh   ri   rk   rp   rs   )
rx   ry   rz   rl   rm   rn   ro   rY   r[   re   r|   r   r}   r~   zYProxy protocol must be either 'http', 'https', or 'socks5', but got {proxy.url.scheme!r}.)r	   r/   r1   r   r   r€   ÚAsyncConnectionPoolrm   rn   ro   r‚   rj   rt   ÚAsyncHTTPProxyr„   r…   rv   r†   r‡   rˆ   r‰   rŠ   r‹   ÚAsyncSOCKSProxyr�   rŽ   s                 r7   rC   zAsyncHTTPTransport.__init__  s   € õ )°¸TÈYÐWÑWÔWˆÝ$.¨uµs½C°jÑ$AÔ$AÐL•˜%Ð Ñ Ô Ð Àuˆàˆ=Ý!Ô5Ø'Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØØØ+ØØ-ðñ ô ˆDŒJˆJˆJð ŒYÔÐ!2Ð2Ð2Ý!Ô0Ý"œ,Ø œ9Ô/ØœÔ+ØœœØ œ9Ô-ð	ñ ô ð !œ>Ø#œmÔ/Ø'Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØØ-ðñ ô ˆDŒJˆJˆJð" ŒYÔ Ò)Ð)ðØ����øÝð ð ð Ý!ðSñô ð ððøøøõ "Ô1Ý"œ,Ø œ9Ô/ØœÔ+ØœœØ œ9Ô-ð	ñ ô ð !œ>Ø'Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØðñ ô ˆDŒJˆJˆJõ  ð1ñô ð s   ÄD ÄD7rB   r&   c              ƒ  óH   K  — | j                              ¦   «         ƒ d {V —† | S r+   )r‚   Ú
__aenter__rO   s    r7   r½   zAsyncHTTPTransport.__aenter__U  s1   è è € ØŒj×#Ò#Ñ%Ô%Ð%Ð%Ð%Ð%Ð%Ð%Ð%ØˆrE   r‘   r’   r“   r”   r•   r–   c              ƒ  óœ   K  — t          ¦   «         5  | j                             |||¦  «        ƒ d {V —† d d d ¦  «         d S # 1 swxY w Y   d S r+   )r8   r‚   Ú	__aexit__r™   s       r7   r¿   zAsyncHTTPTransport.__aexit__Y  s¸   è è € õ %Ñ&Ô&ð 	Gð 	GØ”*×&Ò& x°¸IÑFÔFÐFÐFÐFÐFÐFÐFÐFð	Gð 	Gð 	Gñ 	Gô 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gøøøð 	Gð 	Gð 	Gð 	Gð 	Gð 	Gs   ‘#AÁAÁArš   r   r   c           	   ƒ  óT  K  — t          |j        t          ¦  «        sJ ‚t          j        |j        t          j        |j        j        |j        j	        |j        j
        |j        j        ¬¦  «        |j        j        |j        |j        ¬¦  «        }t          ¦   «         5  | j                             |¦  «        ƒ d {V —†}d d d ¦  «         n# 1 swxY w Y   t          |j        t$          j        ¦  «        sJ ‚t)          |j        |j        t-          |j        ¦  «        |j        ¬¦  «        S rœ   )r/   r¡   r   r€   r   r�   r   rj   r„   r…   rv   r†   rˆ   r‰   rŸ   r8   r‚   Úhandle_async_requestr£   ÚAsyncIterabler   r¥   r¯   r¦   s       r7   rÁ   z'AsyncHTTPTransport.handle_async_requestb  s_  è è € õ ˜'œ.­/Ñ:Ô:Ð:Ð:Ð:åÔØ”>Ý”Ø”{Ô-Ø”[Ô)Ø”[Ô%Ø”{Ô+ð	ñ ô ð ”OÔ'Ø”NØÔ)ð
ñ 
ô 
ˆõ %Ñ&Ô&ð 	>ð 	>Øœ×8Ò8¸Ñ=Ô=Ð=Ð=Ð=Ð=Ð=Ð=ˆDð	>ð 	>ð 	>ñ 	>ô 	>ð 	>ð 	>ð 	>ð 	>ð 	>ð 	>øøøð 	>ð 	>ð 	>ð 	>õ ˜$œ+¥vÔ';Ñ<Ô<Ð<Ð<Ð<åØœØ”LÝ& t¤{Ñ3Ô3Ø”ð	
ñ 
ô 
ð 	
s   Â!C
Ã
CÃCc              ƒ  óH   K  — | j                              ¦   «         ƒ d {V —† d S r+   )r‚   r¶   rO   s    r7   r¶   zAsyncHTTPTransport.aclose€  s2   è è € ØŒj×ÒÑ!Ô!Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ð!rE   rª   )rB   r&   r(   r&   r«   r¬   r­   rP   )	rQ   rR   rS   r   rC   r½   r¿   rÁ   r¶   rT   rE   r7   r'   r'     s»   € € € € € ð #Ø!%ØØØ'ØØ#'ØØ$(ØØ@DðLð Lð Lð Lð Lð\ð ð ð ð 04Ø*.Ø*.ð	Gð Gð Gð Gð Gð
ð 
ð 
ð 
ð<"ð "ð "ð "ð "ð "rE   )r(   r)   ):Ú__doc__Ú
__future__r   Ú
contextlibr£   Útypesr   r€   Ú_configr   r   r   r	   Ú_exceptionsr
   r   r   r   r   r   r   r   r   r   r   r   r   r   Ú_modelsr   r   Ú_typesr   r   r   r   r   Ú_urlsr   Úbaser!   r"   ÚTypeVarr#   r&   ÚUnionÚTuplerd   ÚbytesÚ	bytearrayÚSOCKET_OPTIONÚcontextmanagerr8   r-   r:   r$   r¯   r'   rT   rE   r7   ú<module>rÕ      sk  ððð ð2 #Ð "Ð "Ð "Ð "Ð "à Ð Ð Ð Ø €€€Ø Ð Ð Ð Ð Ð à €€€à GÐ GÐ GÐ GÐ GÐ GÐ GÐ GÐ GÐ GÐ GÐ Gðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð  (Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ø XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XÐ XØ Ð Ð Ð Ð Ð Ø 3Ð 3Ð 3Ð 3Ð 3Ð 3Ð 3Ð 3à€F„N�3˜oÐ.Ñ.Ô.€Ø€F„N�3Ð2Ð3Ñ3Ô3€à”Ø
„L��c˜3�ÔØ
„L��c˜6œ<¨¨yÐ(8Ô9Ð9Ô:Ø
„L��c˜4 Ð$Ô%ð'ô€ð Ôð+ð +ð +ñ Ôð+ð. ÔÐ/ØÔ˜^ØÔ˜+ØÔ˜<ØÔ˜+ØÔ˜<ØÔ˜<ØÔ˜	ØÔ˜ØÔ˜ØÔ Ð"5ØÔ˜MØÔÐ!3ØÔ Ð"5ðÐ ð$*ð *ð *ð *ð *�^ñ *ô *ð *ð|ð |ð |ð |ð |�Mñ |ô |ð |ð~1ð 1ð 1ð 1ð 1˜/ñ 1ô 1ð 1ð{"ð {"ð {"ð {"ð {"Ð+ñ {"ô {"ð {"ð {"ð {"rE   