Ë
    $Æ%hŸ6  ã                  ó†  — 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jV                  dd¬«      Z, ejV                  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jp                  dd„«       Z9 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://": 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_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   )Úhttpcorer   r   r   r   r   r   r
   r   r   r   r   r   r   r   )r+   s    úW/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/httpx/_transports/default.pyÚ_load_httpcore_exceptionsr-   J   s¯   € Ûð 	×!Ñ!Ô#3Ø×Ñ¤Ø×ÑœkØ×Ñœ|Ø×ÑœkØ×Ñœ|Ø×Ñœ|Ø×ÑœIØ×ÑœZØ×ÑœZØ×$Ñ$Ô&9Ø×Ñ¤Ø×#Ñ#Ô%7Ø×$Ñ$Ô&9ðð ó    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__z   ó
   € Ø /ˆÕr.   c              #  óv   K  — t        «       5  | j                  D ]  }|–— Œ 	 d d d «       y # 1 sw Y   y xY w­wr?   ©r;   rA   ©rC   Úparts     r,   Ú__iter__zResponseStream.__iter__}   s:   è ø€ Ü$Ó&ñ 	Ø×-Ñ-ò �Ø“
ñ÷	÷ 	ñ 	üs   ‚9�-¤	9­6²9c                óf   — t        | j                  d«      r| j                  j                  «        y y )NÚclose)ÚhasattrrA   rM   ©rC   s    r,   rM   zResponseStream.close‚   s)   € Ü�4×(Ñ(¨'Ô2Ø×!Ñ!×'Ñ'Õ)ð 3r.   N)rD   ztyping.Iterable[bytes]ÚreturnÚNone)rP   ztyping.Iterator[bytes]©rP   rQ   )Ú__name__Ú
__module__Ú__qualname__rE   rK   rM   © r.   r,   r=   r=   y   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_contextra   rb   rc   rd   re   ri   ©Úsocks5Úsocks5hú{Using SOCKS proxy, but the 'socksio' package is not installed. Make sure to install httpx using `pip install httpx[socks]`.©rr   rs   r`   ra   rb   rc   rd   re   zOProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got ú.)r+   r3   r5   r   r   r	   ÚConnectionPoolra   rb   rc   Ú_poolrZ   rn   Ú	HTTPProxyÚ
raw_schemeÚraw_hostrp   Úraw_pathÚraw_authÚheadersÚrawr`   ÚsocksioÚImportErrorÚ
SOCKSProxyÚ
ValueError©rC   r\   r]   r^   rd   re   ÚlimitsÚproxyrf   rg   rh   ri   r+   r`   r…   s                  r,   rE   zHTTPTransport.__init__ˆ   s)  € ó 	ä$.¨u´s¼C°jÔ$A”˜%Õ ÀuˆÜ(°¸TÈYÔWˆàˆ=Ø!×0Ñ0Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØØØ+ØØ-ð 1ó ˆ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ô  ðØ!ŸI™I×,Ñ,Ð/¨qð2óð øô- ò Ü!ðSóð ððús   Å4I ÉIc                ó:   — | j                   j                  «        | S r?   )r}   Ú	__enter__rO   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__©rC   Ú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   rm   )ÚmethodrZ   rƒ   ÚcontentÚ
extensions)Ústatus_coderƒ   Ústreamr˜   )r3   rš   r   r+   r   r–   r   rZ   r   r€   rp   r�   rƒ   r„   r˜   r;   r}   Úhandle_requestÚtypingÚIterabler   Ústatusr=   ©rC   Ú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   rO   s    r,   rM   zHTTPTransport.close  s   € Ø�
‰
×ÑÕr.   ©r\   zssl.SSLContext | str | boolr]   zCertTypes | Noner^   Úboolrd   r¥   re   r¥   rŠ   r   r‹   zProxyTypes | Nonerf   ú
str | Nonerg   r¦   rh   Úintri   z%typing.Iterable[SOCKET_OPTION] | NonerP   rQ   )rC   r"   rP   r"   ©NNN©r‘   ztype[BaseException] | Noner’   zBaseException | Noner“   zTracebackType | NonerP   rQ   ©r    r   rP   r   rR   )	rS   rT   rU   r   rE   r�   r�   r›   rM   rV   r.   r,   r#   r#   ‡   s
  „ ð /3Ø!%ØØØØ'Ø#'ØØ$(ØØ@DðOà+ðOð ðOð ð	Oð
 ðOð ðOð ðOð !ðOð ðOð "ðOð ðOð >ðOð 
óOóbð 04Ø*.Ø*.ð	@à,ð@ð (ð@ð (ð	@ð
 
ó@ð
àð
ð 
ó
ô>r.   c                  ó$   — e Zd Zdd„Zdd„Zdd„Zy)ÚAsyncResponseStreamc                ó   — || _         y r?   r@   rB   s     r,   rE   zAsyncResponseStream.__init__
  rF   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?   rH   rI   s     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   rA   r±   rO   s    r,   r±   zAsyncResponseStream.aclose  s6   è ø€ Ü�4×(Ñ(¨(Ô3Ø×'Ñ'×.Ñ.Ó0×0Ñ0ð 4Ø0ús   ‚4?¶=·?N)rD   ztyping.AsyncIterable[bytes]rP   rQ   )rP   ztyping.AsyncIterator[bytes]rR   )rS   rT   rU   rE   r¯   r±   rV   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«      ‚# t.        $ r t/        d	«      d ‚w xY w)Nr   rY   r[   r_   rj   rm   )rr   rs   rt   ru   r`   ra   rb   rc   rd   re   ri   rv   ry   rz   zdProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got {proxy.url.scheme!r}.)r+   r3   r5   r   r   r	   ÚAsyncConnectionPoolra   rb   rc   r}   rZ   rn   ÚAsyncHTTPProxyr   r€   rp   r�   r‚   rƒ   r„   r`   r…   r†   ÚAsyncSOCKSProxyrˆ   r‰   s                  r,   rE   zAsyncHTTPTransport.__init__  s  € ó 	ä$.¨u´s¼C°jÔ$A”˜%Õ ÀuˆÜ(°¸TÈYÔWˆàˆ=Ø!×5Ñ5Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØØØ+ØØ-ð 6ó ˆD�Jð �Y‰Y×ÑÐ!2Ñ2Ø!×0Ñ0Ø"Ÿ,™,Ø Ÿ9™9×/Ñ/ØŸ™×+Ñ+ØŸ™Ÿ™Ø Ÿ9™9×-Ñ-ð	 'ó ð !Ÿ>™>Ø#Ÿm™m×/Ñ/Ø"'×"3Ñ"3Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØØ-ð! 1ó ˆD�Jð$ �Y‰Y×ÑÐ!6Ñ6ðÛð "×1Ñ1Ø"Ÿ,™,Ø Ÿ9™9×/Ñ/ØŸ™×+Ñ+ØŸ™Ÿ™Ø Ÿ9™9×-Ñ-ð	 'ó ð !Ÿ>™>Ø'Ø &× 6Ñ 6Ø*0×*JÑ*JØ!'×!8Ñ!8ØØð 2ó ˆD�Jô  ð1óð øô- ò Ü!ðSóð ððús   Å4H- È-Ic              ƒ  óV   K  — | j                   j                  «       ƒ d {  –—†  | S 7 Œ­wr?   )r}   Ú
__aenter__rO   s    r,   r¸   zAsyncHTTPTransport.__aenter__i  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__m  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•   )r3   rš   r   r+   r   r–   r   rZ   r   r€   rp   r�   rƒ   r„   r˜   r;   r}   Úhandle_async_requestrœ   ÚAsyncIterabler   rž   r¬   rŸ   s        r,   r¼   z'AsyncHTTPTransport.handle_async_requestv  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±   rO   s    r,   r±   zAsyncHTTPTransport.aclose•  s   è ø€ Ø�j‰j×ÑÓ!×!Ò!ús   ‚( &¡(r¤   )rC   r%   rP   r%   r¨   r©   rª   rR   )	rS   rT   rU   r   rE   r¸   rº   r¼   r±   rV   r.   r,   r&   r&     s
  „ ð /3Ø!%ØØØØ'Ø#'ØØ$(ØØ@DðOà+ðOð ðOð ð	Oð
 ðOð ðOð ðOð !ðOð ðOð "ðOð ðOð >ðOð 
óOóbð 04Ø*.Ø*.ð	Gà,ðGð (ðGð (ð	Gð
 
óGð
àð
ð 
ó
ô>"r.   )rP   r'   )rP   ztyping.Iterator[None])>Ú__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ÚTupler§   ÚbytesÚ	bytearrayÚSOCKET_OPTIONÚ__all__r(   Ú__annotations__r-   Úcontextmanagerr;   r=   r#   r¬   r&   rV   r.   r,   ú<module>rÕ      s?  ðòõ4 #ã Û Ý à	×ÒÛãç GÓ G÷÷ ÷ ÷ ÷  (ß KÓ KÝ ß 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 Ð$Ñ%ð'ñ€ð   Ð
1€àACÐ Ð>Ó Cóð* ×Ñò+ó ð+ô2*�^ô *ô�Mô ôD1˜/ô 1ô"Ð+õ "r.   