§
    ÑÁ³gŸ6  ã                  óv  — U d Z ddlmZ ddlZddlZddlmZ ej        rddl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% 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/        e0e0e0f         ej/        e0e0ej.        e1e2f         f         ej/        e0e0de0f         f         Z3ddgZ4i a5de6d<   dd„Z7ej8        dd„¦   «         Z9 G d„ de%¦  «        Z: G d„ de*¦  «        Z; G d„ de"¦  «        Z< G d„ de)¦  «        Z=d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)ÚURLé   )ÚAsyncBaseTransportÚBaseTransportÚTÚHTTPTransport)ÚboundÚAÚAsyncHTTPTransportú,dict[type[Exception], type[httpx.HTTPError]]ÚHTTPCORE_EXC_MAPÚreturnc                 ó^  — dd l } | j        t          | j        t          | j        t          | j        t          | j        t
          | j        t          | j        t          | j        t          | j	        t          | j
        t          | j        t          | j        t          | j        t          | j        t          iS ©Nr   )Úhttpcorer   r   r   r   r   r   r
   r   r   r   r   r   r   r   )r,   s    úW/var/www/html/mpstechhub/venv/lib/python3.11/site-packages/httpx/_transports/default.pyÚ_load_httpcore_exceptionsr.   J   s‹   € Ø€O€O€Oð 	Ô!Õ#3ØÔ¥ØÔ�kØÔ�|ØÔ�kØÔ�|ØÔ�|ØÔ�IØÔ�ZØÔ�ZØÔ$Õ&9ØÔ¥ØÔ#Õ%7ØÔ$Õ&9ðð ó    útyping.Iterator[None]c               #  óL  K  — t          t          ¦  «        dk    rt          ¦   «         a	 d V — d S # t          $ ri} d }t                               ¦   «         D ]*\  }}t          | |¦  «        sŒ|�t          ||¦  «        r|}Œ+|€‚ t          | ¦  «        } ||¦  «        | ‚d } ~ ww xY wr+   )Úlenr(   r.   Ú	ExceptionÚitemsÚ
isinstanceÚ
issubclassÚstr)ÚexcÚ
mapped_excÚfrom_excÚto_excÚmessages        r-   Úmap_httpcore_exceptionsr=   _   sÖ   è è € õ ÕÑÔ Ò!Ð!Ý4Ñ6Ô6Ðð+ØˆˆˆˆˆøÝð +ð +ð +Øˆ
å 0× 6Ò 6Ñ 8Ô 8ð 	$ð 	$ÑˆH�fÝ˜c 8Ñ,Ô,ð Øð Ð!¥Z°¸
Ñ%CÔ%CÐ!Ø#�
øàÐØå�c‘(”(ˆØˆj˜Ñ!Ô! sÐ*øøøøð!+øøøs   ª0 °
B#ºA$BÂB#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 ©N©Ú_httpcore_stream©Úselfr@   s     r-   Ú__init__zResponseStream.__init__z   ó   € Ø /ˆÔÐÐr/   ú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 rD   ©r=   rF   ©rH   Úparts     r-   Ú__iter__zResponseStream.__iter__}   s˜   è è € Ý$Ñ&Ô&ð 	ð 	ØÔ-ð ð �Ø�
�
�
�
ðð	ð 	ð 	ñ 	ô 	ð 	ð 	ð 	ð 	ð 	ð 	ð 	øøøð 	ð 	ð 	ð 	ð 	ð 	s   ‘.®2µ2c                óf   — t          | j        d¦  «        r| j                             ¦   «          d S d S )NÚclose)ÚhasattrrF   rR   ©rH   s    r-   rR   zResponseStream.close‚   s<   € Ý�4Ô(¨'Ñ2Ô2ð 	*ØÔ!×'Ò'Ñ)Ô)Ð)Ð)Ð)ð	*ð 	*r/   N)r@   rA   r)   rB   )r)   rK   ©r)   rB   )Ú__name__Ú
__module__Ú__qualname__rI   rP   rR   © r/   r-   r?   r?   y   sP   € € € € € ð0ð 0ð 0ð 0ðð ð ð ð
*ð *ð *ð *ð *ð *r/   r?   c                  óV   — e Zd Zddddde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   Úverifyússl.SSLContext | str | boolÚcertúCertTypes | NoneÚ	trust_envÚboolÚhttp1Úhttp2Úlimitsr   ÚproxyúProxyTypes | NoneÚudsú
str | NoneÚlocal_addressÚretriesÚintÚsocket_optionsú%typing.Iterable[SOCKET_OPTION] | Noner)   rB   c                ó²  — dd l }t          |t          t          f¦  «        rt	          |¬¦  «        n|}t          |||¬¦  «        }|€5|                     ||j        |j        |j	        ||||	|
|¬¦
  «
        | _
        d S |j        j        dv r‰|                     |                     |j        j        |j        j        |j        j        |j        j        ¬¦  «        |j        |j        j        ||j        |j        |j        |j	        |||¬¦  «        | _
        d S |j        j        dv r›	 dd l}n# t.          $ r t/          d	¦  «        d ‚w xY w|                     |                     |j        j        |j        j        |j        j        |j        j        ¬¦  «        |j        ||j        |j        |j	        ||¬
¦  «        | _
        d S t3          d|j        j        ›d�¦  «        ‚)Nr   ©Úurl©r[   r]   r_   ©
Ússl_contextÚmax_connectionsÚmax_keepalive_connectionsÚkeepalive_expiryra   rb   rf   rh   ri   rk   ©ÚhttpÚhttps©ÚschemeÚhostÚportÚtarget)Ú	proxy_urlÚ
proxy_authÚproxy_headersrr   Úproxy_ssl_contextrs   rt   ru   ra   rb   rk   ©Úsocks5Úsocks5hú{Using SOCKS proxy, but the 'socksio' package is not installed. Make sure to install httpx using `pip install httpx[socks]`.©r~   r   rr   rs   rt   ru   ra   rb   zOProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got ú.)r,   r5   r7   r   r   r	   ÚConnectionPoolrs   rt   ru   Ú_poolro   rz   Ú	HTTPProxyÚ
raw_schemeÚraw_hostr|   Úraw_pathÚraw_authÚheadersÚrawrr   ÚsocksioÚImportErrorÚ
SOCKSProxyÚ
ValueError©rH   r[   r]   r_   ra   rb   rc   rd   rf   rh   ri   rk   r,   rr   r‘   s                  r-   rI   zHTTPTransport.__init__ˆ   s4  € ð 	ˆˆˆå$.¨uµs½C°jÑ$AÔ$AÐL•˜%Ð Ñ Ô Ð ÀuˆÝ(°¸TÈYÐWÑWÔWˆàˆ=Ø!×0Ò0Ø'Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØØØ+ØØ-ð 1ñ ô ˆDŒJˆJˆJð ŒYÔÐ!2Ð2Ð2Ø!×+Ò+Ø"Ÿ,š,Ø œ9Ô/ØœÔ+ØœœØ œ9Ô-ð	 'ñ ô ð !œ>Ø#œmÔ/Ø'Ø"'Ô"3Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØØ-ð! ,ñ ô ˆDŒJˆJˆJð$ ŒYÔÐ!6Ð6Ð6ðØ����øÝð ð ð Ý!ðSñô ð ððøøøð "×,Ò,Ø"Ÿ,š,Ø œ9Ô/ØœÔ+ØœœØ œ9Ô-ð	 'ñ ô ð !œ>Ø'Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØð -ñ ô ˆDŒJˆJˆJõ  ð2Ø!œIÔ,ð2ð 2ð 2ñô ð ó   Ä"D' Ä'ErH   r"   c                ó8   — | j                              ¦   «          | S rD   )r‰   Ú	__enter__rT   s    r-   r˜   zHTTPTransport.__enter__Ù   s   € ØŒ
×ÒÑÔÐØˆr/   Ú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 rD   )r=   r‰   Ú__exit__©rH   r™   r›   r�   s       r-   r    zHTTPTransport.__exit__Ý   s¢   € õ %Ñ&Ô&ð 	@ð 	@ØŒJ×Ò ¨)°YÑ?Ô?Ð?ð	@ð 	@ð 	@ñ 	@ô 	@ð 	@ð 	@ð 	@ð 	@ð 	@ð 	@ð 	@øøøð 	@ð 	@ð 	@ð 	@ð 	@ð 	@s   �9¹=Á =Úrequestr   r   c           	     óP  — t          |j        t          ¦  «        sJ ‚dd l}|                     |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 ©Nr   ry   )Úmethodro   r�   ÚcontentÚ
extensions)Ústatus_coder�   Ústreamr§   )r5   r©   r   r,   r   r¥   r   ro   r‹   rŒ   r|   r�   r�   r�   r§   r=   r‰   Úhandle_requestÚtypingÚIterabler   Ústatusr?   ©rH   r¢   r,   ÚreqÚresps        r-   rª   zHTTPTransport.handle_requestæ   sV  € õ ˜'œ.­.Ñ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 rD   )r‰   rR   rT   s    r-   rR   zHTTPTransport.close  s   € ØŒ
×ÒÑÔÐÐÐr/   ©r[   r\   r]   r^   r_   r`   ra   r`   rb   r`   rc   r   rd   re   rf   rg   rh   rg   ri   rj   rk   rl   r)   rB   )rH   r"   r)   r"   ©NNN©r™   rš   r›   rœ   r�   rž   r)   rB   ©r¢   r   r)   r   rU   )	rV   rW   rX   r   rI   r˜   r    rª   rR   rY   r/   r-   r#   r#   ‡   s»   € € € € € ð /3Ø!%ØØØØ'Ø#'ØØ$(ØØ@DðOð Oð Oð Oð Oðbð ð ð ð 04Ø*.Ø*.ð	@ð @ð @ð @ð @ð
ð 
ð 
ð 
ð>ð ð ð ð ð r/   c                  ó&   — e Zd Zd
d„Zdd„Zdd„Zd	S )ÚAsyncResponseStreamr@   útyping.AsyncIterable[bytes]r)   rB   c                ó   — || _         d S rD   rE   rG   s     r-   rI   zAsyncResponseStream.__init__
  rJ   r/   ú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 rD   rM   rN   s     r-   Ú	__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)rS   rF   r¾   rT   s    r-   r¾   zAsyncResponseStream.aclose  sR   è è € Ý�4Ô(¨(Ñ3Ô3ð 	1ØÔ'×.Ò.Ñ0Ô0Ð0Ð0Ð0Ð0Ð0Ð0Ð0Ð0Ð0ð	1ð 	1r/   N)r@   r¸   r)   rB   )r)   rº   rU   )rV   rW   rX   rI   r¼   r¾   rY   r/   r-   r·   r·   	  sP   € € € € € ð0ð 0ð 0ð 0ðð ð ð ð
1ð 1ð 1ð 1ð 1ð 1r/   r·   c                  óV   — e Zd Zddddde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   r[   r\   r]   r^   r_   r`   ra   rb   rc   r   rd   re   rf   rg   rh   ri   rj   rk   rl   r)   rB   c                ó–  — dd l }t          |t          t          f¦  «        rt	          |¬¦  «        n|}t          |||¬¦  «        }|€5|                     ||j        |j        |j	        ||||	|
|¬¦
  «
        | _
        d S |j        j        dv r‰|                     |                     |j        j        |j        j        |j        j        |j        j        ¬¦  «        |j        |j        j        |j        ||j        |j        |j	        |||¬¦  «        | _
        d S |j        j        dv r›	 dd l}n# t.          $ r t/          d	¦  «        d ‚w xY w|                     |                     |j        j        |j        j        |j        j        |j        j        ¬¦  «        |j        ||j        |j        |j	        ||¬
¦  «        | _
        d S t3          d¦  «        ‚)Nr   rn   rp   rq   rv   ry   )r~   r   r€   r�   rr   rs   rt   ru   ra   rb   rk   r‚   r…   r†   zdProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got {proxy.url.scheme!r}.)r,   r5   r7   r   r   r	   ÚAsyncConnectionPoolrs   rt   ru   r‰   ro   rz   ÚAsyncHTTPProxyr‹   rŒ   r|   r�   rŽ   r�   r�   rr   r‘   r’   ÚAsyncSOCKSProxyr”   r•   s                  r-   rI   zAsyncHTTPTransport.__init__  s  € ð 	ˆˆˆå$.¨uµs½C°jÑ$AÔ$AÐL•˜%Ð Ñ Ô Ð ÀuˆÝ(°¸TÈYÐWÑWÔWˆàˆ=Ø!×5Ò5Ø'Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØØØ+ØØ-ð 6ñ ô ˆDŒJˆJˆJð ŒYÔÐ!2Ð2Ð2Ø!×0Ò0Ø"Ÿ,š,Ø œ9Ô/ØœÔ+ØœœØ œ9Ô-ð	 'ñ ô ð !œ>Ø#œmÔ/Ø"'Ô"3Ø'Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØØ-ð! 1ñ ô ˆDŒJˆJˆJð$ ŒYÔÐ!6Ð6Ð6ðØ����øÝð ð ð Ý!ðSñô ð ððøøøð "×1Ò1Ø"Ÿ,š,Ø œ9Ô/ØœÔ+ØœœØ œ9Ô-ð	 'ñ ô ð !œ>Ø'Ø &Ô 6Ø*0Ô*JØ!'Ô!8ØØð 2ñ ô ˆDŒJˆJˆJõ  ð1ñô ð r–   rH   r%   c              ƒ  óH   K  — | j                              ¦   «         ƒ d {V —† | S rD   )r‰   Ú
__aenter__rT   s    r-   rÅ   zAsyncHTTPTransport.__aenter__i  s1   è è € ØŒj×#Ò#Ñ%Ô%Ð%Ð%Ð%Ð%Ð%Ð%Ð%Øˆr/   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 rD   )r=   r‰   Ú	__aexit__r¡   s       r-   rÇ   zAsyncHTTPTransport.__aexit__m  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           	   ƒ  ó`  K  — t          |j        t          ¦  «        sJ ‚dd l}|                     |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¤   )r5   r©   r   r,   r   r¥   r   ro   r‹   rŒ   r|   r�   r�   r�   r§   r=   r‰   Úhandle_async_requestr«   ÚAsyncIterabler   r­   r·   r®   s        r-   rÉ   z'AsyncHTTPTransport.handle_async_requestv  sm  è è € õ ˜'œ.­/Ñ:Ô:Ð:Ð:Ð:Øˆˆˆà×ÒØ”>Ø—’Ø”{Ô-Ø”[Ô)Ø”[Ô%Ø”{Ô+ð	 ñ ô ð ”OÔ'Ø”NØÔ)ð ñ 
ô 
ˆõ %Ñ&Ô&ð 	>ð 	>Øœ×8Ò8¸Ñ=Ô=Ð=Ð=Ð=Ð=Ð=Ð=ˆDð	>ð 	>ð 	>ñ 	>ô 	>ð 	>ð 	>ð 	>ð 	>ð 	>ð 	>øøøð 	>ð 	>ð 	>ð 	>õ ˜$œ+¥vÔ';Ñ<Ô<Ð<Ð<Ð<åØœØ”LÝ& t¤{Ñ3Ô3Ø”ð	
ñ 
ô 
ð 	
s   Â#!CÃCÃCc              ƒ  óH   K  — | j                              ¦   «         ƒ d {V —† d S rD   )r‰   r¾   rT   s    r-   r¾   zAsyncHTTPTransport.aclose•  s2   è è € ØŒj×ÒÑ!Ô!Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ð!r/   r²   )rH   r%   r)   r%   r³   r´   rµ   rU   )	rV   rW   rX   r   rI   rÅ   rÇ   rÉ   r¾   rY   r/   r-   r&   r&     s»   € € € € € ð /3Ø!%ØØØØ'Ø#'ØØ$(ØØ@DðOð Oð Oð Oð Oðbð ð ð ð 04Ø*.Ø*.ð	Gð Gð Gð Gð Gð
ð 
ð 
ð 
ð>"ð "ð "ð "ð "ð "r/   )r)   r'   )r)   r0   )>Ú__doc__Ú
__future__r   Ú
contextlibr«   Útypesr   ÚTYPE_CHECKINGÚsslÚhttpxÚ_configr   r   r   r	   Ú_exceptionsr
   r   r   r   r   r   r   r   r   r   r   r   r   r   Ú_modelsr   r   Ú_typesr   r   r   r   Ú_urlsr   Úbaser    r!   ÚTypeVarr"   r%   ÚUnionÚTuplerj   ÚbytesÚ	bytearrayÚSOCKET_OPTIONÚ__all__r(   Ú__annotations__r.   Úcontextmanagerr=   r?   r#   r·   r&   rY   r/   r-   ú<module>râ      s2  ððð ð ð4 #Ð "Ð "Ð "Ð "Ð "à Ð Ð Ð Ø €€€Ø Ð Ð Ð Ð Ð à	Ôð Ø€J€J€Jà€L€L€Là GÐ GÐ GÐ GÐ GÐ GÐ GÐ GÐ GÐ GÐ GÐ Gðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð  (Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ø KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ KÐ KØ Ð Ð Ð Ð Ð Ø 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 Ð$Ô%ð'ô€ð   Ð
1€àACÐ Ð CÐ CÐ CÑ Cðð ð ð ð* Ôð+ð +ð +ñ Ôð+ð2*ð *ð *ð *ð *�^ñ *ô *ð *ðð ð ð ð �Mñ ô ð ðD1ð 1ð 1ð 1ð 1˜/ñ 1ô 1ð 1ð"ð "ð "ð "ð "Ð+ñ "ô "ð "ð "ð "r/   