diWddlmZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z mZmZddlmZddlmZddlmZmZmZmZmZmZmZmZddlmZdd lm Z d d l!m"Z"d d l#m$Z$m%Z%m&Z&d d l'm(Z(m)Z)m*Z*d dl+m,Z,ddl-m.Z.m/Z/m0Z0ddl1m2Z2m3Z3m4Z4ddl5m6Z6m7Z7ddl8m9Z9m:Z:m;Z;ddlZ>ddl+m?Z?m@Z@mAZAddlBmCZCmDZDmEZEejdk\r ede>e>ZGn ede>ZGer?ddlHmIZIGddedZJGd d!eeGedZKGd"d#edZLGd$d%eLdZMnGd&d'ZNeNZIeOePePfZJeZKeecZLZMed(ZQed)ZRd3d*ZSd4d5d+ZTd4d6d,ZUGd-d.eeGZVGd/d0eVeGZWGd1d2eVeGZXy)7) annotationsN)ThreadPoolExecutor)asynccontextmanagercontextmanagersuppress)Callable)BytesIO) TYPE_CHECKINGGenericLiteralOptional TypedDictTypeVarUnioncast)urlparse) timedelta) AsyncCurl)CurlHttpVersionCurlInfoCurlOpt)Curl CurlErrorCurlMime)CurlCffiWarning)Cookies CookieTypes CurlMorsel)RequestException SessionClosed code2error)Headers HeaderTypes)BrowserTypeLiteralExtraFingerprints ExtraFpDict) STREAM_ENDResponse)HttpVersionLiteralnot_setset_curl_options)AsyncWebSocket WebSocketWebSocketError) R)bounddefault)r4)Unpackc@eZdZUded<ded<ded<ded<ded<y) ProxySpecstrallhttphttpswswssN__name__ __module__ __qualname____annotations__Q/root/funda.leads/venv/lib/python3.12/site-packages/curl_cffi/requests/session.pyr8r80s    rEr8F)totalc&eZdZUded<ded<ded<ded<d ed <ded <d ed <d ed<ded<ded<ded<ded<ded<ded<d ed<d ed<ded<ded<ded<d ed <d!ed"<d#ed$<ded%<d ed&<d'ed(<d)ed*<ded+<ded,<y-).BaseSessionParamsOptional[HeaderTypes]headersOptional[CookieTypes]cookiesOptional[tuple[str, str]]authOptional[ProxySpec]proxies Optional[str]proxy proxy_authbase_urlOptional[dict]paramsboolverify!Union[float, tuple[float, float]]timeout trust_envallow_redirectsint max_redirectsOptional[BrowserTypeLiteral] impersonateja3akamai/Optional[Union[ExtraFingerprints, ExtraFpDict]]extra_fpdefault_headers"Union[str, Callable[[bytes], str]]default_encoding curl_optionsOptional[list] curl_infos4Optional[Union[CurlHttpVersion, HttpVersionLiteral]] http_versiondebug interface%Optional[Union[str, tuple[str, str]]]certOptional[type[R]]response_classdiscard_cookiesraise_for_statusNr?rDrErFrIrI7s&&&&''$$-- 2211 AA<<$$""JJ   33))rErIc:eZdZUded<ded<ded<ded<d ed <d ed <d ed<ded<ded<ded<ded<ded<d ed<ded<ded<ded<ded<ded <ded!<ded"<d#ed$<ded%<d&ed'<d(ed)<d*ed+<ded,<d-ed.<d/ed0<d1ed2<d3ed4<y5)6StreamRequestParams"Optional[Union[dict, list, tuple]]rWAOptional[Union[dict[str, str], list[tuple], str, BytesIO, bytes]]dataOptional[dict | list]jsonrJrKrLrMrVfilesrNrO3Optional[Union[float, tuple[float, float], object]]r[Optional[bool]r] Optional[int]r_rPrQrRrSrTrYrefereraccept_encodingOptional[Callable]content_callbackr`rarbrcrdrerfrgrhUnion[str, Literal[False]]quoterlrmrorprqr^max_recv_speedOptional[CurlMime] multipartrXrtNr?rDrErFrwrwUs22OO##&&&&''DD''$$$$--&&,,11 AA''<<))JJ  33%%rErwceZdZUded<y) RequestParamsrstreamNr?rDrErFrrusrErceZdZedZy)_UnpackcyNrD)argskwargss rF __getitem__z_Unpack.__getitem__{s rEN)r@rArB staticmethodrrDrErFrrzs    rEr)eventletgevent) GETPOSTPUTDELETEOPTIONSHEADTRACEPATCHQUERYc^t|}t|jxr |jS)z,Check if the provided url is an absolute url)rrXschemehostname)url parsed_urls rF_is_absolute_urlrs'#J  !!9j&9&9 ::rEcD |jdS#t$r|cYSwxYwNr)queue IndexErrorqr5s rF _peek_queuers)wwqz   cD |jdS#t$r|cYSwxYwr)_queuerrs rF_peek_aio_queuers)xx{ rc eZdZdZddddddddddddddddddddddddddddd d dZ dd Zd Zedd Zejdd Zy) BaseSessionzMProvide common methods for setting curl options and reading info in sessions.NTutf-8F)rKrMrOrQrSrTrUrWrYr[r\r]r_rarbrcrerfrhrirkrmrnrorqrsrtruc|t||_t||_||_||_||_| |_| |_| |_ | |_ | |_ ||_ ||_ ||_||_||_||_|xsi|_|xsg|_||_||_||_||_|!t1|t2durt5d|d|xst2|_||_||_|r |r t5d|rd|i}|xsi|_||_|j r tA|j s tCdd|_"|jdus |jTtFjHjKdxs-tFjHjKd xs |j|_yy) NFzZ`response_class` must be a subclass of `curl_cffi.requests.models.Response`, not of type ``z)Cannot specify both 'proxy' and 'proxies'r:z2You need to provide an absolute url for 'base_url'TREQUESTS_CA_BUNDLECURL_CA_BUNDLE)&r$rKr_cookiesrOrUrWrYr[r\r]r_rarbrcrerfrhrirkrmrnrorq issubclassr* TypeErrorrsrtrurQrTr ValueError_closedosenvironget)selfrKrMrOrQrSrTrUrWrYr[r\r]r_rarbrcrerfrhrirkrmrnrorqrsrtrus rF__init__zBaseSession.__init__s@w' (       ".*&   . 0(.B$*( "  %*^X*NRW*W ./q2  -8. 0 WGH H enG")-R $ ==!1$--!@QR R  ;;$ $++"5 34::>>"23;; K#6rEc  |}tt|j|}tt|j t j j|_|r|j|_ tt|j t j|_ tt|j t j|_d|jcxkxrdknc|_|jj#}g} |D]} | j%s| j'dr'|j)| j|_g} L| j'ds| j'dr| dxx| z cc<|| j-| t/| |_t3|_|j0j7d} | D]} t8j4j;} | j=| | j?D]g\}}|j4jA||jB|jEdd |jEd d tG|jEd  i|xs |jJ}|sZ|j t jLDcgc]}tOjP|}}|jRjU|ttj t jVj|_,tt|j t jZ|_.tt|j t j^j|_0tt|j t jb|_2||_3tittj|j t jl|_7tt|j t jp|_9tt|j t jt} |j|_;tt|j t jz|_>tt|j t j~|_@tt|j t j|_Btt|j t j|_D|j||jz|_E|jD] }|j ||j|<"|S#tH$rYwxYwcc}w#tx$r|jd|_;YNwxYw)NisHTTP/  z set-cookiedomainpath/secure)rrr)secondszlatin-1)Hrr3rsbytesgetinfor EFFECTIVE_URLdecodergetvaluecontentr^ HTTP_VERSIONrm RESPONSE_CODE status_codeok splitlinesstrip startswithget_reason_phrasereasonappendr$rKrrMget_listr; SimpleCookieloaditemssetvaluerrX Exceptionrt COOKIELISTr from_curl_formatrupdate_cookies_from_curl PRIMARY_IP primary_ip PRIMARY_PORT primary_portLOCAL_IPlocal_ip LOCAL_PORT local_portrhrfloat TOTAL_TIMEelapsedREDIRECT_COUNTredirect_count REDIRECT_URL redirect_urlUnicodeDecodeErrorSIZE_DOWNLOAD_T download_size SIZE_UPLOAD_T upload_size HEADER_SIZE header_size REQUEST_SIZE request_size response_sizerkinfos)rcurlbuffer header_bufferrhrtcrsp header_lines header_list header_lineset_cookie_headers set_cookiecookienamemorselmorselsredirect_url_bytesinfos rF_parse_responsezBaseSession._parse_responsesq 1d))!,-uaii(>(>?@GGI  //+CKQYYx/D/D%EFsAIIh.D.D$EF-#-$--/::< $& ' ,K$$&%%h/00=DDF  %%d+{/E/Ee/LB;.   { + ,k* i  [[11,?, J 224 J'$*LLNLD&KKOO %zz(B7#ZZ4#FJJx$89 $  *AT-A-A89 (BUBU8V34 ++A.G MM 2 27 ;eQYYx/B/B%CDKKMQYYx/D/D%EFE199X->->#?@GGI c199X-@-@#AB/UAIIh>Q>Q4R(ST !#qyy1H1H'IJ!%83H3H)IJ D188:C !aii0H0H&IJsAIIh.D.D$EFsAIIh.B.B$CDQYYx/D/D%EF--?OO .DiioCIIdO . E   " D188CC  Ds+-B)V7 W W 7 WW W/.W/c2|jr tdy)Nz'Session is closed, cannot send request.)rr"rs rF_check_session_closedz!BaseSession._check_session_closedHs << IJ J rEc|jSr)rrs rFrMzBaseSession.cookiesLs }}rEc$t||_yr)rr)rrMs rFrMzBaseSession.cookiesPs ( rE)8rKrJrMrLrOrNrQrPrSrRrTrNrUrRrWrVrYrXr[rZr\rXr]rXr_r^rar`rbrRrcrRrerdrfrXrhrgrirVrkrjrmrlrnrXrorRrqrprsrrrtrXrurX)returnr3)rr)rMrrNone) r@rArB__doc__rrrpropertyrMsetterrDrErFrrsW *.)-*.'+#04"&!%57 $48! $DH $?F'+%)MQ#'6:,0 %!&=S'S' S ( S % SS.S SSS3SSSS 2!S"#S$%S&B'S()S*=+S,%-S.#/S0K1S23S4!5S647S8*9S:;S<=SjO ObK ^^))rErceZdZdZ d dfd ZedZedZdZdZ ddZ e dd Z d d d Z d!d Zdddddddedddddddd ddddddd ddddddddf d"dZd#dZd#dZd#dZd#dZd#dZd#dZd#dZd#dZd#dZxZS)$SessionzA request session, cookies and connections will be reused. This object is thread-safe, but it's recommended to use a separate session for each thread.Nc `t|di|||_||_d|_d|_|rat j|_|rd|_ ||j_ yd|_ t|j|j_ y|r|nt|j|_ y)a Parameters set in the ``__init__`` method will be overriden 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, prefer to use proxy if they are the same. 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 str. 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. response_class: A customized subtype of ``Response`` to use. raise_for_status: automatically raise an HTTPError for 4xx and 5xx status codes. 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") NTFrnrD)superr_thread_use_thread_local_curlr _executor threadinglocal_local_is_customized_curlrrrn_curl)rrthreaduse_thread_local_curlr __class__s rFrzSession.__init__Zsp "6" &;#  #//+DK+/(#'  +0(#'djj#9  !%4djj+ADJrEc&|jrz|jrtjdtdt |j dds%t|j|j _ |j jS|jS)Nz/Creating fresh curl handle in different thread.r) stacklevelrr ) r#r(warningswarnrgetattrr'rrnrr)rs rFrz Session.curlsj  & &'' E#  4;;5#'djj#9  ;;## #:: rEcP|jt|_|jSr)r$rrs rFexecutorzSession.executors >> !/1DN~~rEc|SrrDrs rF __enter__zSession.__enter__s rEc$|jyrcloserrs rF__exit__zSession.__exit__s  rEcFd|_|jjy)Close the session.TN)rrr8rs rFr8z Session.closes  rEc+K|jd||d|ddi} ||jy#|jwxYww)z6Equivalent to ``with request(..., stream=True) as r:``methodrrTNrD)requestr8rr?rrrs rFrzSession.streamsCdllI&cIVIDI I IIKCIIKsA2AAAc |j|jj}|jjt |||||}|j |fi||S)a"Connects to a websocket url. Note: This method is deprecated, use WebSocket instead. 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 WebSocket instance to communicate with the server. )r on_messageon_erroron_openon_close)rr duphandleresetr/connect) rrrCrDrErFrrr=s rF ws_connectzSession.ws_connectsc& ""$yy""$  !    3!&! rEc6|jjSr)rupkeeprs rFrLzSession.upkeepsyy!!rEgzip, deflate, brrrrFc" !,-./012j|r5jj-jjn j-t -fid|d|dj |gdj d|d|dj|gdj|gd |d | xs jd | tur jn| d | jn| d| jn| dj| gd|d|xs jdj |gd|d|d|d|xs j"d|xs j$d|xs j&d|xs j(d| j*n|d|d|xs j,d|xs j.d|d|d | d!|xs j0d"j2d#t4j6d$t8j:\2,.10}"|rt9j:/,-!.012f d%}#-/fd&}$j<j?|#}%|%jA|$0jCjE-,.!}&/jGtI1}'tK|'tLr-j|'2|&_'|%|&_(|"|&_)1|&_jTr|&jU|&S jVd'k(r*d(d l,}(|(jZj]-j^nejVd)k(rFd(d l0})|)jcjdjg-j^jin-j_jE-,.!}&2|&_'jTr|&jU|&-jS#tj$r^}*jE-,.!}&2|&_'tm|*jntq|*}+|+tq|*|*jn|&|*d }*~*wwxYw#-jwxYw)*zESend the request, see ``requests.request`` for details on parameters.r?r params_listrUrzr| headers_list cookies_listr}rOr[r]Nr_ proxies_listrSrT verify_listrrrrarbrcrerfrrmrorrrrqri queue_class event_classc jttjjs(ttjjjty#t$rU} j} |_j t t ||j|Yd}~d}~wwxYw#ttjjs(ttjjjtwxYwr)performrrr@ put_nowaitr!r9coderr%Eventis_setrputr)) errrrhrtr header_recvedrreqrs rFrWz Session.request..performUs &IIK ?FFHY__m<@@BEE*%!H..6=2BOC#&CKLL!1#a&!&&#!FGG H ?FFHY__m<@@BEE*%s+A99 CA C CCCA'EcFjjyr)waitrH)futr header_parseds rFcleanupz Session.request..cleanupcs""$ rErrr)9rrrGrHr-rWrUrKrrOr,r[r]r_rQrTrYrarbrcrerfrmrorqrirQueuer%rZr3submitadd_done_callbackrarrr isinstancer!r@ stream_taskquit_nowrur"eventlet.tpooltpoolexecuterWrget_hub threadpoolspawnrrr#rYr9)3rr?rrWrzr|rKrMr}rOr[r]r_rQrSrTrYrrrrarbrcrerfrhrrmrorqrrrrtrjrWrdrir first_elementrrr]errorrrrrcr^rr_s3` ` ` @@@@@@@rFr@zSession.requestsL ""$  ##%A IIOO  AAQ +B +B +B f- +B ]] +B  +B +B ,,0+B --1+B +B "+B %,w$6DLLG+B )8(?$$_+B "'4&;""#+B &,,0'+B ()+B *"4T__++B ,f--+B ./+B 0,1+B 2.3+B 4$7t'7'75+B 6txx7+B 8(T[[9+B :.;+B >)8(?$$_?+B BC+B D&:):):E+B F 14>>G+B HI+B J*K+B L M+B N"O+B P**Q+B R S+B T"U+B >V]A}hZ %OO-M & & --..w7K  ) )' 2    &&6=*:OC    (NM-)9: ##CK)CO#CLCI$$$$&J <<:-)NN**1995\\X-!NN$//55aii@DDFIIK**v}.>" ((((* ! 8**v}.>" "1663q62CFAFFC0a7  8  s,2BO9Q Q#AP<<QQQc ,|jdd|d|SNrr>rDr@rrrs rFheadz Session.headt||=6s=f==rEc ,|jdd|d|SNrr>rDrurvs rFrz Session.gett||<5crDrurvs rFpostz Session.postrxrEc ,|jdd|d|SNrr>rDrurvs rFr\z Session.putr{rEc ,|jdd|d|SNrr>rDrurvs rFpatchz Session.patcht||>7>v>>rEc ,|jdd|d|SNrr>rDrurvs rFdeletezSession.deletest||?8???rEc ,|jdd|d|SNrr>rDrurvs rFoptionszSession.optionsst||@9#@@@rEc ,|jdd|d|SNrr>rDrurvs rFtracez Session.tracerrEc ,|jdd|d|SNrr>rDrurvs rFqueryz Session.queryrrE)NNT)rzOptional[Curl]r*zOptional[ThreadType]r+rXrUnpack[BaseSessionParams[R]]rrr? HttpMethodrr9rzUnpack[StreamRequestParams])NNNN)rr/)rr^)Br?rrr9rWrxrzryr|r{rKrJrMrLr}rVrOrNr[r~r]rr_rrQrPrSrRrTrNrYrrrRrrRrrrar`rbrRrcrRrerdrfrrhrgrrrmrlrorRrqrprrrr^rrrtrX)rr9rUnpack[RequestParams])r@rArBrrrrr3r5r:r8rrrJrLr,r@rwrr~r\rrrrr __classcell__r,s@rFrrVsT $'+&* FBFB%FB $ FB / FBP       .  KO! !F"6:RV&*)-)- $*.GN*.'+'+#04!%!%)?g@AgB&CgDEgR>=>=?@A??rErc eZdZdZdddd d%fdZedZedZdZd Z d Z d Z d Z d&d Z dZe d'dZdddddeddddddddddddddddddddddddddf d(dZdddddddedddddddddddddddddddddddf d)dZd*dZd*dZd*dZd*dZd*d Zd*d!Zd*d"Zd*d#Zd*d$ZxZS)+ AsyncSessionzAAn async request session, cookies and connections will be reused.N )loop async_curl max_clientsc nt|di|||_||_||_|j y)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, prefer to use ``proxy`` if they are the same. 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 str. 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. response_class: A customized subtype of ``Response`` to use. raise_for_status: automatically raise an HTTPError for 4xx and 5xx status codes. 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. NrD)r!r_loop_acurlr init_pool)rrrrrr,s rFrzAsyncSession.__init__s6x "6"   & rEcd|jtj|_|jSr)rasyncioget_running_looprs rFrzAsyncSession.loops& ::  113DJzzrEch|jt|j|_|jS)N)r)rrrrs rFacurlzAsyncSession.acurls& ;; #3DK{{rEctj|j|_ |jj d#tj $rYywxYwr)r LifoQueuerpoolrX QueueFullrs rFrzAsyncSession.init_pool sS%%d&6&67   $$T*$$  sAAAcK|jjd{}|t|j}|S7w)Nr )rrrrnrrs rFpop_curlzAsyncSession.pop_curls5YY]]_$ <djj)D %sA?Acttj5|jj |dddy#1swYyxYwr)rrrrrXrs rF push_curlzAsyncSession.push_curls7 g'' ( ' II  & ' ' 's ?AcK|SwrrDrs rF __aenter__zAsyncSession.__aenter__s  sc@K|jd{y7wrr7r9s rF __aexit__zAsyncSession.__aexit__!sjjl s cK|jjd{d|_ |jj }|r|j.7:#t j $rYywxYww)r<NT)rr8rr get_nowaitr QueueEmptyrs rFr8zAsyncSession.close%sljj     yy++-JJL  !%%  s2A6A A6,AA6A30A62A33A6c|j|js=|jj||j |j |y|j yr)clean_handles_and_buffersrr remove_handlerHrr8rs rF release_curlzAsyncSession.release_curl1sE &&(|| JJ $ $T * JJL NN4 JJLrEc K|jd||d|ddid{} ||jd{y7#7#|jd{7wxYww)zrTNrD)r@acloserAs rFrzAsyncSession.stream:s^!DLLOCO6O$OO I**,   P #**,  sAA%AA%AA%AA%A%A"AA""A%TrMrriFgMbP??c" K|j|jd{}"td#id|"ddd|d|jd|j|gd|j |gd |j |gd |xs |jd |tur |jn|d | |jn|d | |jn| d|j| gd| d| xs |jd|j| gd|d|d|xs |jd|xs |j d|xs |j"d|xs |j$d| |j&n|d|d|xs |j(d|xs |j*d|d|xs |j,dt.j0dt.j2|"j5t6j8d |"j5t6j:d!|j<j?d|"j@d{tCtEtFtH||"|||||||| |!" }# |#jK|#S7/7E#tL$r|#jOwxYww)$aConnects to a WebSocket. Args: url: url for the requests. autoclose: whether to close the WebSocket after receiving a close frame. params: query string for the requests. headers: headers to send. cookies: cookies to use. auth: HTTP basic auth, a tuple of (username, password), only basic auth is supported. timeout: how many seconds to wait before giving up. allow_redirects: whether to allow redirection. max_redirects: max redirect counts, default 30, use -1 for unlimited. proxies: dict of proxies to use, prefer to use ``proxy`` if they are the same. format: ``{"http": proxy_url, "https": proxy_url}``. proxy: proxy to use, format: "http://user@pass:proxy_url". Can't be used with `proxies` parameter. proxy_auth: HTTP basic auth for proxy, a tuple of (username, password). verify: whether to verify https certs. referer: shortcut for setting referer header. accept_encoding: shortcut for setting accept-encoding header. impersonate: which browser version to impersonate. ja3: ja3 string to impersonate. akamai: akamai string to impersonate. extra_fp: extra fingerprints options, in complement to ja3 and akamai str. default_headers: whether to set default browser headers. quote: Set characters to be quoted, i.e. percent-encoded. Default safe string is ``!#$%&'()*+,/:;=?@[]~``. If set to a sting, the character will be removed from the safe string, thus quoted. If set to False, the url will be kept as is, without any automatic percent-encoding, you must encode the URL yourself. curl_options: extra curl options to use. http_version: limiting http version, defaults to http2. interface: which interface to use. cert: a tuple of (cert, key) filenames for client cert. max_recv_speed: maximum receive speed, bytes per second. recv_queue_size: The maximum number of incoming WebSocket messages to buffer internally. This queue stores messages received by the Curl socket that are waiting to be consumed by calling `recv()`. send_queue_size: The maximum number of outgoing WebSocket messages to buffer before applying network backpressure. When you call `send(...)` the message is placed in this queue and transmitted when the Curl socket is next available for sending. max_send_batch_size: The max batch size for sent frames. coalesce_frames: If `True`, multiple pending messages in the send queue may be merged into a single WebSocket frame for improved throughput. **Warning:** This breaks the one-to-one mapping of `send()` calls to frames and should only be used when the application protocol is designed to handle concatenated data streams. Defaults to `False`. retry_on_recv_error: Retries `ws_recv()` if a recv error is raised. Retries up to a limited number of times with a delay in between. yield_interval: How often to yield control back to the event loop. This is a trade-off between throughput and responsiveness. Lower values means the loop yields more frequently and enables other tasks to run, while higher values are better for throughput. The balanced default is `1ms` but you can customize this to fit your application/use case. fair_scheduling: Changes the I/O priority from favoring receives (`5:1`) to a balanced ratio (`1:1`). Enable this to improve send responsiveness under heavy, concurrent load, at the cost of significantly lower overall throughput. yield_mask: Controls the frequency of cooperative multitasking yields in the read loop. The loop yields every `yield_mask + 1` operations. For efficiency, this value must be a power of two minus one (e.g., `63`, `127`, `255`). Lower values yield more often, improving fairness at the cost of throughput. Higher values yield less often, prioritizing throughput. Nrr?rrrUrOrPrQrOr[r]r_rRrSrTrSrrrarbrcrerfrrmrorrqrTrUrr) autocloserecv_queue_sizesend_queue_sizemax_send_batch_sizecoalesce_framesretry_on_recv_erroryield_intervalfair_scheduling yield_maskrD)(rrr-rUrWrKrMrOr,r[r]r_rQrTrYrarbrcrerfrmrorqrrerZsetoptr TCP_NODELAY CONNECT_ONLYrrun_in_executorrWr.rrr*_start_io_tasksr0 terminate)$rrrrWrKrMrOr[r]r_rQrSrTrYrrrarbrcrerfrrmrorqrrrrrrrrrrr=s$ rFrJzAsyncSession.ws_connectHsP ""$]]_$$ $ $ $ ]] $ f- $ ,,0 $ ,,0$ "$ %,w$6DLLG$ )8(?$$_$ '4&;""$ ,,0!$ "#$ $"4T__%$ &f-'$ ()$ *,+$ ,$7t'7'7-$ .txx/$ 0(T[[1$ 2.3$ 6)8(?$$_7$ :;$ <&:):):=$ > 14>>?$ @*A$ B"C$ D E$ F G$ J G''+ G((!,ii''dll;;;+ h' . ++ 3+ 3)+!        }%R <"  LLN  s:$I8IG+I8I/I8II8I8I55I8rc" !*+,-./0Kjjd{+td(id+d|d|dj|gdjd|d|d j |gd j |gd |d | xs jd | tur jn| d| jn| d| jn| dj| gd|d|xs jdj|gd|d|d|d|xs jd|xs j d|xs j"d|xs j$d| j&n|d|d|xs j(d|xs j*d|d |d!| d"|xs j,d#j.d$t0j2d%t0j4\/*,.-}"|rj6j9+0*+!,-./0f d&}#+fd'}$t1j:|#}%|%j=|$t?t0j4-jAd{jC+*,!}&tE.}'tG|'tHrjK+|'/|&_&|%|&_'|"|&_(.|&_)jTr|&jU|&S j6j9+00d{jC+*,!}&/|&_&jTr|&jU|&jK+S7$77T#tV$r^}(jC+*,!}&/|&_&tY|(jZt]|(})|)t]|(|(jZ|&|(d}(~(wwxYw#jK+wxYww))zISend the request, see ``curl_cffi.requests.request`` for details on args.Nrr?rrOrUrzr|rPrQr}rOr[r]r_rRrSrTrSrrrrarbrcrerfrrmrorrrrqrirTrUc K d{ttjjs(ttjjjtd{y7r#t$rU} j} |_jt t ||j |Yd}~d}~wwxYw7h#ttjjs(ttjjjtd{7wxYwwr)rrr@rXr!r9rYrrrZr[rr\r)) r]rrrrhrtrr^rr_rtasks rFrWz%AsyncSession.request..performJs ,JJ  }=DDFW]]M:>>@%% +++ H..fm5EC#&CKLL!1#a&!&&#!FGG H,  }=DDFW]]M:>>@%% +++sjEA?A=A?A(E7C 8E=A?? CA CC"CC" E"A)E E EEc(jyr)r)rbrrs rFrdz%AsyncSession.request..cleanupXs!!$'rErD)/rrr-rWrUrKrMrOr,r[r]r_rQrTrYrarbrcrerfrmrorqrirrerZr add_handle create_taskrgrrarrrhr!rr@ astream_taskrjrrurr#rYr9)1rr?rrWrzr|rKrMr}rOr[r]r_rQrSrTrYrrrrarbrcrerfrhrrmrorqrrrrtrjrWrdrirrqr]rrrrrr^rr_rs1` ` ` @@@@@@@rFr@zAsyncSession.requestsL ""$]]_$AQ+B +B +B +B f- +B ]] +B  +B +B ,,0+B ,,0+B +B "+B %,w$6DLLG+B )8(?$$_+B "'4&;""#+B &,,0'+B ()+B *"4T__++B ,f--+B ./+B 0,1+B 2.3+B 4$7t'7'75+B 6txx7+B 8(T[[9+B :.;+B >)8(?$$_?+B BC+B D&:):):E+B F 14>>G+B HI+B J*K+B L M+B N"O+B P**Q+B R S+B T U+B >V]A}hX ::((.D , , ("--gi8K  ) )' 2w}}m499; ; ; &&fm-=C,A.M-)9:!!$'##CK*C #CLCI$$$$&J (zz,,T2 **&-1A?" ((((*!!$']%H <2 8**&-1A?" "1663q62CFAFFC0a7  8 !!$'sl$OMH0O!M"BO$ MMM 9OOOM O$AN==OOOOcHK|jdd|d|d{S7wrtrurvs rFrwzAsyncSession.head'!T\\CSCFCCCC " "cHK|jdd|d|d{S7wrzrurvs rFrzAsyncSession.get'!T\\BCB6BBBBrcHK|jdd|d|d{S7wr}rurvs rFr~zAsyncSession.postrrcHK|jdd|d|d{S7wrrurvs rFr\zAsyncSession.putrrcHK|jdd|d|d{S7wrrurvs rFrzAsyncSession.patch'!T\\DcDVDDDDrcHK|jdd|d|d{S7wrrurvs rFrzAsyncSession.deletes'!T\\EsEfEEEErcHK|jdd|d|d{S7wrrurvs rFrzAsyncSession.optionss'!T\\FFvFFFFrcHK|jdd|d|d{S7wrrurvs rFrzAsyncSession.tracerrcHK|jdd|d|d{S7wrrurvs rFrzAsyncSession.queryrr)rzOptional[AsyncCurl]rr^rrrr)Drr9rrXrWrxrKrJrMrLrOrNr[r~r]rr_rrQrPrSrRrTrNrYrrrRrrRrar`rbrRrcrRrerdrfrrrrmrlrorRrqrprr^rr^rr^rr^rrXrrXrrrrXrr^rr.)Dr?rrr9rWrxrzryr|r{rKrJrMrLr}rVrOrNr[r~r]rr_rrQrPrSrRrTrNrYrrrRrrRrrrar`rbrRrcrRrerdrfrrhrgrrrmrlrorRrqrprrrr^rrrtrXrr3)rr9rrrr3)r@rArBrrrrrrrrrrr8rrrr,rJr@rwrr~r\rrrrrrrs@rFrrsK *. @( @  @ / @D   '    .   59)-)-*.GN*.'+'+#04!%!%)<48! $DH*.,.MQ#'6:""#& %$) % %Eh hh3 h ' h ' h(hEh(h%h%hh.hhh '!h"2#h$%h&'h(B)h*(+h,*-h.K/h0!1h243h45h67h89h:!;h<=h>"?h@AhBChDEhF Gh\6:RV&*)-)- $*.GN*.'+'+#04!%!%)?V(@AV(B&CV(DEV(F GV(pDCDCEFGEErEr)rr9rrXr)rz queue.Queue)rz asyncio.Queue)Y __future__rr http.cookiesr;rrsysr%r/concurrent.futuresr contextlibrrrcollections.abcrior typingr r r r rrrr urllib.parserdatetimeraiorconstrrrrrrrutilsrrMrrr exceptionsr!r"r#rKr$r%rar&r'r(modelsr)r*r+r,r- websocketsr.r/r0 version_infor3typing_extensionsr6r8rIrwrrdictr9 ThreadTyperrrrrrrrDrErFrs}" 1DD$   "66,,#55CC)KK(@@AAw8X6A8$A(IUGAJ <iu@+5  YFS#XI!)2I& ) * P ; t)'!*t)nb?k!nb?J hE;q>hErE