{L iw(ddlmZddlZddlZddlZddlmZddlmZm Z m Z m Z ddl m Z ddlmZddlmZd d lmZd d lmZmZd d lmZ dd lmZee5ddlmZddlZ dddejBdZ"e#Z$dejJfdZ&GddZ'GddZ(y#e$r dd lmZYfwxYw#1swYXxYw))suppressN)Future)AnyCallableOptionalUnion) Awaitable)Curl)CurlCffiWarning)Cookies) HTTPErrorRequestException)Headers)loads) markdownifyzcharset=([\w-]+)qc|j5|jj|jj d|_dddy#1swYyxYw)Nr)mutexqueueclearall_tasks_done notify_allunfinished_tasks)rs _/mnt/ssd/data/python-lab/Trading/venv/lib/python3.12/site-packages/curl_cffi/requests/models.py clear_queuersE    ##%s z
z
)rdDocumentr6titlesummarymd)r$docrfrg body_as_mds rmarkdownzResponse.markdownsNkk$,,' ++4+0$ug[ AB r&r6c |j|jdS#ttf$r|jdcYSwxYw)Nreplace)errorsz utf-8-sig)decoderKUnicodeDecodeError LookupError)r$r6s rr`zResponse._decodesA />>$-- >B B"K0 />>+. . /s AAcj|js'td|jd|jd|y)z2Raise an error if status code is not in [200, 400)z HTTP Error z: rN)r9rr7r8rLs rraise_for_statuszResponse.raise_for_statuss6wwk$*:*:);2dkk]KQPTU Ur&c# Kd}|j||D]_}|||z}|r|j|n|j}|r%|dr |r|dd|dk(r|jnd}|Ed{a||yy7wz 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$rvrw delimiterpendingchunkliness r iter_lineszResponse.iter_liness&&!.' E"%.7EKK *U=M=M=OEU2Y5U2Yr]eBi5O        M  sA1B3B4Bc#FK|rtjdtd|r t|jr |j sJd |jj }t|tr|j j||tury|TwzD 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.N) warningswarnr NotImplementedErrorrr/rYrRrreset STREAM_ENDr$rvrwrs rryzResponse.iter_contents  MMK  %' 'zzdiiF)FF'JJNN$E%!12 !  "KsBB!c .t|jfi|S)z+return a parsed json object of the content.)rr6)r$kws rjsonz Response.jsonsT\\(R((r&c|jr|jj|jr|jjyyz:Close the streaming connection, only valid in stream mode.N)rHsetrFresultrLs rclosezResponse.closes; == MM          # # % r&cKd}|j||23d{}|||z}|r|j|n|j}|r%|dr |r|dd|dk(r|jnd}|D]}| i7d6||yywru) aiter_contentrzr{r|)r$rvrwr}r~rrlines r aiter_lineszResponse.aiter_liness--!..  %"%.7EKK *U=M=M=OEU2Y5U2Yr]eBi5O          M s&B BBBA!B B B cK|rtjdtd|r t|jr |j sJd |jj d{}t|tr|jd{||tur|jd{y|s7U7/7wr) rrr rrr/rYrRracloserrs rrzResponse.aiter_contents  MMK  %' 'zzdiiF)FF'**..**E%!12kkm##  "kkm##K*$ $s6A(C*C+'CC!C4C5 CCCc\K|j|jd{S7w)z* Return a decoded string. N)r`acontentrLs ratextzResponse.atext%s#||$--/1221s ,* ,cKg}|j23d{}|j|76dj|Sw)z8wait and read the streaming content in one bytes object.Nr&)rappendjoin)r$chunksrs rrzResponse.acontent+sG--/ ! !% MM%  !/xxsA202A2AcRK|jr|jd{yy7wr)rGrLs rrzResponse.aclose2s(   ## # #  #s '%'c"d|jdS)Nz )r7rLs r__repr__zResponse.__repr__9sT--.b11r&)NN)NFN)NF)r'r(r)r*rr rr%propertyr+rMrKsetterrQrarkbytesr`rsrryrrrrrrrrr,r&rr.r.-s%8Xd^Xg=N4#*__cd (3-c#/u// V 4:)&6<3S3   $2#2r&r.)) contextlibrrrerconcurrent.futuresrtypingrrrrcollections.abcr r/r utilsr r:r exceptionsrrr!rorjsonr ImportErrorrrrh readabilityrdcompilerZobjectrQueuerrr.r,r&rrs %11%#3k-RZZ+ , X 5;;M2M27s B+ B<+ B98B9<C