j<0UdZddlmZddlZddlZddlZddlZddlZddlZddl m Z  ddl Z n#e $r ddl Z n #e $rdZ YnwxYwYnwxYwejr"ejdkr ddlmZmZnddlmZmZded <n- ejdkr ddlmZmZnddlmZmZd Zn #e $rd ZYnwxYwd ZGd dejZGddZGddZGddeZGddeZGddeZGddeZGddeZGddeZ Gdd Z!Gd!d"Z"Gd#d$Z#Gd%d&Z$eeeeed'Z%d(ed)<e e%&d*ese%&d+dSdS),zq Handlers for Content-Encoding. See: https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Content-Encoding ) annotationsN) DecodingError))ZstdDecompressor ZstdErrorbool_zstandard_installedTFic6eZdZed dZd dZd dZd S) DecompressorreturnbytescdSNselfs >C:\Projects\DSCons\.venv\Lib\site-packages\httpx2\_decoders.pyunconsumed_tailzDecompressor.unconsumed_tail8s(+data max_lengthintcdSrr)rrrs r decompresszDecompressor.decompress;rcdSrrrs rflushzDecompressor.flush=rrNrr)rrrrrr)__name__ __module__ __qualname__propertyrrrrrrr r 7s> +++X+DDDD!!!!!!rr c*eZdZdZd dZdd Zdd Zd S)ZlibDecompressorz Drain a `zlib`/`gzip` decompressor in bounded pieces so a small compressed input cannot inflate to an unbounded buffer in a single call. decompressorr rNonec||_dSr)r')rr's r__init__zZlibDecompressor.__init__Fs(rrrtyping.Iterator[bytes]c#K|j|t}|r2|V|j|jjt}|0dSdSr)r'rMAX_DECODE_CHUNK_SIZEr)rr decompresseds rrzZlibDecompressor.decompressIsv(33D:OPP  r   ,778I8Y[pqqL r r r r rrc4|jSr)r'rrs rrzZlibDecompressor.flushOs &&(((rN)r'r rr(rrrr+r )r!r"r#__doc__r*rrrrrr&r&@s^ ))))rrrr ))))))rr&ceZdZddZd dZdS) ContentDecoderrrrr+ctrNotImplementedErrorrrs rdecodezContentDecoder.decodeT!###rctrr5rs rrzContentDecoder.flushWr9rNr0rr+)r!r"r#r8rrrrr3r3Ss<$$$$$$$$$$rr3c"eZdZdZd dZd dZdS) IdentityDecoderz Handle unencoded data. rrrr+c#K|VdSrrr7s rr8zIdentityDecoder.decode`s rc#KdEd{VdSNrrrs rrzIdentityDecoder.flushcs rNr0r;)r!r"r#r1r8rrrrr=r=[sFrr=c*eZdZdZd dZd dZd d Zd S)DeflateDecoderzZ Handle 'deflate' decoding. See: https://stackoverflow.com/questions/1838699 rr(c^d|_ttj|_dS)NT) first_attemptr&zlib decompressobjr'rs rr*zDeflateDecoder.__init__ns)!,T-?-A-ABBrrrr+c#zK|j}d|_ |j|Ed{VdS#tj$rw}|rMt tjtj |_||Ed{Vntt||Yd}~dSd}~wwxYwNF) rDr'rrEerrorr&rF MAX_WBITSr8rstr)rrwas_first_attemptexcs rr8zDeflateDecoder.decoders ." 7(33D99 9 9 9 9 9 9 9 9 9z 7 7 7  7$4T5G5X5X$Y$Y!;;t,,,,,,,,,,#CHH--36-,,,,, 7s 4B:A,B55B:c#K |jVdS#tj$r"}t t ||d}~wwxYwrr'rrErIrrKrrMs rrzDeflateDecoder.flush~c 3#))++ + + + + +z 3 3 3C))s 2 3!AA  ANrr(r0r;r!r"r#r1r*r8rrrrrBrBgs^ CCCC 7 7 7 7333333rrBc*eZdZdZd dZd dZd d Zd S) GZipDecoderzW Handle 'gzip' decoding. See: https://stackoverflow.com/questions/1838699 rr(clttjtjdz|_dS)N)r&rErFrJr'rs rr*zGZipDecoder.__init__s+,T-?QS@S-T-TUUrrrr+c#K |j|Ed{VdS#tj$r"}t t ||d}~wwxYwr)r'rrErIrrK)rrrMs rr8zGZipDecoder.decodesq 3(33D99 9 9 9 9 9 9 9 9 9z 3 3 3C))s 2 3s &AAAc#K |jVdS#tj$r"}t t ||d}~wwxYwrrOrPs rrzGZipDecoder.flushrQrRNrSr0r;rTrrrrVrVs^ VVVV3333 333333rrVc*eZdZdZd dZd dZd 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' rr(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]`.Fr) brotli ImportErrorr r' seen_datahasattrr _decompressprocessrs rr*zBrotliDecoder.__init__s >P   #/11 5 4$l 3 3 9#0;D    $08D   rrrr+c#K|sdSd|_ tdz}|||}|r|V|d|}|dSdS#tj$r"}t t ||d}~wwxYw)NT)output_buffer_limitr)r`r-rbr^rIrrK)rrrfr.rMs rr8zBrotliDecoder.decodes  F 3"71"< ++DFY+ZZL ^""""#//I\/]]  ^ ^ ^ ^ ^| 3 3 3C))s 2 3sAAB"A??Bc#K|jsdS t|jdr|jn4#tj$r"}t t||d}~wwxYwdEd{VdS)Nfinishr)r`rar'rhr^rIrrKrPs rrzBrotliDecoder.flushs~  F 3t((33 + !((***| 3 3 3C))s 2 3 s.<A- A((A-NrSr0r;rTrrrr\r\sZ9999$ 3 3 3 3      rr\c*eZdZdZd dZd dZd d Zd S)ZStandardDecoderznHandle 'zstd' RFC 8878 decoding. On Python 3.13 and below, this requires `pip install httpx2[zstd]`. rr(chtstddt|_d|_dS)NzXUsing 'ZStandardDecoder', ...Make sure to install httpx using `pip install httpx[zstd]`.F)r r_rr'r`rs rr*zZStandardDecoder.__init__s=# j -..rrrr+c#K|sdSd|_ |jjr"|jj|z}t |_ |j|t }|r?|V|jjs |jjrn"|jdt }|?|jjr |jjsdS|jj}t |_#t$r"}tt||d}~wwxYw)NTr) r`r'eof unused_datarrr- needs_inputr rrK)rrr.rMs rr8zZStandardDecoder.decodes7  F 3 $ 7(4t;$4$6$6! 7#0;;DBWXX "\&&&&(48I8M#'#4#?#?EZ#[#[L #\ )-$2C2OE(4$4$6$6! 7 3 3 3C))s 2 3sB(C9 C D#DDc#bK|jsdS|jjstddEd{VdS)NzZstandard data is incompleter)r`r'rmrrs rrzZStandardDecoder.flushsH~  F $ @ >?? ? rNrSr0r;rTrrrrjrjsZ 3333,rrjcReZdZUdZdZded<dd Zdd ZddZe ddZ dS) MultiDecoderzE Handle the case where multiple encodings have been applied. ztyping.ClassVar[int]max_decode_links encodingstyping.Sequence[str]rr(cd|D}t||jkrtd|jddt|D|_dS)zk 'encodings' should be the content codings in the order in which each was applied. c$g|] }|tv |SrSUPPORTED_DECODERS).0encodings r z)MultiDecoder.__init__..s#XXXEW9W9W89W9W9WrzCannot apply more than z content encodings.c6g|]}t|Srry)r{codings rr}z)MultiDecoder.__init__..s%.l.l.lPV/A&/I/K/K.l.l.lrN)lenrtrreversedchildren)rrucodingss rr*zMultiDecoder.__init__ sl YXIXXX w<<$/ / / d$:O d d dee e.l.lZbcjZkZk.l.l.l rrrr+c#Kt|f}|jD]}||j|}|Ed{VdSr)iterr_piper8)rrstreamschilds rr8zMultiDecoder.decodesY*.w--] 8 8Ejjw77GGrc#Ktd}|jD]B}tj||j||}C|Ed{VdSr@)rr itertoolschainrr8r)rrrs rrzMultiDecoder.flushsm*.r((] X XEodjjw&G&GWWGGrr80typing.Callable[[bytes], typing.Iterator[bytes]]upstreamc#6K|D]}||Ed{VdSrr)r8rchunks rrzMultiDecoder._pipe"sD  % %Eve}} $ $ $ $ $ $ $ $ % %rN)rurvrr(r0r;)r8rrr+rr+) r!r"r#r1rt__annotations__r*r8r staticmethodrrrrrrrrs./.... m m m m  %%%\%%%rrrc,eZdZdZd ddZdd Zdd ZdS) ByteChunkerz> Handles returning byte content in fixed-size chunks. N chunk_size int | Nonerr(cDtj|_||_dSr)ioBytesIO_buffer _chunk_sizerrs rr*zByteChunker.__init__0sz|| %rcontentr list[bytes]cj|r|gngSj|jjkrjfdt dt jD}t |djkr5jdj|Sjdj|dj|ddSgS)Nc4g|]}||jzSrrr{irvalues rr}z&ByteChunker.decode..;+fff!eAD$4 445fffrr rrwritetellgetvaluerangerseektruncaterrchunksrs` @rr8zByteChunker.decode43   # '/G99R / 7### <    $"2 2 2L))++EfffffuQE TXTd?e?efffF6":$"222 !!!$$$ %%'''  !!!$$$ ""6":... %%'''crc{"Irc|j}|jd|j|r|gngSNrrrrrrrs rrzByteChunker.flushHP %%'' ! 'wwR'rrrrrr()rrrr)rrrTrrrrr+_&&&&&(((((((rrc,eZdZdZd ddZdd Zdd ZdS) TextChunkerz> Handles returning text content in fixed-size chunks. Nrrrr(cDtj|_||_dSr)rStringIOrrrs rr*zTextChunker.__init__Ts{}} %rrrK list[str]cj|r|gngSj|jjkrjfdt dt jD}t |djkr5jdj|Sjdj|dj|ddSgS)Nc4g|]}||jzSrrrs rr}z&TextChunker.decode.._rrrrrrs` @rr8zTextChunker.decodeXrrc|j}|jd|j|r|gngSrrrs rrzTextChunker.flushlrrrr)rrKrrrrrTrrrrrOrrrc,eZdZdZd ddZdd Zdd Zd S) TextDecoderz8 Handles incrementally decoding bytes into text utf-8r|rKrr(cLtj|d|_dS)Nreplace)errors)codecsgetincrementaldecoderdecoder)rr|s rr*zTextDecoder.__init__xs%=v3H==YOOO rrrc6|j|Srrr8r7s rr8zTextDecoder.decode{s|""4(((rc8|jddS)NrTrrs rrzTextDecoder.flush~s|""3---rN)r)r|rKrr()rrrrK)rrKrTrrrrrssdPPPPP))))......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. rr(c"g|_d|_dSrH)buffer trailing_crrs rr*zLineDecoder.__init__s!# !&rtextrKrcd}|jr d|z}d|_|drd|_|dd}|sgS|d|v}|}t|dkr$|s"|j|dgS|jr6d|j|dzg|ddz}g|_|s|g|_|S) Nu …

 FTrrr)rendswith splitlinesrrappendjoinpop)rr NEWLINE_CHARStrailing_newlineliness rr8zLineDecoder.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.flushsE{ 4#3 I%%&   rNrS)rrKrrrrTrrrrrs[''''$$$$Lrr)identitygzipdeflatebrzstdzdict[str, type[ContentDecoder]]rzrr)'r1 __future__rrrrsystypingrE _exceptionsrr^r_ brotlicffi TYPE_CHECKING version_infocompression.zstdrr backports.zstdrr r-Protocolr r&r3r=rBrVr\rjrrrrrrrzrrrrrsL #"""""  &&&&&& MMMM $####   % 7""@@@@@@@@@>>>>>>>>%  w & & D D D D D D D D D B B B B B B B B# %%%$%"""""6?"""))))))))&$$$$$$$$     n   33333^333<33333.333.77777N777t+++++~+++\$%$%$%$%$%>$%$%$%N!(!(!(!(!(!(!(!(H!(!(!(!(!(!(!(!(H . . . . . . . .99999999z    77 >4   #6"""""##sA.A 9A AA AA A 6BBB