+
    Ȝi?*                        ^ 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   "b/Users/mibo/.openclaw/workspace/.venv-ak/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                   6   a  ] tR t^%t o RtV 3R lR ltRtV tR# )RequestzRepresenting a sent request.c                ,   < V ^8  d   QhRS[ RS[RS[ /# )r   urlheadersmethod)strr   )r   __classdict__s   "r   r   Request.__annotate__(   s"      C ' 3 r   c                *    Wn         W n        W0n        R # )N)r&   r'   r(   )selfr&   r'   r(   s   &&&&r   __init__Request.__init__(   s    r   )r'   r(   r&   N)__name__
__module____qualname____firstlineno____doc__r.   __static_attributes____classdictcell__r*   s   @r   r$   r$   %   s     & r   r$   c                   t  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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__P   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        ^ V n        ^ V n        ^ V n        ^ V n        ^ V n        R# ) r   OKTutf-8N) 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download_sizeupload_sizeheader_sizerequest_sizeresponse_size)r-   r;   r<   s   &&&r   r.   Response.__init__P   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=   p   s       r   c                    V P                   # )zAlias for encoding.)encodingr-   s   &r   charsetResponse.charseto   s     }}r   c                    < V ^8  d   QhRS[ /# r\   r^   )r   r*   s   "r   r   r=   u   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.
	_encodingrA   )hasattrcharset_encoding
isinstancerH   r)   callablerB   rf   )r-   r`   s   & r   r`   Response.encodingt   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   valuer]   Nr^   )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)rg   
ValueErrorrf   )r-   rm   s   &&r   r`   rk      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)r-   content_typecharset_matchs   &  r   rh   Response.charset_encoding   sF     ||''7&--l;M-:=&&q)DDr   c                    < V ^8  d   QhRS[ /# r\   r^   )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                  # )ro   r?   )rg   rB   ro   _decodera   s   &r   textResponse.text   sK    tW%%<<<
 zz "\\$,,7
zzr   c                    < V ^8  d   QhRS[ /# r\   r^   )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DocumentrB   titlesummarymd)r-   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   rB   r]   )bytesr)   )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)decoder`   UnicodeDecodeErrorLookupError)r-   rB   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)rE   r   rC   rD   ra   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)r-   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
                  P                  4        VhV\        J d   R# Vx  K_  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;   rs   ri   r   reset
STREAM_ENDr-   r   r   r   s   &&& r   r   Response.iter_content   s      MMK
 %''zzzdiiiF)FF'JJNN$E %!122		! 
"Ks   -CCCA&Cc                .    \        V P                  3/ VB # )z+return a parsed json object of the content.)r   rB   )r-   kws   &,r   jsonResponse.json   s    T\\(R((r   c                    V P                   '       d   V P                   P                  4        V P                  '       d   V P                  P                  4        R# R# z:Close the streaming connection, only valid in stream mode.N)rT   setrR   resultra   s   &r   closeResponse.close   s@     ===MM##% 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   )r-   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;   rs   ri   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\   r^   )r   r*   s   "r   r   r=   0  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|   acontentra   s   &r   atextResponse.atext0  s"      ||$--/1221s   ,*	,c                    < V ^8  d   QhRS[ /# r\   )r   )r   r*   s   "r   r   r=   6  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)r-   chunksr   s   &  r   r   Response.acontent6  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   )rS   ra   s   &r   r   Response.aclose=  s*      #### #s   "/-	/c                    < V ^8  d   QhRS[ /# r\   r^   )r   r*   s   "r   r   r=   D  s     2 2# 2r   c                "    R V P                    R2# )z<Response [z]>)rC   ra   s   &r   __repr__Response.__repr__D  s    T--.b11r   )rf   ro   rS   rB   rF   r;   rH   rU   rG   rW   r'   rP   rK   rQ   rN   rO   rE   rL   rM   r   rT   rD   rI   rJ   r<   rX   rY   rC   rR   rV   r&   )NN)NFN)NF)r0   r1   r2   r3   r4   r.   propertyrb   r`   setterrh   r}   r   r|   r   r   r   r   r   r   r   r   r   r   r   r5   r6   r7   s   @r   r9   r9   .   s     B$ $>    * __ 
     / /V
4:)&6<3 3   $2 2r   r9   )*
contextlibr   r   rer   concurrent.futuresr   typingr   r   r   collections.abcr   r	   datetimer
   r;   r   utilsr   rF   r   
exceptionsr   r   r'   r   orjsonr   ImportErrorr   r   r   readabilityr   compilert   objectr   r"   r$   r9    r   r   <module>r      s      	  % ' ' /   #  3  k-  ZZ+,
X
 W2 W27   s   B0 (C0C ?C C	