idxSSKJr SSKrSSKJr SSKJrJr SSKJ r SSK J r J r J r JrJrJr SSKJrJrJr S S KJrJrJr /S QrS r\"S S5Vs/sH n\"U5PM snr"SS\5rSSjrSSjr"SS\5r SSjr!"SS\5r"SSjr#gs snf)) annotationsN)Sequence)AnyLiteral)frames)DuplicateParameterInvalidParameterNameInvalidParameterValueNegotiationError PayloadTooBig ProtocolError) BytesLike ExtensionNameExtensionParameter)ClientExtensionFactory ExtensionServerExtensionFactory)PerMessageDeflateClientPerMessageDeflateFactory enable_client_permessage_deflateServerPerMessageDeflateFactory enable_server_permessage_deflatesc~\rSrSrSr\"S5rS S SjjrS SjrSS.SSjjr SS jr S r g)r!z! Per-Message Deflate extension. permessage-deflateNcUc0nUS;deUS;deSUs=::aS::de eSUs=::aS::de eSU;deXlX lX0lX@lXPlUR(d$[ R "UR*S9UlUR(d2[ R"SSUR*0URD6Ul SUl g) z/ Configure the Per-Message Deflate extension. N)FTrwbitsr"F) remote_no_context_takeoverlocal_no_context_takeoverremote_max_window_bitslocal_max_window_bitscompress_settingszlib decompressobjdecoder compressobjencoderdecode_cont_data)selfr%r&r'r(r)s e/home/mande/repo/quber/.venv/lib/python3.13/site-packages/websockets/extensions/permessage_deflate.py__init__PerMessageDeflate.__init__)s  $ " )]:::(M999*0b00000)/R/////////*D')B&&<#%:"!2..--T5P5P4PQDL--++111((DL!&c pSURSURSURSURS3 $)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(r0s r1__repr__PerMessageDeflate.__repr__SsV**.*I*I)JK))-)G)G(HI&&*&A&A%BC%%)%?%?$@  C r4)max_sizecUR[R;aU$UR[RLa,UR(dU$UR (aSUlO`UR (dU$UR (dSUlUR(a$[R"UR*S9Ul UR (a6[UR5S:a[UR5[-nO URnUcSOUnURR!X45nURR"(aUce[%SU5eUR (a8[UR5S:aURR![5 UR (aUR(aU? [R*"URUUR SUR,UR.5$![R&an[)S5UeSnAff=f)z Decode an incoming frame. FTr#iNrzdecompression failed)opcoder CTRL_OPCODESOP_CONTr/finrsv1r%r*r+r'r,lendatabytes_EMPTY_UNCOMPRESSED_BLOCK decompressunconsumed_tailr errorrFramersv2rsv3)r0framer:rB max_lengthexcs r1decodePerMessageDeflate.decode\s <<6.. .L <<6>> )(( yy(-%:: 99(,%..#119T9T8TU 99UZZ4/$'@@D::D"*Q  A<<**4r&r*r-r(r)r.compressrBflush Z_SYNC_FLUSHr?rDrA memoryviewrHrIrJ)r0rKrBs r1encodePerMessageDeflate.encodes7 <<6.. .L <Ub [U5eU(aUcSnMU[;a [U5nM[Xg5e[ U5e UUUU4$)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. FNrhTrirjrk)r r _MAX_WINDOW_BITS_VALUESrZr )rm is_serverrhrirjrkrevalues r1_extract_parametersrss&(-',)-9=  / /)(..}-1*+D88 1 1)(..}-1*+D88 - -%1(..//),U&+D88 - -%1(..U])-&11),U&+D88't, ,IN #"  r4cv\rSrSrSr\"S5rS S SjjrS SjrS Sjr Sr g) ri*a 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``. rNcUbSUs=::aS::d O [S5eUbUSLdSUs=::aS::d O [S5eUbSU;a [S5eXlX lX0lX@lXPlg) 7 Configure the Per-Message Deflate extension factory. Nrr!/server_max_window_bits must be between 8 and 15T/client_max_window_bits must be between 8 and 15r"zLcompress_settings must not include wbits, set client_max_window_bits instead) ValueErrorrhrirjrkr))r0rhrirjrkr)s r1r2'ClientPerMessageDeflateFactory.__init__Ds'.!7M2SQS2SNO O " *%-*0b0NO O  (W8I-I5  +E'*D'&<#&<#!2r4cn[URURURUR5$)z Build request parameters. )rnrhrirjrkr7s r1get_request_params1ClientPerMessageDeflateFactory.get_request_paramsds5 !  + +  + +  ' '  ' '   r4cr^[U4SjU55(a[STR35e[USS9unnnnTR(aU(d [S5eTR (a U(dSnTR cO)Uc [S5eUTR :a [S5eTRcUb [S 5eO;TRSLaO+Uc TRnOUTR:a [S 5e[UUU=(d S U=(d S TR5$) z> Process response parameters. Return an extension instance. c3T># UHoRTR:Hv M g7frXre.0otherr0s r1 IClientPerMessageDeflateFactory.process_response_params..{H4G5zzTYY&4G%(zreceived duplicate Frqz#expected server_no_context_takeoverTzexpected server_max_window_bitsz"unsupported server_max_window_bitsz!unexpected client_max_window_bitsz"unsupported client_max_window_bitsr!) anyr rersrhrirjrkrr)r0rmaccepted_extensionsrhrirjrks` r1process_response_params6ClientPerMessageDeflateFactory.process_response_paramspsJ H4GH H H"%8 #DE E % 8  & & " "  * *-&'LMM  * *--1*  & & . &-&'HII'$*E*EE&'KLL  & & .%1&'JKK2 ( (D 0 &-)-)D)D&'$*E*EE&'KLL & & " (b " (b  " "   r4)rkrir)rjrh)FFNTN) rhrYrirYrjr_rkint | Literal[True] | Noner)dict[str, Any] | Noner[r\)r[Sequence[ExtensionParameter])rmrrSequence[Extension]r[r) r`rarbrcrdrrer2r|rrfr$r4r1rr*s. - .D,1+0-1=A37 3$(3%)3!+ 3 !; 3 1 3 3@  g ,g 1g   g r4rcnUc/n[SU55(d[U5[SS0S9/-nU$)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. c3\# UH"nUR[R:Hv M$ g7frX)rer)rextension_factorys r1r3enable_client_permessage_deflate..s*!+  "@"E"EE!+*,memLevel)r))rlistr extensionss r1rrsV !+  *% *#-q/ )  r4cr\rSrSrSr\"S5rSS SjjrS SjrSr g) riaS 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``. rNcUbSUs=::aS::d O [S5eUbSUs=::aS::d O [S5eUbSU;a [S5eUcU(a [S5eXlX lX0lX@lXPlX`lg) rvNrr!rwrxr"zLcompress_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)ryrhrirjrkr)require_client_max_window_bits)r0rhrirjrkr)rs r1r2'ServerPerMessageDeflateFactory.__init__s'.!7M2SQS2SNO O&.!7M2SQS2SNO O  (W8I-I5  " ).L>  +E'*D'&<#&<#!2.L+r4c^[U4SjU55(a[STR35e[USS9unnnnTR(a U(dSnTR (a U(dSnTR cO,Uc TR nOUTR :a TR nTRcUSLa TRnONUcTR(a [S5eO.USLa TRnOTRU:a TRn[UUUU5[UUU=(d SU=(d STR54$)zQ Process request parameters. Return response params and an extension instance. c3T># UHoRTR:Hv M g7frXrrs r1rHServerPerMessageDeflateFactory.process_request_params..=rrzskipped duplicate Trzrequired client_max_window_bitsr!) rr rersrhrirjrkrrnrr)rs` r1process_request_params5ServerPerMessageDeflateFactory.process_request_params2so H4GH H H"%7 {#CD D $ 7  & & " ""  * *--1*  * *--1*  & & . &-)-)D)D&'$*E*EE)-)D)D&  & & .%-)-)D)D&&-66*+LMM7'4/)-)D)D&,,/EE)-)D)D& **&&   **&,"&,"&&    r4)rkrir)rrjrh)FFNNNF)rhrYrirYrjr_rkr_r)rrrYr[r\)rmrrrr[z2tuple[list[ExtensionParameter], PerMessageDeflate]) r`rarbrcrdrrer2rrfr$r4r1rrs4 - .D,1+0-1-137/4!M$(!M%)!M!+ !M !+ !M 1 !M)-!M !MFo ,o 1o  < o r4rcrUc/n[SU55(d[U5[SSSS0S9/-nU$)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. c3\# UH"nUR[R:Hv M$ g7frX)rer)r ext_factorys r1r3enable_server_permessage_deflate..s)%K :???%r rr)rjrkr))rrrrs r1rrs\ %  *% *')')#-q/ )   r4) rhrYrirYrjr_rkrr[zlist[ExtensionParameter])rmrrqrYr[z9tuple[bool, bool, int | None, int | Literal[True] | None])rz'Sequence[ClientExtensionFactory] | Noner[z Sequence[ClientExtensionFactory])rz'Sequence[ServerExtensionFactory] | Noner[z Sequence[ServerExtensionFactory])$ __future__rr*collections.abcrtypingrrr exceptionsr r r r r rrrrbaserrr__all__rDranger]rprrnrsrrrr)bitss0r1rs " $BAKK 016q">3t9>q q h $ $'7   0: (:8<:>:zm %;m `7%0o %;o d7%M?sB7