
    h6                       % S r SSKJr  SSKrSSKrSSKJr  \R                  (       a  SSKrSSK	r	SSK
JrJrJrJr  SSKJrJrJrJrJrJrJrJrJrJrJrJrJrJr  SSKJrJ r   SS	K!J"r"J#r#J$r$J%r%  SS
K&J'r'  SSK(J)r)J*r*  \RV                  " SSS9r,\RV                  " SSS9r-\R\                  \R^                  \0\0\04   \R^                  \0\0\R\                  \1\24   4   \R^                  \0\0S\04   4   r3SS/r40 q5S\6S'   SS jr7\Rp                  SS j5       r9 " S S\%5      r: " S S\*5      r; " S S\"5      r< " S S\)5      r=g)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                    SS K n U R                  [        U R                  [        U R                  [        U R                  [        U R
                  [
        U R                  [        U R                  [        U R                  [        U R                  [        U R                  [        U R                  [        U R                  [        U R                  [        U R                  [        0$ Nr   )httpcorer   r   r   r   r   r   r
   r   r   r   r   r   r   r   )r+   s    K/var/www/html/env/lib/python3.13/site-packages/httpx/_transports/default.py_load_httpcore_exceptionsr-   J   s     	!!#3k|k||IZZ$$&9##%7$$&9     c               #  4  #    [        [        5      S:X  a
  [        5       q S v   g ! [         ae  n S n[        R	                  5        H.  u  p#[        X5      (       d  M  Ub  [        X15      (       d  M,  UnM0     Uc  e [        U 5      nU" U5      U eS n A ff = f7f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c,, !Z%C%C#
 !9 c(!s*!+s*   B& B
B>B2BBBc                  2    \ rS rSrSS jrSS jrS	S jrSrg)
ResponseStreamy   c                    Xl         g N_httpcore_streamselfhttpcore_streams     r,   __init__ResponseStream.__init__z        /r.   c              #     #    [        5          U R                   H  nUv   M	     S S S 5        g ! , (       d  f       g = f7fr@   r;   rB   rD   parts     r,   __iter__ResponseStream.__iter__}   s+     $&--
 . '&&s   ?.	?
<?c                p    [        U R                  S5      (       a  U R                  R                  5         g g )Nclose)hasattrrB   rP   rD   s    r,   rP   ResponseStream.close   s,    4(('22!!'') 3r.   rA   N)rE   ztyping.Iterable[bytes]returnNone)rT   ztyping.Iterator[bytes]rT   rU   )__name__
__module____qualname____firstlineno__rF   rM   rP   __static_attributes__ r.   r,   r=   r=   y   s    0
*r.   r=   c                      \ rS rSrSSSSS\SSSSS4                       SS jjrSS jr   S       SS jjr    SS	 jrSS
 jr	Sr
g)r#      TNFr   c                   SS K n[        U[        [        45      (       a	  [	        US9OUn[        XUS9nUc<  UR                  UUR                  UR                  UR                  UUUU	U
US9
U l
        g UR                  R                  S;   a  UR                  UR                  UR                  R                  UR                  R                  UR                  R                   UR                  R"                  S9UR$                  UR&                  R(                  UUR*                  UR                  UR                  UR                  UUUS9U l
        g UR                  R                  S;   a   SS KnUR1                  UR                  UR                  R                  UR                  R                  UR                  R                   UR                  R"                  S9UR$                  UUR                  UR                  UR                  UUS
9U l
        g [3        SUR                  R                  < S35      e! [.         a    [/        S	5      S ef = f)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_headersrg   proxy_ssl_contextrh   ri   rj   rk   rl   rp   socks5socks5h{Using SOCKS proxy, but the 'socksio' package is not installed. Make sure to install httpx using `pip install httpx[socks]`.ry   rz   rg   rh   ri   rj   rk   rl   zOProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got .)r+   r3   r5   r   r   r	   ConnectionPoolrh   ri   rj   _poolra   ru   	HTTPProxy
raw_schemeraw_hostrw   raw_pathraw_authheadersrawrg   socksioImportError
SOCKSProxy
ValueErrorrD   rc   rd   re   rk   rl   limitsproxyrm   rn   ro   rp   r+   rg   r   s                  r,   rF   HTTPTransport.__init__   s*    	$.usCj$A$A% u(YW=!00' & 6 6*0*J*J!'!8!8+- 1 DJ YY!22!++",, 99//++ 99--	 '  !>>#mm//'"'"3"3 & 6 6*0*J*J!'!8!8-! , DJ$ YY!66 ",,",, 99//++ 99--	 '  !>>' & 6 6*0*J*J!'!8!8 - DJ  !II,,/q2 -  !S s   .H: :Ic                :    U R                   R                  5         U $ r@   )r   	__enter__rR   s    r,   r   HTTPTransport.__enter__   s    

r.   c                    [        5          U R                  R                  XU5        S S S 5        g ! , (       d  f       g = fr@   )r;   r   __exit__rD   exc_type	exc_value	tracebacks       r,   r   HTTPTransport.__exit__   s*     %&JJY? '&&s   1
?c           
        [        UR                  [        5      (       d   eSS KnUR	                  UR
                  UR                  UR                  R                  UR                  R                  UR                  R                  UR                  R                  S9UR                  R                  UR                  UR                  S9n[        5          U R                   R#                  U5      nS S S 5        [        WR                  [$        R&                  5      (       d   e[)        UR*                  UR                  [-        UR                  5      UR                  S9$ ! , (       d  f       Nv= fNr   rt   )methodra   r   content
extensions)status_coder   streamr   )r3   r   r   r+   r   r   r   ra   r   r   rw   r   r   r   r   r;   r   handle_requesttypingIterabler   statusr=   rD   requestr+   reqresps        r,   r   HTTPTransport.handle_request   s    '...9999>>{{--[[))[[%%{{++	   OO''NN))  
 %&::,,S1D ' $++v7777LL!$++.	
 	
 '&s   E!!
E/c                8    U R                   R                  5         g r@   )r   rP   rR   s    r,   rP   HTTPTransport.close  s    

r.   r   rc   zssl.SSLContext | str | boolrd   zCertTypes | Nonere   boolrk   r   rl   r   r   r   r   zProxyTypes | Nonerm   
str | Nonern   r   ro   intrp   z%typing.Iterable[SOCKET_OPTION] | NonerT   rU   )rD   r"   rT   r"   NNNr   ztype[BaseException] | Noner   zBaseException | Noner   zTracebackType | NonerT   rU   r   r   rT   r   rV   )rW   rX   rY   rZ   r   rF   r   r   r   rP   r[   r\   r.   r,   r#   r#      s
    /3!%'#'$(@DO+O O 	O
 O O O !O O "O O >O 
Ob 04*.*.	@,@ (@ (	@
 
@

 

>r.   c                  2    \ rS rSrSS jrSS jrS	S jrSrg)
AsyncResponseStreami	  c                    Xl         g r@   rA   rC   s     r,   rF   AsyncResponseStream.__init__
  rH   r.   c                  #    [        5          U R                    S h  vN nU7v   M   N
 S S S 5        g ! , (       d  f       g = f7fr@   rJ   rK   s     r,   	__aiter__AsyncResponseStream.__aiter__  s3     $&"33 d
3 '&&s1   A6,*,6,6	A
A Ac                   #    [        U R                  S5      (       a#  U R                  R                  5       I S h  vN   g g  N7f)Naclose)rQ   rB   r   rR   s    r,   r   AsyncResponseStream.aclose  s8     4(((33''..000 40s   9AAArA   N)rE   ztyping.AsyncIterable[bytes]rT   rU   )rT   ztyping.AsyncIterator[bytes]rV   )rW   rX   rY   rZ   rF   r   r   r[   r\   r.   r,   r   r   	  s    0
1r.   r   c                      \ rS rSrSSSSS\SSSSS4                       SS jjrSS jr   S       SS jjr    SS	 jrSS
 jr	Sr
g)r&   i  TNFr   c                v   SS K n[        U[        [        45      (       a	  [	        US9OUn[        XUS9nUc<  UR                  UUR                  UR                  UR                  UUUU	U
US9
U l
        g UR                  R                  S;   a  UR                  UR                  UR                  R                  UR                  R                  UR                  R                   UR                  R"                  S9UR$                  UR&                  R(                  UR*                  UUR                  UR                  UR                  UUUS9U l
        g UR                  R                  S;   a   SS KnUR1                  UR                  UR                  R                  UR                  R                  UR                  R                   UR                  R"                  S9UR$                  UUR                  UR                  UR                  UUS
9U l
        g [3        S5      e! [.         a    [/        S	5      S ef = f)Nr   r`   rb   rf   rq   rt   )ry   rz   r{   r|   rg   rh   ri   rj   rk   rl   rp   r}   r   r   zdProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got {proxy.url.scheme!r}.)r+   r3   r5   r   r   r	   AsyncConnectionPoolrh   ri   rj   r   ra   ru   AsyncHTTPProxyr   r   rw   r   r   r   r   rg   r   r   AsyncSOCKSProxyr   r   s                  r,   rF   AsyncHTTPTransport.__init__  s    	$.usCj$A$A% u(YW=!55' & 6 6*0*J*J!'!8!8+- 6 DJ YY!22!00",, 99//++ 99--	 '  !>>#mm//"'"3"3' & 6 6*0*J*J!'!8!8-! 1 DJ$ YY!66 "11",, 99//++ 99--	 '  !>>' & 6 6*0*J*J!'!8!8 2 DJ  1 -  !S s   .H! !H8c                V   #    U R                   R                  5       I S h  vN   U $  N7fr@   )r   
__aenter__rR   s    r,   r   AsyncHTTPTransport.__aenter__i  s%     jj##%%% 	&s   )')c                   #    [        5          U R                  R                  XU5      I S h  vN   S S S 5        g  N! , (       d  f       g = f7fr@   )r;   r   	__aexit__r   s       r,   r   AsyncHTTPTransport.__aexit__m  s:      %&**&&xIFFF '&F '&s%   A =;=	A=
AAc           
        #    [        UR                  [        5      (       d   eSS KnUR	                  UR
                  UR                  UR                  R                  UR                  R                  UR                  R                  UR                  R                  S9UR                  R                  UR                  UR                  S9n[        5          U R                   R#                  U5      I S h  vN nS S S 5        [        WR                  [$        R&                  5      (       d   e[)        UR*                  UR                  [-        UR                  5      UR                  S9$  Nt! , (       d  f       Nx= f7fr   )r3   r   r   r+   r   r   r   ra   r   r   rw   r   r   r   r   r;   r   handle_async_requestr   AsyncIterabler   r   r   r   s        r,   r   'AsyncHTTPTransport.handle_async_requestv  s     '../::::>>{{--[[))[[%%{{++	   OO''NN))  
 %&88==D ' $++v';';<<<<LL&t{{3	
 	
	 > '&s1   CE>E-6E+7E-;A0E>+E--
E;7E>c                T   #    U R                   R                  5       I S h  vN   g  N7fr@   )r   r   rR   s    r,   r   AsyncHTTPTransport.aclose  s     jj!!!s   (&(r   r   )rD   r%   rT   r%   r   r   r   rV   )rW   rX   rY   rZ   r   rF   r   r   r   r   r[   r\   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.   )rT   r'   )rT   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&   r\   r.   r,   <module>r      s;  4 #   	 G G     ( K K  3
NN3o.
NN323
LLc3
LLc6<<y(899:
LLc4$%'  
1AC > C* + +2*^ *M D1/ 1"+ "r.   