vg>d.ddlmZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z mZmZddlmZmZd d lmZmZmZgd Zd Zd eddDZGddeZd,dZd-d ZGd!d"eZd.d&ZGd'd(eZd/d+Z dS)0) annotationsN)Sequence)Any)frames)DuplicateParameterInvalidParameterNameInvalidParameterValueNegotiationError PayloadTooBig ProtocolError) ExtensionNameExtensionParameter)ClientExtensionFactory ExtensionServerExtensionFactory)PerMessageDeflateClientPerMessageDeflateFactory enable_client_permessage_deflateServerPerMessageDeflateFactory enable_server_permessage_deflatesc,g|]}t|S)str).0bitss e/var/www/pixelcanvas.ch/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_settingsdict[Any, Any] | NonereturnNonecl|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- +11(DL!&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__Ss_ C*.*I C C)-)G C C'+&A C C&*%?  C C C r )max_sizeframe frames.Framer? int | NonecN|jtjvr|S|jtjur|js|S|jrd|_n>|js|S|jsd|_|jr tj |j |_ |jr5t|j dkrt|j tz}n|j }|dn|} |j ||}|j jr|Jt%d||jr7t|j dkr|j tn'#tj$r}t)d|d}~wwxYw|jr |jr|` tj|j||jd|j|jS)z, Decode an incoming frame. FTr2iNrzdecompression failed)opcoder CTRL_OPCODESOP_CONTr8finrsv1r%r3r4r(r5lendatabytes_EMPTY_UNCOMPRESSED_BLOCK decompressunconsumed_tailr errorr Framersv2rsv3)r9r@r?rJ max_lengthexcs rdecodezPerMessageDeflate.decode\s <6. . .L <6> ) )(  y .(-%:  9 -(,%. V#19T8TUUU 9 UZ4//$$'@@DD:D"*QQ  A<**4<rUr\rr rrr!s =- . .D48 &&&&&&&&&&T     $ F F F F F F P, , , , , , r rserver_no_context_takeoverr&client_no_context_takeoverserver_max_window_bitsrBclient_max_window_bitsint | bool | Noner-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. )rcN)rdNreT)rfNrf)appendr)rcrdrerfparamss r_build_parametersrls(*F!< :;;;!< :;;;O /5K1L1LMNNN%% 67777 O /5K1L1LMNNN Mr rkSequence[ExtensionParameter] is_server0tuple[bool, bool, int | None, int | bool | None]cd}d}d}d}|D]\}}|dkr&|rt||d}!t|||dkr&|rt||d}Mt|||dkr:|t||tvrt|}t|||dkrA|t||r|d}|tvrt|}t||t |||||fS)z Extract compression parameters from a list of ``(name, value)`` pairs. If ``is_server`` is :obj:`True`, ``client_max_window_bits`` may be provided without a value. This is only allowed in handshake requests. FNrcTrdrerf)rr _MAX_WINDOW_BITS_VALUESr)r )rkrnrcrdrerfrbvalues r_extract_parametersrss(-',)-04$-$- e / / /) /(...}-1**+D%888 1 1 1) /(...}-1**+D%888 - - -%1(...///),U&&+D%888 - - -%1(... 9U])-&&111),U&&+D%888't,, , #"  r cLeZdZdZedZ dddZddZddZdS)ra Client-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://datatracker.ietf.org/doc/html/rfc7692#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, or :obj:`True` to indicate support without setting a limit. compress_settings: Additional keyword arguments for :func:`zlib.compressobj`, excluding ``wbits``. r$FNTrcr&rdrerBrfrgr+dict[str, Any] | Noner-r.c|d|cxkrdksntd|"|dusd|cxkrdksntd|d|vrtd||_||_||_||_||_dS) G Configure the Per-Message Deflate extension factory. Nr!r0/server_max_window_bits must be between 8 and 15T/client_max_window_bits must be between 8 and 15r1zLcompress_settings must not include wbits, set client_max_window_bits instead) ValueErrorrcrdrerfr+)r9rcrdrerfr+s rr:z'ClientPerMessageDeflateFactory.__init__Bs'.!7M2S2S2S2SQS2S2S2S2SNOO O " *%--*0000b0000NOO O  (W8I-I-I5  +E'*D'&<#&<#!2r rhcNt|j|j|j|jS)z, Build request parameters. )rlrcrdrerfr=s rget_request_paramsz1ClientPerMessageDeflateFactory.get_request_paramsbs. !  +  +  '  '    r rkrmaccepted_extensionsSequence[Extension]rctfd|Drtdjt|d\}}}}jr|stdjr|sd}jn+|td|jkrtd j|td n.jdurn$|j}n|jkrtd t|||pd |pd j S) zV Process response parameters. Return an extension instance. c38K|]}|jjkVdSr]rbrotherr9s r zIClientPerMessageDeflateFactory.process_response_params..y,HH5uzTY&HHHHHHr zreceived duplicate Frnz#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 rbrsrcrdrerfrr+r9rkr}rcrdrerfs` rprocess_response_paramsz6ClientPerMessageDeflateFactory.process_response_paramsns HHHH4GHHH H H F"#D#D#DEE E % 8 8 8  & & " "  * N- N&'LMMM  * 2- 2-1*  & . &-&'HIII'$*EEE&'KLLL  & .%1&'JKKK2 (D 0 0 &-)-)D&&'$*EEE&'KLLL & & " (b " (b  "    r )FFNTN) rcr&rdr&rerBrfrgr+rur-r.)r-rh)rkrmr}r~r-r) r^r_r`rarrbr:r|rrr rrr(s. =- . .D,1+0-14837 33333@     g g g g g g r r extensions'Sequence[ClientExtensionFactory] | None 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])rbr)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://datatracker.ietf.org/doc/html/rfc7692#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$FNrcr&rdrerBrfr+rurequire_client_max_window_bitsr-r.c*|d|cxkrdksntd|d|cxkrdksntd|d|vrtd||rtd||_||_||_||_||_||_dS) rwNr!r0rxryr1zLcompress_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)rzrcrdrerfr+r)r9rcrdrerfr+rs rr:z'ServerPerMessageDeflateFactory.__init__ s'.!7M2S2S2S2SQS2S2S2S2SNOO O&.!7M2S2S2S2SQS2S2S2S2SNOO O  (W8I-I-I5  " ).L )>  +E'*D'&<#&<#!2.L+++r rkrmr}r~2tuple[list[ExtensionParameter], PerMessageDeflate]ctfd|Drtdjt|d\}}}}jr|sd}jr|sd}jn|j}n|jkrj}j |durj}n7|jrtdn|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 rbrsrcrdrerfrrlrr+rs` rprocess_request_paramsz5ServerPerMessageDeflateFactory.process_request_params0s HHHH4GHHH H H E"#C #C#CDD D $ 7 7 7  & & " ""  * 2- 2-1*  * 2- 2-1*  & . &-)-)D&&'$*EEE)-)D&  & .%--)-)D&&-6N*+LMMMN'4//)-)D&&,/EEE)-)D& **&&    **&,"&,"&     r )FFNNNF)rcr&rdr&rerBrfrBr+rurr&r-r.)rkrmr}r~r-r)r^r_r`rarrbr:rrr rrrs}4 =- . .D,1+0-1-137/4!M!M!M!M!MFo o o o o o r r'Sequence[ServerExtensionFactory] | None 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])rbr)r ext_factorys rrz3enable_server_permessage_deflate..sB  :??r rr)rerfr+)rrrrs rrrs} %    *%% *')')#-q/   )   r ) rcr&rdr&rerBrfrgr-rh)rkrmrnr&r-ro)rrr-r)rrr-r)! __future__rr3collections.abcrtypingrr exceptionsrr r r r r rrbaserrr__all__rLrangerqrrlrsrrrrrr rrs """""" $$$$$$76666666KKKKKKKKKK   0>>q">>>o o o o o o o o d0::::zm m m m m %;m m m `0o o o o o %;o o o dr