hw( d dl mZ d dlZd dlZd dlZd dlmZ d dlmZm Z m
Z
m Z d dl m
Z
ddlmZ ddlmZ d d
lmZ d d lmZmZ d d lmZ d d
lmZ n# e$ r d d
l mZ Y nw xY w ee 5 d dl m Z d dl Z ddd n # 1 swxY w Y ej! d Z" e# Z$dej% fdZ& G d d Z' G d d Z(dS ) )suppressN)Future)AnyCallableOptionalUnion) Awaitable )Curl)CurlCffiWarning )Cookies) HTTPErrorRequestException)Headers)loads) markdownifyzcharset=([\w-]+)qc | j 5 | j | j d| _ d d d d S # 1 swxY w Y d S )Nr )mutexqueueclearall_tasks_done
notify_allunfinished_tasks)r s W/var/www/html/marketdash/venv/lib/python3.11/site-packages/curl_cffi/requests/models.py clear_queuer s
##%%% s :AAAc & e Zd ZdZdededefdZdS )Requestz Representing a sent request.urlheadersmethodc 0 || _ || _ || _ d S )N)r r! r" )selfr r! r" s r __init__zRequest.__init__' s N)__name__
__module__ __qualname____doc__strr r% r& r r r $ sC && C ' 3 r& r c Z e Zd ZdZd dee dee fdZede fd Z
ede fd Z e j d e ddfd
Z edee fd Z
ede fd Zde fd
Zdede fdZd Zd dZd dZd Zd Zd dZd dZde fdZdefdZd Zde fdZ dS ) 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: how many seconds the request cost.
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.
Ncurlrequestc || _ || _ d| _ d| _ d| _ d| _ d| _ t | _ t | _
d| _ d| _ d| _
d| _ d| _ d| _ d| _ d| _ d| _ g | _ i | _ d | _ d | _ d | _ d | _ d S ) N r& OKTg utf-8r )r/ r0 r content status_codereasonokr r! r cookieselapseddefault_encodingredirect_count redirect_url http_version
primary_ip primary_portlocal_ip
local_porthistoryinfosr stream_task astream_taskquit_now)r$ r/ r0 s r r% zResponse.__init__J s yy yy DK !!"
-/ %'
,0
-115
r& returnc | j S )zAlias for encoding.)encodingr$ s r charsetzResponse.charsetd s } r& c t | d sb| j }|Pt | j t r| j }n.t | j r| | j }|pd| _ | j S )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.
_encodingNr5 )hasattrcharset_encoding
isinstancer< r+ callabler6 rO )r$ rK s r rK zResponse.encodingi s t[)) 1,H d 3S99 C # 4HH d 344 C # 4 4T\ B BH % 0DN~ r& valuec R t | d rt d || _ d S )N_textz0Cannot set encoding after text has been accessed)rP
ValueErrorrO )r$ rT s r rK zResponse.encoding s/ 4 ! ! Q OPP P r& c | j d }|r3t | }|r| d ndS dS )z=Return the encoding, as specified by the Content-Type header.z Content-Typer
N)r! get
CHARSET_REsearchgroup)r$ content_type
charset_matchs r rQ zResponse.charset_encoding sX |''77 E & - -l ; ;M-:D=&&q))) Dtr& c t | d s.| j sd| _ n | | j | _ | j S )NrV r2 )rP r6 rV _decoderL s r textz
Response.text sD tW%% 8<
8
!\\$, 7 7
zr& c t j | j }| }| d }t d| d| d }|S )NT) html_partialzz
z)rdDocumentr6 titlesummarymd)r$ docrf rg
body_as_mds r markdownzResponse.markdown sZ k$,'' ++4+00AuAAAAABB
r& r6 c | | j d S # t t f$ r | d cY S w xY w)Nreplace)errorsz utf-8-sig)decoderK UnicodeDecodeError LookupError)r$ r6 s r r` zResponse._decode sW />>$- >BB B"K0 / / />>+.. . . . /s &AAc V | j s!t d| j d| j d| dS )z2Raise an error if status code is not in [200, 400)z HTTP Error z: r N)r9 r r7 r8 rL s r raise_for_statuszResponse.raise_for_status sB w V K$*: K Kdk K KQPTUU U V Vr& Fc # : K d}| || D ]v}|||z }|r| | n| }|r6|d r.|r,|d d |d k r| nd}|E d{V w||V dS dS 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_sizedecode_unicode) iter_contentsplit
splitlinespop)r$ rv rw delimiterpendingchunkliness r
iter_lineszResponse.iter_lines s &&!. '
E " %.7OEKK ***U=M=M=O=OE "2Y+05:2Yr]eBi5O5O
MMMMM r& c # F K |r t j dt d |rt | j r| j s
J d | j }t |t r| j ||t u rdS |V YzD
iterate streaming content chunk by chunk in bytes.
z9chunk_size is ignored, there is no way to tell curl that.r
)
stacklevelzstream mode is not enabled.TN) warningswarnr NotImplementedErrorr r/ rY rR r reset
STREAM_ENDr$ rv rw r s r ry zResponse.iter_content s MK
(%'' 'zFdiFF)FFFF JNN$$E %!122
!!!
""KKK r& c & t | j fi |S )z+return a parsed json object of the content.)r r6 )r$ kws r jsonz
Response.json s T\((R(((r& c | j r| j | j r| j dS dS z:Close the streaming connection, only valid in stream mode.N)rH setrF resultrL s r closezResponse.close sR = M & # # % % % % % & &r& c L K d}| || 2 3 d{V }|||z }|r| | n| }|r6|d r.|r,|d d |d k r| nd}|D ]}|W V ~6 ||W V dS dS ru )
aiter_contentrz r{ r| )r$ rv rw r} r~ r r lines r aiter_lineszResponse.aiter_lines s --!. .
% " %.7OEKK ***U=M=M=O=OE "2Y+05:2Yr]eBi5O5O
MMMMMM s Bc K |r t j dt d |rt | j r| j s
J d | j d{V }t |t r | d{V ||t u r | d{V dS |W V {r ) r r r r r r/ rY rR r acloser r s r r zResponse.aiter_content s
MK
(%'' 'zFdiFF)FFFF
*..********E %!122
kkmm#######
""kkmm#######KKKK
r& c ` K | | d{V S )z*
Return a decoded string.
N)r` acontentrL s r atextzResponse.atext% s4 ||$--// 1 1 1 1 1 1222r& c K g }| 2 3 d{V }| | 6 d | S )z8wait and read the streaming content in one bytes object.Nr& )r appendjoin)r$ chunksr s r r zResponse.acontent+ sk --// ! ! ! ! ! ! !% MM% 0xx s 6c 6 K | j r| j d{V dS dS r )rG rL s r r zResponse.aclose2 s> $# # # # # # # # # # $ $r& c d| j dS )Nz )r7 rL s r __repr__zResponse.__repr__9 s 1T -1111r& )NN)NFN)NF) r' r( r) r* r r r r% propertyr+ rM rK setterrQ ra rk bytesr` rs r ry r r r r r r r r r, r& r r. r. - s; 8 Xd^ Xg=N 4 X # X * _ c d _
(3- X c X# /u / / / / / V V V
4 :) ) )& & & 6 <3S 3 3 3 3 $ $ $2# 2 2 2 2 2 2r& r. ))
contextlibr r rer concurrent.futuresr typingr r r r collections.abcr r/ r utilsr r: r
exceptionsr r r! r orjsonr ImportErrorr r rh readabilityrd compilerZ objectr Queuer r r. r, r& r r sL % % % % % % 1 1 1 1 1 1 1 1 1 1 1 1 % % % % % % # # # # # # 3 3 3 3 3 3 3 3 Xk ------ RZ+
,
,
VXX
5; M2 M2 M2 M2 M2 M2 M2 M2 M2 M2s$ A A! A!/ BB
B