Ë
    ,Œ:jw3  ã                   ó   — d 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! d	d
l"m#Z#m$Z$  ejJ                  dd¬«      Z& ejJ                  dd¬«      Z'ejP                  ejR                  e*e*e*f   ejR                  e*e*ejP                  e+e,f   f   ejR                  e*e*de*f   f   Z-ej\                  dej^                  d   fd„«       Z0ej,                  eej                  eej(                  eej2                  eej                   eej                  eej                  eej&                  eej0                  eej$                  eej.                  eej"                  eej                  eej*                  eiZ1 G d„ de «      Z2 G d„ de$«      Z3 G d„ de«      Z4 G d„ de#«      Z5y)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)
é    N)Ú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ÚSyncByteStreamÚVerifyTypesé   )ÚAsyncBaseTransportÚBaseTransportÚTÚHTTPTransport)ÚboundÚAÚAsyncHTTPTransportÚreturnc               #   óÞ   K  — 	 d –— y # t         $ rX} d }t        j                  «       D ]#  \  }}t        | |«      sŒ|�t	        ||«      sŒ"|}Œ% |€‚ t        | «      } ||«      | ‚d } ~ ww xY w­w©N)Ú	ExceptionÚHTTPCORE_EXC_MAPÚitemsÚ
isinstanceÚ
issubclassÚstr)ÚexcÚ
mapped_excÚfrom_excÚto_excÚmessages        ú[/var/www/html/tokenscope/api/venv/lib/python3.12/site-packages/httpx/_transports/default.pyÚmap_httpcore_exceptionsr4   ?   sƒ   è ø€ ð+ÜøÜò +Øˆ
ä 0× 6Ñ 6Ó 8ò 	$ÑˆH�fÜ˜c 8Ô,Øð Ð!¤Z°¸
Õ%CØ#‘
ð	$ð ÐØä�c“(ˆÙ˜Ó! sÐ*ûð!+üs*   ‚A-„	 ˆA-‰	A*’7A%Á
A%Á%A*Á*A-c                   ó`   — e Zd Zdej                  e   fd„Zdej                  e   fd„Zdd„Z	y)ÚResponseStreamÚhttpcore_streamc                 ó   — || _         y r'   ©Ú_httpcore_stream©Úselfr7   s     r3   Ú__init__zResponseStream.__init__i   ó
   € Ø /ˆÕó    r%   c              #   óv   K  — t        «       5  | j                  D ]  }|–— Œ 	 d d d «       y # 1 sw Y   y xY w­wr'   ©r4   r:   ©r<   Úparts     r3   Ú__iter__zResponseStream.__iter__l   s:   è ø€ Ü$Ó&ñ 	Ø×-Ñ-ò �Ø“
ñ÷	÷ 	ñ 	üs   ‚9�-¤	9­6²9Nc                 óf   — t        | j                  d«      r| j                  j                  «        y y )NÚclose)Úhasattrr:   rF   ©r<   s    r3   rF   zResponseStream.closeq   s)   € Ü�4×(Ñ(¨'Ô2Ø×!Ñ!×'Ñ'Õ)ð 3r?   ©r%   N)
Ú__name__Ú
__module__Ú__qualname__ÚtypingÚIterableÚbytesr=   ÚIteratorrD   rF   © r?   r3   r6   r6   h   s1   „ ð0¨¯©¸Ñ(>ó 0ð˜&Ÿ/™/¨%Ñ0ó ô
*r?   r6   c                   ó¨  — e Zd Zddddeddddddfdedej                  e   deded	e	d
edej                  e
   dej                  e   dej                  e   dedej                  ej                  e      ddfd„Zdedefd„Z	 	 	 ddej                  ej$                  e      dej                  e   dej                  e   ddfd„Zdedefd„Zdd„Zy)r!   TNFr   ÚverifyÚcertÚhttp1Úhttp2ÚlimitsÚ	trust_envÚproxyÚudsÚlocal_addressÚretriesÚsocket_optionsr%   c                 ó–  — t        |||¬«      }|€Ct        j                  ||j                  |j                  |j
                  ||||	|
|¬«
      | _        y |j                  j                  dv rÓt        j                  t        j                  |j                  j                  |j                  j                  |j                  j                  |j                  j                  ¬«      |j                  |j                   j"                  ||j$                  |j                  |j                  |j
                  |||¬«      | _        y |j                  j                  dk(  r·	 dd l}t        j*                  t        j                  |j                  j                  |j                  j                  |j                  j                  |j                  j                  ¬«      |j                  ||j                  |j                  |j
                  ||¬	«      | _        y t-        d
|j                  j                  ›d�«      ‚# t(        $ r t)        d«      d ‚w xY w)N©rS   rT   rX   ©
Ússl_contextÚmax_connectionsÚmax_keepalive_connectionsÚkeepalive_expiryrU   rV   rZ   r[   r\   r]   ©ÚhttpÚhttps©ÚschemeÚhostÚportÚtarget)Ú	proxy_urlÚ
proxy_authÚproxy_headersra   Úproxy_ssl_contextrb   rc   rd   rU   rV   r]   Úsocks5r   ú{Using SOCKS proxy, but the 'socksio' package is not installed. Make sure to install httpx using `pip install httpx[socks]`.©rm   rn   ra   rb   rc   rd   rU   rV   úDProxy protocol must be either 'http', 'https', or 'socks5', but got ú.)r   ÚhttpcoreÚConnectionPoolrb   rc   rd   Ú_poolÚurlri   Ú	HTTPProxyÚURLÚ
raw_schemeÚraw_hostrk   Úraw_pathÚraw_authÚheadersÚrawra   ÚsocksioÚImportErrorÚ
SOCKSProxyÚ
ValueError©r<   rS   rT   rU   rV   rW   rX   rY   rZ   r[   r\   r]   ra   r‚   s                 r3   r=   zHTTPTransport.__init__w   sò  € ô )°¸TÈYÔWˆàˆ=Ü!×0Ñ0Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØØØ+ØØ-ôˆ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×Ñ Ò)ðÛô "×,Ñ,Ü"Ÿ,™,Ø Ÿ9™9×/Ñ/ØŸ™×+Ñ+ØŸ™Ÿ™Ø Ÿ9™9×-Ñ-ô	ð !Ÿ>™>Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØôˆD�Jô  ØVÐW\×W`ÑW`×WgÑWgÐVjÐjkÐlóð øô- ò Ü!ðSóð ððús   ÅH2 È2Ir<   c                 ó:   — | j                   j                  «        | S r'   )rx   Ú	__enter__rH   s    r3   rˆ   zHTTPTransport.__enter__Ä   s   € Ø�
‰
×ÑÔØˆr?   Úexc_typeÚ	exc_valueÚ	tracebackc                 ó|   — t        «       5  | j                  j                  |||«       d d d «       y # 1 sw Y   y xY wr'   )r4   rx   Ú__exit__©r<   r‰   rŠ   r‹   s       r3   r�   zHTTPTransport.__exit__È   s9   € ô %Ó&ñ 	@Ø�J‰J×Ñ ¨)°YÔ?÷	@÷ 	@ñ 	@ús   ‹2²;Úrequestc           	      óà  — 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                   j#                  |«      }d d d «       t        j                  t$        j&                  «      sJ ‚t)        |j*                  |j                  t-        |j                  «      |j                  ¬«      S # 1 sw Y   ŒoxY w©Nrh   )Úmethodry   r€   ÚcontentÚ
extensions)Ústatus_coder€   Ústreamr”   )r+   r–   r   rv   r   r’   r{   ry   r|   r}   rk   r~   r€   r�   r”   r4   rx   Úhandle_requestrM   rN   r   Ústatusr6   ©r<   r�   ÚreqÚresps       r3   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'   )rx   rF   rH   s    r3   rF   zHTTPTransport.closeï   s   € Ø�
‰
×ÑÕr?   ©NNNrI   )rJ   rK   rL   r   r   rM   ÚOptionalr   Úboolr   r   r-   ÚintrN   ÚSOCKET_OPTIONr=   r    rˆ   ÚTypeÚBaseExceptionr   r�   r   r   r—   rF   rQ   r?   r3   r!   r!   v   st  „ ð #Ø+/ØØØ'ØØ(,Ø$(Ø.2ØØJNñKàðKð �o‰o˜iÑ(ðKð ð	Kð
 ðKð ðKð ðKð �‰˜uÑ%ðKð �_‰_˜SÑ!ðKð —‘ sÑ+ðKð ðKð Ÿ™¨¯©¸Ñ(FÑGðKð 
óKðZ˜ð ˜aó ð AEØ48Ø48ñ	@à—/‘/ &§+¡+¨mÑ"<Ñ=ð@ð —?‘? =Ñ1ð@ð —?‘? =Ñ1ð	@ð
 
ó@ð
àð
ð 
ó
ô<r?   c                   ó`   — e Zd Zdej                  e   fd„Zdej                  e   fd„Zdd„Z	y)ÚAsyncResponseStreamr7   c                 ó   — || _         y r'   r9   r;   s     r3   r=   zAsyncResponseStream.__init__ô   r>   r?   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'   rA   rB   s     r3   Ú	__aiter__zAsyncResponseStream.__aiter__÷   sC   è ø€ Ü$Ó&ñ 	Ø"×3Ñ3÷ ð �dØ”
ðøÑ3÷	÷ 	ñ 	üs/   ‚A�6š+ž)Ÿ+¢6©+«6­	A¶?»ANc              ƒ   ó‚   K  — t        | j                  d«      r#| j                  j                  «       ƒ d {  –—†  y y 7 Œ­w)NÚaclose)rG   r:   rª   rH   s    r3   rª   zAsyncResponseStream.acloseü   s6   è ø€ Ü�4×(Ñ(¨(Ô3Ø×'Ñ'×.Ñ.Ó0×0Ñ0ð 4Ø0ús   ‚4?¶=·?rI   )
rJ   rK   rL   rM   ÚAsyncIterablerO   r=   ÚAsyncIteratorr¨   rª   rQ   r?   r3   r¥   r¥   ó   s5   „ ð0¨×(<Ñ(<¸UÑ(Có 0ð ×!5Ñ!5°eÑ!<ó ô
1r?   r¥   c                   ó¨  — e Zd Zddddeddddddfdedej                  e   deded	e	d
edej                  e
   dej                  e   dej                  e   dedej                  ej                  e      ddfd„Zdedefd„Z	 	 	 ddej                  ej$                  e      dej                  e   dej                  e   ddfd„Zdedefd„Zdd„Zy)r$   TNFr   rS   rT   rU   rV   rW   rX   rY   rZ   r[   r\   r]   r%   c                 ó€  — t        |||¬«      }|€Ct        j                  ||j                  |j                  |j
                  ||||	|
|¬«
      | _        y |j                  j                  dv rÈt        j                  t        j                  |j                  j                  |j                  j                  |j                  j                  |j                  j                  ¬«      |j                  |j                   j"                  ||j                  |j                  |j
                  |||¬«
      | _        y |j                  j                  dk(  r·	 dd l}t        j(                  t        j                  |j                  j                  |j                  j                  |j                  j                  |j                  j                  ¬«      |j                  ||j                  |j                  |j
                  ||¬	«      | _        y t+        d
|j                  j                  ›d�«      ‚# t&        $ r t'        d«      d ‚w xY w)Nr_   r`   re   rh   )
rm   rn   ro   ra   rb   rc   rd   rU   rV   r]   rq   r   rr   rs   rt   ru   )r   rv   ÚAsyncConnectionPoolrb   rc   rd   rx   ry   ri   ÚAsyncHTTPProxyr{   r|   r}   rk   r~   r   r€   r�   r‚   rƒ   ÚAsyncSOCKSProxyr…   r†   s                 r3   r=   zAsyncHTTPTransport.__init__  sé  € ô )°¸TÈYÔWˆàˆ=Ü!×5Ñ5Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØØØ+ØØ-ôˆD�Jð �Y‰Y×ÑÐ!2Ñ2Ü!×0Ñ0Ü"Ÿ,™,Ø Ÿ9™9×/Ñ/ØŸ™×+Ñ+ØŸ™Ÿ™Ø Ÿ9™9×-Ñ-ô	ð !Ÿ>™>Ø#Ÿm™m×/Ñ/Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØØ-ôˆD�Jð" �Y‰Y×Ñ Ò)ðÛô "×1Ñ1Ü"Ÿ,™,Ø Ÿ9™9×/Ñ/ØŸ™×+Ñ+ØŸ™Ÿ™Ø Ÿ9™9×-Ñ-ô	ð !Ÿ>™>Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØôˆD�Jô  ØVÐW\×W`ÑW`×WgÑWgÐVjÐjkÐlóð øô- ò Ü!ðSóð ððús   ÅH' È'H=r<   c              ƒ   óV   K  — | j                   j                  «       ƒ d {  –—†  | S 7 Œ­wr'   )rx   Ú
__aenter__rH   s    r3   r³   zAsyncHTTPTransport.__aenter__N  s&   è ø€ Ø�j‰j×#Ñ#Ó%×%Ð%Øˆð 	&ús   ‚) '¡)r‰   rŠ   r‹   c              ƒ   ó˜   K  — t        «       5  | j                  j                  |||«      ƒ d {  –—†  d d d «       y 7 Œ# 1 sw Y   y xY w­wr'   )r4   rx   Ú	__aexit__rŽ   s       r3   rµ   zAsyncHTTPTransport.__aexit__R  sL   è ø€ ô %Ó&ñ 	GØ—*‘*×&Ñ& x°¸IÓF×FÐF÷	Gð 	GØFø÷	Gð 	Güs%   ‚A
�!>®<¯>³	A
¼>¾AÁA
r�   c           	   ƒ   óü  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                   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‘   )r+   r–   r   rv   r   r’   r{   ry   r|   r}   rk   r~   r€   r�   r”   r4   rx   Úhandle_async_requestrM   r«   r   r˜   r¥   r™   s       r3   r·   z'AsyncHTTPTransport.handle_async_request[  s  è ø€ ô ˜'Ÿ.™.¬/Ô:Ð:Ð:ä×ÑØ—>‘>Ü—‘Ø—{‘{×-Ñ-Ø—[‘[×)Ñ)Ø—[‘[×%Ñ%Ø—{‘{×+Ñ+ô	ð —O‘O×'Ñ'Ø—N‘NØ×)Ñ)ô
ˆô %Ó&ñ 	>ØŸ™×8Ñ8¸Ó=×=ˆD÷	>ô ˜$Ÿ+™+¤v×';Ñ';Ô<Ð<Ð<äØŸ™Ø—L‘LÜ& t§{¡{Ó3Ø—‘ô	
ð 	
ð	 >ø÷	>ð 	>üs1   ‚CE<ÃE0Ã;E.Ã<E0Ä A.E<Å.E0Å0E9Å5E<c              ƒ   óT   K  — | j                   j                  «       ƒ d {  –—†  y 7 Œ­wr'   )rx   rª   rH   s    r3   rª   zAsyncHTTPTransport.aclosey  s   è ø€ Ø�j‰j×ÑÓ!×!Ò!ús   ‚( &¡(r�   rI   )rJ   rK   rL   r   r   rM   rž   r   rŸ   r   r   r-   r    rN   r¡   r=   r#   r³   r¢   r£   r   rµ   r   r   r·   rª   rQ   r?   r3   r$   r$     st  „ ð #Ø+/ØØØ'ØØ(,Ø$(Ø.2ØØJNñJàðJð �o‰o˜iÑ(ðJð ð	Jð
 ðJð ðJð ðJð �‰˜uÑ%ðJð �_‰_˜SÑ!ðJð —‘ sÑ+ðJð ðJð Ÿ™¨¯©¸Ñ(FÑGðJð 
óJðX˜qð  Qó ð AEØ48Ø48ñ	Gà—/‘/ &§+¡+¨mÑ"<Ñ=ðGð —?‘? =Ñ1ðGð —?‘? =Ñ1ð	Gð
 
óGð
àð
ð 
ó
ô<"r?   )6Ú__doc__Ú
contextlibrM   Útypesr   rv   Ú_configr   r   r   r   Ú_exceptionsr	   r
   r   r   r   r   r   r   r   r   r   r   r   r   Ú_modelsr   r   Ú_typesr   r   r   r   Úbaser   r   ÚTypeVarr    r#   ÚUnionÚTupler    rO   Ú	bytearrayr¡   ÚcontextmanagerrP   r4   r)   r6   r!   r¥   r$   rQ   r?   r3   ú<module>rÆ      sÈ  ðñó2 Û Ý ã ç GÓ G÷÷ ÷ ÷ ÷  (ß LÓ Lß 3à€F‡N�N�3˜oÔ.€Ø€F‡N�N�3Ð2Ô3€à—‘Ø
‡L�L��c˜3�ÑØ
‡L�L��c˜6Ÿ<™<¨¨yÐ(8Ñ9Ð9Ñ:Ø
‡L�L��c˜4 Ð$Ñ%ð'ñ€ð ×Ñð+ §¡°Ñ!6ò +ó ð+ð. ×ÑÐ/Ø×Ñ˜^Ø×Ñ˜+Ø×Ñ˜<Ø×Ñ˜+Ø×Ñ˜<Ø×Ñ˜<Ø×Ñ˜	Ø×Ñ˜Ø×Ñ˜Ø× Ñ Ð"5Ø×Ñ˜MØ×ÑÐ!3Ø× Ñ Ð"5ðÐ ô$*�^ô *ôz�Mô zôz1˜/ô 1ôy"Ð+õ y"r?   