
    zi3                     
   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j%        dd          Z& ej%        dd          Z'ej(        ej)        e*e*e*f         ej)        e*e*ej(        e+e,f         f         ej)        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j        eej        eej        eej        eej        eej        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#          Z5d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)
    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 V  d S # t           $ ri} d }t                                          D ]*\  }}t          | |          s|t	          ||          r|}+| t          |           } ||          | d } ~ ww xY wN)	ExceptionHTTPCORE_EXC_MAPitems
isinstance
issubclassstr)exc
mapped_excfrom_excto_excmessages        d/var/www/tmov.alphamb/tmov_inventario/venv/lib/python3.11/site-packages/httpx/_transports/default.pymap_httpcore_exceptionsr4   ?   s      + + + +
 0 6 6 8 8 	$ 	$Hfc8,,  !Z
%C%C!#
c((j!!s*!+s   
 
A=A$A88A=c                   ^    e Zd Zdej        e         ddfdZdej        e         fdZddZ	dS )ResponseStreamhttpcore_streamr%   Nc                     || _         d S r'   _httpcore_streamselfr7   s     r3   __init__zResponseStream.__init__i        /    c              #   v   K   t                      5  | j        D ]}|V  	 d d d            d S # 1 swxY w Y   d S r'   r4   r:   r<   parts     r3   __iter__zResponseStream.__iter__l   s      $&& 	 	-  



	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	s   .22c                 f    t          | j        d          r| j                                         d S d S )Nclose)hasattrr:   rF   r<   s    r3   rF   zResponseStream.closeq   s<    4('22 	*!'')))))	* 	*r?   r%   N)
__name__
__module____qualname__typingIterablebytesr=   IteratorrD   rF    r?   r3   r6   r6   h   ss        0(> 04 0 0 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dS )r!   TNFr   verifycerthttp1http2limits	trust_envproxyudslocal_addressretriessocket_optionsr%   c                 H   t          |||          }|4t          j        ||j        |j        |j        ||||	|
|
  
        | _        d S |j        j        dv rt          j	        t          j
        |j        j        |j        j        |j        j        |j        j                  |j        |j        j        ||j        |j        |j        |j        |||          | _        d S |j        j        dk    r	 dd l}n# t(          $ r t)          d          d w xY wt          j        t          j
        |j        j        |j        j        |j        j        |j        j                  |j        ||j        |j        |j        ||	          | _        d S t-          d
|j        j        d          )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    )TYWWW=!0' & 6*0*J!'!8+-  DJJJ Y!222!+", 9/+ 9-	   !>#m/'"'"3 & 6*0*J!'!8-!  DJJJ$ Y))   !S   ",", 9/+ 9-	   !>' & 6*0*J!'!8  DJJJ  lW\W`Wglll  s   /C4 4Dr<   c                 8    | j                                          | S r'   )rx   	__enter__rH   s    r3   r   zHTTPTransport.__enter__   s    
r?   exc_type	exc_value	tracebackc                     t                      5  | j                            |||           d d d            d S # 1 swxY w Y   d S r'   )r4   rx   __exit__r<   r   r   r   s       r3   r   zHTTPTransport.__exit__   s     %&& 	@ 	@J)Y???	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@s   9= =requestc           	      D   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                            |          }d d d            n# 1 swxY w Y   t          |j        t$          j                  sJ t)          |j        |j        t-          |j                  |j                  S 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   sH    '..99999>{-[)[%{+	   O'N)
 
 
 %&& 	2 	2:,,S11D	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 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   s        #+/'(,$(.2JNK KK oi(K 	K
 K K K u%K _S!K s+K K (FGK 
K K K KZ a     AE4848	@ @/&+m"<=@ ?=1@ ?=1	@
 
@ @ @ @

 

 
 
 
<     r?   c                   ^    e Zd Zdej        e         ddfdZdej        e         fdZddZ	dS )AsyncResponseStreamr7   r%   Nc                     || _         d S r'   r9   r;   s     r3   r=   zAsyncResponseStream.__init__   r>   r?   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 r'   rA   rB   s     r3   	__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)rG   r:   r   rH   s    r3   r   zAsyncResponseStream.aclose   sR      4((33 	1'..00000000000	1 	1r?   rI   )
rJ   rK   rL   rM   AsyncIterablerO   r=   AsyncIteratorr   r   rQ   r?   r3   r   r      su        0(<U(C 0 0 0 0 0!5e!<    
1 1 1 1 1 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dS )r$   TNFr   rS   rT   rU   rV   rW   rX   rY   rZ   r[   r\   r]   r%   c                 <   t          |||          }|4t          j        ||j        |j        |j        ||||	|
|
  
        | _        d S |j        j        dv rt          j	        t          j
        |j        j        |j        j        |j        j        |j        j                  |j        |j        j        ||j        |j        |j        |||
  
        | _        d S |j        j        dk    r	 dd l}n# t&          $ r t'          d          d w xY wt          j        t          j
        |j        j        |j        j        |j        j        |j        j                  |j        ||j        |j        |j        ||	          | _        d S t+          d
|j        j        d          )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    )TYWWW=!5' & 6*0*J!'!8+-  DJJJ Y!222!0", 9/+ 9-	   !>#m/' & 6*0*J!'!8-  DJJJ" Y))   !S   "1", 9/+ 9-	   !>' & 6*0*J!'!8  DJJJ  lW\W`Wglll  s   )C. .D	r<   c                 H   K   | j                                          d {V  | S r'   )rx   
__aenter__rH   s    r3   r   zAsyncHTTPTransport.__aenter__N  s1      j##%%%%%%%%%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 r'   )r4   rx   	__aexit__r   s       r3   r   zAsyncHTTPTransport.__aexit__R  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   c           	      T  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                            |           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   )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'N)
 
 
 %&& 	> 	>88========D	> 	> 	> 	> 	> 	> 	> 	> 	> 	> 	> 	> 	> 	> 	> $+v';<<<<<L&t{33	
 
 
 	
s   !C

CCc                 H   K   | j                                          d {V  d S r'   )rx   r   rH   s    r3   r   zAsyncHTTPTransport.aclosey  s2      j!!!!!!!!!!!r?   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$     s        #+/'(,$(.2JNJ JJ oi(J 	J
 J J J u%J _S!J s+J J (FGJ 
J J J JXq Q     AE4848	G G/&+m"<=G ?=1G ?=1	G
 
G G 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      sO   2             G G G G G G G G G G G G                                 ( ' ' ' ' ' ' ' L L L L L L L L L L L L 3 3 3 3 3 3 3 3FN3o...FN32333
Lc3
Lc6<y(899:
Lc4$%' +!6 + + + +. /^+<+<<	 "5M!3 "5 $* * * * *^ * * *z z z z zM z z zz1 1 1 1 1/ 1 1 1y" y" y" y" y"+ y" y" y" y" y"r?   