Ë
    Eü´jY6  ã                  ó*  — U d Z ddlmZ ddlZddlZddlm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jZ                  dd¬«      Z. ejZ                  dd¬«      Z/e0e1e1e1f   e0e1e1e2e3z  f   z  e0e1e1de1f   z  Z4ddgZ5i a6de7d<   dd„Z8ejr                  dd„«       Z: G d„ de'«      Z; G d„ de,«      Z< G d„ de$«      Z= G d„ de+«      Z>y)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://": httpx2.HTTPTransport(http2=True),
    "all://*example.org": httpx2.HTTPTransport()
}

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

# Using advanced httpcore configuration, with unix domain sockets.
transport = httpx2.HTTPTransport(uds="socket.uds")
client = httpx2.Client(transport=transport)
é    )ÚannotationsN)Ú	Generator)Ú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[httpx2.HTTPError]]ÚHTTPCORE_EXC_MAPc                 óÎ  — 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   )Ú	httpcore2r   r   r   r   r   r   r   r   r   r   r   r   r   r   )r,   s    úX/root/workspace/ytshorts/venv/lib/python3.12/site-packages/httpx2/_transports/default.pyÚ_load_httpcore_exceptionsr.   G   s¯   € Ûð 	×"Ñ"Ô$4Ø× Ñ ¤.Ø×Ñœ{Ø×Ñ¤Ø×Ñœ{Ø×Ñ¤Ø×Ñ¤Ø×ÑœYØ×ÑœjØ×ÑœjØ×%Ñ%Ô':Ø×Ñ¤Ø×$Ñ$Ô&8Ø×%Ñ%Ô':ðð ó    c               #  ó  K  — t        t        «      dk(  r
t        «       a	 d –— y # t        $ rX} d }t        j	                  «       D ]#  \  }}t        | |«      sŒ|�t        ||«      sŒ"|}Œ% |€‚ t        | «      } ||«      | ‚d } ~ ww xY w­wr+   )Úlenr)   r.   Ú	ExceptionÚitemsÚ
isinstanceÚ
issubclassÚstr)ÚexcÚ
mapped_excÚfrom_excÚto_excÚmessages        r-   Úmap_httpcore_exceptionsr<   \   sœ   è ø€ ô ÔÓ Ò!Ü4Ó6Ðð+ÜøÜò +Øˆ
ä 0× 6Ñ 6Ó 8ò 	$ÑˆH�fÜ˜c 8Ô,Øð Ð!¤Z°¸
Õ%CØ#‘
ð	$ð ÐØä�c“(ˆÙ˜Ó! sÐ*ûð!+üs*   ‚B	 % ¤B	¥	B®7BÁ&BÂBÂB	c                  ó$   — e Zd Zdd„Zdd„Zdd„Zy)ÚResponseStreamc                ó   — || _         y ©N©Ú_httpcore_stream©ÚselfÚhttpcore_streams     r-   Ú__init__zResponseStream.__init__w   ó
   € Ø /ˆÕr/   c              #  óv   K  — t        «       5  | j                  E d {  –—†  d d d «       y 7 Œ# 1 sw Y   y xY w­wr@   ©r<   rB   ©rD   s    r-   Ú__iter__zResponseStream.__iter__z   s8   è ø€ Ü$Ó&ñ 	-Ø×,Ñ,×,Ð,÷	-ð 	-Ø,ø÷	-ð 	-üs    ‚9�-�+ž-¢	9«-­6²9c                óf   — t        | j                  d«      r| j                  j                  «        y y )NÚclose)ÚhasattrrB   rM   rJ   s    r-   rM   zResponseStream.close~   s)   € Ü�4×(Ñ(¨'Ô2Ø×!Ñ!×'Ñ'Õ)ð 3r/   N)rE   ztyping.Iterable[bytes]ÚreturnÚNone)rO   ztyping.Iterator[bytes]©rO   rP   )Ú__name__Ú
__module__Ú__qualname__rF   rK   rM   © r/   r-   r>   r>   v   s   „ ó0ó-ô*r/   r>   c                  ó˜   — 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y)r$   TNFr   c                ó¼  — dd l }t        |t        t        f«      rt	        |¬«      n|}t        |||¬«      }|€?|j                  ||j                  |j                  |j                  ||||	|
|¬«
      | _
        y |j                  j                  dv rË|j                  |j                  |j                  j                  |j                  j                  |j                  j                   |j                  j"                  ¬«      |j$                  |j&                  j(                  ||j*                  |j                  |j                  |j                  |||¬«      | _
        y |j                  j                  dv r¯	 dd l}|j1                  |j                  |j                  j                  |j                  j                  |j                  j                   |j                  j"                  ¬«      |j$                  ||j                  |j                  |j                  ||¬
«      | _
        y t3        d|j                  j                  ›d�«      ‚# t.        $ r t/        d	«      d ‚w xY w)Nr   ©Úurl©ÚverifyÚcertÚ	trust_env©
Ússl_contextÚmax_connectionsÚmax_keepalive_connectionsÚkeepalive_expiryÚhttp1Úhttp2ÚudsÚlocal_addressÚretriesÚsocket_options©ÚhttpÚhttps©ÚschemeÚhostÚportÚtarget)Ú	proxy_urlÚ
proxy_authÚproxy_headersr_   Úproxy_ssl_contextr`   ra   rb   rc   rd   rh   ©Úsocks5Úsocks5hú{Using SOCKS proxy, but the 'socksio' package is not installed. Make sure to install httpx using `pip install httpx[socks]`.©rq   rr   r_   r`   ra   rb   rc   rd   úOProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got ú.)r,   r4   r6   r   r	   r
   ÚConnectionPoolr`   ra   rb   Ú_poolrY   rm   Ú	HTTPProxyÚ
raw_schemeÚraw_hostro   Úraw_pathÚraw_authÚheadersÚrawr_   ÚsocksioÚImportErrorÚ
SOCKSProxyÚ
ValueError©rD   r[   r\   r]   rc   rd   ÚlimitsÚproxyre   rf   rg   rh   r,   r_   r…   s                  r-   rF   zHTTPTransport.__init__„   s(  € ó 	ä$.¨u´s¼C°jÔ$A”˜%Õ ÀuˆÜ(°¸TÈYÔWˆàˆ=Ø"×1Ñ1Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØØØ+ØØ-ð 2ó ˆD�Jð �Y‰Y×ÑÐ!2Ñ2Ø"×,Ñ,Ø#Ÿ-™-Ø Ÿ9™9×/Ñ/ØŸ™×+Ñ+ØŸ™Ÿ™Ø Ÿ9™9×-Ñ-ð	 (ó ð !Ÿ>™>Ø#Ÿm™m×/Ñ/Ø'Ø"'×"3Ñ"3Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØØ-ð! -ó ˆD�Jð$ �Y‰Y×ÑÐ!6Ñ6ðÛð #×-Ñ-Ø#Ÿ-™-Ø Ÿ9™9×/Ñ/ØŸ™×+Ñ+ØŸ™Ÿ™Ø Ÿ9™9×-Ñ-ð	 (ó ð !Ÿ>™>Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØð .ó ˆD�Jô  ØaÐbg×bkÑbk×brÑbrÐauÐuvÐwóð øô- ò Ü!ðSóð ððúó   Å4I ÉIc                ó:   — | j                   j                  «        | S r@   )r}   Ú	__enter__rJ   s    r-   rŽ   zHTTPTransport.__enter__Ô   s   € Ø�
‰
×ÑÔØˆr/   c                ó|   — t        «       5  | j                  j                  |||«       d d d «       y # 1 sw Y   y xY wr@   )r<   r}   Ú__exit__©rD   Úexc_typeÚ	exc_valueÚ	tracebacks       r-   r�   zHTTPTransport.__exit__Ø   s9   € ô %Ó&ñ 	@Ø�J‰J×Ñ ¨)°YÔ?÷	@÷ 	@ñ 	@ús   ‹2²;c           	     óØ  — t        |j                  t        «      sJ ‚dd l}|j	                  |j
                  |j                  |j                  j                  |j                  j                  |j                  j                  |j                  j                  ¬«      |j                  j                  |j                  |j                  ¬«      }t        «       5  | j                   j#                  |«      }d d d «       t        j                  t$        j&                  «      sJ ‚t)        |j*                  |j                  t-        |j                  «      |j                  ¬«      S # 1 sw Y   ŒoxY w©Nr   rl   )ÚmethodrY   rƒ   ÚcontentÚ
extensions)Ústatus_coderƒ   Ústreamr™   )r4   r›   r   r,   r   r—   r   rY   r   r€   ro   r�   rƒ   r„   r™   r<   r}   Úhandle_requestÚtypingÚIterabler   Ústatusr>   ©rD   Úrequestr,   ÚreqÚresps        r-   rœ   zHTTPTransport.handle_requestá   s  € ô ˜'Ÿ.™.¬.Ô9Ð9Ð9Ûà×ÑØ—>‘>Ø—‘Ø—{‘{×-Ñ-Ø—[‘[×)Ñ)Ø—[‘[×%Ñ%Ø—{‘{×+Ñ+ð	 ó ð —O‘O×'Ñ'Ø—N‘NØ×)Ñ)ð  ó 
ˆô %Ó&ñ 	2Ø—:‘:×,Ñ,¨SÓ1ˆD÷	2ô ˜$Ÿ+™+¤v§¡Ô7Ð7Ð7äØŸ™Ø—L‘LÜ! $§+¡+Ó.Ø—‘ô	
ð 	
÷	2ð 	2ús   ÃE Å E)c                ó8   — | j                   j                  «        y r@   )r}   rM   rJ   s    r-   rM   zHTTPTransport.close   s   € Ø�
‰
×ÑÕr/   ©r[   zssl.SSLContext | str | boolr\   zCertTypes | Noner]   Úboolrc   r¦   rd   r¦   rŠ   r   r‹   zProxyTypes | Nonere   ú
str | Nonerf   r§   rg   Úintrh   z%typing.Iterable[SOCKET_OPTION] | NonerO   rP   )rD   r#   rO   r#   ©NNN©r’   ztype[BaseException] | Noner“   zBaseException | Noner”   zTracebackType | NonerO   rP   ©r¡   r   rO   r   rQ   )	rR   rS   rT   r   rF   rŽ   r�   rœ   rM   rU   r/   r-   r$   r$   ƒ   s
  „ ð /3Ø!%ØØØØ'Ø#'ØØ$(ØØ@DðNà+ðNð ðNð ð	Nð
 ðNð ðNð ðNð !ðNð ðNð "ðNð ðNð >ðNð 
óNó`ð 04Ø*.Ø*.ð	@à,ð@ð (ð@ð (ð	@ð
 
ó@ð
àð
ð 
ó
ô>r/   c                  ó$   — e Zd Zdd„Zdd„Zdd„Zy)ÚAsyncResponseStreamc                ó   — || _         y r@   rA   rC   s     r-   rF   zAsyncResponseStream.__init__  rG   r/   c               óˆ   K  — t        «       5  | j                  2 3 d {  –—† }|­–— Œ7 Œ
6 	 d d d «       y # 1 sw Y   y xY w­wr@   rI   )rD   Úparts     r-   Ú	__aiter__zAsyncResponseStream.__aiter__  sC   è ø€ Ü$Ó&ñ 	Ø"×3Ñ3÷ ð �dØ”
ðøÑ3÷	÷ 	ñ 	üs/   ‚A�6š+ž)Ÿ+¢6©+«6­	A¶?»Ac              ƒ  ó‚   K  — t        | j                  d«      r#| j                  j                  «       ƒ d {  –—†  y y 7 Œ­w)NÚaclose)rN   rB   r³   rJ   s    r-   r³   zAsyncResponseStream.aclose  s6   è ø€ Ü�4×(Ñ(¨(Ô3Ø×'Ñ'×.Ñ.Ó0×0Ñ0ð 4Ø0ús   ‚4?¶=·?N)rE   ztyping.AsyncIterable[bytes]rO   rP   )rO   ztyping.AsyncIterator[bytes]rQ   )rR   rS   rT   rF   r±   r³   rU   r/   r-   r­   r­     s   „ ó0óô
1r/   r­   c                  ó˜   — 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y)r'   TNFr   c                ó¼  — dd l }t        |t        t        f«      rt	        |¬«      n|}t        |||¬«      }|€?|j                  ||j                  |j                  |j                  ||||	|
|¬«
      | _
        y |j                  j                  dv rË|j                  |j                  |j                  j                  |j                  j                  |j                  j                   |j                  j"                  ¬«      |j$                  |j&                  j(                  |j*                  ||j                  |j                  |j                  |||¬«      | _
        y |j                  j                  dv r¯	 dd l}|j1                  |j                  |j                  j                  |j                  j                  |j                  j                   |j                  j"                  ¬«      |j$                  ||j                  |j                  |j                  ||¬
«      | _
        y t3        d|j                  j                  ›d�«      ‚# t.        $ r t/        d	«      d ‚w xY w)Nr   rX   rZ   r^   ri   rl   )rq   rr   rs   rt   r_   r`   ra   rb   rc   rd   rh   ru   rx   ry   rz   r{   )r,   r4   r6   r   r	   r
   ÚAsyncConnectionPoolr`   ra   rb   r}   rY   rm   ÚAsyncHTTPProxyr   r€   ro   r�   r‚   rƒ   r„   r_   r…   r†   ÚAsyncSOCKSProxyrˆ   r‰   s                  r-   rF   zAsyncHTTPTransport.__init__  s(  € ó 	ä$.¨u´s¼C°jÔ$A”˜%Õ ÀuˆÜ(°¸TÈYÔWˆàˆ=Ø"×6Ñ6Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØØØ+ØØ-ð 7ó ˆD�Jð �Y‰Y×ÑÐ!2Ñ2Ø"×1Ñ1Ø#Ÿ-™-Ø Ÿ9™9×/Ñ/ØŸ™×+Ñ+ØŸ™Ÿ™Ø Ÿ9™9×-Ñ-ð	 (ó ð !Ÿ>™>Ø#Ÿm™m×/Ñ/Ø"'×"3Ñ"3Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØØ-ð! 2ó ˆD�Jð$ �Y‰Y×ÑÐ!6Ñ6ðÛð #×2Ñ2Ø#Ÿ-™-Ø Ÿ9™9×/Ñ/ØŸ™×+Ñ+ØŸ™Ÿ™Ø Ÿ9™9×-Ñ-ð	 (ó ð !Ÿ>™>Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØð 3ó ˆD�Jô  ØaÐbg×bkÑbk×brÑbrÐauÐuvÐwóð øô- ò Ü!ðSóð ððúrŒ   c              ƒ  óV   K  — | j                   j                  «       ƒ d {  –—†  | S 7 Œ­wr@   )r}   Ú
__aenter__rJ   s    r-   rº   zAsyncHTTPTransport.__aenter__c  s&   è ø€ Ø�j‰j×#Ñ#Ó%×%Ð%Øˆð 	&ús   ‚) '¡)c              ƒ  ó˜   K  — t        «       5  | j                  j                  |||«      ƒ d {  –—†  d d d «       y 7 Œ# 1 sw Y   y xY w­wr@   )r<   r}   Ú	__aexit__r‘   s       r-   r¼   zAsyncHTTPTransport.__aexit__g  sL   è ø€ ô %Ó&ñ 	GØ—*‘*×&Ñ& x°¸IÓF×FÐF÷	Gð 	GØFø÷	Gð 	Güs%   ‚A
�!>®<¯>³	A
¼>¾AÁA
c           	   ƒ  óô  K  — t        |j                  t        «      sJ ‚dd l}|j	                  |j
                  |j                  |j                  j                  |j                  j                  |j                  j                  |j                  j                  ¬«      |j                  j                  |j                  |j                  ¬«      }t        «       5  | j                   j#                  |«      ƒ d {  –—† }d d d «       t        j                  t$        j&                  «      sJ ‚t)        |j*                  |j                  t-        |j                  «      |j                  ¬«      S 7 Œr# 1 sw Y   ŒqxY w­wr–   )r4   r›   r   r,   r   r—   r   rY   r   r€   ro   r�   rƒ   r„   r™   r<   r}   Úhandle_async_requestr�   ÚAsyncIterabler   rŸ   r­   r    s        r-   r¾   z'AsyncHTTPTransport.handle_async_requestp  s"  è ø€ ô ˜'Ÿ.™.¬/Ô:Ð:Ð:Ûà×ÑØ—>‘>Ø—‘Ø—{‘{×-Ñ-Ø—[‘[×)Ñ)Ø—[‘[×%Ñ%Ø—{‘{×+Ñ+ð	 ó ð —O‘O×'Ñ'Ø—N‘NØ×)Ñ)ð  ó 
ˆô %Ó&ñ 	>ØŸ™×8Ñ8¸Ó=×=ˆD÷	>ô ˜$Ÿ+™+¤v×';Ñ';Ô<Ð<Ð<äØŸ™Ø—L‘LÜ& t§{¡{Ó3Ø—‘ô	
ð 	
ð	 >ø÷	>ð 	>üs1   ‚CE8ÃE,Ã7E*Ã8E,Ã<A.E8Å*E,Å,E5Å1E8c              ƒ  óT   K  — | j                   j                  «       ƒ d {  –—†  y 7 Œ­wr@   )r}   r³   rJ   s    r-   r³   zAsyncHTTPTransport.aclose�  s   è ø€ Ø�j‰j×ÑÓ!×!Ò!ús   ‚( &¡(r¥   )rD   r&   rO   r&   r©   rª   r«   rQ   )	rR   rS   rT   r   rF   rº   r¼   r¾   r³   rU   r/   r-   r'   r'     s
  „ ð /3Ø!%ØØØØ'Ø#'ØØ$(ØØ@DðNà+ðNð ðNð ð	Nð
 ðNð ðNð ðNð !ðNð ðNð "ðNð ðNð >ðNð 
óNó`ð 04Ø*.Ø*.ð	Gà,ðGð (ðGð (ð	Gð
 
óGð
àð
ð 
ó
ô>"r/   )rO   r(   )rO   zGenerator[None])?Ú__doc__Ú
__future__r   Ú
contextlibr�   Úcollections.abcr   Útypesr   ÚTYPE_CHECKINGÚsslÚhttpx2Ú_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&   Útupler¨   ÚbytesÚ	bytearrayÚSOCKET_OPTIONÚ__all__r)   Ú__annotations__r.   Úcontextmanagerr<   r>   r$   r­   r'   rU   r/   r-   ú<module>r×      s"  ðòõ4 #ã Û Ý %Ý à	×ÒÛãç GÓ G÷÷ ÷ ÷ ÷  (ß KÓ KÝ ß 3à€F‡N�N�3˜oÔ.€Ø€F‡N�N�3Ð2Ô3€à�c˜3 �mÑ$ u¨S°#°u¸yÑ7HÐ-HÑ'IÑIÈEÐRUÐWZÐ\`ÐbeÐReÑLfÑf€à Ð
1€àBDÐ Ð?Ó Dóð* ×Ñò+ó ð+ô2
*�^ô 
*ô~�Mô ~ôB1˜/ô 1ô~"Ð+õ ~"r/   