a _g / @sdZddlmZddlZddlZddlZddlZddlmZz ddl Z Wn6e y~z ddl Z Wne yxdZ Yn0Yn0z ddl Z Wne ydZ Yn0GdddZ Gdd d e ZGd d d e ZGd d d e ZGddde ZGddde ZGddde ZGdddZGdddZGdddZGdddZeeeeedZe durnede dureddS)zq Handlers for Content-Encoding. See: https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Content-Encoding ) annotationsN) DecodingErrorc@s*eZdZdddddZddddZdS) ContentDecoderbytesdatareturncCs tdSNNotImplementedErrorselfrr]/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/httpx/_decoders.pydecode%szContentDecoder.decoder cCs tdSr r rrrrflush(szContentDecoder.flushN)__name__ __module__ __qualname__rrrrrrr$src@s.eZdZdZdddddZddddZd S) IdentityDecoderz Handle unencoded data. rrcCs|Sr rr rrrr1szIdentityDecoder.decodercCsdSNrrrrrr4szIdentityDecoder.flushN)rrr__doc__rrrrrrr,src@s<eZdZdZddddZddddd Zddd d Zd S) DeflateDecoderzZ Handle 'deflate' decoding. See: https://stackoverflow.com/questions/1838699 NonercCsd|_t|_dSNT) first_attemptzlib decompressobj decompressorrrrr__init__?szDeflateDecoder.__init__rrc Cs~|j}d|_z|j|WStjyx}zD|rVttj |_||WYd}~Stt ||WYd}~n d}~00dSNF) rr" decompressr errorr! MAX_WBITSrrstr)rrZwas_first_attemptexcrrrrCszDeflateDecoder.decodec CsFz |jWStjy@}ztt||WYd}~n d}~00dSr r"rr r&rr(rr)rrrrNs zDeflateDecoder.flushNrrrrr#rrrrrrr8s rc@s<eZdZdZddddZddddd Zddd d Zd S) GZipDecoderzW Handle 'gzip' decoding. See: https://stackoverflow.com/questions/1838699 rrcCsttjdB|_dS)N)r r!r'r"rrrrr#\szGZipDecoder.__init__rrc CsHz|j|WStjyB}ztt||WYd}~n d}~00dSr )r"r%r r&rr(rrr)rrrr_szGZipDecoder.decodec CsFz |jWStjy@}ztt||WYd}~n d}~00dSr r*r+rrrres zGZipDecoder.flushNr,rrrrr-Usr-c@s<eZdZdZddddZddddd Zddd d Zd S) BrotliDecoderaT Handle 'brotli' decoding. Requires `pip install brotlipy`. See: https://brotlipy.readthedocs.io/ or `pip install brotli`. See https://github.com/google/brotli Supports both 'brotlipy' and 'Brotli' packages since they share an import name. The top branches are for 'brotlipy' and bottom branches for 'Brotli' rrcCsLtdurtddt|_d|_|t|jdr>|jj|_n |jj|_dS)NzUsing 'BrotliDecoder', but neither of the 'brotlicffi' or 'brotli' packages have been installed. Make sure to install httpx using `pip install httpx[brotli]`.Fr%) brotli ImportErrorZ Decompressorr" seen_datahasattrr% _decompressprocessrrrrr#vs   zBrotliDecoder.__init__rrc CsT|sdSd|_z ||WStjyN}ztt||WYd}~n d}~00dSNrT)r3r5r1r&rr(r/rrrrs zBrotliDecoder.decodec Cs`|js dSzt|jdr"|jWdStjyZ}ztt||WYd}~n d}~00dS)Nrfinish)r3r4r"r8r1r&rr(r+rrrrs  zBrotliDecoder.flushNr,rrrrr0ls  r0c@s<eZdZdZddddZddddd Zddd d Zd S) ZStandardDecoderz Handle 'zstd' RFC 8878 decoding. Requires `pip install zstandard`. Can be installed as a dependency of httpx using `pip install httpx[zstd]`. rrcCs*tdurtddt|_d|_dS)NzXUsing 'ZStandardDecoder', ...Make sure to install httpx using `pip install httpx[zstd]`.F) zstandardr2ZstdDecompressorr!r"r3rrrrr#szZStandardDecoder.__init__rrc Cstdus Jd|_t}zP||j||jjrh|jjrh|jj}t |_||j|q.Wn4tj y}zt t ||WYd}~n d}~00|Sr)r:r3ioBytesIOwriter"r%eof unused_datar;r!Z ZstdErrorrr(getvalue)rroutputr@r)rrrrs $zZStandardDecoder.decodecCs,|js dS|j}|jjs$tdt|S)NrzZstandard data is incomplete)r3r"rr?rr)rretrrrrs  zZStandardDecoder.flushNr,rrrrr9s r9c@s>eZdZdZdddddZdddd d Zdd d d ZdS) MultiDecoderzE Handle the case where multiple encodings have been applied. ztyping.Sequence[ContentDecoder]r)childrenr cCstt||_dS)zm 'children' should be a sequence of decoders in the order in which each was applied. N)listreversedrE)rrErrrr#szMultiDecoder.__init__rrcCs|jD]}||}q|Sr )rErrrchildrrrrs  zMultiDecoder.decodercCs&d}|jD]}|||}q |Sr)rErrrHrrrrs zMultiDecoder.flushNr,rrrrrDsrDc@s@eZdZdZddddddZdd d d d Zd d ddZdS) ByteChunkerz> Handles returning byte content in fixed-size chunks. N int | Noner chunk_sizer cCst|_||_dSr )r<r=_buffer _chunk_sizerrMrrrr#s zByteChunker.__init__rz list[bytes]contentr csjdur|r|gSgSj|jjkrjfddtdtjD}t|djkrjdj|Sjdj|dj|ddSngSdS)Ncsg|]}||jqSrrO.0irvaluerr sz&ByteChunker.decode..r rOrNr>tellrArangelenseektruncaterrRchunksrrWrrs"        zByteChunker.decodercCs.|j}|jd|j|r*|gSgSNrrNrAr_r`rWrrrrs   zByteChunker.flush)Nr,rrrrrJsrJc@s@eZdZdZddddddZdd d d d Zd d ddZdS) TextChunkerz> Handles returning text content in fixed-size chunks. NrKrrLcCst|_||_dSr )r<StringIOrNrOrPrrrr#s zTextChunker.__init__r( list[str]rQcsjdur|r|gSgSj|jjkrjfddtdtjD}t|djkrjdj|Sjdj|dj|ddSngSdS)Ncsg|]}||jqSrrSrTrWrrrYsz&TextChunker.decode..rrZr[rarrWrrs"        zTextChunker.decodercCs.|j}|jd|j|r*|gSgSrcrdrWrrrr+s   zTextChunker.flush)Nr,rrrrre srec@s@eZdZdZddddddZddd d d Zdd d dZdS) TextDecoderz8 Handles incrementally decoding bytes into text utf-8r(r)encodingr cCst|dd|_dS)Nreplace)errors)codecsgetincrementaldecoderdecoder)rrjrrrr#7szTextDecoder.__init__rrcCs |j|Sr rorr rrrr:szTextDecoder.decodercCs|jddSr7rprrrrr=szTextDecoder.flushN)rir,rrrrrh2srhc@s<eZdZdZddddZdddd d Zddd d Zd S) LineDecoderz Handles incrementally reading lines from text. Has the same behaviour as the stdllib splitlines, but handling the input iteratively. rrcCsg|_d|_dSr$)buffer trailing_crrrrrr#IszLineDecoder.__init__r(rg)textr cCsd}|jrd|}d|_|dr4d|_|dd}|ssL          5*''=