o LDi(@sUddlZddlZddlZddlmZddlmZmZmZm Z m Z m Z ej dkr/ddl mZnddlmZeeeddfZzzddlZWn eyQddlZYnwd ZWn ey`d ZYnwzej d krndd lmZndd lmZd ZWn eyd ZYnwd ZGddde ZGddde ZGddde ZGddde d dZGdddZeeZ ee!d<deddfddZ"  d,dee#de$de%fd d!Z&Gd"d#d#Z'Gd$d%d%e'Z(Gd&d'd'e'Z)Gd(d)d)Z*Gd*d+d+Z+dS)-N)Executor)AnyFinalOptionalProtocol TypedDictcast) )Buffer)Unionzmemoryview[int]zmemoryview[bytes]TF)r )ZstdDecompressoric@s2eZdZdedefddZd dedefddZd S) ZLibCompressObjProtocoldatareturncCdSNselfrrre/var/www/www-root/data/www/77.83.87.30/venv/lib/python3.10/site-packages/aiohttp/compression_utils.pycompress'z ZLibCompressObjProtocol.compress.modecCrrrrrrrrflush(rzZLibCompressObjProtocol.flushN.)__name__ __module__ __qualname__r bytesrintrrrrrr&src@sJeZdZd dededefddZd dedefdd Zede fd d Z d S)ZLibDecompressObjProtocol.r max_lengthrcCrrrrrr$rrr decompress,rz$ZLibDecompressObjProtocol.decompresslengthcCrrrrr'rrrr-rzZLibDecompressObjProtocol.flushcCrrrrrrreof/zZLibDecompressObjProtocol.eofNr) rrr r r"r!r&rpropertyboolr*rrrrr#+s r#c@seZdZUeed<eed<eed<eed<eed<      ddeded ed ed ed eed efddZ dd ed ed e fddZ dded eded e fddZ dd ededed e fddZ dS)ZLibBackendProtocol MAX_WBITS Z_FULL_FLUSH Z_SYNC_FLUSH Z_BEST_SPEEDZ_FINISH.levelmethodwbitsmemLevelstrategyzdictrcCrrr)rr4r5r6r7r8r9rrr compressobj:szZLibBackendProtocol.compressobjcCrrr)rr6r9rrr decompressobjCz!ZLibBackendProtocol.decompressobjrcCrrr)rrr4r6rrrrGr<zZLibBackendProtocol.compressbufsizecCrrr)rrr6r=rrrr&Jr<zZLibBackendProtocol.decompressN)......)..)rrr r"__annotations__rr rr:r#r;r!rr&rrrrr.3sn     r.c@s&eZdZUeed<eed<eed<dS)CompressObjArgsr6r8r4N)rrr r"r>rrrrr?Os  r?)totalc@seZdZdefddZedefddZedefddZ edefd d Z edefd d Z edefd dZ edefddZ dededefddZdededefddZdedededefddZdedededefddZdedefddZdS) ZLibBackendWrapper _zlib_backendcCs ||_dSr)rB)rrBrrr__init__V zZLibBackendWrapper.__init__rcCst|jddS)Nr undefinedgetattrrBr)rrrnameYszZLibBackendWrapper.namecC|jjSr)rBr/r)rrrr/]zZLibBackendWrapper.MAX_WBITScCrIr)rBr0r)rrrr0arJzZLibBackendWrapper.Z_FULL_FLUSHcCrIr)rBr1r)rrrr1erJzZLibBackendWrapper.Z_SYNC_FLUSHcCrIr)rBr2r)rrrr2irJzZLibBackendWrapper.Z_BEST_SPEEDcCrIr)rBr3r)rrrr3mrJzZLibBackendWrapper.Z_FINISHargskwargscO|jj|i|Sr)rBr:rrKrLrrrr:qzZLibBackendWrapper.compressobjcOrMr)rBr;rNrrrr;trOz ZLibBackendWrapper.decompressobjrcO|jj|g|Ri|Sr)rBrrrrKrLrrrrwzZLibBackendWrapper.compresscOrPr)rBr&rQrrrr&zrRzZLibBackendWrapper.decompressattrnamecCs t|j|SrrF)rrSrrr __getattr__~ zZLibBackendWrapper.__getattr__N)rrr r.rCr,strrHr"r/r0r1r2r3rrr:r#r;r r!rr&rTrrrrrAUs&rA ZLibBackendnew_zlib_backendrcCs |t_dSr)rWrB)rXrrrset_zlib_backendrDrYencodingsuppress_deflate_headercCs$|dkr dtjS|rtj StjS)Ngzip)rWr/)rZr[rrrencoding_to_modes r^c@s0eZdZdefdedeedeefddZdS)ZlibBaseHandlerNrexecutormax_sync_chunk_sizecCs||_||_||_dSr)_mode _executor_max_sync_chunk_size)rrr`rarrrrCs zZlibBaseHandler.__init__)rrr MAX_SYNC_CHUNK_SIZEr"rrrCrrrrr_sr_cseZdZddddddefdeededeedeedeedeed eeffd d Z d e d e fddZ d e d e fddZ ddeed e fddZ ZS)ZLibCompressorNFrZr[r4r6r8r`rac svtj|dur t||n|||dttj|_i}|j|d<|dur'||d<|dur/||d<|jjdi||_dS)Nrr`rar6r8r4r) superrCr^rArWrBrbr: _compressor) rrZr[r4r6r8r`rarL __class__rrrCs    zZLibCompressor.__init__rrcC |j|Sr)rirrrrr compress_syncrUzZLibCompressor.compress_synccsF|jduo t||jk}|rt|j|jj|IdHS||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) rdlenasyncioget_running_looprun_in_executorrcrirrm)rrshould_use_executorrrrrs    zZLibCompressor.compressrcCs|j|dur |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. N)rirrBr3rrrrrs  zZLibCompressor.flushr)rrr rerrVr-r"rrCr!rmrr __classcell__rrrjrrfs4 rfc seZdZdddefdeededeedeeffdd Z dd e d ed e fd dZ dd e d ed e fddZ dded e fddZ ed efddZZS)ZLibDecompressorNFrZr[r`racs:tjt||||dttj|_|jj|jd|_dS)Nrg)r6) rhrCr^rArWrBr;rb _decompressor)rrZr[r`rarjrrrCs zZLibDecompressor.__init__rrr$rcCs|j||Sr)rur&r%rrrdecompress_syncsz ZLibDecompressor.decompress_synccsF|jdurt||jkrt|j|jj||IdHS|||S)zDecompress the data and return the decompressed bytes. If the data size is large than the max_sync_chunk_size, the decompression will be done in the executor. Otherwise, the decompression will be done in the event loop. N) rdrnrorprqrcrur&rvr%rrrr&s  zZLibDecompressor.decompressr'cCs|dkr |j|S|jS)Nr)rurr(rrrrs  zZLibDecompressor.flushcCrIr)rur*r)rrrr*rJzZLibDecompressor.eof)r)rrr rerrVr-rr"rCr!rvr&rr,r*rsrrrjrrts&rtc@6eZdZd ddZdedefddZdefdd ZdS) BrotliDecompressorrNcCststdt|_dS)NzIThe brotli decompression is not available. Please install `Brotli` module) HAS_BROTLI RuntimeErrorbrotli Decompressor_objr)rrrrCs zBrotliDecompressor.__init__rcCs0t|jdrtt|j|Stt|j|S)Nr&)hasattrr}rr!r&processrrrrrv's z"BrotliDecompressor.decompress_synccCs t|jdrtt|jSdS)Nr)r~r}rr!rr)rrrr,s zBrotliDecompressor.flushrNrrr rCr!rvrrrrrrxs rxc@rw) ZSTDDecompressorrNcCststdt|_dS)NzOThe zstd decompression is not available. Please install `backports.zstd` module)HAS_ZSTDrzrr}r)rrrrC3s  zZSTDDecompressor.__init__rcCrlr)r}r&rrrrrv;rUz ZSTDDecompressor.decompress_synccCsdS)Nrrr)rrrr>r+zZSTDDecompressor.flushrrrrrrr2s r)NF),rosyszlibconcurrent.futuresrtypingrrrrrr version_infocollections.abcr r r! bytearray brotlicffir{ ImportErrorrycompression.zstdrbackports.zstdrrerr#r.r?rArWr>rYrVr-r"r^r_rfrtrxrrrrrsb            -   M/