o )if&@sdZddlmZddlZddlZddlZddlZddlmZddl m Z GdddZ Gd d d e Z Gd d d e Z Gd dde ZGddde ZGddde ZGdddZGdddZGdddZGdddZe ee edZedureddSdS)zq Handlers for Content-Encoding. See: https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Content-Encoding ) annotationsN)brotli) DecodingErrorc@s eZdZd ddZd ddZdS) ContentDecoderdatabytesreturncCtNNotImplementedErrorselfrrH/var/www/html/corbot_env/lib/python3.10/site-packages/httpx/_decoders.pydecodezContentDecoder.decodecCr r r rrrrflushrzContentDecoder.flushNrrr rr r)__name__ __module__ __qualname__rrrrrrrs rc@s$eZdZdZd ddZd ddZd S) IdentityDecoderz Handle unencoded data. rrr cCs|Sr rrrrrrzIdentityDecoder.decodecCsdSNrrrrrr!rzIdentityDecoder.flushNrr)rrr__doc__rrrrrrrs rc@.eZdZdZd ddZddd Zdd d Zd S)DeflateDecoderzZ Handle 'deflate' decoding. See: https://stackoverflow.com/questions/1838699 r NonecCsd|_t|_dS)NT) first_attemptzlib decompressobj decompressorrrrr__init__,szDeflateDecoder.__init__rrc Csn|j}d|_z|j|WStjy6}z|r+ttj |_||WYd}~Stt ||d}~wwNF) r#r& decompressr$errorr% MAX_WBITSrrstr)rrwas_first_attemptexcrrrr0szDeflateDecoder.decodec C6z|jWStjy}ztt||d}~wwr r&rr$r*rr,rr.rrrr;  zDeflateDecoder.flushNr r"rrrrrrr'rrrrrrr!%s    r!c@r ) GZipDecoderzW Handle 'gzip' decoding. See: https://stackoverflow.com/questions/1838699 r r"cCsttjdB|_dS)N)r$r%r+r&rrrrr'IzGZipDecoder.__init__rrc Cs8z|j|WStjy}ztt||d}~wwr )r&r)r$r*rr,rrr.rrrrLs zGZipDecoder.decodec Cr/r r0r1rrrrRr2zGZipDecoder.flushNr3rrr4rrrrr5Bs   r5c@r ) 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' r r"cCsNtdur tddt|_d|_|t|jdr |jj|_dS|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)) r ImportError Decompressorr& seen_datahasattrr) _decompressprocessrrrrr'cs  zBrotliDecoder.__init__rrc CsD|sdSd|_z||WStjy!}ztt||d}~wwNrT)r<r>rr*rr,r8rrrrus zBrotliDecoder.decodec CsP|jsdSzt|jdr|jWdStjy'}ztt||d}~ww)Nrfinish)r<r=r&rArr*rr,r1rrrr~s  zBrotliDecoder.flushNr3rrr4rrrrr9Ys   r9c@s.eZdZdZdddZdd d Zdd d ZdS) MultiDecoderzE Handle the case where multiple encodings have been applied. childrentyping.Sequence[ContentDecoder]r r"cCstt||_dS)zm 'children' should be a sequence of decoders in the order in which each was applied. N)listreversedrC)rrCrrrr'szMultiDecoder.__init__rrcCs|jD]}||}q|Sr )rCrrrchildrrrrs  zMultiDecoder.decodecCs&d}|jD] }|||}q|Sr)rCrrrGrrrrs zMultiDecoder.flushN)rCrDr r"rrr4rrrrrBs   rBc@0eZdZdZddddZdd d ZdddZdS) ByteChunkerz> Handles returning byte content in fixed-size chunks. N chunk_size int | Noner r"cCt|_||_dSr )ioBytesIO_buffer _chunk_sizerrKrrrr'  zByteChunker.__init__contentr list[bytes]cjdur |r |gSgSj|jjkr_jfddtdtjD}t|djkrFjdj|Sjdj|dj|ddSgS)Ncg|] }||jqSrrQ.0irvaluerr z&ByteChunker.decode..r rQrPwritetellgetvaluerangelenseektruncaterrTchunksrr\rr"         zByteChunker.decodecC.|j}|jd|j|r|gSgSNrrPrdrgrhr\rrrr   zByteChunker.flushr rKrLr r")rTrr rU)r rUr4rrrrrJ   rJc@rI) TextChunkerz> Handles returning text content in fixed-size chunks. NrKrLr r"cCrMr )rNStringIOrPrQrRrrrr'rSzTextChunker.__init__rTr, list[str]crV)NcrWrrXrYr\rrr^r_z&TextChunker.decode..rr`rarirr\rrrkzTextChunker.decodecCrlrmrnr\rrrrrozTextChunker.flushr rp)rTr,r rtr rtr4rrrrrrrqrrc@s0eZdZdZddddZdd d Zdd dZdS) TextDecoderz8 Handles incrementally decoding bytes into text utf-8encodingr,r r"cCst|dd|_dS)Nreplace)errors)codecsgetincrementaldecoderdecoder)rrxrrrr'r7zTextDecoder.__init__rrcCs |j|Sr r}rrrrrrs zTextDecoder.decodecCs|jddSr@r~rrrrrszTextDecoder.flushN)rw)rxr,r r")rrr r,)r r,r4rrrrrvs   rvc@s.eZdZdZdddZdd d Zdd d Zd S) LineDecoderz Handles incrementally reading lines from text. Has the same behaviour as the stdllib splitlines, but handling the input iteratively. r r"cCsg|_d|_dSr()buffer trailing_crrrrrr' s zLineDecoder.__init__textr,rtcCsd}|jr d|}d|_|drd|_|dd}|sgS|d|v}|}t|dkr:|s:|j|dgS|jrQd|j|dg|dd}g|_|sY|g|_|S) Nu …

 FTr`rr)rendswith splitlinesrfrappendjoinpop)rr NEWLINE_CHARStrailing_newlinelinesrrrrs(   " zLineDecoder.decodecCs.|js|jsgSd|jg}g|_d|_|S)NrF)rrr)rrrrrr6s zLineDecoder.flushNr3)rr,r rtrur4rrrrrs   &r)identitygzipdeflatebrr)r __future__rr{rNtypingr$_compatr _exceptionsrrrr!r5r9rBrJrrrvrSUPPORTED_DECODERSrrrrrs4    5''=