
    F2jL                       d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dl	m
Z
 d dlmZ ddlmZ ej        rd dlmZ dd	lmZmZmZ dd
l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%m&Z&m'Z' ddl(m)Z)m*Z* ddl+m,Z, ddl-m.Z. 	 ddl/m0Z0 n)# e1$ r! dZ0ej2        dk    r ej3        de4           Y nw xY wddl5m6Z6m7Z7 ddl8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z> ddl?m@Z@ ddlAmBZB ddlCmDZD ddlEmFZFmGZG ddlHmIZImJZJ ddlmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z] ddl^m_Z_m`Z`maZambZbmcZcmdZdmeZemfZfmgZgmhZhmiZimjZj ej2        dk    rejk        Zlnej        Zl G d deF          ZmdS )     )annotationsN)OrderedDict)	timedelta)urlparse   )codes)Literal)HAS_LEGACY_URLLIB3iscoroutinefunctionurllib3_ensure_type)DEFAULT_POOLSIZEDEFAULT_RETRIESREAD_DEFAULT_TIMEOUTWRITE_DEFAULT_TIMEOUT)AsyncBaseAdapterAsyncHTTPAdapter)RequestsCookieJarcoerce_to_requests_cookiejarextract_cookies_to_jarmerge_cookies)ChunkedEncodingErrorContentDecodingErrorInvalidSchemaTooManyRedirects)DEFAULT_STRATEGYRevocationConfiguration)AsyncServerGatewayInterface)AsyncUnixAdapter)AsyncPyodideAdapter
emscriptenzUunable to load native WASM adapter for AsyncSession. HTTP requests may fail in async.)async_dispatch_hookdefault_hooks)DEFAULT_REDIRECT_LIMITAsyncResponsePreparedRequestRequestResponseTransferProgress)ConnectionInfo)AsyncBaseResolver)load_extension)Sessionmerge_hooks)AsyncQuicSharedCacheCaseInsensitiveDict)ASGIAppAsyncBodyTypeAsyncHookTypeAsyncHttpAuthenticationTypeAsyncResolverTypeBodyTypeCacheLayerAltSvcTypeCookiesTypeHeadersTypeHttpAuthenticationTypeHttpMethodTypeMultiPartFilesAltTypeMultiPartFilesType	ProxyTypeQueryParameterType	RetryTypeTimeoutTypeTLSClientCertTypeTLSVerifyType)_deepcopy_ci_swap_contextarewind_bodycreate_async_resolverdefault_headersparse_schemerequote_uriresolve_proxiesrewind_bodyshould_check_crlshould_check_ocspurljoin_safewin32c                  .    e Zd ZdZdddeddddddeeddddddddedddddddddd8Zdd;Zdd=Z	dd>Z
dd@ZdA Zd fdEZddGZej        ddO            Zej        ddQ            ZddSZ	 	 	 	 	 	 	 ddd\Zej        	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dddj            Zej        	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dddk            Z	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dddmZej        d]d]d]d]d]d]d]d]d]d]d]dnddo            Zej        d]d]d]d]d]d]d]d]d]d]d]dnddp            ZddddddddddddnddqZej        d]d]d]d]d]d]d]d]d]d]d]dndds            Zej        d]d]d]d]d]d]d]d]d]d]dt
ddu            ZddddddddddddnddvZej        d]d]d]d]d]d]d]d]d]d]d]dnddw            Zej        d]d]d]d]d]d]d]d]d]d]dt
ddx            ZddddddddddddnddyZej        	 	 dd]d]d]d]d]d]d]d]d]d]d]d]dzdd{            Zej        	 	 dd]d]d]d]d]d]d]d]d]d]d]d|dd}            Z	 	 ddddddddddddddzdd~Zej        	 dd]d]d]d]d]d]d]d]d]d]d]d]d]ddd            Zej        	 dd]d]d]d]d]d]d]d]d]d]d]d]ddd            Z	 dddddddddddddddddZej        	 dd]d]d]d]d]d]d]d]d]d]d]d]d]ddd            Zej        	 dd]d]d]d]d]d]d]d]d]d]d]d]ddd            Z	 dddddddddddddddddZej        d]d]d]d]d]d]d]d]d]d]d]dndd            Zej        d]d]d]d]d]d]d]d]d]d]dt
dd            ZddddddddddddnddZddddZddZ xZS )AsyncSessiona  A Requests asynchronous session.

    Provides cookie persistence, connection-pooling, and configuration.

    Basic Usage::

      >>> import niquests
      >>> s = niquests.AsyncSession()
      >>> await s.get('https://httpbin.org/get')
      <Response HTTP/2 [200]>

    Or as a context manager::

      >>> async with niquests.AsyncSession() as s:
      ...     await s.get('https://httpbin.org/get')
      <Response HTTP/2 [200]>
    NFg     @g      N@T)resolversource_addressquic_cache_layerretriesmultiplexeddisable_http1disable_http2disable_http3disable_ipv6disable_ipv4pool_connectionspool_maxsizehappy_eyeballskeepalive_delaykeepalive_idle_windowbase_urltimeoutheadersauthhooksrevocation_configurationappparamscookiesproxiesverifycertallow_incoming_cookiesrR   AsyncResolverType | NonerS   tuple[str, int] | NonerT   CacheLayerAltSvcType | NonerU   r?   rV   boolrW   rX   rY   rZ   r[   r\   intr]   r^   
bool | intr_   float | int | Noner`   ra   
str | Nonerb   TimeoutType | Nonerc   HeadersType | Nonerd   ;HttpAuthenticationType | AsyncHttpAuthenticationType | Nonere   @AsyncHookType[PreparedRequest | Response | AsyncResponse] | Nonerf   RevocationConfiguration | Nonerg   ASGIApp | Nonerh   QueryParameterType | Noneri   CookiesType | Nonerj   ProxyType | Nonerk   TLSVerifyType | Nonerl   TLSClientCertType | Nonerm   c                  |
|	g                     d          dk    rt          d          || _        | j        rXt          rQt	          | j        d          r<dt          t          | j                            vrt          | j                  | _        |t          |          nt                      | _
        || _        ||ni | _        |t          t                      |          nt                      | _        ||ni | _        d| _        || _        t'          |          | _        || j        k    | _        || _        || _        || _        || _        || _        |
| _        |	| _        || _        || _        || _        || _         || _!        ||nd| _"        || _#        tH          | _%        d| _&        || _'        tQ          |d          | _)        || _*        ||ntW          d	          | _,        d | _-        d | _.        || _/        ta                      | _1        td          | 3                    d
ti          d%i d| j,        d|d|d|d|d|d|d|
d|	d|d|d|d|d|d|d|           | 3                    dti          |||||||
|	|||||||                     | 3                    dtk          |||||||
|	|||||||                     n.te          |          }dD ]}| 3                    | d |           |Utm          ||!          }| 3                    d"|           d#D ]} | 3                    |  d$|           | j'        d"| _'        d S d S d S )&NT   z!Cannot disable both IPv4 and IPv6totalurllib3_futureF)thread_freei 0  )max_sizehttps://rT   max_retriesrW   rX   rY   rR   rS   r[   rZ   r\   r]   r^   r_   r`   rf   rm   http://r   rW   rX   rY   rR   rS   r[   rZ   r\   r]   r^   r_   r`   rf   rm   http+unix://)r   )httphttpsssepssewswssz://)rg   r   zasgi://default)r   r   r   r   z
://default )7countRuntimeErrorrU   r
   hasattrstrtyper   r/   rG   rc   rd   rj   r-   r"   re   rh   streamrV   rF   rR   _own_resolverrb   rS   _disable_http1_disable_http2_disable_http3_disable_ipv4_disable_ipv6_pool_connections_pool_maxsize_happy_eyeballs_keepalive_delay_keepalive_idle_windowrk   rl   r#   max_redirects	trust_envra   r   ri   rm   r.   rT   _ocsp_cache
_crl_cache_revocation_configurationr   adaptersr   mountr   r   r   )!selfrR   rS   rT   rU   rV   rW   rX   rY   rZ   r[   r\   r]   r^   r_   r`   ra   rb   rc   rd   re   rf   rg   rh   ri   rj   rk   rl   rm   wasm_adaptersupported_schemeadapter_schemes!                                    ^/home/thesage/.hermes/hermes-agent/venv/lib/python3.11/site-packages/niquests/async_session.py__init__zAsyncSession.__init__~   s   @ ,'--d33q88BCCC  L	="	= g..	= !D,>,>(?(???.t|<<DL
 8?7J*7333P_PaPa 	
 .5-@''b
   /// 	
 5;4F&&B  ' ,A+J+J#+t}#<  -+++))!1)- /&;# 06/AVVt /3	 #9  $ %- +Gw\`*a*a*a
 -C#
 5E4P 0 0VjtzV{V{V{
 /3
 .2 Jb& =HMM&JJ    %)%:%: ' #0- #0-	
 #0- &X $2> ". ". &6%5 ". $2> %4O +@*? .F-E  ,B+A!  * JJ  '"/"/"/%#1!-!-%5!-#1$3*?-E+A    ( JJ  '"/"/"/%#1!-!-%5!-#1$3*?-E+A     * /#  L %R C C 

.333\BBBB?1#  G JJ'1117 < <

g1117;;;;}$ 0 ? %$    returnr   c                j    dt          | j                                      dd          d d          dS )Nz<AsyncSession zOrderedDict( >)reprr   replacer   s    r   __repr__zAsyncSession.__repr__p  s9    WT] 3 3 ; ;NB O OPSQSPS TWWWWr   typing.NoReturnc                     t          d          )NzOYou probably meant "async with". Did you forget to prepend the "async" keyword?)SyntaxErrorr   s    r   	__enter__zAsyncSession.__enter__s  s    klllr   c                
   K   | S Nr   r   s    r   
__aenter__zAsyncSession.__aenter__v  s      r   Nonec                >   K   |                                   d {V  d S r   )close)r   excvaluetbs       r   	__aexit__zAsyncSession.__aexit__y  s,      jjllr   c                   |                                 D ]\  }}t          | ||           t          d           | _        d| _        t                      | _        |                     dt          di d| j	        d| j
        d| j        d| j        d| j        d| j        d	| j        d
| j        d| j        d| j        d| j        d| j        d| j        d| j        d| j        d| j                   |                     dt          | j
        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j                             |                     dt1          | j
        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j        | j                             | j                                        D ]:}t5          |d          r| j        |_        t5          |d          r| j        |_        ;d S )NTr   rT   r   rW   rX   rY   rS   r[   rZ   rR   r\   r]   r^   r_   r`   rf   rm   r   )r   rW   rX   rY   rS   r[   rZ   rR   r\   r]   r^   r_   r`   rf   rm   r   r   r   r   )itemssetattrrF   rR   r   r   r   r   r   rT   rU   r   r   r   rS   r   r   r   r   r   r   r   r   rm   r   valuesr   r   r   )r   stateattrr   r   s        r   __setstate__zAsyncSession.__setstate__|  s    ;;== 	' 	'KD%D$&&&&-d33!#

   !%!6!6 LL #11 #11	
 #11  $22 "// "//  "&!7!7 "//  $33 !% 5 5 '+&A&A *.)G)G  (,'B'B!	
 	
 	
* 	

 L"1"1"1#2!/!/!%!7!/#3 $ 5&*&A)-)G'+'B  	
 	
 	
( 	

 L"1"1"1#2!/!/!%!7!/#3 $ 5&*&A)-)G'+'B  	
 	
 	
( }++-- 	5 	5Gw.. 7&*&6#w-- 5%)_"		5 	5r   prefixr   r   c                L    t                                          ||           d S r   )superr   )r   r   r   	__class__s      r   r   zAsyncSession.mount  s!    fg&&&&&r   urlc                   | j                                         D ]B\  }}|                                                    |                                          r|c S Ct	          |          }d|v r(t          |                    dd                    \  }}nd }	 t          ||          }| j                                         D ]E\  }}||                                v r*|	                    |          t	          |          k    r|c S Fn# t          $ r Y nw xY w|                    d          s|                    d          rd}nd}t          d	||           )
N+r   )maxsplit)implementationzws://zwss://z_ Did you forget to install the extra for WebSocket? Run `pip install niquests[ws]` to fix this.r   z&No connection adapters were found for )r   r   lower
startswithrH   tuplesplitr+   supported_schemesscheme_to_http_schemeImportErrorr   )r   r   r   r   schemer   	extensionadditional_hints           r   get_adapterzAsyncSession.get_adapter  s   #}2244 	 	OFGyy{{%%fllnn55 
 c""&==%*6<<a<+H+H%I%I"FNN!N	&vnMMMI#'=#6#6#8#8 # #Y88::::y?^?^_e?f?fjvw}j~j~?~?~"NNN#  	 	 	D	
 >>'"" 	!cnnX&>&> 	!OO O ]S]O]]^^^s   A.D 
D 
DDrequestr%   r   Literal[True]kwargs
typing.Anyr$   c               
   K   d S r   r   )r   r   r   r   s       r   sendzAsyncSession.send  s      uxuxr   r'   c                
   K   d S r   r   )r   r   r   s      r   r   zAsyncSession.send  s      VYVYr   Response | AsyncResponsec                H   K   t          t                    rt          d                              d j                                       d j                                       d j                   dvrt           j         j	                  d<   dv rad         rYt          rRt          d         d          r<dt          t          d                             vrt          d                   d<                       d	d
          }                    d          }j        t%          d           d{V d? fd}d@fd}dAfd}                    d|                               d|                               d j                                       d |           j        J  j                                        s j        st1          j        d!t4                                                       d{V   j                                         _                             d"t=          dBi d# j        d$ j         d% j!        d& j"        d' j#        d( j        d) j$        d* j%        d+ j&        d, j'        d- j(        d. j)        d/ j*        d0 j+        d1 j,        d2 j-                                        d3t=           j          j!         j"         j#         j         j$         j%         j&         j'         j(         j)         j*         j+         j,         j-        4                                          d5t]           j          j!         j"         j#         j         j$         j%         j&         j'         j(         j)         j*         j+         j,         j-        4                      /                    j        6          }ta                      }	 |j1        fi  d{V }
te          j3                  _3        t          |
d7          r[|
j4        d
u rR fd8}||
_5        dd<   |
j6        7                    ||	 j8        |d9 j9        d:           |stu          |
           |
S ta                      |	z
  }tw          |;          |
_<        t%          d<|
fi  d{V }
 j-        rL|
j=        r*|
j=        D ]"}t}           j8        |j?        |j@                   #t}           j8        |
j@                   |rL  jA        |
fd=d
i}g }|2 3 d{V }t          |t                    r|C                    |           2|56 ng }|rZ|D                    d9|
           |                                }
|D ]&}t          |t                    rtu          |           '||
_=        |s|
jF        r|  jA        |
fd>d
i}	 |G                                 d{V |
_H        n# t          $ r Y nw xY w|J                                 d{V  n# |J                                 d{V  w xY w|sGt          |
t                    r$|
jK        |
jL         d{V  tu          |
           n|
jK        |
jL         |
S )CzSend a given PreparedRequest.z#You can only send PreparedRequests.r   rk   rl   rj   rb   r   r   allow_redirectsTpre_requestN	conn_infor)   r   r   c           	       K   | 	_         	j        r	j                            d          rd         rt          j                            dd          dk    }|sj        j        j        }t          | j                  r	 ddl	m
} ddl	m} j        G |            _        j                                        D ]}t          |d	          rj        |_         |	||sd
ndd         j        j        j                   d{V  n# t$          $ r Y nw xY wt'          | j                  r	 ddlm} ddlm} j        G |            _        j                                        D ]}t          |d          rj        |_         |	||sd
ndd         j        j        j                   d{V  n# t$          $ r Y nw xY w	
k    rt/          d	           d{V  dS dS )zVThis function will be called by urllib3.future just after establishing the connection.r   rk   NIQUESTS_STRICT_OCSP0Nr   )InMemoryRevocationStatus)rk   r   g?g      ?rj   )rR   r^   cache)InMemoryRevocationListr   pre_send)r   r   r   osenvirongetr   strict_moderM   "extensions.revocation._ocsp._asyncr   rk   r   r   r   r   rR   r   r   rL   !extensions.revocation._crl._asyncr   r   r!   )r   strict_ocsp_enabledr   ocsp_verifyr   r   
crl_verifyre   r   ptr_requestr   r   s          r   on_post_connectionz-AsyncSession.send.<locals>.on_post_connection  s)      %.K! <;?#=#=j#I#I <fU]N^ <,.JNN;QSV,W,W[^,^#* Ut/M/Y*.*H*T'$Y0NOO             +3/G/G/I/ID,+/=+?+?+A+A K K#*7M#B#B !K:>:JG$7)k'/':CCC"9-%)]+/+?"&"2           '   ( $It/MNN             ?2.D.D.F.FDO+/=+?+?+A+A I I#*7L#A#A !I9=G$6(j'/':CCC"9-%)]+/+?"&/           '   * g%%)*e[IIIIIIIIIII &%s$   D 
DD8G 
GG
total_sentrr   content_length
int | Noneis_completedrq   	any_errorc                   K   k    rd S j         t                      _         | j         _        |j         _        |j         _        |j         _        t          d           d {V  d S )N	on_upload)upload_progressr(   r   r  r  r  r!   )r  r  r  r  re   r   r  r   s       r   handle_upload_progressz1AsyncSession.send.<locals>.handle_upload_progressd  s       g%%&.*:*<*<',6G#)5CG#23?G#009G#-%k5'BBBBBBBBBBBr   early_responser'   c                :   K   t          d|            d {V  d S )Nr  )r!   )r  re   s    r   on_early_responsez,AsyncSession.send.<locals>.on_early_responsew  s2      %&6~NNNNNNNNNNNr   r  on_upload_bodyrV   r  zA externally instantiated resolver was closed. Attempt to recycling it internally, the Session will detach itself from given resolver.r   rT   r   rW   rX   rY   rR   rS   r[   rZ   r\   r]   r^   r_   r`   rf   rm   r   r   r   )r   lazyc                *  K    j         | |fddi}	 |                                 d {V 	 |                                 d {V  S # t          $ r Y |                                 d {V  d S w xY w# |                                 d {V  w xY w)Nyield_requestsT)resolve_redirects	__anext__acloseStopAsyncIteration)xy	aiter_genr   r   s      r   _redirect_method_refz/AsyncSession.send.<locals>._redirect_method_ref  s      2D21aWWWPVWW	-!*!4!4!6!66666666 $**,,,,,,,,,, *      #**,,,,,,,,,,,  $**,,,,,,,,,,s#   A 
A3A6 2A33A6 6Br   )niquests_is_streamniquests_startniquests_hooksniquests_cookiesniquests_allow_redirectniquests_kwargsniquests_redirect_countniquests_max_redirects)secondsresponseyield_requests_trailr  )r   r)   r   r   )
r  rr   r  r  r  rq   r  rq   r   r   )r  r'   r   r   r   )M
isinstancer&   
ValueError
setdefaultr   rk   rl   rJ   rj   r   r
   r   r   r   r   popr   re   r!   rV   r   rR   is_availabler   warningswarnResourceWarningr   recycler   r   rT   rU   r   r   r   rS   r   r   r   r   r   r   r   r   rm   r   r   preferred_clockr   rC   r   r  _resolve_redirect_promiseupdate_parametersri   r   rD   r   elapsedhistoryr   r   rawr  r'   appendinsertr$   is_redirectr  _nextr  r  r   content)r   r   r   r   r   r  r  r  r   startrr  r3  respgenr4  resp_or_reqhrre   r  s   ```               @@r   r   zAsyncSession.send  s	      gw'' 	DBCCC 	(DK000(DK000&$),,,F"" /t~ V VF9 y!  "   y)733   !D	1B,C,C(D(DDD 3F94E F FF9 !**%6==H%% ,
 
 
 
 
 
 
 
 E	J E	J E	J E	J E	J E	J E	J E	J E	J E	JN	C 	C 	C 	C 	C 	C 	C 	C 	C&	O 	O 	O 	O 	O 	O 	.0BCCC*,BCCC-)9:::-/@AAA{&&& }))++ E	% J#  
 **,, M1133DMJJ    %)%:%: $ #'"5"5 #'"5"5	
 #'"5"5 "]] $(#6#6 "&!3!3 "&!3!3 &*%;%; "&!3!3 $(#7#7 %)$9$9 +/*E*E .2-K-K  ,0+F+F!  * JJ  $"&"5"&"5"&"5!]#'#6!%!3!%!3%)%;!%!3#'#7$($9*.*E-1-K+/+F    ( JJ  $"&"5"&"5"&"5!]#'#6!%!3!%!3%)%;!%!3#'#7$($9*.*E-1-K+/+F    , ""w{"33  !! ',w11&11111111 )):;; 1f #	!&D..- - - - - - #7A ,0F'( J((*0&+&+(,/>'- 01.2.@     !a   H "##e+g...	 &j%EEfEEEEEEEE & 	Ay QI Q QD*4<txPPPP"4<!%@@@  	($(GYY$YRXYYCG%( * * * * * * *kk844 NN;///)	 &)S G  	 NN1a   A & &b-00 &!"%%%AI  		'} ',d,QWWWPVWW'$'MMOO333333AGG)   D **,,&&&&&&&&#**,,&&&&&&&& 	!]++ ;&)OOOOOOOa    ;&IIs0   ?U4/X X: 
XX: XX: :Yr=  reqint | float | NonerB   r  r%  adapter_kwargs<typing.AsyncGenerator[AsyncResponse | PreparedRequest, None]c
           
    
  K   g }|                      |          }t          |j                  j        }|r|                                }|                    |           |dd         |_        |j        J 	 t          |t                    r|j
         d{V  n|j
         n># t          t          t          f$ r$ |j                            d           d{V  Y nw xY wt          |j                  | j        k    rt#          d| j         d|          t          |t                    r|                                 d{V  n|                                 |                    d          r]|j        J t)          |j                  }t          |t*                    r|                                }d	                    ||g          }t          |          }|j        d
k    rC|rA|                    t          |t2                    r|n|                    d                    }n|j        r|j        }|                                }|j        sSt9          |j        t;          |                    }t          |t2                    sJ dt=          |           d            nt;          |          }t          |t*                    r|                    d          }||_        |j        J |                      ||           |j!        tD          j#        tD          j$        fvr)d}|D ]}|j        %                    |d           d|_&        |j        }|%                    dd           |j'        J | j(        rtS          |j'        ||j                   tU          |j'        | j+                   |,                    |j'                   | -                    ||          }| .                    ||           |j/        duod|v pd|v }|rZ|j&        Dta          |j&        d          r/tc          |j&        j2                  rtg          |           d{V  nti          |           |}|r|W V  n|	r|W V   | j5        |f|||||dd|
 d{V }ta          |d          r"|j6        r| 7                    |           d{V  | j(        rtS          | j+        ||j                   |                      |          }|W V  |dS dS )zBReceives a Response. Returns a generator of Responses or Requests.r   NF)decode_contentz	Exceeded z redirects.)r$  z//:r   zutf-8)fragmentzurljoin produced z instead of str)Content-LengthzContent-TypeTransfer-EncodingCookierI  rJ  tell)r   rb   rk   rl   rj   r   r  )8get_redirect_targetr   r   rH  copyr6  r4  r5  r&  r$   r:  r   r   r   readlenr   r   r   r   rH   bytesdecodejoin_replacer   geturlnetlocrN   rI   r   rc   rebuild_methodstatus_coder   temporary_redirectpermanent_redirectr)  body_cookiesrm   r   r   ri   prepare_cookiesrebuild_proxiesrebuild_auth_body_positionr   r   rL  rE   rK   r   r  gather)r   r=  rA  r   rb   rk   rl   rj   r  r%  rC  histr   previous_fragmentprepared_requesttarget_schemeparsedpurged_headersheaderrc   
rewindables                        r   r  zAsyncSession.resolve_redirects<  s      &&t,,$SW--6 M	"xxzz KK8DL8''':dM22 !,&&&&&&&&LL(*>M : : :hmm5m99999999999: 4<  D$666&'R43E'R'R'R]abbbb $.. jjll""""""""

 ~~d## 5x+++ ,TX 6 6mU33 ;$1$8$8$:$:Mhhs344 c]]F"$$):$2<=NPS2T2T{..ZkZrZrszZ{Z{ )    4$*O!--//C
 = '"48[-=-=>>!#s++[[-[c-[-[-[[[+[!#&& #u%% *jj))#& #+777 0$777 (((  
 "Y, ? ?F$,00>>>>(, %&.GKK$'''#,888 * Q&'7'@#txPPP*3T\BBB,,-=-FGGG **+;WEEG.555
 *8D  G+M/Bg/M 
  	2 %)5 0 5v>> 6+,<,A,FGG 6 ''78888888888 0111 #C 					' IIII&TY	!#!#$)	 	 %	 	 	 	 	 	 	 	 4(( ,TY ,++d+++++++++. U*4<9I48TTT ..t44



[  M	 M	 M	 M	 M	s   8*B# #8CC.methodr:   dataBodyType | AsyncBodyType | Nonefiles1MultiPartFilesType | MultiPartFilesAltType | Noner   0AsyncHookType[PreparedRequest | Response] | NoneLiteral[False] | Nonejsontyping.Any | Noneoverride_schemec                
   K   d S r   r   r   rj  r   rh   rk  rc   ri   rm  rd   rb   r   rj   re   r   rk   rl   rq  rs  s                     r   r   zAsyncSession.request  s      ( 3r   c                
   K   d S r   r   ru  s                     r   r   zAsyncSession.request  s      ( r   bool | Nonec                  K   |                                 du r|                                }t          |||||pi ||pi |||| j        |          }|                     |          }|j        rV|                    |           d {V }|j                            |j                   |	                    |j
                   |`t          |j        t                    rk|j
        dt          |j
        d          rOt          |j
        j                  r6	 |j
                                         d {V |_        n# t"          $ r Y nw xY w|j        J |pi }|                     |j        ||||          }|	p| j        |
d}|                    |           |d         |dv rt*          nt,          |d<    | j        |fi | d {V S )NF)rj  r   rc   rm  rk  rq  rh   rd   ri   re   ra   rs  rL  )rb   r   rb   >   PUTPOSTPATCHDELETE)isupperupperr&   ra   prepare_request_asynchronous_auth_pending_async_auth__dict__updateprepare_content_lengthr[  r&  r`  objectr   r   rL  OSErrorr   merge_environment_settingsrb   r   r   r   )r   rj  r   rh   rk  rc   ri   rm  rd   rb   r   rj   re   r   rk   rl   rq  rs  rA  prepr<  settingssend_kwargss                          r   r   zAsyncSession.request
  s>     ( >>u$$\\^^F <R]+
 
 
 !% 4 4S 9 9" 	)..t44444444AM  ,,,''	222( t*F33			%	6** &#DIN33 &,0INN,<,<&<&<&<&<&<&<##    x###-R2248WffVZ[[ .$,.
 
 	8$$$ y!))/3U)U)U%%[o 	" TYt33{333333333s   $D8 8
EErh   rc   ri   rd   rb   r   rj   re   rk   r   rl   c               
   K   d S r   r   r   r   rh   rc   ri   rd   rb   r   rj   re   rk   r   rl   r   s                 r   r   zAsyncSession.getY        " 3r   c               
   K   d S r   r   r  s                 r   r   zAsyncSession.getl        " r   c               H   K    | j         d|f||||||||	|
||d| d {V S )NGETr  r   r  s                 r   r   zAsyncSession.get  sy      " "T\
 +
 
 
 
 
 
 
 
 
 
 	
r   Literal[False] | Literal[None]c               
   K   d S r   r   r  s                 r   optionszAsyncSession.options  r  r   )
rh   rc   ri   rd   rb   r   rj   re   rk   rl   c               
   K   d S r   r   r  s                 r   r  zAsyncSession.options  r  r   c               H   K    | j         d|f||||||||	|
||d| d {V S )NOPTIONSr  r  r  s                 r   r  zAsyncSession.options  sy      " "T\
 +
 
 
 
 
 
 
 
 
 
 	
r   c               
   K   d S r   r   r  s                 r   headzAsyncSession.head  r  r   c               
   K   d S r   r   r  s                 r   r  zAsyncSession.head  r  r   c               H   K    | j         d|f||||||||	|
||d| d {V S )NHEADr  r  r  s                 r   r  zAsyncSession.head  sy      " "T\
 +
 
 
 
 
 
 
 
 
 
 	
r   )rh   rc   ri   rm  rd   rb   r   rj   re   rk   r   rl   c               
   K   d S r   r   r   r   rk  rq  rh   rc   ri   rm  rd   rb   r   rj   re   rk   r   rl   s                   r   postzAsyncSession.post1        & 3r   )rh   rc   ri   rm  rd   rb   r   rj   re   rk   rl   c               
   K   d S r   r   r  s                   r   r  zAsyncSession.postF        & r   c               \   K   |                      d|||||||||	|
|||||           d {V S )Nrz  rk  rq  rh   rc   ri   rm  rd   rb   r   rj   re   rk   r   rl   r  r  s                   r   r  zAsyncSession.post[  sq      & \\+! " 
 
 
 
 
 
 
 
 	
r   )rq  rh   rc   ri   rm  rd   rb   r   rj   re   rk   r   rl   c               
   K   d S r   r   r  s                   r   putzAsyncSession.put  r  r   )rq  rh   rc   ri   rm  rd   rb   r   rj   re   rk   rl   c               
   K   d S r   r   r  s                   r   r  zAsyncSession.put  r  r   c               \   K   |                      d|||||||||	|
|||||           d {V S )Nry  r  r  r  s                   r   r  zAsyncSession.put  sq      & \\+! " 
 
 
 
 
 
 
 
 	
r   c               
   K   d S r   r   r  s                   r   patchzAsyncSession.patch  r  r   c               
   K   d S r   r   r  s                   r   r  zAsyncSession.patch  r  r   c               \   K   |                      d|||||||||	|
|||||           d {V S )Nr{  r  r  r  s                   r   r  zAsyncSession.patch  sq      & \\+! " 
 
 
 
 
 
 
 
 	
r   c               
   K   d S r   r   r  s                 r   deletezAsyncSession.delete!  r  r   c               
   K   d S r   r   r  s                 r   r  zAsyncSession.delete4  r  r   c               H   K    | j         d|f||||||||	|
||d| d {V S )Nr|  r  r  r  s                 r   r  zAsyncSession.deleteG  sy      " "T\
 +
 
 
 
 
 
 
 
 
 
 	
r   )	max_fetch	responsesr  r  c               ~   K   | j         du rd S | j                                        D ]} |j        |d|i d {V  d S )NFr  )rV   r   r   ra  )r   r  r  r   s       r   ra  zAsyncSession.gatheri  sp      u$$F}++-- 	B 	BG '.)AyAAAAAAAAAA	B 	Br   c                   K   | j                                         D ]}|                                 d {V  | j        r!| j                                         d {V  d S d S r   )r   r   r   r   rR   )r   vs     r   r   zAsyncSession.closep  s      %%'' 	 	A''))OOOOOOOO 	(-%%'''''''''''	( 	(r   )8rR   rn   rS   ro   rT   rp   rU   r?   rV   rq   rW   rq   rX   rq   rY   rq   rZ   rq   r[   rq   r\   rr   r]   rr   r^   rs   r_   rt   r`   rt   ra   ru   rb   rv   rc   rw   rd   rx   re   ry   rf   rz   rg   r{   rh   r|   ri   r}   rj   r~   rk   r   rl   r   rm   rq   )r   r   )r   r   )r   rQ   )r   r   )r   r   r   r   r   r   )r   r   r   r   )r   r%   r   r   r   r   r   r$   )r   r%   r   r   r   r'   )r   r%   r   r   r   r   )FNTNNFF)r=  r$   rA  r%   r   rq   rb   rB  rk   rB   rl   r   rj   r~   r  rq   r%  rq   rC  r   r   rD  )...............)$rj  r:   r   r   rh   r|   rk  rl  rc   rw   ri   r}   rm  rn  rd   rx   rb   rv   r   rq   rj   r~   re   ro  r   rp  rk   r   rl   r   rq  rr  rs  ru   r   r'   )$rj  r:   r   r   rh   r|   rk  rl  rc   rw   ri   r}   rm  rn  rd   rx   rb   rv   r   rq   rj   r~   re   ro  r   r   rk   r   rl   r   rq  rr  rs  ru   r   r$   )NNNNNNNTNNNNNNN)$rj  r:   r   r   rh   r|   rk  rl  rc   rw   ri   r}   rm  rn  rd   rx   rb   rv   r   rq   rj   r~   re   ro  r   rw  rk   r   rl   r   rq  rr  rs  ru   r   r   )r   r   rh   r|   rc   rw   ri   r}   rd   rx   rb   rv   r   rq   rj   r~   re   ro  rk   r   r   rp  rl   r   r   r   r   r'   )r   r   rh   r|   rc   rw   ri   r}   rd   rx   rb   rv   r   rq   rj   r~   re   ro  rk   r   r   r   rl   r   r   r   r   r$   )r   r   rh   r|   rc   rw   ri   r}   rd   rx   rb   rv   r   rq   rj   r~   re   ro  rk   r   r   rw  rl   r   r   r   r   r   )r   r   rh   r|   rc   rw   ri   r}   rd   rx   rb   rv   r   rq   rj   r~   re   ro  rk   r   r   r  rl   r   r   r   r   r'   )..) r   r   rk  rl  rq  rr  rh   r|   rc   rw   ri   r}   rm  rn  rd   rx   rb   rv   r   rq   rj   r~   re   ro  rk   r   r   r  rl   r   r   r'   ) r   r   rk  rl  rq  rr  rh   r|   rc   rw   ri   r}   rm  rn  rd   rx   rb   rv   r   rq   rj   r~   re   ro  rk   r   r   r   rl   r   r   r$   )NN) r   r   rk  rl  rq  rr  rh   r|   rc   rw   ri   r}   rm  rn  rd   rx   rb   rv   r   rq   rj   r~   re   ro  rk   r   r   rw  rl   r   r   r   ).r   )r  r'   r  r  r   r   )__name__
__module____qualname____doc__r   r   r   r   r   r   r   r   r   r   r   typingoverloadr   r  r   r   r  r  r  r  r  r  ra  r   __classcell__)r   s   @r   rQ   rQ   k   s	        * .2158<,!###"" 0,%*.348#&*&*LPRVCS",0&*$('+)-'+=p1 p1 p1 p1 p1 p1dX X X Xm m m m      I5 I5 I5V' ' ' ' ' '_ _ _ _@ _xxx _x_YYY _YJ J J J`
 &* $)-$($%*` ` ` ` `D _
 -003&)&)CFLO&) #$'BE(+'*),"%&)%    _* _
 -003&)&)CFLO&) #$'BE #'*),"%&)%    _2 -104&*&*CGLP&* $$(BF"'+)-"&&*%M4 M4 M4 M4 M4^ _
 -0&)&)LO&) #$'BE'*(+),     _$ _
 -0&)&)LO&) #$'BE'* #),     _, -1&*&*LP&* $$(BF'+")- 
  
  
  
  
  
D _
 -0&)&)LO&) #$'BE'*14),     _$ _
 -0&)&)LO&) #$'BE'*),     _, -1&*&*LP&* $$(BF'+")- 
  
  
  
  
  
D _
 -0&)&)LO&) #$'BE'*14),     _$ _
 -0&)&)LO&) #$'BE'*),     _, -1&*&*LP&* %$(BF'+")- 
  
  
  
  
  
D _ 14"%	 -0&)&)CFLO&) #$'BE'*14),#     _( _ 14"%	 -0&)&)CFLO&) #$'BE'*),#     _. 15"&	$
 -1&*&*CGLP&* $$(BF'+")-#$
 $
 $
 $
 $
 $
L _ 14
 #&,/&)&)CFLO&) #$'BE'*14),#     _( _ 14
 #&,/&)&)CFLO&) #$'BE'*),#     _. 15$

 #',0&*&*CGLP&* $$(BF'+")-#$
 $
 $
 $
 $
 $
L _ 14
 #&,/&)&)CFLO&) #$'BE'*14),#     _( _ 14
 #&,/&)&)CFLO&) #$'BE'*),#     _. 15$

 #',0&*&*CGLP&* $$(BF'+")-#$
 $
 $
 $
 $
 $
L _
 -0&)&)LO&) #$'BE'*14),     _$ _
 -0&)&)LO&) #$'BE'*),     _, -1&*&*LP&* $$(BF'+")- 
  
  
  
  
  
D JN B B B B B B( ( ( ( ( ( ( (r   rQ   )n
__future__r   r   systimer  r+  collectionsr   datetimer   urllib.parser   status_codesr   TYPE_CHECKINGtyping_extensionsr	   _compatr
   r   r   	_constantr   r   r   r   r   r   r   ri   r   r   r   r   
exceptionsr   r   r   r   extensions.revocationr   r   extensions.sgi._asyncr   extensions.unixsocket._asyncr   extensions.pyodide._asyncr   r   platformr,  UserWarningre   r!   r"   modelsr#   r$   r%   r&   r'   r(   packages.urllib3r)   (packages.urllib3.contrib.resolver._asyncr*   -packages.urllib3.contrib.webextensions._asyncr+   sessionsr,   r-   
structuresr.   r/   r0   r1   r2   r3   r4   r5   r6   r7   r8   r9   r:   r;   r<   r=   r>   r?   r@   rA   rB   utilsrC   rD   rE   rF   rG   rH   rI   rJ   rK   rL   rM   rN   perf_counterr/  rQ   r   r   r   <module>r     s   " " " " " " 				 



    # # # # # #       ! ! ! ! ! !      	 *)))))) Q Q Q Q Q Q Q Q Q Q            9 8 8 8 8 8 8 8                       M L L L L L L L > > > > > > : : : : : :
>>>>>>> 
 
 

||##c	
 	
 	

 6 5 5 5 5 5 5 5                - , , , , , G G G G G G I I I I I I * * * * * * * * A A A A A A A A                                         *                             <7'OOiOI( I( I( I( I(7 I( I( I( I( I(s   B #B87B8