o Zju3@sNddlmZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z m Z ddlmZddlmZdd lmZd d lmZd d lmZmZd d lmZd dlmZzddlmZWneymddl mZYnweeddl!m!Z"ddl#Z$Wdn1swYe%dZ&hdZ'dZ(GdddZ)GdddZ*dS))suppressN)Future)AnyOptionalUnion) AwaitableCallable) timedelta)Curl)CurlCffiWarning)Cookies) HTTPErrorRequestException)Headers) STREAM_END)loads) markdownifyzcharset=([\w-]+)>utf-16utf-32utf-16beutf-16leutf-32beutf-32le utf-16-be utf-16-le utf-32-be utf-32-leutf8utf16utf32utf-8 utf-8-sig)i-i.i/i3i4c @s2eZdZdZ d dedededeefddZdS) 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. NurlheadersmethodbodycCs||_||_||_||_dSN)r%r&r'r()selfr%r&r'r(r+T/home/dinkstrade/pdmp/venv/lib/python3.10/site-packages/curl_cffi/requests/models.py__init__;s zRequest.__init__r)) __name__ __module__ __qualname____doc__strrrbytesr-r+r+r+r,r$1sr$c@sneZdZdZd7deedeefddZdee e ffdd Z d ee e fddfd d Z e de fd dZe de fddZejde ddfddZe dee fddZe de fddZde fddZdede fddZddZe defddZd8d!d"Zd9d#d$Zd%d&Zd'd(Zd:d)d*Zd8d+d,Zd9d-d.Zde fd/d0Z defd1d2Z!d3d4Z"de fd5d6Z#dS);ResponseaContains 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: redirect responses, in request order. Response bodies are not 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 NcurlrequestcCs||_||_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|_ dS) NOKTr"rF)!r5r6r%content status_codereasonokrr&rcookiesr elapseddefault_encodingredirect_count redirect_url http_version primary_ip primary_portlocal_ip local_porthistoryinfosqueue stream_task astream_taskquit_now_stream_closed download_size upload_size header_size request_size response_size)r*r5r6r+r+r,r-ks< zResponse.__init__returncCsNtdd|j|j|j|jfDrtd|j}dD]}||dq|S)Ncss|]}|duVqdSr)r+).0valuer+r+r, s  z(Response.__getstate__..ziStreaming responses cannot be pickled; make the request without stream=True before pickling the response.)r5rKrLrMrN) anyrKrLrMrN TypeError__dict__copypop)r*state attributer+r+r, __getstate__s  zResponse.__getstate__r^cCs4|j|d|_d|_d|_d|_d|_d|_dSNT)r[updater5rKrLrMrNrO)r*r^r+r+r, __setstate__s  zResponse.__setstate__cCs|jS)zAlias for encoding.)encodingr*r+r+r,charsetszResponse.charsetcCsRt|ds&|j}|dur!t|jtr|j}n t|jr!||j}|p$d|_|jS)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. _encodingNr")hasattrcharset_encoding isinstancerAr2callabler;rg)r*rdr+r+r,rds     zResponse.encodingrWcCst|dr td||_dS)N_textz0Cannot set encoding after text has been accessed)rh ValueErrorrg)r*rWr+r+r,rds  cCs0|jd}|rt|}|r|dSdSdS)z=Return the encoding, as specified by the Content-Type header.z Content-Typer N)r&get CHARSET_REsearchgroup)r* content_type charset_matchr+r+r,ris  zResponse.charset_encodingcCs0t|ds|jsd|_|jS||j|_|jS)Nrlr7)rhr;rl_decoderer+r+r,texts z Response.textcCs:t|j}|}|jdd}td|d|d}|S)NT) html_partialz

z

z
)rdDocumentr;titlesummarymd)r*docryrz body_as_mdr+r+r,markdowns  zResponse.markdownr;c Cs4z |j|jddWSttfy|dYSw)Nreplace)errorsr#)decoderdUnicodeDecodeError LookupError)r*r;r+r+r,rts zResponse._decodecCs&|jstd|jd|jd|dS)z2Raise an error if status code is not in [200, 400)z HTTP Error z: rN)r>rr<r=rer+r+r,raise_for_statusszResponse.raise_for_statuscCsd|jvo |jtvS)z0Whether this response is a well-formed redirect.location)r&r<REDIRECT_STATIrer+r+r, is_redirectszResponse.is_redirectFccsd}|j||dD]2}|dur||}|r||n|}|r5|dr5|r5|dd|dkr5|nd}|EdHq |durF|VdSdSz 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 splitlinesr])r*rr delimiterpendingchunklinesr+r+r, iter_liness,   zResponse.iter_linesccst|r tjdtdd|rt|jr|jsJd |j}t|tr+| ||t ur0n|Vq| dSzD 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 NotImplementedErrorrKr5rnrjr_finalize_streamrr*rrrr+r+r,rs(   zResponse.iter_contentcKsJ|j}|dur|dd}|tvrt|jfi|St|jfi|S)z+return a parsed json object of the content.N_-)rilowerrJSON_NATIVE_ENCODINGSrrur;)r*kwrirdr+r+r,json0s z Response.jsoncCs |dSz:Close the streaming connection, only valid in stream mode.N)rrer+r+r,close9s zResponse.closecCsj|jrdS|jdur|jdur|jdurdSd|_|jr!|j|jr)|j|jr3|jdSdSra)rOrKrLrNsetresultr5rrer+r+r,r=s  zResponse._finalize_streamcCsd}|j||d2z93dHW}|dur||}|r||n|}|r9|dr9|r9|dd|dkr9|nd}|D]}|Vq=q 6|durN|VdSdSr) aiter_contentrrr])r*rrrrrrliner+r+r, aiter_linesJs2 zResponse.aiter_linescCs|r tjdtdd|rt|jr|jsJd |jIdH}t|tr1| IdH||t ur>| IdHdS|Vqr) rrr rrKr5rnrjracloserrr+r+r,res( zResponse.aiter_contentcs||IdHS)z* Return a decoded string. N)rtacontentrer+r+r,atextszResponse.atextcs2g}|2z 3dHW}||q6d|S)z8wait and read the streaming content in one bytes object.Nr8)rappendjoin)r*chunksrr+r+r,rs   zResponse.acontentcs|jr |jIdHdSdSr)rMrer+r+r,rszResponse.aclosecCsd|jdS)Nz )r<rer+r+r,__repr__szResponse.__repr__)NN)NFN)NF)rUN)$r.r/r0r1rr r$r-dictr2rr`rcpropertyrfrdsetterrirur~r3rtrboolrrrrrrrrrrrrr+r+r+r,r4Hs>"      r4)+ contextlibrrKrerconcurrent.futuresrtypingrrrcollections.abcrrdatetimer r5r utilsr r?r exceptionsrrr&rstreamsrorjsonr ImportErrorrrr{ readabilityrwcompilerorrr$r4r+r+r+r,s8