
     jS4                       S r SSKJr  SSKrSSKrSSKJ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#J$r$  SS
K%J&r&  SSK'J(r(J)r)  \RT                  " SSS9r+\RT                  " SSS9r,\RZ                  \R\                  \/\/\/4   \R\                  \/\/\RZ                  \0\14   4   \R\                  \/\/S\/4   4   r2SS/r3\Rh                  SS j5       r5\R0                  \\R                  \\R,                  \\R6                  \\R$                  \\R"                  \\R                  \\R*                  \\R4                  \\R(                  \\R2                  \\R&                  \\R                   \\R.                  \0r6 " S S\#5      r7 " S S\)5      r8 " S S\ 5      r9 " 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VerifyTypes)URL   )AsyncBaseTransportBaseTransportTHTTPTransport)boundAAsyncHTTPTransportc               #     #     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N)	ExceptionHTTPCORE_EXC_MAPitems
isinstance
issubclassstr)exc
mapped_excfrom_excto_excmessages        c/home/ubuntu/second-brain/public-api/venv/lib/python3.13/site-packages/httpx/_transports/default.pymap_httpcore_exceptionsr6   E   s}     + +
 0 6 6 8Hc,, !Z%C%C#
 !9 c(!s*!+s*   A;	 A;
A8>A3A33A88A;c                  2    \ rS rSrSS jrSS jrS	S jrSrg)
ResponseStreamn   c                    Xl         g r)   _httpcore_streamselfhttpcore_streams     r5   __init__ResponseStream.__init__o        /    c              #     #    [        5          U R                   H  nUv   M	     S S S 5        g ! , (       d  f       g = f7fr)   r6   r<   r>   parts     r5   __iter__ResponseStream.__iter__r   s+     $&--
 . '&&s   ?.	?
<?c                p    [        U R                  S5      (       a  U R                  R                  5         g g )Nclose)hasattrr<   rK   r>   s    r5   rK   ResponseStream.closew   s,    4(('22!!'') 3rC   r;   N)r?   ztyping.Iterable[bytes]returnNone)rO   ztyping.Iterator[bytes]rO   rP   )__name__
__module____qualname____firstlineno__r@   rH   rK   __static_attributes__ rC   r5   r8   r8   n   s    0
*rC   r8   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                   [        XUS9n[        U[        [        45      (       a	  [	        US9OUnUcA  [
        R                  " UUR                  UR                  UR                  UUUU	U
US9
U l
        g UR                  R                  S;   a  [
        R                  " [
        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:X  a   SS Kn[
        R0                  " [
        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)Nverifycert	trust_envurl
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_headersrb   proxy_ssl_contextrc   rd   re   rf   rg   rk   socks5r   {Using SOCKS proxy, but the 'socksio' package is not installed. Make sure to install httpx using `pip install httpx[socks]`.rt   ru   rb   rc   rd   re   rf   rg   zDProxy protocol must be either 'http', 'https', or 'socks5', but got .)r	   r-   r/   r   r   httpcoreConnectionPoolrc   rd   re   _poolr`   rp   	HTTPProxy
raw_schemeraw_hostrr   raw_pathraw_authheadersrawrb   socksioImportError
SOCKSProxy
ValueErrorr>   r\   r]   rf   rg   limitsr^   proxyrh   ri   rj   rk   rb   r   s                 r5   r@   HTTPTransport.__init__}   s    )YW$.usCj$A$A% u=!00' & 6 6*0*J*J!'!8!8+-DJ YY!22!++",, 99//++ 99--	 !>>#mm//'"'"3"3 & 6 6*0*J*J!'!8!8-!DJ$ YY) ",,",, 99//++ 99--	 !>>' & 6 6*0*J*J!'!8!8DJ  !II,,/q2 -  !S s   9I I&c                :    U R                   R                  5         U $ r)   )r~   	__enter__rM   s    r5   r   HTTPTransport.__enter__   s    

rC   c                    [        5          U R                  R                  XU5        S S S 5        g ! , (       d  f       g = fr)   )r6   r~   __exit__r>   exc_type	exc_value	tracebacks       r5   r   HTTPTransport.__exit__   s*     %&JJY? '&&s   1
?c           
        [        UR                  [        5      (       d   e[        R                  " UR
                  [        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Nro   )methodr`   r   content
extensions)status_coder   streamr   )r-   r   r   r|   r   r   r   r`   r   r   rr   r   r   r   r   r6   r~   handle_requesttypingIterabler   statusr8   r>   requestreqresps       r5   r   HTTPTransport.handle_request   s    '...9999>>{{--[[))[[%%{{++	 OO''NN))
 %&::,,S1D ' $++v7777LL!$++.	
 	
 '&s   E''
E5c                8    U R                   R                  5         g r)   )r~   rK   rM   s    r5   rK   HTTPTransport.close   s    

rC   r~   r\   r   r]   zCertTypes | Nonerf   boolrg   r   r   r   r^   r   r   zProxyTypes | Nonerh   
str | Noneri   r   rj   intrk   z%typing.Iterable[SOCKET_OPTION] | NonerO   rP   )r>   r#   rO   r#   NNNr   ztype[BaseException] | Noner   zBaseException | Noner   zTracebackType | NonerO   rP   r   r   rO   r   rQ   )rR   rS   rT   rU   r   r@   r   r   r   rK   rV   rW   rC   r5   r$   r$   |   s
    #!%'#'$(@DMM M 	M
 M M M !M M "M M >M 
M^ 04*.*.	@,@ (@ (	@
 
@

 

<rC   c                  2    \ rS rSrSS jrSS jrS	S jrSrg)
AsyncResponseStream   c                    Xl         g r)   r;   r=   s     r5   r@   AsyncResponseStream.__init__   rB   rC   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)   rE   rF   s     r5   	__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)rL   r<   r   rM   s    r5   r   AsyncResponseStream.aclose  s8     4(((33''..000 40s   9AAAr;   N)r?   ztyping.AsyncIterable[bytes]rO   rP   )rO   ztyping.AsyncIterator[bytes]rQ   )rR   rS   rT   rU   r@   r   r   rV   rW   rC   r5   r   r      s    0
1rC   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                   [        XUS9n[        U[        [        45      (       a	  [	        US9OUnUcA  [
        R                  " UUR                  UR                  UR                  UUUU	U
US9
U l
        g UR                  R                  S;   a  [
        R                  " [
        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:X  a   SS Kn[
        R0                  " [
        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_   ra   rl   ro   )rt   ru   rv   rw   rb   rc   rd   re   rf   rg   rk   rx   r   ry   rz   zYProxy protocol must be either 'http', 'https', or 'socks5', but got {proxy.url.scheme!r}.)r	   r-   r/   r   r   r|   AsyncConnectionPoolrc   rd   re   r~   r`   rp   AsyncHTTPProxyr   r   rr   r   r   r   r   rb   r   r   AsyncSOCKSProxyr   r   s                 r5   r@   AsyncHTTPTransport.__init__
  s    )YW$.usCj$A$A% u=!55' & 6 6*0*J*J!'!8!8+-DJ YY!22!00",, 99//++ 99--	 !>>#mm//"'"3"3' & 6 6*0*J*J!'!8!8-!DJ$ YY) "11",, 99//++ 99--	 !>>' & 6 6*0*J*J!'!8!8DJ  1 -  !S s   9H6 6Ic                V   #    U R                   R                  5       I S h  vN   U $  N7fr)   )r~   
__aenter__rM   s    r5   r   AsyncHTTPTransport.__aenter__Y  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)   )r6   r~   	__aexit__r   s       r5   r   AsyncHTTPTransport.__aexit__]  s:      %&**&&xIFFF '&F '&s%   A =;=	A=
AAc           
       #    [        UR                  [        5      (       d   e[        R                  " UR
                  [        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   )r-   r   r   r|   r   r   r   r`   r   r   rr   r   r   r   r   r6   r~   handle_async_requestr   AsyncIterabler   r   r   r   s       r5   r   'AsyncHTTPTransport.handle_async_requestf  s     '../::::>>{{--[[))[[%%{{++	 OO''NN))
 %&88==D ' $++v';';<<<<LL&t{{3	
 	
	 > '&s1   CFE3<E1=E3A0F1E33
F=Fc                T   #    U R                   R                  5       I S h  vN   g  N7fr)   )r~   r   rM   s    r5   r   AsyncHTTPTransport.aclose  s     jj!!!s   (&(r   r   )r>   r&   rO   r&   r   r   r   rQ   )rR   rS   rT   rU   r   r@   r   r   r   r   rV   rW   rC   r5   r'   r'   	  s
    #!%'#'$(@DMM M 	M
 M M M !M M "M M >M 
M^ 04*.*.	G,G (G (	G
 
G

 

<"rC   )rO   ztyping.Iterator[None]);__doc__
__future__r   
contextlibr   typesr   r|   _configr   r   r   r	   _exceptionsr
   r   r   r   r   r   r   r   r   r   r   r   r   r   _modelsr   r   _typesr   r   r   r   r   _urlsr   baser!   r"   TypeVarr#   r&   UnionTupler   bytes	bytearraySOCKET_OPTION__all__contextmanagerr6   r+   r8   r$   r   r'   rW   rC   r5   <module>r      s  4 #     G G     ( X X  3
NN3o.
NN323
LLc3
LLc6<<y(899:
LLc4$%'  
1 + +. /^+<+<<	  "5M!3  "5 $*^ *|M |~1/ 1|"+ |"rC   