&th`&ddlmZddlZddlZddlmZmZmZmZm Z m Z m Z ddl m Z mZddlmZmZddlmZmZmZgd Zd Zd ed d DZGddeZd*dZd+dZGdd eZd,d$ZGd%d&eZd-d)ZdS).) annotationsN)AnyDictListOptionalSequenceTupleUnion) exceptionsframes) ExtensionNameExtensionParameter)ClientExtensionFactory ExtensionServerExtensionFactory)PerMessageDeflateClientPerMessageDeflateFactory enable_client_permessage_deflateServerPerMessageDeflateFactory enable_server_permessage_deflatesc,g|]}t|S)str).0bitss |/var/www/html/mycamper/aliexpress-site/backend/venv/lib/python3.11/site-packages/websockets/extensions/permessage_deflate.py rs>>>3t99>>>cReZdZdZedZ dddZddZddddZddZ dS)rz) Per-Message Deflate extension. permessage-deflateNremote_no_context_takeoverboollocal_no_context_takeoverremote_max_window_bitsintlocal_max_window_bitscompress_settingsOptional[Dict[Any, Any]]returnNonecl|i}|dvsJ|dvsJd|cxkrdksnJd|cxkrdksnJd|vsJ||_||_||_||_||_|js t j|j |_|js#t jdd|j i|j|_ d|_ dS) z? Configure the Per-Message Deflate extension. N)FTr!wbitsr1Fr) r%r'r(r*r+zlib decompressobjdecoder compressobjencoderdecode_cont_data)selfr%r'r(r*r+s r__init__zPerMessageDeflate.__init__!s,  $ " )]::::(M9999*0000b000000)////R///////////*D')B&&<#%:"!2. R-T5P4PQQQDL- +11595KDL !&r rc Hd|jd|jd|jd|jd S)Nz-PerMessageDeflate(remote_no_context_takeover=z, local_no_context_takeover=z, remote_max_window_bits=z, local_max_window_bits=))r%r'r(r*r9s r__repr__zPerMessageDeflate.__repr__Js_ C*.*I C C)-)G C C'+&A C C&*%?  C C C r )max_sizeframe frames.Framer? Optional[int]c|jtjvr|S|jtjur|js|S|jrd|_nT|js|Stj|d}|jsd|_|j r tj |j |_ |j}|jr |tz }|dn|} |j ||}n,#tj$r}t%jd|d}~wwxYw|j jrt%jd|d |jr |j r|` tj|| S) z, Decode an incoming frame. Frsv1Tr2Nrzdecompression failedzover size limit (? > z bytes)data)opcoder CTRL_OPCODESOP_CONTr8finrE dataclassesreplacer%r3r4r(r5rG_EMPTY_UNCOMPRESSED_BLOCK decompresserrorr ProtocolErrorunconsumed_tail PayloadTooBig)r9r@r?rG max_lengthexcs rdecodezPerMessageDeflate.decodeSs <6. . .L <6> ) )(  y .(-%:  'E:::E9 -(,%. V#19T8TUUU z 9 . - -D"*QQ  L<**4<rVr]rr rrrs =- . .D7; %&%&%&%&%&R    #' 858585858585t555555r rserver_no_context_takeoverr&client_no_context_takeoverserver_max_window_bitsrBclient_max_window_bitsOptional[Union[int, bool]]r-List[ExtensionParameter]c2g}|r|d|r|d|r$|dt|f|dur|dn&|r$|dt|f|S)zS Build a list of ``(name, value)`` pairs for some compression parameters. )rdN)reNrfT)rgNrg)appendr)rdrerfrgparamss r_build_parametersrms(*F!< :;;;!< :;;;O /5K1L1LMNNN%% 67777 O /5K1L1LMNNN Mr rlSequence[ExtensionParameter] is_servers. !  +  +  '  '    r rlrnaccepted_extensionsSequence[Extension]rcBtfd|Drtjdjt |d\}}}}jr|stjdjr|sd}jn5|tjd|jkrtjd j|tjd n3jdurn)|j}n|jkrtjd t|||pd |pd j S) zV Process response parameters. Return an extension instance. c38K|]}|jjkVdSr^rcrotherr9s r zIClientPerMessageDeflateFactory.process_response_params..U,HH5uzTY&HHHHHHr zreceived duplicate Froz#expected server_no_context_takeoverTNzexpected server_max_window_bitsz"unsupported server_max_window_bitsz!unexpected client_max_window_bitsz"unsupported client_max_window_bitsr0) anyr NegotiationErrorrcrwrdrerfrgrr+r9rlrrdrerfrgs` rprocess_response_paramsz6ClientPerMessageDeflateFactory.process_response_paramsJs HHHH4GHHH H H Q-.ODI.O.OPP P % 8 8 8  & & " "  * Y- Y 12WXXX  * 2- 2-1*  & . &- 12STTT'$*EEE 12VWWW  & .%1 12UVVV2 (D 0 0 &-)-)D&&'$*EEE 12VWWW & & " (b " (b  "    r )FFNTN) rdr&rer&rfrBrgrhr+ryr-r.)r-ri)rlrnrrr-r) r_r`rarbrrcr:rrrr rrrs. =- . .D,1+004=A6: 33333@     g g g g g g r r extensions*Optional[Sequence[ClientExtensionFactory]] Sequence[ClientExtensionFactory]c|g}td|Ds#t|tddigz}|S)z Enable Per-Message Deflate with default settings in client extensions. If the extension is already present, perhaps with non-default settings, the configuration isn't changed. Nc3@K|]}|jtjkVdSr^)rcr)rextension_factorys rrz3enable_client_permessage_deflate..sB  "@"EEr memLevel)r+)rlistrrs rrrsw !+   *%% *#-q/   )  r cFeZdZdZedZ dddZddZdS)ra Server-side extension factory for the Per-Message Deflate extension. Parameters behave as described in `section 7.1 of RFC 7692`_. .. _section 7.1 of RFC 7692: https://www.rfc-editor.org/rfc/rfc7692.html#section-7.1 Set them to :obj:`True` to include them in the negotiation offer without a value or to an integer value to include them with this value. Args: server_no_context_takeover: prevent server from using context takeover. client_no_context_takeover: prevent client from using context takeover. server_max_window_bits: maximum size of the server's LZ77 sliding window in bits, between 8 and 15. client_max_window_bits: maximum size of the client's LZ77 sliding window in bits, between 8 and 15. compress_settings: additional keyword arguments for :func:`zlib.compressobj`, excluding ``wbits``. require_client_max_window_bits: do not enable compression at all if client doesn't advertise support for ``client_max_window_bits``; the default behavior is to enable compression without enforcing ``client_max_window_bits``. r$FNrdr&rerfrBrgr+ryrequire_client_max_window_bitsr-r.c*|d|cxkrdksntd|d|cxkrdksntd|d|vrtd||rtd||_||_||_||_||_||_dS) r{Nr!r0r|r}r1zLcompress_settings must not include wbits, set server_max_window_bits insteadzVrequire_client_max_window_bits is enabled, but client_max_window_bits isn't configured)r~rdrerfrgr+r)r9rdrerfrgr+rs rr:z'ServerPerMessageDeflateFactory.__init__s'.!7M2S2S2S2SQS2S2S2S2SNOO O&.!7M2S2S2S2SQS2S2S2S2SNOO O  (W8I-I-I5  " ).L )>  +E'*D'&<#&<#!2.L+++r rlrnrr2Tuple[List[ExtensionParameter], PerMessageDeflate]c tfd|Drtjdjt |d\}}}}jr|sd}jr|sd}jn|j}n|jkrj}j |durj}n<|j rtjdn|durj}nj|krj}t||||t|||pd|pdj fS)zi Process request parameters. Return response params and an extension instance. c38K|]}|jjkVdSr^rrs rrzHServerPerMessageDeflateFactory.process_request_params..rr zskipped duplicate TrNzrequired client_max_window_bitsr0) rr rrcrwrdrerfrgrrmrr+rs` rprocess_request_paramsz5ServerPerMessageDeflateFactory.process_request_params s HHHH4GHHH H H P-.N49.N.NOO O $ 7 7 7  & & " ""  * 2- 2-1*  * 2- 2-1*  & . &-)-)D&&'$*EEE)-)D&  & .%--)-)D&&-6Y$56WXXXY'4//)-)D&&,/EEE)-)D& **&&    **&,"&,"&     r )FFNNNF)rdr&rer&rfrBrgrBr+ryrr&r-r.)rlrnrrr-r)r_r`rarbrrcr:rrr rrrs}4 =- . .D,1+004046:/4!M!M!M!M!MFo o o o o o r r*Optional[Sequence[ServerExtensionFactory]] Sequence[ServerExtensionFactory]c|g}td|Ds%t|tddddigz}|S)z Enable Per-Message Deflate with default settings in server extensions. If the extension is already present, perhaps with non-default settings, the configuration isn't changed. Nc3@K|]}|jtjkVdSr^)rcr)r ext_factorys rrz3enable_server_permessage_deflate..sB  :??r rr)rfrgr+)rrrrs rrr~s} %    *%% *')')#-q/   )   r ) rdr&rer&rfrBrgrhr-ri)rlrnror&r-rp)rrr-r)rrr-r) __future__rrLr3typingrrrrrr r r r rrbaserrr__all__rNrangertrrmrwrrrrrr rrs"""""" DDDDDDDDDDDDDDDDDD!!!!!!!!66666666KKKKKKKKKK   0>>q">>>R5R5R5R5R5 R5R5R5j0;;;;|m m m m m %;m m m `0o o o o o %;o o o dr