i(ZUddlZddlZddlZddlmZddlmZmZmZm Z m Z m Z ejdk\rddl mZnddlmZeeeddfZ ddlZd Z ejd k\rdd lmZndd lmZd Zd ZGdde ZGdde ZGdde ZGdde d ZGddZeeZ ee!d<deddfdZ" d*dee#de$de%fdZ&Gd d!Z'Gd"d#e'Z(Gd$d%e'Z)Gd&d'Z*Gd(d)Z+y#e$rddlZYwxYw#e$rd ZYwxYw#e$rd ZYwxYw)+N)Executor)AnyFinalOptionalProtocol TypedDictcast) )Buffer)Unionzmemoryview[int]zmemoryview[bytes]TF)r )ZstdDecompressoric.eZdZdedefdZddedefdZy)ZLibCompressObjProtocoldatareturncyNselfrs T/var/www/html/binance/venv/lib/python3.12/site-packages/aiohttp/compression_utils.pycompressz ZLibCompressObjProtocol.compress'modecyrrrrs rflushzZLibCompressObjProtocol.flush(rrN.)__name__ __module__ __qualname__r bytesrintr rrrrr&s2V225#555rrcJeZdZd dededefdZd dedefdZede fdZ y) ZLibDecompressObjProtocolr max_lengthrcyrrrrr)s r decompressz$ZLibDecompressObjProtocol.decompress,rrlengthcyrrrr-s rr zZLibDecompressObjProtocol.flush-rrcyrrrs reofzZLibDecompressObjProtocol.eof/srNr!) r"r#r$r r&r%r,r propertyboolr2rrrr(r(+s4KvK3KK7C7U7 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>r?r@rAs r compressobjzZLibBackendProtocol.compressobj:s#&rcyrr)rr>rAs r decompressobjz!ZLibBackendProtocol.decompressobjCs$'rrcyrr)rrr<r>s rrzZLibBackendProtocol.compressGrbufsizecyrr)rrr>rHs rr,zZLibBackendProtocol.decompressJrGrN)......)..)r"r#r$r&__annotations__rr rrCr(rEr%rr,rrrr6r63sNM"%&&& &  &  && !&14(('-( "( ?B&)8; AD&):= rr6c,eZdZUeed<eed<eed<y)CompressObjArgsr>r@r<N)r"r#r$r&rJrrrrLrLOs JM JrrL)totalceZdZdefdZedefdZedefdZ edefdZ edefdZ edefdZ edefd Z d ed edefd Zd ed edefd Zded ed edefdZded ed edefdZdedefdZy)ZLibBackendWrapper _zlib_backendc||_yr)rP)rrPs r__init__zZLibBackendWrapper.__init__Vs 2?rrc0t|jddS)Nr" undefinedgetattrrPr1s rnamezZLibBackendWrapper.nameYst)):{CCrc.|jjSr)rPr7r1s rr7zZLibBackendWrapper.MAX_WBITS]s!!+++rc.|jjSr)rPr8r1s rr8zZLibBackendWrapper.Z_FULL_FLUSHa!!...rc.|jjSr)rPr9r1s rr9zZLibBackendWrapper.Z_SYNC_FLUSHerZrc.|jjSr)rPr:r1s rr:zZLibBackendWrapper.Z_BEST_SPEEDirZrc.|jjSr)rPr;r1s rr;zZLibBackendWrapper.Z_FINISHms!!***rargskwargsc:|jj|i|Sr)rPrCrr^r_s rrCzZLibBackendWrapper.compressobjqs -t!!--t>v>>rc:|jj|i|Sr)rPrEras rrEz ZLibBackendWrapper.decompressobjts /t!!//@@@rrcB|jj|g|i|Sr)rPrrrr^r_s rrzZLibBackendWrapper.compressws%*t!!**4A$A&AArcB|jj|g|i|Sr)rPr,rds rr,zZLibBackendWrapper.decompresszs%,t!!,,TCDCFCCrattrnamec.t|j|SrrU)rrfs r __getattr__zZLibBackendWrapper.__getattr__~st))844rN)r"r#r$r6rRr3strrWr&r7r8r9r:r;rrrCr(rEr r%rr,rhrrrrOrOUsO@&9@DcDD,3,,/c///c///c//+#++???8O?A3A#A:SABVBCB3B5BDvDcDSDUD5C5C5rrO ZLibBackendnew_zlib_backendrc|t_yr)rjrP)rks rset_zlib_backendrms 0Krencodingsuppress_deflate_headercx|dk(rdtjzS|rtj StjS)Ngzip)rjr7)rnros rencoding_to_moderss96K))))%r@rvrwct || t||n|||ttj |_i}|j |d<|||d<|||d<|j jdi||_y)Nrrvrwr>r@r<r) superrRrsrOrjrPryrC _compressor) rrnror<r>r@rvrwr_ __class__s rrRzZLibCompressor.__init__s =!+BC 3  %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{lenasyncioget_running_looprun_in_executorrzrrr)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 rPr;rs rr zZLibCompressor.flushs>%%$D  *.*<*<*E*E  rr)r"r#r$r|rrir4r&rrRr%rrr __classcell__rs@rr~r~s#'(-##"&'+-@D3-D"&D} D } D 3- D8$D&c]D:/%/E/(5(U(8  (3-  5  rr~c eZdZdddefdeededeedeeffd Z dde d ed e fd Z dde d ed e fd Z dd ed e fdZ ed efdZxZS)ZLibDecompressorNFrnrorvrwct|t||||ttj |_|j j |j|_y)Nr)r>) rrRrsrOrjrPrEry _decompressor)rrnrorvrwrs rrRzZLibDecompressor.__init__s] !(,CD 3  %7{7P7P$Q!//==DJJ=Orrr)rc:|jj||Sr)rr,r+s rdecompress_syncz ZLibDecompressor.decompress_syncs!!,,T:>>rcK|jdt||jkDrLtjj |j |j j||d{S|j||S7w)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) r{rrrrrzrr,rr+s rr,zZLibDecompressor.decompresssz  % % 1D D555 113CC 2 2 = =tZ ##D*55sA,B.B/Br-cv|dkDr|jj|S|jjS)Nr)rr r/s rr zZLibDecompressor.flushs?z    $ $V , ##))+ rc.|jjSr)rr2r1s rr2zZLibDecompressor.eofs!!%%%r)r)r"r#r$r|rrir4rr&rRr%rr,r r3r2rrs@rrrs#'(-'+-@ P3- P"& P8$ P &c] P?E?s?5?6U66E6  C  &T&&rrc0eZdZddZdedefdZdefdZy)BrotliDecompressorrNcXts tdtj|_y)NzIThe brotli decompression is not available. Please install `Brotli` module) HAS_BROTLI RuntimeErrorbrotli Decompressor_objr1s rrRzBrotliDecompressor.__init__s)1 '') rrct|jdr)tt|jj |Stt|jj |S)Nr,)hasattrrr r%r,processrs rrz"BrotliDecompressor.decompress_sync'sH 499l +tyy33D9: :E499,,T233rct|jdr(tt|jj Sy)Nr r)rrr r%r r1s rr zBrotliDecompressor.flush,s+ 499g &tyy01 1rrNr"r#r$rRr%rr rrrrrs&*4E4e4 urrc0eZdZddZdedefdZdefdZy)ZSTDDecompressorrNcDts tdt|_y)NzOThe zstd decompression is not available. Please install `backports.zstd` module)HAS_ZSTDrrrr1s rrRzZSTDDecompressor.__init__3s#9 %& rrc8|jj|Sr)rr,rs rrz ZSTDDecompressor.decompress_sync;syy##D))rcy)Nrrr1s rr zZSTDDecompressor.flush>srrrrrrrr2s&'*E*e*urr)NF),rsyszlibconcurrent.futuresrtypingrrrrrr version_infocollections.abcr r r% bytearray brotlicffir ImportErrorrcompression.zstdrbackports.zstdrr|rr(r6rLrOrjrJrmrir4r&rsrur~rrrrrrrs 'BBw& 5)%68KK LF#J 7"53H 6h6 (8iu *5*5Z#5T": :1':1t1 #$)XsmX!X X 8 8J _J Z,&,&^.  C JHsB DDD  D DDDDD D*)D*