o Fh"@sUddlZddlZddlZddlmZddlmZmZmZm Z m Z m Z ej dkr/ddl mZnddlmZeeeddfZzzddlZWn eyQddlZYnwd ZWn ey`d ZYnwd ZGd d d e ZGddde ZGddde ZGddde d dZGdddZeeZeed<deddfddZ  d(deede de!fddZ"Gd d!d!Z#Gd"d#d#e#Z$Gd$d%d%e#Z%Gd&d'd'Z&dS))N)Executor)AnyFinalOptionalProtocol TypedDictcast) )Buffer)Unionzmemoryview[int]zmemoryview[bytes]TFic@s2eZdZdedefddZd dedefddZd S) ZLibCompressObjProtocoldatareturncCdSNselfrrrL/var/www/html/venv/lib/python3.10/site-packages/aiohttp/compression_utils.pycompressz ZLibCompressObjProtocol.compress.modecCrrrrrrrrflushrzZLibCompressObjProtocol.flushN.)__name__ __module__ __qualname__r bytesrintrrrrrr sr c@sJeZdZd dededefddZd dedefdd Zede fd d Z d S)ZLibDecompressObjProtocol.r max_lengthrcCrrrrrr"rrr decompress!rz$ZLibDecompressObjProtocol.decompresslengthcCrrrrr%rrrr"rzZLibDecompressObjProtocol.flushcCrrrrrrreof$szZLibDecompressObjProtocol.eofNr) rrrr r rr$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)rr1r2r3r4r5r6rrr compressobj/szZLibBackendProtocol.compressobjcCrrr)rr3r6rrr decompressobj8z!ZLibBackendProtocol.decompressobjrcCrrr)rrr1r3rrrr<r9zZLibBackendProtocol.compressbufsizecCrrr)rrr3r:rrrr$?r9zZLibBackendProtocol.decompressN)......)..)rrrr __annotations__rr r r7r!r8rrr$rrrrr+(sn     r+c@s&eZdZUeed<eed<eed<dS)CompressObjArgsr3r5r1N)rrrr r;rrrrr<Ds  r<)totalc@seZdZdefddZedefddZedefddZ edefd d Z edefd d Z edefd dZ edefddZ dededefddZdededefddZdedededefddZdedededefddZdedefddZdS) ZLibBackendWrapper _zlib_backendcCs ||_dSr)r?)rr?rrr__init__K zZLibBackendWrapper.__init__rcCst|jddS)Nr undefinedgetattrr?r'rrrnameNszZLibBackendWrapper.namecC|jjSr)r?r,r'rrrr,RzZLibBackendWrapper.MAX_WBITScCrFr)r?r-r'rrrr-VrGzZLibBackendWrapper.Z_FULL_FLUSHcCrFr)r?r.r'rrrr.ZrGzZLibBackendWrapper.Z_SYNC_FLUSHcCrFr)r?r/r'rrrr/^rGzZLibBackendWrapper.Z_BEST_SPEEDcCrFr)r?r0r'rrrr0brGzZLibBackendWrapper.Z_FINISHargskwargscO|jj|i|Sr)r?r7rrHrIrrrr7fzZLibBackendWrapper.compressobjcOrJr)r?r8rKrrrr8irLz ZLibBackendWrapper.decompressobjrcO|jj|g|Ri|Sr)r?rrrrHrIrrrrlzZLibBackendWrapper.compresscOrMr)r?r$rNrrrr$orOzZLibBackendWrapper.decompressattrnamecCs t|j|SrrC)rrPrrr __getattr__s zZLibBackendWrapper.__getattr__N)rrrr+r@r)strrEr r,r-r.r/r0rr r7r!r8r rrr$rQrrrrr>Js&r> ZLibBackendnew_zlib_backendrcCs |t_dSr)rTr?)rUrrrset_zlib_backendzrArVencodingsuppress_deflate_headercCs$|dkr dtjS|rtj StjS)Ngzip)rTr,)rWrXrrrencoding_to_mode~s r[c@s0eZdZdefdedeedeefddZdS)ZlibBaseHandlerNrexecutormax_sync_chunk_sizecCs||_||_||_dSr)_mode _executor_max_sync_chunk_size)rrr]r^rrrr@s zZlibBaseHandler.__init__)rrrMAX_SYNC_CHUNK_SIZEr rrr@rrrrr\sr\cseZdZddddddefdeededeedeedeedeed eeffd d Z d e d e fddZ d e d e fddZ ddeed e fddZ ZS)ZLibCompressorNFrWrXr1r3r5r]r^c stj|dur t||n|||dttj|_i}|j|d<|dur'||d<|dur/||d<|jjdi||_t |_ dS)Nrr]r^r3r5r1r) superr@r[r>rTr?r_r7 _compressorasyncioLock_compress_lock) rrWrXr1r3r5r]r^rI __class__rrr@s     zZLibCompressor.__init__rrcCs |j|Sr)rfrrrrr compress_syncrRzZLibCompressor.compress_syncc s|j4IdH5|jdur.t||jkr.t|j|jj|IdHWdIdHS| |WdIdHS1IdHsCwYdS)aCCompress 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. N) riralenrgget_running_looprun_in_executorr`rfrrlrrrrrs   0zZLibCompressor.compressrcCs|j|dur |S|jjSr)rfrr?r0rrrrrs  zZLibCompressor.flushr)rrrrbrrSr*r rr@rrlrr __classcell__rrrjrrcs4 rcc seZdZdddefdeededeedeeffdd Z dd e d ed e fd dZ dd e d ed e fddZ dded e fddZ ed efddZZS)ZLibDecompressorNFrWrXr]r^cs:tjt||||dttj|_|jj|jd|_dS)Nrd)r3) rer@r[r>rTr?r8r_ _decompressor)rrWrXr]r^rjrrr@s zZLibDecompressor.__init__rrr"rcCs|j||Sr)rrr$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) rarmrgrnror`rrr$rsr#rrrr$s  zZLibDecompressor.decompressr%cCs|dkr |j|S|jS)Nr)rrrr&rrrrs  zZLibDecompressor.flushcCrFr)rrr(r'rrrr(rGzZLibDecompressor.eof)r)rrrrbrrSr*rr r@rrsr$rr)r(rprrrjrrqs&rqc@s6eZdZd ddZdedefddZdefdd ZdS) BrotliDecompressorrNcCststdt|_dS)NzIThe brotli decompression is not available. Please install `Brotli` module) HAS_BROTLI RuntimeErrorbrotli Decompressor_objr'rrrr@s zBrotliDecompressor.__init__rcCs0t|jdrtt|j|Stt|j|S)Nr$)hasattrryrrr$processrrrrrss z"BrotliDecompressor.decompress_synccCs t|jdrtt|jSdS)Nr)rzryrrrr'rrrrs zBrotliDecompressor.flush)rN)rrrr@rrsrrrrrrts rt)NF)'rgsyszlibconcurrent.futuresrtypingrrrrrr version_infocollections.abcr r r bytearray brotlicffirw ImportErrorrurbr r!r+r<r>rTr;rVrSr*r r[r\rcrqrtrrrrsP         -   ?/