i-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 S/var/www/telegram/bot_env/lib/python3.12/site-packages/aiohttp/compression_utils.pycompressz ZLibCompressObjProtocol.compress-modecyrrrr s rflushzZLibCompressObjProtocol.flush.rrN.)__name__ __module__ __qualname__rbytesrintr#rrrrr,s2V225#555rrcJeZdZd dededefdZd dedefdZede fdZ y) ZLibDecompressObjProtocolr max_lengthrcyrrrrr,s r decompressz$ZLibDecompressObjProtocol.decompress2rrlengthcyrrrr0s rr#zZLibDecompressObjProtocol.flush3rrcyrrrs reofzZLibDecompressObjProtocol.eof5srNr$) r%r&r'rr)r(r/r#propertyboolr5rrrr+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@rArBrCrDs r compressobjzZLibBackendProtocol.compressobj@s#&rcyrr)rrArDs r decompressobjz!ZLibBackendProtocol.decompressobjIs$'rrcyrr)rrr?rAs rrzZLibBackendProtocol.compressMrbufsizecyrr)rrrArKs rr/zZLibBackendProtocol.decompressPrJrN)......)..)r%r&r'r)__annotations__rrrrFr+rHr(rr/rrrr9r99sNM"%&&& &  &  && !&14(('-( "( ?B&)8; AD&):= rr9c,eZdZUeed<eed<eed<y)CompressObjArgsrArCr?N)r%r&r'r)rMrrrrOrOUs JM JrrO)totalceZdZdefdZedefdZedefdZ edefdZ edefdZ edefdZ edefd Z d ed edefd Zd ed edefd Zded ed edefdZded ed edefdZdedefdZy)ZLibBackendWrapper _zlib_backendc||_yr)rS)rrSs r__init__zZLibBackendWrapper.__init__\s 2?rrc0t|jddS)Nr% undefinedgetattrrSr4s rnamezZLibBackendWrapper.name_st)):{CCrc.|jjSr)rSr:r4s rr:zZLibBackendWrapper.MAX_WBITScs!!+++rc.|jjSr)rSr;r4s rr;zZLibBackendWrapper.Z_FULL_FLUSHg!!...rc.|jjSr)rSr<r4s rr<zZLibBackendWrapper.Z_SYNC_FLUSHkr]rc.|jjSr)rSr=r4s rr=zZLibBackendWrapper.Z_BEST_SPEEDor]rc.|jjSr)rSr>r4s rr>zZLibBackendWrapper.Z_FINISHss!!***rargskwargsc:|jj|i|Sr)rSrFrrarbs rrFzZLibBackendWrapper.compressobjws -t!!--t>v>>rc:|jj|i|Sr)rSrHrds rrHz ZLibBackendWrapper.decompressobjzs /t!!//@@@rrcB|jj|g|i|Sr)rSrrrrarbs rrzZLibBackendWrapper.compress}s%*t!!**4A$A&AArcB|jj|g|i|Sr)rSr/rgs rr/zZLibBackendWrapper.decompresss%,t!!,,TCDCFCCrattrnamec.t|j|SrrX)rris r __getattr__zZLibBackendWrapper.__getattr__st))844rN)r%r&r'r9rUr6strrZr)r:r;r<r=r>rrrFr+rHrr(rr/rkrrrrRrR[sO@&9@DcDD,3,,/c///c///c//+#++???8O?A3A#A:SABVBCB3B5BDvDcDSDUD5C5C5rrR ZLibBackendnew_zlib_backendrc|t_yr)rmrS)rns rset_zlib_backendrps 0Krencodingsuppress_deflate_headercx|dk(rdtjzS|rtj StjS)Ngzip)rmr:)rqrrs rencoding_to_modervs96K))))% ? %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 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#rSr>r"s rr#zZLibCompressor.flushs>%%$D  *.*<*<*E*E  rr)r%r&r'rrrlr7r)rrUr(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)ZLibDecompressorNFrqrrryrzct|||t|||_t t j |_|j j|j|_y)Nryrz)rA) superrUrvrrRrmrSrH _decompressor)rrqrrryrz __class__s rrUzZLibDecompressor.__init__sZ (@ST%h0GH $6{7P7P$Q!//==DJJ=Orrr,rc:|jj||Sr)rr/r.s rrz ZLibDecompressor.decompress_syncs!!,,T:>>rr0cv|dkDr|jj|S|jjS)Nr)rr#r2s rr#zZLibDecompressor.flushs?z    $ $V , ##))+ rc.|jjSr)rr5r4s rr5zZLibDecompressor.eofs!!%%%r)r)r%r&r'rrrlr7rr)rUrrr(rr#r6r5 __classcell__rs@rrrs#'(-'+-@ P3- P"& P8$ P &c] P/H??(+? ?  C  &T&&rrcbeZdZdefdeedeeddffd Zefde dede fdZ de fd Z xZ S) BrotliDecompressorNryrzrc|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_objrrUrryrzrs rrUzBrotliDecompressor.__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#r4s rr#zBrotliDecompressor.flush:s+ 499g &tyy01 1r)r%r&r'rrrr)rUrrr(rr#rrs@rrr sl (,-@ U8$ U&c] U  U/H@@(+@ @urrcbeZdZdefdeedeeddffd Zefde dede fdZ de fd Z xZ S) ZSTDDecompressorNryrzrchts tdt|_t|||y)NzOThe zstd decompression is not available. Please install `backports.zstd` moduler)HAS_ZSTDrrrrrUrs rrUzZSTDDecompressor.__init__Bs9 9 %&  (@STrrr,c\|tk(rtn|}|jj||Sr)rZSTD_MAX_LENGTH_UNLIMITEDrr/)rrr,zstd_max_lengths rrz ZSTDDecompressor.decompress_syncOs366 &  yy##D/::rcy)Nrrr4s rr#zZSTDDecompressor.flush[sr) r%r&r'rrrr)rUrr(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+r9rOrRrmrMrprlr7r)rvrxrrrrrrrrs #'BBw& 5)%68KK LF#J 7"53H #6h6 (8iu *5*5Z#5T": :1':1t1 #$)XsmX!X X6s6