rj-zUddlZddlZddlZddlmZmZddlmZddlm Z m Z m Z m Z m Z mZejdk\rddlmZnddlmZeeedd fZ ddlZd Z ejd k\rdd lmZndd lmZd ZdZdZdZdZ Gdde Z!Gdde Z"Gdde Z#Gdde d Z$GddZ%e%eZ&e%e'd<de#ddfdZ( d-d e e)d!e*de+fd"Z,Gd#d$eZ-Gd%d&Z.Gd'd(e-Z/Gd)d*e-Z0Gd+d,e-Z1y#e$rddlZYwxYw#e$rd ZYwxYw#e$rd ZYwxYw).N)ABCabstractmethod)Executor)AnyFinalOptionalProtocol TypedDictcast) )Buffer)Unionzmemoryview[int]zmemoryview[bytes]TF)r )ZstdDecompressoriic.eZdZdedefdZddedefdZy)ZLibCompressObjProtocoldatareturncyNselfrs F/DATA/.local/lib/python3.12/site-packages/aiohttp/compression_utils.pycompressz ZLibCompressObjProtocol.compress-ssmodecyrrrrs rflushzZLibCompressObjProtocol.flush.s#rN.)__name__ __module__ __qualname__rbytesrintr"rrrrr,s2V225#555rrcJeZdZd dededefdZd dedefdZede fdZ y) ZLibDecompressObjProtocolr max_lengthrcyrrrrr+s r decompressz$ZLibDecompressObjProtocol.decompress2srlengthcyrrrr/s rr"zZLibDecompressObjProtocol.flush3sCrcyrrrs reofzZLibDecompressObjProtocol.eof5srNr#) r$r%r&rr(r'r.r"propertyboolr4rrrr*r*1s4KvK3KK7C7U7 Trr*ceZdZUeed<eed<eed<eed<eed< ddededed ed ed eed efd Z dded ed e fdZ ddededed e fdZ ddededed e fdZ y)ZLibBackendProtocol MAX_WBITS Z_FULL_FLUSH Z_SYNC_FLUSH Z_BEST_SPEEDZ_FINISHlevelmethodwbitsmemLevelstrategyzdictrcyrr)rr>r?r@rArBrCs r compressobjzZLibBackendProtocol.compressobj@s#&rcyrr)rr@rCs r decompressobjz!ZLibBackendProtocol.decompressobjIs$'rrcyrr)rrr>r@s rrzZLibBackendProtocol.compressMrbufsizecyrr)rrr@rJs rr.zZLibBackendProtocol.decompressPrIrN)......)..)r$r%r&r(__annotations__rrrrEr*rGr'rr.rrrr8r89sNM"%&&& &  &  && !&14(('-( "( ?B&)8; AD&):= rr8c,eZdZUeed<eed<eed<y)CompressObjArgsr@rBr>N)r$r%r&r(rLrrrrNrNUs JM JrrN)totalceZdZdefdZedefdZedefdZ edefdZ edefdZ edefdZ edefd Z d ed edefd Zd ed edefd Zded ed edefdZded ed edefdZdedefdZy)ZLibBackendWrapper _zlib_backendc||_yr)rR)rrRs r__init__zZLibBackendWrapper.__init__\s 2?rrc0t|jddS)Nr$ undefinedgetattrrRr3s rnamezZLibBackendWrapper.name_st)):{CCrc.|jjSr)rRr9r3s rr9zZLibBackendWrapper.MAX_WBITScs!!+++rc.|jjSr)rRr:r3s rr:zZLibBackendWrapper.Z_FULL_FLUSHg!!...rc.|jjSr)rRr;r3s rr;zZLibBackendWrapper.Z_SYNC_FLUSHkr\rc.|jjSr)rRr<r3s rr<zZLibBackendWrapper.Z_BEST_SPEEDor\rc.|jjSr)rRr=r3s rr=zZLibBackendWrapper.Z_FINISHss!!***rargskwargsc:|jj|i|Sr)rRrErr`ras rrEzZLibBackendWrapper.compressobjws -t!!--t>v>>rc:|jj|i|Sr)rRrGrcs rrGz ZLibBackendWrapper.decompressobjzs /t!!//@@@rrcB|jj|g|i|Sr)rRrrrr`ras rrzZLibBackendWrapper.compress}s%*t!!**4A$A&AArcB|jj|g|i|Sr)rRr.rfs rr.zZLibBackendWrapper.decompresss%,t!!,,TCDCFCCrattrnamec.t|j|SrrW)rrhs r __getattr__zZLibBackendWrapper.__getattr__st))844rN)r$r%r&r8rTr5strrYr(r9r:r;r<r=rrrEr*rGrr'rr.rjrrrrQrQ[sO@&9@DcDD,3,,/c///c///c//+#++???8O?A3A#A:SABVBCB3B5BDvDcDSDUD5C5C5rrQ ZLibBackendnew_zlib_backendrc|t_yr)rlrR)rms rset_zlib_backendros 0Krencodingsuppress_deflate_headercx|dk(rdtjzS|rtj StjS)Ngzip)rlr9)rprqs rencoding_to_moderus96K))))%r@rBrxryc||_||_| t||n||_t t j |_i}|j|d<|||d<|||d<|j jdi||_y)Nr@rBr>r) r{r|ru_moderQrlrRrE _compressor) rrprqr>r@rBrxryras rrTzZLibCompressor.__init__s"$7!} X'> ? %7{7P7P$Q"$**w  !)F:   #F7O94--99CFCrrrc8|jj|Sr)rrrs r compress_synczZLibCompressor.compress_syncs((..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) r|rrget_running_looprr{rrr)rrshould_use_executors rrzZLibCompressor.compresss&  % %T 1 6D D555   113CC 0 0 9 94 !!$''sA1B 3B 4B rcp|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"rRr=r!s rr"zZLibCompressor.flushs>%%$D  *.*<*<*E*E  rr)r$r%r&rrrkr6r(rrTr'rrr"rrrrrs#'(-##"&'+-@D3-D"&D} D } D 3- D8$D&c]D6/%/E/(5(U(8  (3-  5  rrc eZdZdddefdeededeedeeffd Z e fde d ed e fd Z dd ed e fd Zed efdZxZS)ZLibDecompressorNFrprqrxryct|||t|||_t t j |_|j j|j|_y)Nrxry)r@) superrTrurrQrlrRrG _decompressor)rrprqrxry __class__s rrTzZLibDecompressor.__init__sZ (@ST%h0GH $6{7P7P$Q!//==DJJ=Orrr+rc:|jj||Sr)rr.r-s rrz ZLibDecompressor.decompress_syncs!!,,T:>>rr/cv|dkDr|jj|S|jjS)Nr)rr"r1s rr"zZLibDecompressor.flushs?z    $ $V , ##))+ rc.|jjSr)rr4r3s rr4zZLibDecompressor.eofs!!%%%r)r)r$r%r&rrrkr6rr(rTrrr'rr"r5r4 __classcell__rs@rrrs#'(-'+-@ P3- P"& P8$ P &c] P/H??(+? ?  C  &T&&rrcbeZdZdefdeedeeddffd Zefde dede fdZ de fd Z xZ S) BrotliDecompressorNrxryrc|ts tdtj|_t |||y)z)Decompress data using the Brotli library.zIThe brotli decompression is not available. Please install `Brotli` modulerN) HAS_BROTLI RuntimeErrorbrotli Decompressor_objrrTrrxryrs rrTzBrotliDecompressor.__init__$s? 1 '')  (@STrrr+ct|jdr*tt|jj ||Stt|jj ||S)rr.)hasattrrr r'r.processr-s rrz"BrotliDecompressor.decompress_sync2sN 499l +tyy33D*EF FE499,,T:>??rct|jdr(tt|jj Sy)zFlush the decompressor.r"r)rrr r'r"r3s rr"zBrotliDecompressor.flush:s+ 499g &tyy01 1r)r$r%r&rrrr(rTrrr'rr"rrs@rrr sl (,-@ U8$ U&c] U  U/H@@(+@ @urrcbeZdZdefdeedeeddffd Zefde dede fdZ de fd Z xZ S) ZSTDDecompressorNrxryrchts tdt|_t|||y)NzOThe zstd decompression is not available. Please install `backports.zstd` moduler)HAS_ZSTDrrrrrTrs rrTzZSTDDecompressor.__init__Bs9 9 %&  (@STrrr+c\|tk(rtn|}|jj||Sr)rZSTD_MAX_LENGTH_UNLIMITEDrr.)rrr+zstd_max_lengths rrz ZSTDDecompressor.decompress_syncOs366 &  yy##D/::rcy)Nrrr3s rr"zZSTDDecompressor.flush[sr) r$r%r&rrrr(rTrr'rr"rrs@rrrAsh(,-@ U8$ U&c] U  U.G ; ;'* ;  ;urr)NF)2rsyszlibabcrrconcurrent.futuresrtypingrrrr r r version_infocollections.abcrrr' bytearray brotlicffir ImportErrorrcompression.zstdrbackports.zstdrrDEFAULT_MAX_DECOMPRESS_SIZErrrr*r8rNrQrlrLrorkr6r(rurwrrrrrrrrs #'BBw& 5)%68KK LF#J 7"53H #6h6 (8iu *5*5Z#5T": :1':1t1 #$)XsmX!X X6s6