rPj IUddlZddlZddlZddlmZmZddlmZddlm Z m Z m Z m Z m Z mZmZej dk\rddlmZnddlmZeeedd fZ ddlZd Z ej d k\rdd lmZndd lmZd ZdZdZdZ dZ!dZ"dZ#Gdde$Z%Gdde Z&Gdde Z'Gdde Z(Gdde d Z)GddZ*e*eZ+e*e,d <d!e(d"dfd#Z- d8d$e.dzd%e/d"e0fd&Z1Gd'd(e Z2ed)e2*Z3Gd+d,eZ4Gd-d.e4e e3Z5Gd/d0Z6Gd1d2e5e'Z7Gd3d4e4Z8Gd5d6e5d7Z9y#e$rddlZYwxYw#e$rd ZYwxYw#e$rd ZYwxYw)9N)ABCabstractmethod)Executor)AnyFinalGenericProtocol TypedDictTypeVarcast) )Buffer)Unionzmemoryview[int]zmemoryview[bytes]TF)r ZstdDecompressori@iiceZdZdZy)TooManyMembersErrorz:A stream concatenated more members than the caller allows.N)__name__ __module__ __qualname____doc__^/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/aiohttp/compression_utils.pyrr6sDrrc.eZdZdedefdZddedefdZy)ZLibCompressObjProtocoldatareturncyNrselfr!s rcompressz ZLibCompressObjProtocol.compress;rmodecyr$rr&r)s rflushzZLibCompressObjProtocol.flush<r(rN.)rrrrbytesr'intr,rrrr r :s2V225#555rr cveZdZd dededefdZd dedefdZede fdZ edefdZ edefd Z y ) ZLibDecompressObjProtocolr! max_lengthr"cyr$rr&r!r2s r decompressz$ZLibDecompressObjProtocol.decompress@r(rlengthcyr$rr&r6s rr,zZLibDecompressObjProtocol.flushAr(rcyr$rr&s reofzZLibDecompressObjProtocol.eofCrcyr$rr:s runconsumed_tailz)ZLibDecompressObjProtocol.unconsumed_tailFs(+rcyr$rr:s r unused_dataz%ZLibDecompressObjProtocol.unused_dataI$'rNr-) rrrrr/r.r5r,propertyboolr;r>r@rrrr1r1?sZKvK3KK7C7U7 T +++ 'U''rr1ceZdZUeed<eed<eed<eed<eed< ddededed ed ed ed zd efdZ dded ed efdZ ddededed e fdZ ddededed e fdZ y )ZLibBackendProtocol MAX_WBITS Z_FULL_FLUSH Z_SYNC_FLUSH Z_BEST_SPEEDZ_FINISHlevelmethodwbitsmemLevelstrategyzdictNr"cyr$r)r&rKrLrMrNrOrPs r compressobjzZLibBackendProtocol.compressobjTs#&rcyr$r)r&rMrPs r decompressobjz!ZLibBackendProtocol.decompressobj]s$'rr!cyr$r)r&r!rKrMs rr'zZLibBackendProtocol.compressarbufsizecyr$r)r&r!rMrWs rr5zZLibBackendProtocol.decompressdrVr)......)..) rrrr/__annotations__rr rRr1rTr.r'r5rrrrErEMsNM"&&& &  &  &}& !&14(('-( "( ?B&)8; AD&):= rrEc,eZdZUeed<eed<eed<y)CompressObjArgsrMrOrKN)rrrr/rYrrrr[r[is JM Jrr[)totalceZdZdefdZedefdZedefdZ edefdZ edefdZ edefdZ edefd Z d ed edefd Zd ed edefd Zded ed edefdZded ed edefdZdedefdZy)ZLibBackendWrapper _zlib_backendc||_yr$)r_)r&r_s r__init__zZLibBackendWrapper.__init__ps 2?rr"c0t|jddS)Nr undefinedgetattrr_r:s rnamezZLibBackendWrapper.namesst)):{CCrc.|jjSr$)r_rFr:s rrFzZLibBackendWrapper.MAX_WBITSws!!+++rc.|jjSr$)r_rGr:s rrGzZLibBackendWrapper.Z_FULL_FLUSH{!!...rc.|jjSr$)r_rHr:s rrHzZLibBackendWrapper.Z_SYNC_FLUSHrirc.|jjSr$)r_rIr:s rrIzZLibBackendWrapper.Z_BEST_SPEEDrirc.|jjSr$)r_rJr:s rrJzZLibBackendWrapper.Z_FINISHs!!***rargskwargsc:|jj|i|Sr$)r_rRr&rmrns rrRzZLibBackendWrapper.compressobjs -t!!--t>v>>rc:|jj|i|Sr$)r_rTrps rrTz ZLibBackendWrapper.decompressobjs /t!!//@@@rr!cB|jj|g|i|Sr$)r_r'r&r!rmrns rr'zZLibBackendWrapper.compresss%*t!!**4A$A&AArcB|jj|g|i|Sr$)r_r5rss rr5zZLibBackendWrapper.decompresss%,t!!,,TCDCFCCrattrnamec.t|j|Sr$rd)r&rus r __getattr__zZLibBackendWrapper.__getattr__st))844rN)rrrrErarBstrrfr/rFrGrHrIrJrr rRr1rTrr.r'r5rwrrrr^r^osO@&9@DcDD,3,,/c///c///c//+#++???8O?A3A#A:SABVBCB3B5BDvDcDSDUD5C5C5rr^ ZLibBackendnew_zlib_backendr"c|t_yr$)ryr_)rzs rset_zlib_backendr|s 0Krencodingsuppress_deflate_headercx|dk(rdtjzS|rtj StjS)Ngzip)ryrF)r}r~s rencoding_to_moders96K))))% u:"C N"!!%%1 33-:12(<&*%;%;%="*T__,#h.Q;05io0FD-cFlC N3C&&11)C2DfME U#CJ&!!%%C 2 2 > >??VaZ):;AC N"Dxxr) rrrrr/rYrrr.rrrrrrrrsVO"")-%$,-9?99,,C,E,rrceZdZddddddefdedzdededzdedzdedzdedzd edzfd Zd e d e fd Z d e d e fdZ ddedzd e fdZ y)ZLibCompressorNFr}r~rKrMrOrrc||_||_| t||n||_t t j |_i}|j|d<|||d<|||d<|j jdi||_y)NrMrOrKr) rrr_moder^ryr_rR _compressor) r&r}r~rKrMrOrrrns rrazZLibCompressor.__init__!s"$7!} X'> ? %7{7P7P$Q"$**w  !)F:   #F7O94--99CFCrr!r"c8|jj|Sr$)rr'r%s r compress_synczZLibCompressor.compress_sync<s((..rcK|jduxrt||jkD}|rKtjj |j |j j|d{S|j|S7w)aCompress the data and returned the compressed bytes. Note that flush() must be called after the last call to compress() If the data size is large than the max_sync_chunk_size, the compression will be done in the executor. Otherwise, the compression will be done in the event loop. **WARNING: This method is NOT cancellation-safe when used with flush().** If this operation is cancelled, the compressor state may be corrupted. The connection MUST be closed after cancellation to avoid data corruption in subsequent compress operations. For cancellation-safe compression (e.g., WebSocket), the caller MUST wrap compress() + flush() + send operations in a shield and lock to ensure atomicity. N) rrrget_running_looprrrr'r)r&r!should_use_executors rr'zZLibCompressor.compress?s&  % %T 1 6D D555   113CC 0 0 9 94 !!$''sA1B 3B 4B r)cp|jj||S|jjS)a Flush the compressor synchronously. **WARNING: This method is NOT cancellation-safe when called after compress().** The flush() operation accesses shared compressor state. If compress() was cancelled, calling flush() may result in corrupted data. The connection MUST be closed after compress() cancellation. For cancellation-safe compression (e.g., WebSocket), the caller MUST wrap compress() + flush() + send operations in a shield and lock to ensure atomicity. )rr,r_rJr+s rr,zZLibCompressor.flush[s>%%$D  *.*<*<*E*E  rr$)rrrrrxrCr/rrarr.rr'r,rrrrr s $(-  #$(*=D*D"&DTz D Tz D * DT/D!4ZD6/&/U/(6(e(8  #*    rrc eZdZeZdddefdedzdededzde dzffd Z de fd Z efd e d e defd Zdd e defdZedefdZedefdZxZS)ZLibDecompressorNFr}r~rrct|||t|||_t t j |_|j|_d|_ y)NrrF) superrarrr^ryr_rr _last_empty)r&r}r~rr __class__s rrazZLibDecompressor.__init__nsS (@ST%h0GH $6{7P7P$Q!335 rr"cN|jj|jS)N)rM)r_rTrr:s rrz"ZLibDecompressor._new_decompressor{s !!//djj/AArr!r2c|j|jt|z}d|_|jj|jj|z|}|jj r(|jj r|j||}|dk(|_|jj r8|j|jjkDr|j|_|SNr) rr.rr5r>r;r@rrrr_rFrr&r!r2results rrz ZLibDecompressor.decompress_sync~s  $ $ 0,,uT{:D(,D %##..    . . 5z     ! !d&8&8&D&D--fjAF"S=    ! !djj43E3E3O3O&O!%!7!7!9D  rr6cv|dkDr|jj|S|jjS)Nr)rr,r8s rr,zZLibDecompressor.flushs?z    $ $V , ##))+ rc~t|jjxs|j xs|jduSr$)rCrr>rrr:s rrzZLibDecompressor.data_availablesA ##33 4 5### 5((4 rc.|jjSr$)rr;r:s rr;zZLibDecompressor.eofs!!%%%r)r)rrrrrrrxrCrr/rar1rrr.rr,rBrr; __classcell__rs@rrrks*J $(-$(*= !* !"& !T/ ! !4Z !B#<B/H(+ 4 C     &T&&rrcxeZdZdefdedzdedzddffd Zefdedede fdZ de fd Z e de fd ZxZS) BrotliDecompressorNrrr"cts tdtj|_d|_t |||y)z)Decompress data using the Brotli library.zIThe brotli decompression is not available. Please install `Brotli` moduleFrN) HAS_BROTLI RuntimeErrorbrotli Decompressor_objrrrar&rrrs rrazBrotliDecompressor.__init__sG 1 '')   (@STrr!r2ct|jdr^|tk(r*tt|jj |}ntt|jj ||}n]|tk(r*tt|jj |}n*tt|jj ||}|dk(|_|S)rr5r)hasattrrrr r.r5processrrs rrz"BrotliDecompressor.decompress_syncs 499l +66eTYY%9%9$%?@eTYY%9%9$ %KL66eTYY%6%6t%<=eTYY%6%6tZ%HI!S= rct|jdr(tt|jj Sy)zFlush the decompressor.r,r)rrr r.r,r:s rr,zBrotliDecompressor.flushs+ 499g &tyy01 1rcV|jj xr |j Sr$)r is_finishedrr:s rrz!BrotliDecompressor.data_availables&99((**C43C3C/CCr)rrrrrr/rarrr.rr,rBrCrrrs@rrrs %)*= UT/ U!4Z U  U /H(+ $u DDDrrceZdZeZdefdedzdedzddffd Zd dZ e fde dede fd Z de fd Zedefd ZxZS) ZSTDDecompressorNrrr"ctts tdt| |||j |_y)NzOThe zstd decompression is not available. Please install `backports.zstd` moduler)HAS_ZSTDrrrarrrs rrazZSTDDecompressor.__init__s@ 9  (@ST!335rctSr$rr:s rrz"ZSTDDecompressor._new_decompressors !!rr!r2cv|tk(rtn|}|j|j|z}d|_|jj ||}|jj r(|jj r|j||}|jj r|j|_|Sr$) rZSTD_MAX_LENGTH_UNLIMITEDrrr5r;r@rr)r&r!r2zstd_max_lengthrs rrz ZSTDDecompressor.decompress_syncs66 &   $ $ 0,,t3D(,D %##..t_E    ! !d&8&8&D&D--foFF    ! !!%!7!7!9D  rcyrrr:s rr,zZSTDDecompressor.flush src|jj xr|jj xs|jduSr$)r needs_inputr;rr:s rrzZSTDDecompressor.data_available sB"".. . Mt7I7I7M7M3M3  & &d 2 3r)r"r)rrrrrrrr/rarrrr.rr,rBrCrrrs@rrrs*J%)*= 6T/ 6!4Z 6  6"/H(+ 6u333rrr)NF):rsyszlibabcrrconcurrent.futuresrtypingrrrr r r r version_infocollections.abcrrr. bytearray brotlicffir ImportErrorrcompression.zstdrbackports.zstdrrrrrrr ValueErrorrr r1rEr[r^ryrYr|rxrCr/rrrrrrrrrrrrrs  #'JJJw& 5)%68KK LF#J 7"53H  E*E6h6 ( ((8iu *5*5Z#5T": :1':1t1  $)XDjX!X X(((+3NO Fs FF@!97?;S@FH H V>&12KL>&B-D1-D`5312DE53U JHsBEEE- EEEEE*)E*-E76E7