vKg SSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSK J r J r J r SSK Jr SSKJr SSKJr SSKJrJrJrJrJrJrJrJrJrJrJr SS KJ r J!r!J"r"J#r#J$r$J%r%J&r& SS K'J(r( S S K)J*r*J+r+J,r,J-r-J.r.J/r/J0r0 S S K1J2r2J3r3 SSK4J5r5J6r6J7r7 SSK8J9r9J:r:J;r;Jr>J?r? SSK@JArA SSK@JBrBJCrCJDrDJErEJFrFJGrGJHrHJIrI SSKJJKrKJLrL SSKMJNrNJOrOJPrPJQrQJRrR \ "\S5 SSKTrTSSS5 \ "\S5 SSKUrVSSS5 \(a"SS\SS9rW"SS\SS9rXO \\Y\Y4rW\rX\SrZ\Sr[S\YS\\4S jr]\^"S!5r_S4S\YS"\Y4S#jjr`S\YS$\\\\4S\Y4S%jraS5S&\\YS'\YS(\YS)\\4S*jjrbS6S+\R4S,jjrdS6S+\R4S-jjre\f"5rg"S.S/5rh"S0S1\h5ri"S2S3\h5rjg!,(df  N=f!,(df  N=f)7N)Counter)ThreadPoolExecutor)asynccontextmanagercontextmanagersuppress) partialmethod)BytesIO)dumps) TYPE_CHECKINGAnyCallableDictListLiteralOptionalTuple TypedDictUnioncast) ParseResult parse_qslquoteunquote urlencodeurljoinurlparse)Unpack) AsyncCurlCurl CurlErrorCurlHttpVersionCurlInfoCurlOptCurlSslVersion)CURL_WRITEFUNC_ERRORCurlMime)Cookies CookieTypes CurlMorsel)ImpersonateErrorRequestException SessionClosed code2error)Headers HeaderTypes) BrowserType)TLS_CIPHER_NAME_MAPTLS_EC_CURVES_MAPTLS_VERSION_MAPBrowserTypeLiteralExtraFingerprints ExtraFpDictnormalize_browser_typetoggle_extension)RequestResponse) ON_CLOSE_T ON_ERROR_T ON_MESSAGE_T ON_OPEN_T WebSocketcH\rSrSr%\\S'\\S'\\S'\\S'\\S'Srg) ProxySpec8allhttphttpswswssN)__name__ __module__ __qualname____firstlineno__str__annotations____static_attributes__rJZ/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/curl_cffi/requests/session.pyrCrC8s    rRrCF)totalc\rSrSr%\\\S'\\\S'\\\ \ 4\S'\\ \S'\\ \S'\\\ \ 4\S'\\ \S'\\ \S '\ \S '\ \\\\44\S '\ \S '\ \S '\\S'\\\S'\\ \S'\\ \S'\\ \\4\S'\ \S'\ \ \\/\ 44\S'\\ \S'\\\S'\\\S'\ \S'\\ \S'\\ \ \\ \ 44\S'Srg)BaseSessionParams?headerscookiesauthproxiesproxy proxy_authbase_urlparamsverifytimeout trust_envallow_redirects max_redirects impersonateja3akamaiextra_fpdefault_headersdefault_encoding curl_options curl_infos http_versiondebug interfacecertrJN)rKrLrMrNrr1rPr*rrOrCdictboolrfloatintr6r7r8r byteslistr"rQrJrRrSrVrV?s8+&&+&&uS#X'')$$}U38_--3- ueE5L1122011 c] 5!2K!?@AAXugsl%; ;<<tn$TN"// C= uS%S/1233rRrV)eventletgevent)GETPOSTPUTDELETEOPTIONSHEADTRACEPATCHurlreturnch[U5n[UR=(a UR5$)z,Check if the provided url is an absolute url)rrrschemehostname)r parsed_urls rS_is_absolute_urlrbs'#J  !!9j&9&9 ::rRz!#$%&'()*+,/:;=?@[]~ quote_strc JSR[[U5- 5n[U5n[ UR 5n[ USUS9n[URUR[URUS9URUUR5R5$)NT)doseqsafe)r)join SAFE_CHARSsetrrqueryrrrnetlocrpathr_fragmentgeturl)rrrrparsed_get_argsencoded_get_argss rS_quote_path_and_paramsrks 77:I. /D#J 0 01O 4H  jooD)   fhrRr_c[U5n[U5n[UR5n[ SU55n[ U[ 5(a[UR55n[ SU55nUHupg[ U[[ 45(a [U5nURU5S:Xa3URU5S:XaUVs/sHoSU:waUOXg4PM nnMsURXg45 M [USS9n [URUR UR"UR$U UR&5R)5n U $s snf)aAdd URL query params to provided URL being aware of existing. Parameters: url: string of target URL params: dict containing requested params to be added Returns: string with updated URL >> url = 'http://stackoverflow.com/test?answers=true' >> new_params = {'answers': False, 'data': ['some','values']} >> _update_url_params(url, new_params) 'http://stackoverflow.com/test?data=some&data=values&answers=false' c3(# UH oSv M g7frNrJ.0xs rS %_update_url_params..s=_t_c3(# UH oSv M g7frrJrs rSrrs4VtVrr(rT)r)rrrrr isinstancerqrvitemsrrr getappendrrrrrr_rr) rr_rrold_args_counternew_args_counterkeyvaluerrnew_urls rS_update_url_paramsrzsN #,C#J 0 01O=_==&$flln%4V44  edD\ * *%LE    $ ).>.B.B3.G1.LM\]_qTS[sl B_O]O  " "C< 0!=  fh  N%^sE% header_linesrrreplacecSn[U5HNupVUR5RUR5S-5(dM<SnU(a USU3X' O U(dURUSU35 gg)z*Update header line list by key value pair.F:T: N) enumeratelower startswithr)rrrrfoundidxlines rS_update_header_liners{ E|,  ::< " "399;#4 5 5E'*e2eW$5 !  - se2eW-. rRqcFURS$![a Us$f=fNr)queue IndexErrorrdefaults rS _peek_queuers)wwqz    cFURS$![a Us$f=fr)_queuerrs rS_peek_aio_queuers)xx{ rcC\rSrSrSrSSSSSSSSSSSSSSSSSSSSSSSSSS.S \\S \\S \\\ \ 4S \\ S \\ S\\\ \ 4S\\ S\\ S\ S\ \\\\44S\ S\ S\S\\S\\ S\\ S\\ \\4S\ S\ \ \\/\ 44S\\ S\\S\\S\ S \\ S!\\ \ \\ \ 4442S"jjrS#rS>S\ S$\ 4S%jjrS\ 4S&jrS'\4S(jrSSSSSSS\SSSSSSSS)SSSSSSS*SSSSS+SSS4S,\S-\ S\\ \\\4S.\\ \\ \ 4\\\ \ \4S/\\ S \\S \\S0\\S \\\ \ 4S\\ \\\\4\!4S\\ S\\S \\ S \\ S\\\ \ 4S\\ \ \ 4S1\\ S2\\ S3\\S\\S\\ S\\ S\\ \\4S\\ S4\ \ \"S4S\\S \\ S!\\ \ \\ \ 44S5\ S6\S7\\#S8\$S9\$4BS:jjr%S;r&S<r'S=r(g)? BaseSessionzMProvide common methods for setting curl options and reading info in sessions.NTutf-8F)rXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorprXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorpcZ[U5Ul[U5UlX0lXplXlXlXlXl Xl Xl Xl Xl UUlUUlUUlUUlU=(d 0UlU=(d /UlUUlUUlUUlUUlU(aU(a [1S5eU(aSU0nU=(d 0UlX`lUR (a%[7UR 5(d [9S5eSUlg)N)Cannot specify both 'proxy' and 'proxies'rEz2You need to provide an absolute url for 'base_url'F)r0rXr)rYrZr^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorp TypeErrorr[r]r ValueError_closed)selfrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorps rS__init__BaseSession.__init__s:w' w'      ".*&   . 0(.B$*( " WGH H enG")-R $ ==!1$--!@!@QR R rRch1SknX#- nUH n[XSS9 M X2- nUH n[XSS9 M g)N> r #+-3T)enableF)r:)rcurl extension_idsdefault_enabled to_enable_idsext_idto_disable_idss rS_toggle_extensions_by_ids%BaseSession._toggle_extensions_by_idssAH%7 #F T$ 7$ )8$F T% 8%rRpermutecURS5upEpgn[[U5n UR[R U [ R-5 U [ R:XdS5e/n URS5H(n [U 5n [U n U RU 5 M* UR[RSRU 55 URS5(aUSSn[R"SS S 9 [!S URS555nUR#X5 U(d UR[R$U5 /nURS5H(n[U5n[&UnURU5 M* UR[R(SRU55 [U5S :XdS 5eg)zm Detailed explanation: https://engineering.salesforce.com/tls-fingerprinting-with-ja3-and-ja3s-247362855967/ ,zOnly TLS v1.2 works for now.-rz-21NzPadding(21) extension found in ja3 string, whether to add it should be managed by the SSL engine. The TLS client hello packet may contain or not contain this extension, any of which should be correct.r( stacklevelc36# UHn[U5v M g7fN)rt)res rSr/BaseSession._set_ja3_options..=sB,AqCFF,Asrz%Only curve_formats == 0 is supported.)splitr5rtsetoptr$ SSLVERSIONr% MAX_DEFAULTTLSv1_2r3rSSL_CIPHER_LISTrendswithwarningswarnrrTLS_EXTENSION_ORDERr4 SSL_EC_CURVES)rrrfr tls_versionciphers extensionscurves curve_formatscurl_tls_version cipher_namescipher cipher_id cipher_namer curve_namescurvecurve_id curve_names rS_set_ja3_optionsBaseSession._set_ja3_options#sCF))C.? j-*3{+;< G&&(8>;U;U(UV>#9#99Y;YY9 mmC(FF I-i8K    ,) G++SXXl-CD   u % %#CRJ MMQ   BJ,<,*>? G**H5 G//]1CD c> KK--w 7 G66 8L8LSRT8UVrRfpcUR(a9UR[RSR UR55 UR[R UR [R-5 UR[R[UR55 UR[R[UR55 UR[RUR5 UR[R UR"5 UR[R$UR&5 g)Nr)tls_signature_algorithmsrr$SSL_SIG_HASH_ALGSrrtls_min_versionr%r TLS_GREASErt tls_greaseSSL_PERMUTE_EXTENSIONStls_permute_extensionsSSL_CERT_COMPRESSIONtls_cert_compression STREAM_WEIGHThttp2_stream_weightSTREAM_EXCLUSIVEhttp2_stream_exclusive)rrrs rS _set_extra_fpBaseSession._set_extra_fpbs & & KK11388BU!"5m;U""5m:U""5mTR5(dTR5 TR5(a[$TRU5 [ U5$r)is_setrr& put_nowaitlen)chunk header_recvedrquit_nows rSqput+BaseSession._set_curl_options..qputsG$++--!%%'??$$// U#5z!rRrJ)oupperrr$rz CUSTOMREQUESTencodeNOBODYr_rr^rrURLrrqrvtuplerrOr readrurr POSTFIELDS POSTFIELDSIZErBr0rXupdaterrrrpop multi_itemsrr HTTPHEADERr; COOKIEFILE COOKIELISTrYget_cookies_for_curlto_curl_formatr)NotImplementedErrorrraddpartMIMEPOST_formrZUSERNAMEPASSWORDnot_setraCONNECTTIMEOUT_MSrt TIMEOUT_MSLOW_SPEED_LIMITLOW_SPEED_TIMEmathceilrsFOLLOWLOCATIONrc MAXREDIRSrdr[rrPROXYrrrRuntimeWarningHTTPPROXYTUNNELr] PROXYUSERNAME PROXYPASSWORDr`SSL_VERIFYPEERSSL_VERIFYHOSTCAINFOREFERERACCEPT_ENCODINGrpSSLCERTSSLKEYrerir9r,rfr7r#r rgrrhr*rmrrk WRITEFUNCTION WRITEDATA HEADERDATAro INTERFACEMAX_RECV_SPEED_LARGE)=rrr,rr_r-r.rXrYr/rZrarcrdr[r\r]r`r0r1r2rerfrgrhrirrmrorpr3r4r5r6r7cbodyh host_headerurkvreqmorsel temp_cookiesusernamepasswordconnect_timeout read_timeout all_timeoutpartsrretrbufferrF header_bufferrDrrEs= @@@rS_set_curl_optionsBaseSession._set_curl_optionsmsp J  V  HHW\\1 % u_ HHW**FMMO < V  HHW^^Q ' ;;$S++6C $S1C ==$---C  (>C cjjl+ dT4/ 0 0T?))+D c " ";;=D g & &99;D e $ $D \DQR R  *5<<>D 655 HHW'' . HHW**CI 6..7 DLL !  eeFm  " Aahh&+*Cfd# MMODAq   q1#Rs 1g >$    n>PZ^ _ dD ! !f&6  n>a b dS%L ) )  n>X Y L(BE ##,%G,Qahhj,%GHc1f% ##S) ##U+ll77FM1mXEE[&Hs7~ c8Un[U5n[[UR[R 55R 5UlU(aUR5Ul [[UR[R55Ul [[UR[R55UlSURs=:*=(a S:Os UlUR5R!5n/nUHn U R#5(dMU R%S5(a(UR'U 5R 5Ul/nMXU R%S5(dU R%S5(aUS==U - ss'MUR+U 5 M [-U5UlUR[R05Vs/sHn[2R4"U5PM n nUR6R9U 5 UR6Ul[[WR[R:55R 5Ul[[UR[R>55R 5Ul XFl![[DUR[RF55Ul$[[UR[RJ55Ul&[[UR[RN55R 5Ul(URRH!n URU 5URTU 'M# U$s snf)NisHTTP/  )+r<rrugetinfor# EFFECTIVE_URLdecodergetvaluecontentrtrrm RESPONSE_CODE status_codeok splitlinesstriprget_reason_phrasereasonrr0rXrVr+from_curl_formatrYupdate_cookies_from_curl PRIMARY_IP primary_ipLOCAL_IPlocal_iprjrs TOTAL_TIMEelapsedREDIRECT_COUNTredirect_count REDIRECT_URL redirect_urlrlinfos) rrrrrjryrspr header_list header_linemorselsinfos rS_parse_responseBaseSession._parse_responses qkuaii(>(>?@GGI  //+CKQYYx/D/D%EFsAIIh.D.D$EF--#-$--/::<  'K$$&&%%h//00=DDF  %%d++{/E/Ee/L/LB;.   { +(k* ;<99XEXEX;YZ;Ya:..q1;YZ --g6ll eQYYx/B/B%CDKKME199X->->#?@GGI /5!))H,?,?"@A !#qyy1H1H'IJqyy1F1F'GHOOQOODiioCIIdO$ ![s-Nc<UR(a [S5eg)Nz'Session is closed, cannot send request.)rr.rs rS_check_session_closed!BaseSession._check_session_closeds << IJ J rR)rrgrcrZr^rprYrlrkrnrjrirhrXrmrerorfrdr_r[r]rarbr`F))rKrLrMrN__doc__rr1r*rrOrCrqrrrrsrtr6r7r8r rurvr"rrr rr*r_ HttpMethodrrr objectrr'r rrrrQrJrRrSrrs/W *.)-*.'+#04"&!%57 $48! $DH $?F'+%)26#'6:7>+&>+& > uS#X' > )$ >}>U38_->3->>>ueE5L112>>>> 01!>"c]#>$ %>&5!2K!?@A'>()>* Xugsl%; ;<+>,tn->.TN/>0/1>23>4C=5>6uS%S/1237>@ 9 (P#(P(PTWW* I&7 I 6:RV#)-)- $*.GN*.'+'+#04-1!%)B/348! $DH*.,.26#'6:(,GbFbF bF tT5012 bF uT#s(^T%[#wMNO bFtnbF+&bF+&bF~bFuS#X'bF%uUE\':F BCDbF"$bF }bF)$bF }!bF"U38_-#bF$tSy)*%bF&#'bF("#)bF*#8,+bF,01-bF.c]/bF0 1bF25!2K!?@A3bF4"$5bF6S'%.()7bF8/9bF:C=;bF<uS%S/123=bF>?bF@AbFBH%CbFDEbFFGbFH ,\KrRrcCh^\rSrSrSrSDS\\S\\S\S\ \ 4U4Sjjjr \ S 5r \ S 5rS rS rSESjr\S5rSSSSS.S\\S\\S\\S\\S \4 SjjrSSSSSSS\SSSSSSSSSSSSSSSSSSSSSS4S\S\S\\\\\ 4S\\\\\4\\ \\!\"4S\\#S \\$S!\\%S"\\S#\\ \\4S$\\\&\ \&\&4\'4S%\\S&\\(S'\\)S(\\S)\\ \\4S*\\S+\\S,\\S-\\*S.\\+S/\\S0\\S1\\\,\-4S2\\S3\\\*\"/\44S4\\\.S4S5\\/S6\\S7\\\\ \\44S8\S9\(S:\\0S \14BS;jjr2\3"\2S<5r4\3"\2S=5r5\3"\2S>5r6\3"\2S?5r7\3"\2S@5r8\3"\2SA5r9\3"\2SB5r:SCr;U=r<$)FSessionizA request session, cookies and connections will be reused. This object is thread-safe, but it's recommended to use a seperate session for each thread.Nrthreaduse_thread_local_curlkwargsc p>[TU]"S0UD6 X lX0lSUlSUlU(ac[ R"5UlU(aSUl XRl gSUl [URS9URl gU(aUO[URS9Ul g)a Parameters set in the init method will be override by the same parameter in request method. Args: curl: curl object to use in the session. If not provided, a new one will be created. Also, a fresh curl object will always be created when accessed from another thread. thread: thread engine to use for working with other thread implementations. choices: eventlet, gevent. headers: headers to use in the session. cookies: cookies to add in the session. auth: HTTP basic auth, a tuple of (username, password), only basic auth is supported. proxies: dict of proxies to use, format: {"http": proxy_url, "https": proxy_url}. proxy: proxy to use, format: "http://proxy_url". Cannot be used with the above parameter. proxy_auth: HTTP basic auth for proxy, a tuple of (username, password). base_url: absolute url to use as base for relative urls. params: query string for the session. verify: whether to verify https certs. timeout: how many seconds to wait before giving up. trust_env: use http_proxy/https_proxy and other environments, default True. allow_redirects: whether to allow redirection. max_redirects: max redirect counts, default 30, use -1 for unlimited. impersonate: which browser version to impersonate in the session. ja3: ja3 string to impersonate in the session. akamai: akamai string to impersonate in the session. extra_fp: extra fingerprints options, in complement to ja3 and akamai strings. interface: which interface use. default_encoding: encoding for decoding response content if charset is not found in headers. Defaults to "utf-8". Can be set to a callable for automatic detection. cert: a tuple of (cert, key) filenames for client cert. Notes: This class can be used as a context manager. .. code-block:: python from curl_cffi.requests import Session with Session() as s: r = s.get("https://example.com") NTFrnrJ)superr_thread_use_thread_local_curlr _executor threadinglocal_local_is_customized_curlrr rn_curl)rrrrr __class__s rSrSession.__init__sb "6" &;#  #//+DK+/(#'  +0(#'djj#9  !%4djj+ADJrRc0UR(azUR(a[R"SSS9 [ UR SS5(d"[ URS9UR lUR R$UR$)Nz/Creating fresh curl handle in different thread.rrrr) rrrrgetattrrr rnrrrs rSr Session.curlIsf  & &'' O\]^4;;55#'djj#9  ;;## #:: rRcRURc[5UlUR$r)rrrs rSexecutorSession.executorTs >> !/1DN~~rRcU$rrJrs rS __enter__Session.__enter__Zs rRc$UR5 grcloserargss rS__exit__Session.__exit__]s  rRrcFSUlURR5 g)Close the session.TN)rrrrs rSr Session.close`s  rRc/# UR"U0UDSS0D6nUv UR5 g!UR5 f=f7f)z6Equivalent to ``with request(..., stream=True) as r:``r3TN)requestrrrrrs rSr3Session.streames;llD8F848 I IIKCIIKsA/AAA on_messageon_erroron_openon_closerrrrc UR5 UR"URSU/UQ70UD6 URR[R S5 URR 5 [UURUUUUS9$)aConnects to a websocket url. Args: url: the ws url to connect. on_message: message callback, ``def on_message(ws, str)`` on_error: error callback, ``def on_error(ws, error)`` on_open: open callback, ``def on_open(ws)`` on_close: close callback, ``def on_close(ws)`` Other parameters are the same as ``.request`` Returns: a ws instance to communicate with the server. ryrr)rrrrr$ CONNECT_ONLYperformrA)rrrrrrrrs rS ws_connectSession.ws_connectns0 ""$ tyy%FtFvF --q1   II!   rRgzip, deflate, brrrFrr,rr_r-r.rXrYr/rZrarcrdr[r\r]r`r0r1r2rerfrgrhrirjrrmrorpr3r4r5c!^^^)^*^+^,^-^.^/TR5 U(a5TRR5m*TRR5 O TRm*TR"T*40SU_SU_SU_SU_SU_SU_SU_SU_S U _S U _S U _S U _S U _SU_SU_SU_SU_SU_SU_SU_SU_SU_SU_SU_SU_SU_SU_SU_SU_SU _SU_S [ R _S![R_6um/m)m+m.m-n!U(Ga [R"5m,U)U*UU+U-U.U/U4S"jn"U*U,4S#jn#TRRU"5n$U$RU#5 [[RT-5R5 TRT*T)T+T5n%T,R5 [![[ R T.55n&[#U&[$5(aT*R5 U&eT/U%lU$U%lU!U%lT.U%lU%$TR,S$:Xa*[.R0R3T*R45 OgTR,S%:XaG[6R8"5R:R=T*R45R?5 OT*R55 TRT*T)T+T5n%T/U%lU%T*R5 $![@a]n'TRT*T)T+T5n%T/U%l[CU'RD[GU'55n(U("[GU'5U'RDU%5U'eS&n'A'ff=f!T*R5 f=f)'zESend the request, see ``requests.request`` for details on parameters.r,rr_r-r.rXrYr/rZrarcrdr[r\r]r`r0r1r2rerfrgrhrirrmror3r4r5rpr6r7c>TR5 [ [RT5R5(d([ [RT5R5 [ [ R T5RS5 g![alnT RTTTT5nTUl[ [ R T5R[[U5URU55 SnANSnAff=f![ [RT5R5(d([ [RT5R5 [ [ R T5RS5 f=fr)rr!rrrrQueuerAr-rOcoderEventr@rput) rrrryrjrrDrrrs rSr Session.request..performs  3IIK  ?FFHHY__m<@@Ba(,,T2![..q&-IYZC"%CKa(334DSVQVVUX4YZZ[  ?FFHHY__m<@@Ba(,,T2s+B DA"D>D DD BF cF>TR5 TR5 gr)waitreset)futry header_parseds rScleanup Session.request..cleanups""$ rRrwrxN)$rr duphandlerrrrrrrsubmitadd_done_callbackrrrrrrr-r stream_taskrErrwtpoolexecuterrxget_hub threadpoolspawnrr!r/rrO)0rr,rr_r-r.rXrYr/rZrarcrdr[r\r]r`r0r1r2rerfrgrhrirjrrmrorpr3r4r5rErrrr first_elementrerrorrryrrrDrrs0` ` @@@@@@@rSrSession.requestsJ ""$  ##%A IIOO  AAEAWAW #B #B #B  #B  #B  #B #B #B #B #B #B ,#B (#B #B #B "!#B "##B $%#B &,'#B (.)#B *$+#B ,-#B ./#B 01#B 2,3#B 45#B 6&7#B 8 9#B :;#B <*=#B > ?#B @A#B B C#B D"E#B >V]A}hJ %OO-M 3 3 --..w7K  ) )' 2 - 0 5 5 7&&q&-AQRC    (U[[!(<=M-)9:: ##CK)CO#CLCIJ <<:-NN**1995\\X-NN$//55aii@DDFIIK**1fmEUV!   8**1fmEUV! "1663q62CFAFFC0a7  8 s, B!K,M M#AL;;MMMr~ryrzr{rr|r})rrrrrrrr)NNTrN)=rKrLrMrNrrr ThreadTyperrrrVrpropertyrrrrrrr3r?r>r@r=rArr_rrOrrrrr rurqr1r*rsrrtrCr r6r7r8rr"r'r<rrheadrpostrpatchdeleteoptionsrQ __classcell__rs@rSrrs,G $'+&* ?Btn?B$?B $ ?B *+ ?B?BB  .2)-'+)-' \* ' :& ' )$ ' :&'  ' Z6:RV#)-)- $*.GN*.'+'+#04!%!%)?N@ANBH%CND EN` & )D  'C & )D  'C '7 +E 7H -FGY/GrRrcB6^\rSrSrSrSSSS.S\\S\S\\ 4U4S jjjr \ S 5r \ S 5r S rS rSrSrSrSCSjrSr\S5rSrSSSSSSS\SSSSSSSSSSSSSSSSSSSSSS4S\S\S\\\\\4S\\\\\4\\\\\ 4S\\!S\\"S \\#S!\\S"\\\\4S#\\\$\\$\$4\%4S$\\&S%\\S&\\'S'\\S(\\\\4S)\\&S*\\S+\\S,\\(S-\\)S.\\S/\\S0\\\*\+4S1\\&S2\\\(\ /\44S3\\\,S4S4\\-S5\\S6\\\\\\44S7\&S8\S9\\.4@S:jjr/\0"\/S;5r1\0"\/S<5r2\0"\/S=5r3\0"\/S>5r4\0"\/S?5r5\0"\/S@5r6\0"\/SA5r7SBr8U=r9$)D AsyncSessioni0zAAn async request session, cookies and connections will be reused.Nr)loop async_curl max_clientsrrrc j>[TU]"S0UD6 XlX lX0lUR 5 g)a. Parameters set in the init method will be override by the same parameter in request method. Parameters: loop: loop to use, if not provided, the running loop will be used. async_curl: [AsyncCurl](/api/curl_cffi#curl_cffi.AsyncCurl) object to use. max_clients: maxmium curl handle to use in the session, this will affect the concurrency ratio. headers: headers to use in the session. cookies: cookies to add in the session. auth: HTTP basic auth, a tuple of (username, password), only basic auth is supported. proxies: dict of proxies to use, format: {"http": proxy_url, "https": proxy_url}. proxy: proxy to use, format: "http://proxy_url". Cannot be used with the above parameter. proxy_auth: HTTP basic auth for proxy, a tuple of (username, password). base_url: absolute url to use for relative urls. params: query string for the session. verify: whether to verify https certs. timeout: how many seconds to wait before giving up. trust_env: use http_proxy/https_proxy and other environments, default True. allow_redirects: whether to allow redirection. max_redirects: max redirect counts, default 30, use -1 for unlimited. impersonate: which browser version to impersonate in the session. ja3: ja3 string to impersonate in the session. akamai: akamai string to impersonate in the session. extra_fp: extra fingerprints options, in complement to ja3 and akamai strings. default_encoding: encoding for decoding response content if charset is not found in headers. Defaults to "utf-8". Can be set to a callable for automatic detection. cert: a tuple of (cert, key) filenames for client cert. Notes: This class can be used as a context manager, and it's recommended to use via ``async with``. However, unlike aiohttp, it is not required to use ``with``. .. code-block:: python from curl_cffi.requests import AsyncSession # recommended. async with AsyncSession() as s: r = await s.get("https://example.com") s = AsyncSession() # it also works. NrJ)rr_loop_acurlr init_pool)rrrrrrs rSrAsyncSession.__init__3s0j "6"  & rRchURc[R"5UlUR$r)rasyncioget_running_looprs rSrAsyncSession.loopns& ::  113DJzzrRcdURc[URS9UlUR$)N)r)rrrrs rSacurlAsyncSession.acurlts& ;; #3DK{{rRc[R"UR5UlURR S5 M![R a gf=fr)r LifoQueuerpoolrA QueueFullrs rSrAsyncSession.init_poolzsS%%d&6&67   $$T*$$  sAAAc# URR5IShvN nUc[URS9nU$N7f)Nr)r&rr rnrrs rSpop_curlAsyncSession.pop_curls6YY]]_$ <djj)D %s ?=?c[[R5 URR U5 SSS5 g!,(df  g=fr)rrr'r&rAr*s rS push_curlAsyncSession.push_curls. g'' ( II  &) ( (s ? A c# U$7frrJrs rS __aenter__AsyncSession.__aenter__s  sc@# UR5IShvN gN7frrrs rS __aexit__AsyncSession.__aexit__sjjl s c# URR5IShvN SUlURR 5nU(aUR5 M4N@![ R a gf=f7f)rNT)r"rrr& get_nowaitr QueueEmptyr*s rSrAsyncSession.closeskjj     yy++-JJL  !%%  s2A=A! A=1A#A=#A:7A=9A::A=cUR5 UR(d=URRU5 UR 5 UR U5 gUR 5 gr)clean_after_performrr" remove_handlerr.rr*s rS release_curlAsyncSession.release_curlsE   "|| JJ $ $T * JJL NN4 JJLrRc# UR"U0UDSS0D6IShvN nU7v UR5IShvN gN#N!UR5IShvN f=f7f)z&>>> I**,   ? #**,  sAA"AA"AA"AA"A"AAAA"cD# UR5 UR5IShvN nUR"USU/UQ70UD6 UR[R S5 UR RSUR5IShvN [X5$NuN7f)Nryr) rr+rrr$rrrun_in_executorrrA)rrrrrs rSrAsyncSession.ws_connects ""$]]_$ tUCA$A&A G((!,ii''dll;;;$$ % # T IShvN [[RT5R5(d([[RT5R5 [[R T5RS5IShvN gN![alnT RTTTT5nTUl[[R T5R [[U5URU55 SnANSnAff=fN![[RT5R5(d([[RT5R5 [[R T5RS5IShvN f=f7fr)r!rrrrrrAr-rOrrr@rr) rrrrrjrrDrrrtasks rSr%AsyncSession.request..perform s  ;JJ   }=DDFFW]]M:>>@w}}a044T::: ]..tV]L\]C"%CK*556Fs1vqvvWZ6[\\];  }=DDFFW]]M:>>@w}}a044T:::sjFBBBBFDFB D"A"D D DDFBFFFFc(>TRT5 gr)r=)rrrs rSr%AsyncSession.request..cleanups!!$'rRrJ)rr+rrrrr" add_handle create_taskrrrrrrr-r=r astream_taskrErr!r/rrO)0rr,rr_r-r.rXrYr/rZrarcrdr[r\r]r`r0r1r2rerfrgrhrirjrrmrorpr3r4r5rErrrrrrrrrrrDrrrGs0` ` @@@@@@@rSrAsyncSession.requestskH ""$]]_$AEAWAW#B #B #B #B  #B  #B  #B #B #B #B #B #B ,#B (#B #B #B "!#B "##B $%#B &,'#B (.)#B *$+#B ,-#B ./#B 01#B 2,3#B 45#B 6&7#B 8 9#B :;#B <*=#B > ?#B @A#B B C#B D E#B >V]A}hH ::((.D ; ; ("--gi8K  ) )' 2w}}m499; ; ; &&tV]DTUC+D,BCM-)9::!!$'##CK*C #CLCIJ (zz,,T2 **4HXY! !!$'y%v <, 8**4HXY! "1663q62CFAFFC0a7  8!!$'sl$J9H2D,J9H5BJ9 H9?H7H9J# J95J97H99 J AJJ  J##J66J9r~ryrzr{rr|r})rrrrr&r ):rKrLrMrNrrrrtrrVrr rr"rr+r.r1r4rr=rr3rr_rrOrrrrr rurqr1r*rsrrrrCr r6r7r8rr"r'rrr rr rrrrrQrrs@rSrr0sK *. 9Y' 9  9 *+ 99v  ' %6:RV#)-)- $*.GN*.'+'+#04!%!%)?B(@AB(BH%CB(H & )D  'C & )D  'C '7 +E 7H -FGY/GrRr)rrr)krrdrrr collectionsrconcurrent.futuresr contextlibrrr functoolsrior r.r typingr r r rrrrrrrr urllib.parserrrrrrrtyping_extensionsrrrr r!r"r#r$r%rr&r'rYr)r*r+ exceptionsr,r-r.r/rXr0r1rer2r3r4r5r6r7r8r9r:modelsr;r< websocketsr=r>r?r@rA ImportErrorrxeventlet.tpoolrwrCrVrOr rrrrrrrrrrrrrr_rrrrJrRrSr\s 1DD#    ^]]$]]]155UU)$   &RR kkIU4IU48S#XI! ) * X Y ;#;$; ' (    4C4tT5/@)A4c4p /d3i /c /# /PT /5;;w}} (qKqKhi0ki0X X0;X0A sF=4G= G  G