@g&dZddlmZddlZddlZddlZddlZddlmZddl m Z GddZ Gd d e Z Gd d e Z Gd de ZGdde ZGdde ZGddZGddZGddZGddZe ee edZeeddSdS)zq Handlers for Content-Encoding. See: https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Content-Encoding ) annotationsN)brotli) DecodingErrorceZdZddZddZdS) ContentDecoderdatabytesreturnctNNotImplementedErrorselfr s C/var/www/piapp/venv/lib/python3.11/site-packages/httpx/_decoders.pydecodezContentDecoder.decode!###ctr rrs rflushzContentDecoder.flushrrNr r r r r r )__name__ __module__ __qualname__rrrrrrs<$$$$$$$$$$rrc"eZdZdZddZd dZdS) IdentityDecoderz Handle unencoded data. r r r c|Sr rrs rrzIdentityDecoder.decodes rcdSNrrrs rrzIdentityDecoder.flush!ssrNrr)rrr__doc__rrrrrr r sFrr c*eZdZdZd dZd dZd dZd S) DeflateDecoderzZ Handle 'deflate' decoding. See: https://stackoverflow.com/questions/1838699 r NonecDd|_tj|_dS)NT) first_attemptzlib decompressobj decompressorrs r__init__zDeflateDecoder.__init__,s!! .00rr r c<|j}d|_ |j|S#tj$rb}|r>tjtj |_||cYd}~Stt||d}~wwxYwNF) r)r, decompressr*errorr+ MAX_WBITSrrstr)rr was_first_attemptexcs rrzDeflateDecoder.decode0s ." 3$//55 5z 3 3 3  )$($6$G$G!{{4((((((((C))s 2  3s *B:B3B9BBc |jS#tj$r"}t t ||d}~wwxYwr r,rr*r1rr3rr5s rrzDeflateDecoder.flush;S 3$**,, ,z 3 3 3C))s 2 3A AA Nr r'rrrrrr$r-rrrrrr&r&%sZ 1111 3 3 3 3333333rr&c*eZdZdZd dZd dZd dZd S) GZipDecoderzW Handle 'gzip' decoding. See: https://stackoverflow.com/questions/1838699 r r'cRtjtjdz|_dS)N)r*r+r2r,rs rr-zGZipDecoder.__init__Is" .t~/BCCrr r c |j|S#tj$r"}t t ||d}~wwxYwr )r,r0r*r1rr3rr r5s rrzGZipDecoder.decodeLsU 3$//55 5z 3 3 3C))s 2 3sA AA c |jS#tj$r"}t t ||d}~wwxYwr r7r8s rrzGZipDecoder.flushRr9r:Nr;rrr<rrrr>r>Bs^ DDDD3333 333333rr>c*eZdZdZd dZd dZd dZd 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' r r'cttddtj|_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]`.Fr0) r ImportError Decompressorr, seen_datahasattrr0 _decompressprocessrs rr-zBrotliDecoder.__init__cs >P   #/11 9 4$l 3 3 9#0;D    $08D   rr r c|sdSd|_ ||S#tj$r"}t t ||d}~wwxYwNrT)rIrKrr1rr3rBs rrzBrotliDecoder.decodeusf 3 3##D)) )| 3 3 3C))s 2 3s"AAAc|jsdS t|jdr|jdS#tj$r"}t t||d}~wwxYw)Nrfinish)rIrJr,rPrr1rr3r8s rrzBrotliDecoder.flush~s~~ 3 3t((33 + !((***3| 3 3 3C))s 2 3s.;A, A''A,Nr;rrr<rrrrErEYsZ9999$3333 3 3 3 3 3 3rrEc*eZdZdZd dZd d Zdd Zd S) MultiDecoderzE Handle the case where multiple encodings have been applied. childrentyping.Sequence[ContentDecoder]r r'cHtt||_dS)zm 'children' should be a sequence of decoders in the order in which each was applied. N)listreversedrS)rrSs rr-zMultiDecoder.__init__s Xh//00 rr r cD|jD]}||}|Sr )rSrrr childs rrzMultiDecoder.decodes+] & &E<<%%DD rcrd}|jD],}|||z}-|Sr#)rSrrrYs rrzMultiDecoder.flushs=] 6 6E<<%% 5DD rN)rSrTr r'rrr<rrrrRrRsZ1111 rrRc,eZdZdZd ddZdd Zdd ZdS) ByteChunkerz> Handles returning byte content in fixed-size chunks. N chunk_size int | Noner r'cDtj|_||_dSr )ioBytesIO_buffer _chunk_sizerr^s rr-zByteChunker.__init__sz|| %rcontentr list[bytes]cj|r|gngSj|jjkrjfdt dt jD}t |djkr5jdj|Sjdj|dj|ddSgS)Nc4g|]}||jzSrrd.0irvalues r z&ByteChunker.decode..;a!d.../rr rdrcwritetellgetvaluerangelenseektruncaterrfchunksrns` @rrzByteChunker.decodeE   # '/G99R / 7### <    $"2 2 2L))++Eq#e**d.>??F6":$"222 !!!$$$ %%'''  !!!$$$ ""6":... %%'''crc{"Irc|j}|jd|j|r|gngSNrrcrurxryrrns rrzByteChunker.flushP %%'' ! 'wwR'rr r^r_r r')rfr r rg)r rgr<rrrr]r]_&&&&&.((((((rr]c,eZdZdZd ddZdd Zdd ZdS) TextChunkerz> Handles returning text content in fixed-size chunks. Nr^r_r r'cDtj|_||_dSr )raStringIOrcrdres rr-zTextChunker.__init__s{}} %rrfr3 list[str]cj|r|gngSj|jjkrjfdt dt jD}t |djkr5jdj|Sjdj|dj|ddSgS)Nc4g|]}||jzSrrjrks rroz&TextChunker.decode..rprrrqrrrzs` @rrzTextChunker.decoder|rc|j}|jd|j|r|gngSr~rrs rrzTextChunker.flushrrr r)rfr3r rr rr<rrrrrrrrc,eZdZdZd ddZdd Zdd Zd S) TextDecoderz8 Handles incrementally decoding bytes into text utf-8encodingr3r r'cLtj|d|_dS)Nreplace)errors)codecsgetincrementaldecoderdecoder)rrs rr-zTextDecoder.__init__s%=v3H==YOOO rr r c6|j|Sr rrrs rrzTextDecoder.decodes|""4(((rc8|jddSrNrrs rrzTextDecoder.flushs|""3---rN)r)rr3r r')r r r r3)r r3r<rrrrrsdPPPPP))))......rrc*eZdZdZd dZd dZd 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'c"g|_d|_dSr/)buffer trailing_crrs rr-zLineDecoder.__init__ s!# !&rtextr3rcd}|jr d|z}d|_|drd|_|dd}|sgS|d|v}|}t|dkr$|s"|j|dgS|jr6d|j|dzg|ddz}g|_|s|g|_|S) Nu …

 FTrqrr)rendswith splitlinesrwrappendjoinpop)rr NEWLINE_CHARStrailing_newlineliness rrzLineDecoder.decodes B    %$;D$D  ==   #D 9D I8}4!! u::??#3? K  uQx ( ( (I ; WWT[))E!H45abb AEDK (!99;;-DK rcx|js |jsgSd|jg}g|_d|_|S)NrF)rrr)rrs rrzLineDecoder.flush6sE{ 4#3 I%%&   rNr;)rr3r rrr<rrrrrs[''''$$$$Lrr)identitygzipdeflatebrr)r$ __future__rrratypingr*_compatr _exceptionsrrr r&r>rErRr]rrrSUPPORTED_DECODERSrrrrrsL #""""" &&&&&&$$$$$$$$     n   33333^333:33333.333.2323232323N232323j>2$($($($($($($($(N$($($($($($($($(N . . . . . . . .99999999z    >4     >r