F2j`HddlmZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl mZddlmZddlmZmZmZmZdd lmZdd lmZmZmZmZmZmZmZm Z dd l!m"Z"m#Z#dd l$m%Z%m&Z&dd l'm(Z(ddl)m*Z*ej+rddl,m-Z-ddl.m/Z/ddl0m1Z1ddl2m3Z3Gdde#Z4dS)) annotationsN)asynccontextmanager)timeout)HTTPHeaderDict) _TYPE_BODY) C_INT_MAX CHUNK_AMT_MAXDECODE_GROWTH_FACTORDECODE_MIN_RAW_REFERENCE)AsyncLowLevelResponse) BaseSSLError HTTPErrorIncompleteRead ProtocolErrorReadTimeoutErrorResponseNotReadySSLErrorMustRedialError)ContentDecoder HTTPResponse) is_fp_closedBytesQueueBuffer)Retry)AsyncHTTPConnection)Message)AsyncHTTPConnectionPool)AsyncExtensionFromHTTP)AsyncTrafficPolicec(eZdZ dHdId#ZdJd&ZedKd(ZdLd)ZedMd+Z edNd-Z dOd0Z dPd2Z edQd4Z dRdSd7Z dRdSd8Z dTdUd:Z dVdWd=Z dVd;d>dXd@Z dYdZdCZdLdDZd[dFZdLdGZdS)\AsyncHTTPResponseNrTbodyrheaders>typing.Mapping[str, str] | typing.Mapping[bytes, bytes] | Nonestatusintversionreason str | Nonepreload_contentbooldecode_contentoriginal_responseAsyncLowLevelResponse | NonepoolAsyncHTTPConnectionPool | None connectionAsyncHTTPConnection | NonemsgMessage | Noneretries Retry | Noneenforce_content_lengthrequest_method request_url auto_closepolice_officer.AsyncTrafficPolice[AsyncHTTPConnection] | NonereturnNonect|tr||_nt||_ t||_n#t $r d|_YnwxYw||_||_||_d|_ ||_ d|_ d|_ | |_ d|_d|jvrW|jdd}d|dD}d|vrd|_d|_| |_||_d|_d|_d|_||_d|_| t5jd t8d | |_|r#t|t<t>fr||_| |_ | |_!tE|d r||_d|_#||_$|%|j$|_&tO|_(d|_)||_*||_+|j*S|j*,||j!|j*j-)|j*j-,||j dSdSdS) NrFztransfer-encodingr#c3>K|]}|VdSN)strip).0encs _/home/thesage/.hermes/hermes-agent/venv/lib/python3.11/site-packages/urllib3/_async/response.py z-AsyncHTTPResponse.__init__..Xs*BBBBBBBB,chunkedTzjPassing msg=.. is deprecated and no-op in urllib3.future and is scheduled to be removed in a future major.r) stacklevelread). isinstancerr%r(r' ValueErrorr)r*r._has_decoded_content _request_url_retries _extensionr7rKgetlowersplit_decoderr9r<_body_uncached_read_occurred_fp_original_response_fp_bytes_readwarningswarnDeprecationWarningr5strbytes_pool _connectionhasattr chunk_left_request_method _init_lengthlength_remainingr_decoded_buffer_last_raw_read_size_police_officer_preloaded_contentmemorizeparent)selfr$r%r'r)r*r,r.r/r1r3r5r7r9r:r;r<r=tr_enc encodingss rG__init__zAsyncHTTPResponse.__init__,s( g~ . . 3"DLL)'22DL f++DKK   DKKK   ,$)!(3&* 9=  $, . .\%%&92>>DDFFFBB S0A0ABBBII%%# /3 &<#$ ',$IM"3 ? M|"       Jtc5\22 DJ.2 0: 4  DH'+,:,0,=,=d>R,S,S 011 )*   )8   +  ) )$0@ A A A#*6$+44T4:FFFFF , +76sAAAb bytearraycK|t|d{V}t|dkrdS||dt|<t|S)Nr)rMlen)rorstemps rGreadintozAsyncHTTPResponse.readintosbYYs1vv&&&&&&&& t99>>1!AkD kNt99 rI!typing.AsyncGenerator[None, None]cTKd} dWVn#t$r}t|jdd|d}~wt$r=}dt |vrt ||t|jdd|d}~wt tf$r}td|||d}~wwxYwd}|sF|j r|j |j r|j d{V|j r/|j r| dSdSdS#|sF|j r|j |j r|j d{V|j r.|j r| wwwxYw)z Catch low-level python exceptions, instead re-raising urllib3 variants, so that low-level exceptions are not leaked in the high-level api. On exit, release the connection back to the pool. FNzRead timed out.zread operation timed outzConnection broken: T) SocketTimeoutrrbrr`rOSErrorrrr[closercisclosed release_conn)ro clean_exites rG_error_catcherz AsyncHTTPResponse._error_catchersG + $ K  S S S'tz49JKKQRR S S S-SVV;;"1++1,&tz49JKKQRR_- K K K#$?!$?$?CCJ K J 3*4+11333 #3*00222222222& $4+B+K+K+M+M $!!##### $ $ $ $ 3*4+11333 #3*00222222222& $4+B+K+K+M+M $!!#### $ $s; D' B . B 8A33B BB  D''BF'cK |d{Vn#tttf$rYnwxYw|jrt |_d|_dSdS)z Read and discard any remaining HTTP response data in the response connection. Unread data in the HTTPResponse connection blocks the connection from being released back to the pool. N) _raw_readrr|rrPrrirWros rG drain_connzAsyncHTTPResponse.drain_conns  .."" " " " " " " " "7L1    D   $ !$4#5#5D  DMMM  ! !s 99HTTPHeaderDict | NonecZ|jdSt|jdr |jjSdS)z Retrieve post-response (trailing headers) if any. This WILL return None if no HTTP Trailer Headers have been received. Ntrailers)rZrdrrs rGrzAsyncHTTPResponse.trailerss5 8 4 48Z ( ( %8$ $trIAsyncExtensionFromHTTP | Nonec|jSrC)rSrs rG extensionzAsyncHTTPResponse.extensions rIitemrcK|jtdt|jdst ||d{V||_dS)Nzextension already plugged in_dsa)rSr|rdrZrstart)rors rGstart_extensionz!AsyncHTTPResponse.start_extensionsl ? &899 9tx(( %"$$ $jjrI typing.AnycDKtj|jd{VS)a Parses the body of the HTTP response as JSON. To use a custom JSON decoder pass the result of :attr:`HTTPResponse.data` to the decoder. This method can raise either `UnicodeDecodeError` or `json.JSONDecodeError`. Read more :ref:`here `. N)_jsonloadsdatars rGjsonzAsyncHTTPResponse.jsons&{??????+++rIraclK|jr|jS|jr|dd{VSdS)NT) cache_content)rXrZrMrs rGrzAsyncHTTPResponse.datasO : :  8 766666666 6trIamt int | NonecK|jsJ|r |tks|jr|jtkrtjdkrt j}t|jt}||dkr|t|t}||z}nt} |r!|j |d{V}n|j |}n#t$rYn%wxYw|sn| |~||dk|St|jtr |j |d{VS||j |n|j S)a_ Read a response with the thought that reading the number of bytes larger than can fit in a 32-bit int at a time via SSL in some known cases leads to an overflow error that has to be prevented if `amt` or `self.length_remaining` indicate that a problem may happen. The known cases: * 3.8 <= CPython < 3.9.7 because of a bug https://github.com/urllib3/urllib3/issues/2513#issuecomment-1152559900. * urllib3 injected with pyOpenSSL-backed SSL-support. * CPython < 3.10 only when `amt` does not fit 32-bit int. ) Nr)rZr rhsys version_infoioBytesIOrNr minr rMrOwritegetvalue)rorbuffer is_async_ll chunk_amtrs rG_fp_readzAsyncHTTPResponse._fp_readsxx " N9__%%*.*?)*K*K((Z\\F%TX/DEEK+? #C 7 7I9$CC -I"8%)X]]9%=%=======#x}}Y77!E T"""!+"??$$ $$($9:: 0!X]]3/////////),48==%%%dhmmoo Ms=C C%$C%c2K|jdSt|jdd}|4d{V|s||d{Vnd}|duot|jdd }||dkr|r|r|r6t |}|xj|z c_|j|xj|zc_|j|jr,|j%|jdkrt|j|j dddd{Vn#1d{VswxYwY|r8|s6t |}|xj|z c_|j|xj|zc_t|ttfr|rt ||_ |S)z7 Reads `amt` of bytes from the socket. NclosedFrIr)rZgetattrrrrvr\rhr}r9rrNrartrj)ror fp_closedris_foreign_fp_uncloseddata_lens rGrzAsyncHTTPResponse._raw_readLs 8 4DHh66 &&(($ U$ U$ U$ U$ U$ U$ U$ U5>G$--,,,,,,,,,CD &)D[&(E::6 "C1HHTH>TH):"4yyH''83'',8--9--   / U-9-22))STTTTI$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ U$ UL  2. 24yyH   8 +  $0%%1%% dUI. / / 1D 1'*4yyD $ sC D D$'D$ bool | NonecK||pd|d{V}d|_|Gt||kr4|j||j|S|S)a Similar to ``http.client.HTTPResponse.read1`` and documented in :meth:`io.BufferedReader.read1`, but with an additional parameter: ``decode_content``. :param amt: How much of the content to read. :param decode_content: If True, will attempt to decode the body based on the 'content-encoding' header. )rr.NT)rMrYrvriputrTrorr.rs rGread1zAsyncHTTPResponse.read1s$YY r)        (,$ ?s4yy3  $ $T * * *'++C00 0 rIFrcBK||||d{VS)N)rr.r)_read)rorr.rs rGrMzAsyncHTTPResponse.readsJ ZZ)'          rI)partialrc K |||j}|Ud}|dkr%|jrc|jjrWt |jt tz}|d|d|}|r|j |t|j r|j t|j |j rqt|j ddr\|jVt!|j dr|j j|j jjr%|j|d|_SSSSS|dkr |jrl|jjr`t|j |krH|d|d|t|j z }|j ||t|j kr|j ||j rqt|j ddr\|jVt!|j dr|j j|j jjr%|j|d|_SSSSS|j`|j|4d{V||d{V}dddd{Vn#1d{VswxYwYn||d{V}|sd|_|r|dkrt|}d}|d}n |dkr|sd}|st|j dkr|jr |jjs}||j rqt|j ddr\|jVt!|j dr|j j|j jjr%|j|d|_SSSSS|)||||}|r|js||_n|s|jrt3d||j rqt|j ddr\|jVt!|j dr|j j|j jjr%|j|d|_SSSSS|||||t|j z }|j ||ot!|j d} t|j |kr|r| s|j`|j|4d{V||d{V}dddd{Vn#1d{VswxYwYn||d{V}|||||t|j z }|j |t|j |kr|r| |j |}||j rqt|j ddr\|jVt!|j dr|j j|j jjr%|j|d|_SSSSS#|j rpt|j ddrZ|jSt!|j dr|j j|j jjr!|j|d|_wxYw) NFrrI) flush_decoder max_length_eotrTz_Calling read(decode_content=False) is not supported after read(decode_content=True) was called.)r) _init_decoderr.rWhas_unconsumed_tailmaxrjr r _decoderirrvrTrZrrkrdrrforgetborrowrrYrXrP RuntimeError) rorr.rrcap decoded_datarrsurface_per_frames rGrzAsyncHTTPResponse._readsZ Q 0    %!%!4 % 77}C)JC $ 8 83 3(,||**/'* (4(( (C 044\BBB4/00S#377D>>c$"67777#377<%>> ,   $((666$+$I&0I0I!,--333EV3 +7#'#7#>#>t#D#D========)-)<)<#<#<#<#<#<#ZAZB"Z8U&Z& U00Z3U04BZA9\"typing.AsyncGenerator[bytes, None]c:K|dkrdS|jdSt|jr|js|jra|jjrW|||dd{V}|r|WVt|j9|j@|jr|jjSdSdSdSdS)NrT)rr.r)rZrrirWrrrs rGstreamzAsyncHTTPResponse.streamOs !88 F 8  FTX&& #   #'-"C  $D  TX&& #   #'-"C         rIcXK|j+|jjs|jd{V|js |jr|j|jr|jd{V|js!t j|dSdSrC)rrr}rZrcr<rIOBasers rGr}zAsyncHTTPResponse.closebs > %dn.C %.&&(( ( ( ( ( ( ( ({ tx  HNN      +"((** * * * * * * * " IOOD ! ! ! ! ! " "rItyping.AsyncIterator[bytes]c~Kg}|dd23d{V}d|vrc|d}dg||ddWV|ddD] }|dzWV |dr |dg}kg}n||6|rd|WVdSdS)NrT)r. rIrr)rrVjoinappend)rorchunkchunksxs rG __aiter__zAsyncHTTPResponse.__aiter__os$ ;;r$;?? % % % % % % %%~~U++hh:::E:;;;;;;"$$Ae)OOOOO": $Rj\FFFF e$$$$@  #((6"" " " " " " " # #sB c|jsH|jr|j|js#tj|dSdSdSrC)rrZr}r<rrrs rG__del__zAsyncHTTPResponse.__del__s`{ &x !   ? & %%%%%  & & & &rI)r#NrrNTTNNNNNTNNTN)$r$rr%r&r'r(r)r(r*r+r,r-r.r-r/r0r1r2r3r4r5r6r7r8r9r-r:r+r;r+r<r-r=r>r?r@)rsrtr?r()r?ry)r?r@)r?r)r?r)rrr?r@)r?r)r?rarC)rrr?ra)NN)rrr.rr?ra)NNF)rrr.rrr-r?ra) rrr.rrr-rr-r?ra)rN)rrr.rr?r)r?r)__name__ __module__ __qualname__rrrxrrrpropertyrrrrrrrrrMrrr}rrrIrGr"r"+sZRV! $#:>/315" $'+%)"&IM%gGgGgGgGgGR5$5$5$5$n!!!!    X X     , , , ,X1N1N1N1N1Nj;;;;;~&*@&*#      &*# Z0  Z0Z0Z0Z0Z0Z0zFJ& " " " "####"&&&&&&rIr")5 __future__rrrrrtypingr] contextlibrsocketrr{ _collectionsr_typingr _constantr r r r backend._asyncr exceptionsrrrrrrrrresponserr util.responserr util.retryrr3r TYPE_CHECKING email.messager_async.connectionpoolrcontrib.webextensions._asyncrutil._async.traffic_policer r"rrIrGrs+""""""  ******++++++))))))  322222                    43333333::::::::++++++ @%%%%%%??????EEEEEE??????[ &[ &[ &[ &[ & [ &[ &[ &[ &[ &rI