+
    '(j,                        ^ RI Ht ^ RIt^ RIt^ RIt^ RIHt ^ RIHtH	t	H
t
 ^ RIHtHt ^ RIHt ^RIHt ^RIHt ^R	IHt ^R
IHtHt ^RIHt  ^ RIHt ]! ]4      ;_uu_ 4        ^ RIHt  ^ RI!t"RRR4       ]PF                  ! R4      t$]%! 4       t&R R lt' ! R R4      t( ! R R4      t)R#   ] d
    ^ RIHt  Lgi ; i  + '       g   i     LX; i)    )suppressN)Future)AnyOptionalUnion)	AwaitableCallable)	timedelta)Curl)CurlCffiWarning)Cookies)	HTTPErrorRequestException)Headers)loads)markdownifyzcharset=([\w-]+)c                8    V ^8  d   QhR\         P                  /# )   q)queueQueue)formats   "N/home/ubuntu/cf-venv/lib/python3.14/site-packages/curl_cffi/requests/models.py__annotate__r      s      5;;     c                     V P                   ;_uu_ 4        V P                  P                  4        V P                  P	                  4        ^ V n        RRR4       R#   + '       g   i     R# ; i)r   N)mutexr   clearall_tasks_done
notify_allunfinished_tasks)r   s   &r   clear_queuer"      s>    	
		##% 
s   <AA,	c                   :   a  ] tR t^%t o RtRV 3R lR lltRtV tR# )RequestzRepresenting a sent request.

Attributes:
    url: request url.
    headers: request headers.
    method: request http method.
    body: request body as bytes, or None if not provided.
Nc          	      B   < V ^8  d   QhRS[ RS[RS[ RS[S[,          /# )r   urlheadersmethodbody)strr   r   bytes)r   __classdict__s   "r   r   Request.__annotate__/   s7     
 

 
 	

 uo
r   c                6    Wn         W n        W0n        W@n        R # N)r&   r'   r(   r)   )selfr&   r'   r(   r)   s   &&&&&r   __init__Request.__init__/   s     	r   )r)   r'   r(   r&   r/   )__name__
__module____qualname____firstlineno____doc__r1   __static_attributes____classdictcell__r,   s   @r   r$   r$   %   s     
 
 
r   r$   c                     a  ] tR t^<t o RtR$V 3R lR llt]V 3R lR l4       t]V 3R lR l4       t]P                  V 3R	 lR
 l4       t]V 3R lR l4       t
]V 3R lR l4       tV 3R lR ltV 3R lR ltR tR%R ltR&R ltR tR tV 3R lR ltR%R ltR&R ltV 3R lR ltV 3R lR ltR  tV 3R! lR" ltR#tV tR# )'Responsea  Contains information the server sends.

Attributes:
    url: url used in the request.
    content: response body in bytes.
    text: response body in str.
    status_code: http status code.
    reason: http response reason, such as OK, Not Found.
    ok: is status_code in [200, 400)?
    headers: response headers.
    cookies: response cookies.
    elapsed: timedelta of the request duration.
    encoding: http body encoding.
    charset: alias for encoding.
    primary_ip: primary ip of the server.
    primary_port: primary port of the server.
    local_ip: local ip used in this connection.
    local_port: local port used in this connection.
    charset_encoding: encoding specified by the Content-Type header.
    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.
    redirect_count: how many redirects happened.
    redirect_url: the final redirected url.
    http_version: http version used.
    history: history redirections, only headers are available.
    download_size: total downloaded bytes (body).
    upload_size: total uploaded bytes (body).
    header_size: total header size.
    request_size: request size.
    response_size: download_size + header_size
Nc                F   < V ^8  d   QhRS[ S[,          RS[ S[,          /# )r   curlrequest)r   r   r$   )r   r,   s   "r   r   Response.__annotate__^   s$     $ $Xd^ $Xg=N $r   c                   Wn         W n        R V n        RV n        ^V n        RV n        RV n        \        4       V n        \        4       V n
        \        4       V n        RV n        ^ V n        R V n        ^ V n        R V n        ^ V n        R V n        ^ V n        . V n        / V n        RV n        RV n        RV n        RV n        RV n        ^ V n        ^ V n        ^ V n        ^ V n        ^ V n         R# ) r   OKTutf-8NF)!r>   r?   r&   contentstatus_codereasonokr   r'   r   cookiesr
   elapseddefault_encodingredirect_countredirect_urlhttp_version
primary_ipprimary_portlocal_ip
local_porthistoryinfosr   stream_taskastream_taskquit_now_stream_closeddownload_sizeupload_sizeheader_sizerequest_sizeresponse_size)r0   r>   r?   s   &&&r   r1   Response.__init__^   s    	yy"++DK!!" -/%'
,0
-115#"# ! !!""#r   c                    < V ^8  d   QhRS[ /# r   returnr*   )r   r,   s   "r   r   r@      s       r   c                    V P                   # )zAlias for encoding.)encodingr0   s   &r   charsetResponse.charset~   s     }}r   c                    < V ^8  d   QhRS[ /# r`   rb   )r   r,   s   "r   r   r@      s      # r   c                F   \        V R4      '       g   V P                  pVfd   \        V P                  \        4      '       d   V P                  pM6\        V P                  4      '       d   V P                  V P                  4      pT;'       g    RV n        V P                  # )a  
Determines the encoding to decode byte content into text.

The method follows a specific priority to decide the encoding:
1. If ``.encoding`` has been explicitly set, it is used.
2. The encoding specified by the ``charset`` parameter in the ``Content-Type``
    header.
3. The encoding specified by the ``default_encoding`` attribute. This can either
    be a string (e.g., "utf-8") or a callable for charset autodetection.
	_encodingrD   )hasattrcharset_encoding
isinstancerK   r*   callablerE   rj   )r0   rd   s   & r   rd   Response.encoding   s~     t[)),,Hd33S99#44Hd3344#44T\\BH%00DN~~r   c                $   < V ^8  d   QhRS[ RR/# )r   valuera   Nrb   )r   r,   s   "r   r   r@      s      c d r   c                L    \        V R 4      '       d   \        R4      hWn        R# )_textz0Cannot set encoding after text has been accessedN)rk   
ValueErrorrj   )r0   rq   s   &&r   rd   ro      s     4!!OPPr   c                0   < V ^8  d   QhRS[ S[,          /# r`   )r   r*   )r   r,   s   "r   r   r@      s      (3- r   c                    V P                   P                  R4      pV'       d1   \        P                  V4      pV'       d   VP	                  ^4      # R# R# )z=Return the encoding, as specified by the Content-Type header.zContent-TypeN)r'   get
CHARSET_REsearchgroup)r0   content_typecharset_matchs   &  r   rl   Response.charset_encoding   sF     ||''7&--l;M-:=&&q)DDr   c                    < V ^8  d   QhRS[ /# r`   rb   )r   r,   s   "r   r   r@      s      c r   c                    \        V R 4      '       gF   V P                  '       g   RV n        V P                  # V P                  V P                  4      V n        V P                  # )rs   rB   )rk   rE   rs   _decodere   s   &r   textResponse.text   sK    tW%%<<<
 zz "\\$,,7
zzr   c                    < V ^8  d   QhRS[ /# r`   rb   )r   r,   s   "r   r   r@      s      # r   c                    \         P                  ! V P                  4      pVP                  4       pVP	                  R R7      p\        RV RV R24      pV# )T)html_partialz<h1>z</h1><main>z</main>)rdDocumentrE   titlesummarymd)r0   docr   r   
body_as_mds   &    r   markdownResponse.markdown   sN    kk$,,'		++4+0$ug[	AB
r   c                &   < V ^8  d   QhRS[ RS[/# )r   rE   ra   )r+   r*   )r   r,   s   "r   r   r@      s     / /u / /r   c                     VP                  V P                  R R7      #   \        \        3 d    TP                  R4      u # i ; i)replace)errorsz	utf-8-sig)decoderd   UnicodeDecodeErrorLookupError)r0   rE   s   &&r   r   Response._decode   sA    	/>>$--	>BB"K0 	/>>+..	/s    "AAc                x    V P                   '       g(   \        RV P                   RV P                   2^ V 4      hR# )z2Raise an error if status code is not in [200, 400)zHTTP Error z: N)rH   r   rF   rG   re   s   &r   raise_for_statusResponse.raise_for_status   s8    wwwk$*:*:);2dkk]KQPTUU r   c              #  t  "   RpV P                  WR7       F  pVe	   WE,           pV'       d   VP                  V4      MVP                  4       pV'       dD   VR,          '       d5   V'       d-   VR,          R,          VR,          8X  d   VP                  4       MRpT Rj  xL
  K  	  Ve   Vx  R# R#  L5iz
iterate streaming content line by line, separated by ``\n``.

Copied from: https://requests.readthedocs.io/en/latest/_modules/requests/models/
which is under the License: Apache 2.0
N)
chunk_sizedecode_unicode)iter_contentsplit
splitlinespop)r0   r   r   	delimiterpendingchunkliness   &&&&   r   
iter_linesResponse.iter_lines   s      &&! ' 
E ".7EKK	*U=M=M=OE U2YY5U2Yr]eBi5O 		  
 M  s"   +B8(B8B8.3B8!B6"B8c              #    "   V'       d   \         P                  ! R\        ^R7       V'       d   \        4       hV P                  '       d   V P
                  '       g   Q R4       h V P                  P                  4       p\        V\        4      '       d   V P                  4        VhV\        J d   MVx  KT  V P                  4        R# 5iz4
iterate streaming content chunk by chunk in bytes.
z9chunk_size is ignored, there is no way to tell curl that.)
stacklevelzstream mode is not enabled.N)warningswarnr   NotImplementedErrorr   r>   rw   rm   r   _finalize_stream
STREAM_ENDr0   r   r   r   s   &&& r   r   Response.iter_content   s      MMK
 %''zzzdiiiF)FF'JJNN$E %!122%%' 
"Ks   -CCCA-Cc                .    \        V P                  3/ VB # )z+return a parsed json object of the content.)r   rE   )r0   kws   &,r   jsonResponse.json   s    T\\(R((r   c                &    V P                  4        R# z:Close the streaming connection, only valid in stream mode.N)r   re   s   &r   closeResponse.close   s    r   c                   < V ^8  d   QhRR/# )r   ra   N )r   r,   s   "r   r   r@     s      $ r   c                   V P                   '       d   R # V P                  f   V P                  f   V P                  f   R # RV n         V P                  '       d   V P                  P	                  4        V P                  '       d   V P                  P                  4        V P                  '       d   V P                  P                  4        R # R # )NT)rX   r   rU   rW   setresultr>   r   re   s   &r   r   Response._finalize_stream  s    ::$"2"2":t}}?T"===MM##%999IIOO r   c                 "   RpV P                  WR7        Rj  xL
  pVe	   WE,           pV'       d   VP                  V4      MVP                  4       pV'       dD   VR,          '       d5   V'       d-   VR,          R,          VR,          8X  d   VP                  4       MRpV F  pV5x  K
  	  K   LDTe   T5x  R# R# 5ir   )aiter_contentr   r   r   )r0   r   r   r   r   r   r   lines   &&&&    r   aiter_linesResponse.aiter_lines  s      --! . 
 	 	% ".7EKK	*U=M=M=OE U2YY5U2Yr]eBi5O 		  
 	 
 M s6   CB5B3B5C(CC5>C3B55Cc                 "   V'       d   \         P                  ! R\        ^R7       V'       d   \        4       hV P                  '       d   V P
                  '       g   Q R4       h V P                  P                  4       G Rj  xL
 p\        V\        4      '       d   V P                  4       G Rj  xL
  VhV\        J d   V P                  4       G Rj  xL
  R# V5x  K~   L_ L3 L5ir   )r   r   r   r   r   r>   rw   rm   r   acloser   r   s   &&& r   r   Response.aiter_content+  s      MMK
 %''zzzdiiiF)FF'**..**E %!122kkm## 
"kkm##K + $
 $sF   -C)C)C)%C)C#-C)1C%2#C)C'C)%C)'C)c                    < V ^8  d   QhRS[ /# r`   rb   )r   r,   s   "r   r   r@   I  s     3 3S 3r   c                \   "   T P                  V P                  4       G Rj  xL
 4      #  L5i)z
Return a decoded string.
N)r   acontentre   s   &r   atextResponse.atextI  s"      ||$--/1221s   ,*	,c                    < V ^8  d   QhRS[ /# r`   )r+   )r   r,   s   "r   r   r@   O  s          r   c                   "   . pV P                  4         Rj  xL
  pVP                  V4       K   LDRP                  T4      # 5i)z8wait and read the streaming content in one bytes object.Nr   )r   appendjoin)r0   chunksr   s   &  r   r   Response.acontentO  sE     --/ 	! 	!%MM% 	!/xxs   A424A4Ac                b   "   V P                   '       d   V P                   G Rj  xL
  R# R#  L5ir   )rV   re   s   &r   r   Response.acloseV  s*      #### #s   "/-	/c                    < V ^8  d   QhRS[ /# r`   rb   )r   r,   s   "r   r   r@   ]  s     2 2# 2r   c                "    R V P                    R2# )z<Response [z]>)rF   re   s   &r   __repr__Response.__repr__]  s    T--.b11r   ) rj   rX   rs   rV   rE   rI   r>   rK   rY   rJ   r[   r'   rS   rN   rT   rQ   rR   rH   rO   rP   r   rW   rG   rL   rM   r?   r\   r]   rF   rU   rZ   r&   )NN)NFN)NF)r3   r4   r5   r6   r7   r1   propertyrf   rd   setterrl   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r8   r9   r:   s   @r   r<   r<   <   s     B$ $@    * __ 
     / /V
4 <)  6<3 3   $2 2r   r<   )*
contextlibr   r   rer   concurrent.futuresr   typingr   r   r   collections.abcr   r	   datetimer
   r>   r   utilsr   rI   r   
exceptionsr   r   r'   r   orjsonr   ImportErrorr   r   r   readabilityr   compilerx   objectr   r"   r$   r<   r   r   r   <module>r      s      	  % ' ' /   #  3  k-  ZZ+,
X
 .b2 b2S   s   B0 (C0C ?C C	