nbiO0ddlmZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl mZddlmZddlmZdd lmZmZmZmZmZmZmZmZdd lmZmZdd lm Z m!Z!dd l"m#Z#d dl$m%Z%ej&rddl'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.GddeZ/dS)) annotationsN)asynccontextmanager)timeout)HTTPHeaderDict) _TYPE_BODY)AsyncLowLevelResponse) BaseSSLError HTTPErrorIncompleteRead ProtocolErrorReadTimeoutErrorResponseNotReadySSLErrorMustRedialError)ContentDecoder HTTPResponse) is_fp_closedBytesQueueBuffer)Retry)AsyncHTTPConnection)Message)AsyncHTTPConnectionPool)AsyncExtensionFromHTTP)AsyncTrafficPoliceceZdZ dEdFd#ZdGd&ZedHd(ZdId)ZedJd+Z edKd-Z dLd0Z dMd2Z edNd4Z dOdPd7Z dOdPd8Z dQdRd:Z dSdTd=Z dUdVd@ZdIdAZdWdCZdIdDZdS)XAsyncHTTPResponseNrTbodyrheaders>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|_| t3jd t6d | |_|r#t|t:t<fr||_| |_| |_ tC|d r||_d|_"||_#|$|j#|_%tM|_'||_(||_)|j(S|j(*||j |j(j+)|j(j+*||jdSdSdS) NrFztransfer-encodingrc3>K|]}|VdSN)strip).0encs n/var/www/html/mdtn/previsions/meteo_cartes/venv/lib/python3.11/site-packages/urllib3_future/_async/response.py z-AsyncHTTPResponse.__init__..Rs*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 _extensionr3rGgetlowersplit_decoderr5r8_body_fp_original_response_fp_bytes_readwarningswarnDeprecationWarningr1strbytes_pool _connectionhasattr chunk_left_request_method _init_lengthlength_remainingr_decoded_buffer_police_officer_preloaded_contentmemorizeparent)selfr r!r#r%r&r(r*r+r-r/r1r3r5r6r7r8r9tr_enc encodingss rC__init__zAsyncHTTPResponse.__init__&st( 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)rIlen)rirmtemps rCreadintozAsyncHTTPResponse.readintosbYYs1vv&&&&&&&& t99>>1!AkD kNt99 rE!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) SocketTimeoutrr]r r[rOSErrorrr rVcloser^isclosed release_conn)ri clean_exites rC_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'c|K |d{VdS#tttf$rYdSwxYw)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)rIr rvr ris rC drain_connzAsyncHTTPResponse.drain_connsZ  ))++         7L1    DD s  ;;HTTPHeaderDict | 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)rUr_rr~s rCrzAsyncHTTPResponse.trailerss5 8 4 48Z ( ( %8$ $trEAsyncExtensionFromHTTP | Nonec|jSr?)rOr~s rC extensionzAsyncHTTPResponse.extensions rEitemrcK|jtdt|jdst ||d{V||_dS)Nzextension already plugged in_dsa)rOrvr_rUrstart)rirs rCstart_extensionz!AsyncHTTPResponse.start_extensionsl ? &899 9tx(( %"$$ $jjrE typing.AnycnK|jd{Vd}tj|S)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 `. Nzutf-8)datadecode_jsonloads)rirs rCjsonzAsyncHTTPResponse.jsons9i''00{4   rEr\clK|jr|jS|jr|dd{VSdS)NT) cache_content)rTrUrIr~s rCrzAsyncHTTPResponse.datasO : :  8 766666666 6trEamt int | NonecK|jsJd}|r||ks|jr|j|krtjdkrt j}d}||dkr|t ||}||z}n|} t|jtr!|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. i) iNr) rUrcsys version_infoioBytesIOminrJr rIrKwritegetvalue)rir c_int_maxbuffer max_chunk_amt chunk_amtrs rC_fp_readzAsyncHTTPResponse._fp_read sx " N9__%%*.*?)*K*K((Z\\F"M+? #C 7 7I9$CC -I!$(,ABB8%)X]]9%=%=======#x}}Y77!E T"""!+"??$$ $$($9:: 0!X]]3/////////),48==%%%dhmmoo Ms0AC CCcK|jdSt|jdd}|4d{V|s||d{Vnd}|duot|jdddu}||dkr|r|r|rA|xjt |z c_|j|xjt |zc_|j|jr,|j%|jdkrt|j|j dddd{Vn#1d{VswxYwY|rC|sA|xjt |z c_|j|xjt |zc_|S)z7 Reads `amt` of bytes from the socket. NclosedFrEr) rUgetattrr|rrWrprcrwr5r )rir fp_closedris_foreign_fp_uncloseds rC _raw_readzAsyncHTTPResponse._raw_read=sd 8 4DHh66 &&((# U# U# U# U# U# U# U# U5>G$--,,,,,,,,,CD t K(E B Be K #C1HHTH>TH);''3t994'',8--T:--   / U-9-22))STTTTG# 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# UJ  3. 3   3t99 ,  $0%%T2%% sCD&& D03D0 bool | NonecK||pd|d{V}|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*N)rIrprdputrPrirr*rs rCread1zAsyncHTTPResponse.read1us$YY r)         ?s4yy3  $ $T * * *'++C00 0 rEFrc, K |||j}|d}|dkrt|jr|jt|j|jr~t |jdrj|jjr_|jYt |jdr|jj |jj j dur&|j |d|_SSSSSSd|cxkrt|jkrnn|j||jr~t |jdrj|jjr_|jYt |jdr|jj |jj j dur&|j |d|_SSSSSS|j`|j |4d{V| |d{V}dddd{Vn#1d{VswxYwYn| |d{V}|r|dkrt|}d}|d}n |dkr|sd}|st|jdkr||jr~t |jdrj|jjr_|jYt |jdr|jj |jj j dur&|j |d|_SSSSSS|"||||}|r||_n|s|jrt#d||jr~t |jdrj|jjr_|jYt |jdr|jj |jj j dur&|j |d|_SSSSSS||||}|j|t|j|kr|r|j`|j |4d{V| |d{V}dddd{Vn#1d{VswxYwYn| |d{V}||||}|j|t|j|kr||j|}||jr~t |jdrj|jjr_|jYt |jdr|jj |jj j dur&|j |d|_SSSSSS#|jr}t |jdrh|jjr\|jUt |jdr|jj |jj j dur!|j |d|_wxYw)NFr_eotrTz_Calling read(decode_content=False) is not supported after read(decode_content=True) was called.) _init_decoderr*rprdrPrUr_rrerrforgetborrowr_decoderTrL RuntimeErrorr)rirr*rr flush_decoder decoded_datas rCrIzAsyncHTTPResponse.reads( N 0    %!%!4 % 77s4#7887/33C8L4M4MNNr 0DHf-- 0HM 0(4 &110x},x}+t33(//555+/D(( 0 0 05 4As7777c$"67777777/33C88l 0DHf-- 0HM 0(4 &110x},x}+t33(//555+/D(( 0 0 05 4{#//66t<<55555555!%!4!4444444D555555555555555555555555555"^^C00000000 sQww$ii!M{ $ $ $  C 455::H 0DHf-- 0HM 0(4 &110x},x}+t33(//555+/D(( 0 0 05 4W{||D.-HH &!%DJ& 0*D , 0DHf-- 0HM 0(4 &110x},x}+t33(//555+/D(( 0 0 05 4; $||D.-PP $((666$.//#55$5+7#'#7#>#>t#D#D========)-)<)<#<#<#<#<#<#BV BX"typing.AsyncGenerator[bytes, None]cK|jdSt|jrt|jdkrR|||d{V}|r|WVt|j8t|jdkPdSdS)Nrr)rUrrprdrIrs rCstreamzAsyncHTTPResponse.streams 8  Ftx(( C0D,E,E,I,Is>JJJJJJJJD  tx(( C0D,E,E,I,I,I,I,I,IrEc\K|j-|jjdur|jd{V|js |jr|j|jr|jd{V|js!t j|dSdS)NF)rrrwrUr^r8rIOBaser~s rCrwzAsyncHTTPResponse.closes > %$.*?5*H*H.&&(( ( ( ( ( ( ( ({ tx  HNN      +"((** * * * * * * * " IOOD ! ! ! ! ! " "rEtyping.AsyncIterator[bytes]c~Kg}|dd23d{V}d|vrc|d}d||dzdzWV|ddD] }|dzWV |dr |dg}kg}n||6|rd|WVdSdS)NrT)r* rErr)rrRjoinappend)rirchunkchunksxs rC __aiter__zAsyncHTTPResponse.__aiter__s ;;r$;?? % % % % % % %%~~U++hhv&&2U:::::"$$Ae)OOOOO": $Rj\FFFF e$$$$@  #((6"" " " " " " " # #sB c|jsO|js |jr|j|js#tj|dSdSdSr?)rrUrwr8rrr~s rC__del__zAsyncHTTPResponse.__del__si{ &; !48 !   ? & %%%%%  & & & &rE)rNrrNTTNNNNNTNNTN)$r rr!r"r#r$r%r$r&r'r(r)r*r)r+r,r-r.r/r0r1r2r3r4r5r)r6r'r7r'r8r)r9r:r;r<)rmrnr;r$)r;rs)r;r<)r;r)r;r)rrr;r<)r;r)r;r\r?)rrr;r\)NN)rrr*rr;r\)NNF)rrr*rrr)r;r\)rN)rrr*rr;r)r;r)__name__ __module__ __qualname__rlrrrr|rpropertyrrrrrrrrrIrrwrrrErCrr%s$RV! $#:>/315" $'+%)"&IM%aGaGaGaGaGF5$5$5$5$n       X X     ! ! ! !X2N2N2N2N2Nl66666t&*>&*# T0T0T0T0T0nFJ      " " " "####"&&&&&&rEr)0 __future__rrrrrtypingrX contextlibrsocketrru _collectionsr_typingrbackend._asyncr exceptionsr r r r rrrrresponserr util.responserr util.retryrr/r TYPE_CHECKING email.messager_async.connectionpoolrcontrib.webextensions._asyncrutil._async.traffic_policerrrrErCrs""""""  ******++++++)))))) 222222                    43333333::::::::++++++ @%%%%%%??????EEEEEE??????r&r&r&r&r& r&r&r&r&r&rE