xL i6UdZddlmZddlZddlZddlmZejrddlZddl Z ddl m Z m Z m Z mZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZddlmZm Z dd l!m"Z"m#Z#m$Z$m%Z%dd l&m'Z'd d l(m)Z)m*Z*ejVd dZ,ejVddZ-ej\ej^e0e0e0fej^e0e0ej\e1e2ffej^e0e0de0ffZ3ddgZ4ia5de6d<ddZ7ejpddZ9Gdde%Z:Gdde*Z;Gdde"Z<Gdde)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_LIMITSLimitsProxycreate_ssl_context) ConnectErrorConnectTimeoutLocalProtocolError NetworkError PoolTimeout ProtocolError ProxyError ReadError ReadTimeoutRemoteProtocolErrorTimeoutExceptionUnsupportedProtocol WriteError WriteTimeout)RequestResponse)AsyncByteStream CertTypes ProxyTypesSyncByteStream)URL)AsyncBaseTransport BaseTransportT HTTPTransport)boundAAsyncHTTPTransport,dict[type[Exception], type[httpx.HTTPError]]HTTPCORE_EXC_MAPcddl}|jt|jt|jt|jt|j t |j t |jt|jt|jt|jt|jt|jt|jt|jtiSNr)httpcorerr rrrr r rrrrrr r)r+s _/mnt/ssd/data/python-lab/Trading/venv/lib/python3.12/site-packages/httpx/_transports/default.py_load_httpcore_exceptionsr-Js !!#3k|k||IZZ$$&9 ##%7$$&9 c#Kttdk(r ta dy#t$rX}d}tj D]#\}}t ||s| t ||s"|}%|t|}|||d}~wwxYwwr*)lenr(r- Exceptionitems isinstance issubclassstr)exc mapped_excfrom_excto_excmessages r,map_httpcore_exceptionsr;_s !46+ + 0 6 6 8 $ Hfc8,!Z %C#  $   c(!s*!+s*B %B  B7B&BBB c$eZdZddZddZddZy)ResponseStreamc||_yN_httpcore_streamselfhttpcore_streams r,__init__zResponseStream.__init__z /r.c#vKt5|jD]}| dddy#1swYyxYwwr?r;rArCparts r,__iter__zResponseStream.__iter__}s: $ & --      s 9- 969cft|jdr|jjyy)Nclose)hasattrrArMrCs r,rMzResponseStream.closes) 4((' 2  ! ! ' ' ) 3r.N)rDztyping.Iterable[bytes]returnNone)rPztyping.Iterator[bytes]rPrQ)__name__ __module__ __qualname__rErKrMr.r,r=r=ys0 *r.r=c eZdZdddddedddddf d dZd dZ d d dZ ddZdd Zy)r#TNFrc ddl} t|ttfr t |n|}t |||} |?| j | |j|j|j|||| | |  |_ y|jjdvr| j| j|jj|jj|jj |jj"|j$|j&j(| |j*|j|j|j|||  |_ y|jjdvr ddl}| j1| j|jj|jj|jj |jj"|j$| |j|j|j|| |_ yt3d |jjd #t.$r t/d dwxYw) Nrurlverifycert trust_env ssl_contextmax_connectionsmax_keepalive_connectionskeepalive_expiryhttp1http2uds local_addressretriessocket_optionshttphttpsschemehostporttarget) proxy_url proxy_auth proxy_headersr`proxy_ssl_contextrarbrcrdrerisocks5socks5h{Using SOCKS proxy, but the 'socksio' package is not installed. Make sure to install httpx using `pip install httpx[socks]`.rrrsr`rarbrcrdrezOProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got .)r+r3r5rrr ConnectionPoolrarbrc_poolrZrn HTTPProxy raw_schemeraw_hostrpraw_pathraw_authheadersrawr`socksio ImportError SOCKSProxy ValueErrorrCr\r]r^rdrelimitsproxyrfrgrhrir+r`rs r,rEzHTTPTransport.__init__s) $.usCj$A% u(TYW =!00' & 6 6*0*J*J!'!8!8+-1 DJYY  !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,,/q2 - !S s 4IIc:|jj|Sr?)r} __enter__rOs r,rzHTTPTransport.__enter__s  r.c|t5|jj|||dddy#1swYyxYwr?)r;r}__exit__rCexc_type exc_value tracebacks r,rzHTTPTransport.__exit__s9 % & @ JJ  )Y ? @ @ @s2;c t|jtsJddl}|j |j |j |jj|jj|jj|jj|jj|j|j}t5|j j#|}dddtjt$j&sJt)|j*|jt-|j|jS#1swYoxYwNrrm)methodrZrcontent extensions) status_coderstreamr)r3rrr+rrrrZrrrprrrrr;r}handle_requesttypingIterablerstatusr=rCrequestr+reqresps r,rzHTTPTransport.handle_requests'...999>> {{--[[))[[%%{{++  OO''NN))  % & 2::,,S1D 2$++v777 LL!$++.    2 2s E  E)c8|jjyr?)r}rMrOs r,rMzHTTPTransport.closes r.r\zssl.SSLContext | str | boolr]zCertTypes | Noner^boolrdrrerrrrzProxyTypes | Nonerf str | Nonergrrhintriz%typing.Iterable[SOCKET_OPTION] | NonerPrQ)rCr"rPr"NNNrztype[BaseException] | NonerzBaseException | NonerzTracebackType | NonerPrQrrrPrrR) rSrTrUrrErrrrMrVr.r,r#r#s /3!%'#'$(@DO+OO O  O  OO!OO"OO>O Ob 04*.*. @,@(@( @  @    >r.c$eZdZddZddZddZy)AsyncResponseStreamc||_yr?r@rBs r,rEzAsyncResponseStream.__init__ rFr.cKt5|j23d{}|7 6 dddy#1swYyxYwwr?rHrIs r, __aiter__zAsyncResponseStream.__aiter__ sC $ & "33  d  3   s/ A 6+)+6+6 A?AcKt|jdr#|jjd{yy7w)Naclose)rNrArrOs r,rzAsyncResponseStream.acloses6 4((( 3''..0 0 0 4 0s 4?=?N)rDztyping.AsyncIterable[bytes]rPrQ)rPztyping.AsyncIterator[bytes]rR)rSrTrUrErrrVr.r,rr s0 1r.rc eZdZdddddedddddf d dZd dZ d d dZ ddZdd Zy)r&TNFrc ddl} t|ttfr t |n|}t |||} |?| j | |j|j|j|||| | |  |_ y|jjdvr| j| j|jj|jj|jj |jj"|j$|j&j(|j*| |j|j|j|||  |_ y|jjdvr ddl}| j1| j|jj|jj|jj |jj"|j$| |j|j|j|| |_ yt3d #t.$r t/d dwxYw) NrrYr[r_rjrm) rrrsrtrur`rarbrcrdrerirvryrzzdProxy protocol must be either 'http', 'https', 'socks5', or 'socks5h', but got {proxy.url.scheme!r}.)r+r3r5rrr AsyncConnectionPoolrarbrcr}rZrnAsyncHTTPProxyrrrprrrrr`rrAsyncSOCKSProxyrrs r,rEzAsyncHTTPTransport.__init__s $.usCj$A% u(TYW =!55' & 6 6*0*J*J!'!8!8+-6 DJYY  !2 2!00",, 99//++ 99-- ' !>>#mm//"'"3"3' & 6 6*0*J*J!'!8!8-!1DJ$YY  !6 6 "11",, 99//++ 99-- ' !>>' & 6 6*0*J*J!'!8!82DJ 1 - !S s 4H--IcVK|jjd{|S7wr?)r} __aenter__rOs r,rzAsyncHTTPTransport.__aenter__is&jj##%%%  &s )')cKt5|jj|||d{dddy7 #1swYyxYwwr?)r;r} __aexit__rs r,rzAsyncHTTPTransport.__aexit__msL % & G**&&xIF F F G G F G Gs% A !><> A >AA c Kt|jtsJddl}|j |j |j |jj|jj|jj|jj|jj|j|j}t5|j j#|d{}dddtjt$j&sJt)|j*|jt-|j|jS7r#1swYqxYwwr)r3rrr+rrrrZrrrprrrrr;r}handle_async_requestr AsyncIterablerrrrs r,rz'AsyncHTTPTransport.handle_async_requestvs"'../:::>> {{--[[))[[%%{{++  OO''NN))  % & >88==D >$++v';';<<< LL&t{{3   > > >s1CE8E,7E*8E,O Ob 04*.*. G,G(G( G  G    >"r.)rPr')rPztyping.Iterator[None])>__doc__ __future__r contextlibrtypesr TYPE_CHECKINGsslhttpx_configrrrr _exceptionsr r r r rrrrrrrrrr_modelsrr_typesrrrr_urlsrbaser r!TypeVarr"r%UnionTuplerbytes bytearray SOCKET_OPTION__all__r(__annotations__r-contextmanagerr;r=r#rr&rVr.r,rs?4#  GG (KK3FNN3o.FNN323  LLc3 LLc6<<y(899: LLc4$%'  1AC>C* ++2 *^ *MD 1/ 1"+"r.