i-UddlZddlZddlZddlmZmZddlmZddlm Z m Z m Z m Z m Z mZejdkrddlmZnddlmZeeedd fZ ddlZn#e$rddlZYnwxYwd Zn #e$rd ZYnwxYw ejd krdd lmZndd lmZd Zn #e$rd ZYnwxYwdZdZdZdZ 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-Z1dS).N)ABCabstractmethod)Executor)AnyFinalOptionalProtocol TypedDictcast) )Buffer)Unionzmemoryview[int]zmemoryview[bytes]TF)r )ZstdDecompressoriic0eZdZdedefdZddedefdZdS) ZLibCompressObjProtocoldatareturncdSNselfrs ^/home/mmwave/public_html/mmwave/venv/lib/python3.11/site-packages/aiohttp/compression_utils.pycompressz ZLibCompressObjProtocol.compress-.modecdSrrrr s rflushzZLibCompressObjProtocol.flush.rrN.)__name__ __module__ __qualname__rbytesrintr#rrrrr,s?2V2222255#55555555rrcReZdZd dededefdZd dedefdZede fdZ d S) ZLibDecompressObjProtocol.r max_lengthrcdSrrrrr,s r decompressz$ZLibDecompressObjProtocol.decompress2rrlengthcdSrrrr0s rr#zZLibDecompressObjProtocol.flush3rrcdSrrrs reofzZLibDecompressObjProtocol.eof5s3rNr$) r%r&r'rr)r(r/r#propertyboolr5rrrr+r+1sbKKvK3KKKKK77C7U7777 TXrr+ceZdZUeed<eed<eed<eed<eed< ddeded ed ed ed eed efdZ dd ed ed e fdZ dded eded e fdZ dd ededed e fdZ dS)ZLibBackendProtocol MAX_WBITS Z_FULL_FLUSH Z_SYNC_FLUSH Z_BEST_SPEEDZ_FINISH.levelmethodwbitsmemLevelstrategyzdictrcdSrr)rr?r@rArBrCrDs r compressobjzZLibBackendProtocol.compressobj@s #&#rcdSrr)rrArDs r decompressobjz!ZLibBackendProtocol.decompressobjIs$'CrrcdSrr)rrr?rAs rrzZLibBackendProtocol.compressMrbufsizecdSrr)rrrArKs rr/zZLibBackendProtocol.decompressPrJrN)......)..)r%r&r'r)__annotations__rrrrFr+rHr(rr/rrrr9r99swNNNMMM"%&&&& &  &  && !&&&&14((('-( "(((( ?B&)8; AD&):= rr9c.eZdZUeed<eed<eed<dS)CompressObjArgsrArCr?N)r%r&r'r)rMrrrrOrOUs+ JJJMMM JJJJJrrO)totalc*eZdZdefdZedefdZedefdZ edefdZ edefdZ edefdZ edefd Z d ed edefd Zd ed edefd Zded ed edefdZded ed edefdZdedefdZdS)ZLibBackendWrapper _zlib_backendc||_dSr)rS)rrSs r__init__zZLibBackendWrapper.__init__\s2?rrc.t|jddS)Nr% undefinedgetattrrSr4s rnamezZLibBackendWrapper.name_st):{CCCrc|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!/@@@@rrc.|jj|g|Ri|Sr)rSrrrrarbs rrzZLibBackendWrapper.compress}s(*t!*4A$AAA&AAArc.|jj|g|Ri|Sr)rSr/rgs rr/zZLibBackendWrapper.decompresss(,t!,TCDCCCFCCCrattrnamec,t|j|SrrX)rris r __getattr__zZLibBackendWrapper.__getattr__st)8444rN)r%r&r'r9rUr6strrZr)r:r;r<r=r>rrrFr+rHrr(rr/rkrrrrRrR[s@&9@@@@DcDDDXD,3,,,X,/c///X//c///X//c///X/+#+++X+???8O????A3A#A:SAAAABVBCB3B5BBBBDvDcDSDUDDDD5C5C555555rrR ZLibBackendnew_zlib_backendrc|t_dSr)rmrS)rns rset_zlib_backendrps 0Krencodingsuppress_deflate_headercb|dkrdtjzS|r tj n tjS)Ngzip)rmr:)rqrrs rencoding_to_modervs66K)))%< WK ! ! !+BWWrc|eZdZdefdeedeefdZee fde dede fdZ e fde dede fd Z dS) DecompressionBaseHandlerNexecutormax_sync_chunk_sizec"||_||_dS)z&Base class for decompression handlers.N) _executor_max_sync_chunk_size)rryrzs rrUz!DecompressionBaseHandler.__init__s "$7!!!rrr,rcdSDecompress the given data.Nrr.s rdecompress_syncz(DecompressionBaseHandler.decompress_syncrrcK|jQt||jkr9tj|j|j||d{VS|||Sr)r}lenasyncioget_event_looprun_in_executorr|rr.s rr/z#DecompressionBaseHandler.decompresss  % 1D D555 /11AA 4dJ ##D*555r) r%r&r'MAX_SYNC_CHUNK_SIZErrr)rUrZLIB_MAX_LENGTH_UNLIMITEDr(rr/rrrrxrxs(,-@888$8&c]8888-F)))'*) )))^) .G 6 6 6'* 6  6 6 6 6 6 6rrxceZdZddddddefdeededeedeedeedeed eefd Z d e d e fd Z d e d e fdZ ddeed e fdZ dS)ZLibCompressorNFrqrrr?rArCryrzc||_||_|t||n||_t t j|_i}|j|d<|||d<|||d<|jjdi||_dS)NrArCr?r) r|r}rv_moderRrmrSrF _compressor) rrqrrr?rArCryrzrbs rrUzZLibCompressor.__init__s"$7!} X'> ? ? ? %7{7P$Q$Q"$*w  !)F:   #F7O94-9CCFCCrrrc6|j|Sr)rrrs r compress_synczZLibCompressor.compress_syncs((...rcK|jduot||jk}|r=tj|j|jj|d{VS||S)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 D55    133CC 0 94 !!$'''rr cR|j||n |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.flushs1%%$DD$*<*E   rr)r%r&r'rrrlr7r)rrUr(rrr#rrrrrs#'(-##"&'+-@DD3-D"&D} D } D 3- D8$D&c]DDDD6/%/E////(5(U((((8   (3-  5       rrc eZdZdddefdeededeedeeffd Z e fde d ed e fd Z dd ed e fdZed efdZxZS)ZLibDecompressorNFrqrrryrzct||t|||_t t j|_|j|j|_dS)Nryrz)rA) superrUrvrrRrmrSrH _decompressor)rrqrrryrz __class__s rrUzZLibDecompressor.__init__sl (@STTT%h0GHH $6{7P$Q$Q!/==DJ=OOrrr,rc8|j||Sr)rr/r.s rrz ZLibDecompressor.decompress_syncs!,,T:>>>rrr0ct|dkr|j|n|jS)Nr)rr#r2s rr#zZLibDecompressor.flushs=zz   $ $V , , ,#))++ rc|jjSr)rr5r4s rr5zZLibDecompressor.eofs!%%r)r)r%r&r'rrrlr7rr)rUrrr(rr#r6r5 __classcell__rs@rrrs#'(-'+-@ P P3- P"& P8$ P &c] P P P P P P/H???(+? ????   C     &T&&&X&&&&&rrcneZdZdefdeedeeddffd Zefde dede fdZ de fd Z xZ S) BrotliDecompressorNryrzrctstdtj|_t ||dS)z)Decompress data using the Brotli library.zIThe brotli decompression is not available. Please install `Brotli` modulerN) HAS_BROTLI RuntimeErrorbrotli Decompressor_objrrUrryrzrs rrUzBrotliDecompressor.__init__$sZ  1 '))  (@STTTTTrrr,ct|jdr.tt|j||Stt|j||S)rr/)hasattrrr r(r/processr.s rrz"BrotliDecompressor.decompress_sync2s] 49l + + Gty33D*EEFF FE49,,T:>>???rct|jdr,tt|jSdS)zFlush the decompressor.r#r)rrr r(r#r4s rr#zBrotliDecompressor.flush:s7 49g & & 2ty0011 1sr)r%r&r'rrrr)rUrrr(rr#rrs@rrr s (,-@ U U8$ U&c] U  U U U U U U/H@@@(+@ @@@@urrcneZdZdefdeedeeddffd Zefde dede fdZ de fd Z xZ S) ZSTDDecompressorNryrzrctstdt|_t ||dS)NzOThe zstd decompression is not available. Please install `backports.zstd` moduler)HAS_ZSTDrrrrrUrs rrUzZSTDDecompressor.__init__BsW  9 %&&  (@STTTTTrrr,c`|tkrtn|}|j||Sr)rZSTD_MAX_LENGTH_UNLIMITEDrr/)rrr,zstd_max_lengths rrz ZSTDDecompressor.decompress_syncOs:666 & %  y##D/:::rcdS)Nrrr4s rr#zZSTDDecompressor.flush[ssr) r%r&r'rrrr)rUrr(rr#rrs@rrrAs(,-@ U U8$ U&c] U  U U U U U U.G ; ; ;'* ;  ; ; ; ;urr)NF)2rsyszlibabcrrconcurrent.futuresrtypingrrrr r r version_infocollections.abcrrr( bytearray brotlicffir ImportErrorrcompression.zstdrbackports.zstdrrDEFAULT_MAX_DECOMPRESS_SIZErrrr+r9rOrRrmrMrprlr7r)rvrxrrrrrrrrs ########''''''BBBBBBBBBBBBBBBBw&&&&&&& 5)%68KK LF#####  JJJJJ 7""5555555333333HHHHH#66666h666 (8iu *5*5*5*5*5*5*5*5Z#5"4T":": :::1':1t1111 #$)XXsmX!X XXXX66666s666