e i, d dl mZ d dlZd dlZd dlZd dlmZ d dlmZm Z m
Z
d dl m Z m
Z
d dlmZ ddlmZ dd lmZ d
d lmZ d
d lmZmZ d
d
lmZ d dlm Z n# e $ r d dl m Z 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)AnyOptionalUnion) AwaitableCallable) timedelta )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 D/usr/local/lib/python3.11/dist-packages/curl_cffi/requests/models.py clear_queuer s
##%%% s :AAAc
: e Zd ZdZ ddedededee fdZdS ) 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.
Nurlheadersmethodbodyc > || _ || _ || _ || _ d S N)r! r" r# r$ )selfr! r" r# r$ s r __init__zRequest.__init__/ s$ r& ) __name__
__module__ __qualname____doc__strr r bytesr( r) r r r % sf !%
uo
r) r c b 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 dZd dZde fdZdefdZd Z de fd Z 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: 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
Ncurlrequestc || _ || _ d| _ d| _ d| _ d| _ d| _ t | _ t | _
t | _ d| _
d| _ d| _ d| _ d| _ d| _ d| _ d| _ g | _ i | _ d | _ d | _ d | _ d | _ d| _ d| _ d| _ d| _ d| _ d| _ d S ) N r) OKTutf-8r F)!r3 r4 r! content status_codereasonokr r" r cookiesr
elapseddefault_encodingredirect_count redirect_url http_version
primary_ip primary_portlocal_ip
local_porthistoryinfosr stream_task astream_taskquit_now_stream_closed
download_size upload_size header_size request_size
response_size)r' r3 r4 s r r( zResponse.__init__^ s yy yy "+++ DK !!"
-/ %'
,0
-115
#"# ! !!""#r) returnc | j S )zAlias for encoding.)encodingr' s r charsetzResponse.charset~ 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.
_encodingNr9 )hasattrcharset_encoding
isinstancer@ r. callabler: rY )r' rU s r rU zResponse.encoding 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)rZ
ValueErrorrY )r' r^ s r rU 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 r[ zResponse.charset_encoding sX |''77 E & - -l ; ;M-:D=&&q))) Dtr) c t | d s.| j sd| _ n | | j | _ | j S )Nr` r6 )rZ r: r` _decoderV 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)rdDocumentr: titlesummarymd)r' docrp rq
body_as_mds r markdownzResponse.markdown sZ k$,'' ++4+00AuAAAAABB
r) r: c | | j d S # t t f$ r | d cY S w xY w)Nreplace)errorsz utf-8-sig)decoderU UnicodeDecodeError LookupError)r' r: s r rj 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)r= r r; r< rV 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' r r 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| ||t u rn|V S| dS zD
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 r3 rc r\ r _finalize_stream
STREAM_ENDr' r r r s r r 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 r: )r' kws r jsonz
Response.json s T\((R(((r) c . | dS z:Close the streaming connection, only valid in stream mode.N)r rV s r closezResponse.close s r) c | j rd S | j | j | j d S d| _ | j r| j | j r| j | j r| j d S d S )NT)rM r rJ rL setresultr3 r rV s r r zResponse._finalize_stream s F : $"2":t}?T F " = M & # # % % % 9 IOO 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 r )
aiter_contentr r r )r' r r 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 r3 rc r\ 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)rj acontentrV s r atextzResponse.atextI 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.acontentO sk --// ! ! ! ! ! ! !% MM% 0xx s 6c 6 K | j r| j d{V dS dS r )rK rV s r r zResponse.acloseV s> $# # # # # # # # # # $ $r) c d| j dS )Nz )r; rV s r __repr__zResponse.__repr__] s 1T -1111r) )NN)NFN)NF)rS N) r* r+ r, r- r r r r( propertyr. rW rU setterr[ rk ru r/ rj r} r r r r r r r r r r r r0 r) r r2 r2 < sQ B $ $Xd^ $Xg=N $ $ $ $@ 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) r2 )+
contextlibr r rer concurrent.futuresr typingr r r collections.abcr r datetimer
r3 r utilsr
r> r
exceptionsr r r" r orjsonr ImportErrorr r rr readabilityrn compilerd objectr Queuer r r2 r0 r) r r s^ % % % % % % ' ' ' ' ' ' ' ' ' ' / / / / / / / / # # # # # # 3 3 3 3 3 3 3 3 Xk ------ RZ+
,
,
VXX
5; .b2 b2 b2 b2 b2 b2 b2 b2 b2 b2s$ A A'&A'5 B BB