+ Qi_Rt^RIHt^RIt^RIHtHt^RIHtH t H t ^RI H t ^RI HtHt^RIHt^RIHtHtHt^R IHtHt]'d^R IHt]P6!]4tR tR tR t ]!!^ 4Uu.uFp^V,^, NK upt"Rt#RRlt$RRlt%RRlt&RRlt'RRlt(!RR4t)!RR4t*R#uupi)zL Implements the HPACK header compression algorithm as detailed by RFC 7541. ) annotationsN) TYPE_CHECKINGAny)HPACKDecodingErrorInvalidTableSizeErrorOversizedHeaderListError)HuffmanEncoder) REQUEST_CODESREQUEST_CODES_LENGTH)decode_huffman) HeaderTupleHeaderWeaklyTypedNeverIndexedHeaderTuple) HeaderTabletable_entry_size)Iterable@c$V^8dQhRRRRRR/#)headerr rawboolreturnr )formats"`/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/hpack/hpack.py __annotate__r#s" ) )0 )t ) )c\V^,4p\V^,4pV'g1VPVPR4VPR44#VPW#4#)z^ Provides a header as a unicode string if raw is False, otherwise returns it as a bytestring. utf-8)bytes __class__decode)rrnamevalues&& r_unicode_if_neededr'#sY  D &) E  G 4ell76KLL   D ((rc$V^8dQhRRRRRR/#)rintegerint prefix_bitsr bytearrayr)rs"rrr0s!Ccirc\PRW4V^8dRV 2p\V4hV^8gV^8dRV 2p\V4h\V,pW8d \ V.4#V.pW,pV^8d+VP V^,^,4V^,pK1VP V4\ V4#)z] Encodes an integer according to the wacky integer encoding rules defined in the HPACK spec. zEncoding %d with %d bitsz'Can only encode positive integers, got )Prefix bits must be between 1 and 8, got )logdebug ValueError_PREFIX_BIT_MAX_NUMBERSr,append)r)r+msg max_numberelementss&& rencode_integerr70s II('?{7yAoQ+/9+Go(5J'##|H G S.3#-.A  OOG X rc$V^8dQhRRRRRR/#)rdatar"r+r*rztuple[int, int]r)rs"rrrOs!$$$S$_$rcV^8gV^8dRV 2p\V4h\V,p^p^p^^V, , pV^,V,pWs8XdLW,pV^, pV^8dWx^, V,, pMWxV,, pM V^, pKK\P RWt4Wt3# \dp RT: 2p\T4T hRp ? ii;i)z Decodes an integer according to the wacky integer encoding rules defined in the HPACK spec. Returns a tuple of the decoded integer and the number of bytes that were consumed from ``data`` in order to get that integer. r.z3Unable to decode HPACK integer representation from NzDecoded %d, consumed %d bytes)r1r2 IndexErrorrr/r0) r9r+r4r5indexshiftmasknumber next_byteerrs && rdecode_integerrBOsQ+/9+Go(5J E E Q_ %D/a4   K  #3588F500F  II-v= = /CD8L %3./sAB; B;; CCCc V^8dQhRRRR/#)r header_dictzdict[bytes | str, bytes | str]rz)Iterable[tuple[bytes | str, bytes | str]]r)rs"rrrvs$$#A$ 4$rc#"\V\4'gR\V4 2p\V4h\ VP 4RR7pVFpW0V,3xK R#5i)z Converts a dictionary to an iterable of key-value tuples. This is a HPACK-specific function because it pulls "special-headers" out first and then emits them. zheader_dict not a dict, but c@\V4PR4'*#):) _to_bytes startswith)ks&r#_dict_to_iterable..s)A,11$77r)keyN) isinstancedicttype TypeErrorsortedkeys)rDr4rSrMs& r_dict_to_iterablerTvsc k4 ( (,T+->,?@n  7 Ds###sA#A%c V^8dQhRRRR/#)rr&zbytes | str | Anyrr"r)rs"rrrs ! !& !5 !rc|\V4pV\JdV#V\Jd \V4pVPR4#)z: Convert anything to bytes through a UTF-8 encoded string r!)rPr"strencode)r&ts& rrHrHs8 U AEz |E  <<  rc]tRt^tRtRRlt]RRl4t]PRRl4tRRR llt RR R llt R R lt RRRllt RRRllt RRltRtR#)Encoderza An HPACK encoder object. This object takes HTTP headers and emits encoded HTTP/2 header blocks. cV^8dQhRR/#rrNoner)rs"rrEncoder.__annotate__s00$0rc d\4Vn\\\4Vn.VnR#N)r header_tablerr r huffman_codertable_size_changesselfs&r__init__Encoder.__init__s)'M+ / .0rcV^8dQhRR/#rrr*r)rs"rrr_))3)rc .VPP#z. Controls the size of the HPACK header table. rbmaxsizeres&rheader_table_sizeEncoder.header_table_size   (((rc V^8dQhRRRR/#rr&r*rr^r)rs"rrr_s22s2t2rc WPnVPP'dVPP V4R#R#ra)rbroresizedrdr3rfr&s&&rrprqs9$)!    $ $ $  # # * *5 1 %rc$V^8dQhRRRRRR/#)rheaderszIterable[HeaderTuple | tuple[bytes | str, bytes | str] | tuple[bytes | str, bytes | str, bool | None]] | dict[bytes | str, bytes | str]huffmanrrr"r)rs"rrr_s/kk2k  k ). krc n.pVPP'd1VPVP44RVPn\ V\ 4'd \ V4pM \V4pVFpRp\ V\4'dVP'*pM\V4^8d V^,p\V^,4\V^,43pVPVPWvV44K RPV4p\PRV4V#)ah Takes a set of headers and encodes them into a HPACK-encoded header block. :param headers: The headers to encode. Must be either an iterable of tuples, an iterable of :class:`HeaderTuple `, or a ``dict``. If an iterable of tuples, the tuples may be either two-tuples or three-tuples. If they are two-tuples, the tuples must be of the format ``(name, value)``. If they are three-tuples, they must be of the format ``(name, value, sensitive)``, where ``sensitive`` is a boolean value indicating whether the header should be added to header tables anywhere. If not present, ``sensitive`` defaults to ``False``. If an iterable of :class:`HeaderTuple `, the tuples must always be two-tuples. Instead of using ``sensitive`` as a third tuple entry, use :class:`NeverIndexedHeaderTuple ` to request that the field never be indexed. .. warning:: HTTP/2 requires that all special headers (headers whose names begin with ``:`` characters) appear at the *start* of the header block. While this method will ensure that happens for ``dict`` subclasses, callers using any other iterable of tuples **must** ensure they place their special headers at the start of the iterable. For efficiency reasons users should prefer to use iterables of two-tuples: fixing the ordering of dictionary headers is an expensive operation that should be avoided if possible. :param huffman: (optional) Whether to Huffman-encode any header sent as a literal value. Except for use when debugging, it is recommended that this be left enabled. :returns: A bytestring containing the HPACK-encoded header block. FrzEncoded header block to %s)rbrvr3_encode_table_size_changerNrOrTiterr indexablelenrHaddjoinr/r0) rfryrz header_block hpack_headersr sensitive new_headerencodeds &&& rrXEncoder.encodesp     $ $ $    > > @ A(-D   % gt $ $.g6M &!MM$FI&+.. & 0 00 Vq"1I #F1I. &)0DEJ    H I$((<( .8rc(V^8dQhRRRRRRRR/#)rto_addztuple[bytes, bytes]rrrzrr"r)rs"rrr_s*//-/$//Z_/rc \PRVVV4VwrEV'g\M\pVPP WE4pVf8VP WEWc4pV'gVPPWE4V#Vwrp V 'dVPV 4pV#VPWWc4pV'gVPPWE4V#)z& Serializes a header key-value tuple. z7Adding %s to the header table, sensitive:%s, huffman:%s) r/r0INDEX_INCREMENTAL INDEX_NEVERrbsearch_encode_literalr_encode_indexed_encode_indexed_literal) rfrrrzr%r&indexbitmatchrr<perfects &&&& rr Encoder.adds E      -6$;!!((5 =**4JG!!%%d2N %W **51G 22hG!!%%d2rc V^8dQhRRRR/#)rr<r*rr"r)rs"rrr_MsSUrc Z\V^4pV^;;,^,uu&\V4#)z4 Encodes a header using the indexed representation. )r7r")rfr<fields&& rrEncoder._encode_indexedMs(ua( aDU|rc ,V^8dQhRRRRRRRRRR/#)rr%r"r&rrzrrr)rs"rrr_Us1  E % 5 SW di rc V'd7VPPV4pVPPV4p\\V4^4p\\V4^4pV'd+V^;;,^,uu&V^;;,^,uu&RP V\ V4V\ V4V.4#)z Encodes a header with a literal name and literal value. If ``indexing`` is True, the header will be added to the header table: otherwise it will not. r)rcrXr7rrr")rfr%r&rrzname_len value_lens&&&&& rrEncoder._encode_literalUs %%,,T2D&&--e4E!#d)Q/"3u:q1  QK4 K aLD Lxx uXeI.> F  rc ,V^8dQhRRRRRRRRRR/#) rr<r*r&r"rrzrrr)rs"rrr_js8BBSBB%BZ^BkpBrc |V\8wd\V^4pM \V^4pV^;;,\V4,uu&V'dVPP V4p\\ V4^4pV'dV^;;,^,uu&RP \V4\V4V.4#)z^ Encodes a header with an indexed name and a literal value and performs incremental indexing. r)rr7ordrcrXrrr")rfr<r&rrzprefixrs&&&&& rrEncoder._encode_indexed_literaljs ( (#E1-F#E1-Fq S]" &&--e4E"3u:q1  aLD Lxxvi(8%@AArcV^8dQhRR/#)rrr"r)rs"rrr_s  5 rc RpVPF6p\V^4pV^;;,^ ,uu&V\V4, pK8 .VnV#)zL Produces the encoded form of all header table size change context updates. r)rdr7r")rfblock size_bytesbs& rr|!Encoder._encode_table_size_changesO 11Jz1-A aDDLD U1X E2#% r)rbrcrdN)TF)__name__ __module__ __qualname____firstlineno____doc__rgpropertyrpsetterrXrrrrr|__static_attributes__rrrr[r[sa 0)) 22 kZ/b *B,  rr[c]tRtRtRt]3RRllt]RRl4t]PRRl4tRR R llt R R lt R Rlt RRlt RRltRRltRRltRtR#)Decoderia An HPACK decoder object. .. versionchanged:: 2.3.0 Added ``max_header_list_size`` argument. :param max_header_list_size: The maximum decompressed size we will allow for any single header block. This is a protection against DoS attacks that attempt to force the application to expand a relatively small amount of data into a really large header list, allowing enormous amounts of memory to be allocated. If this amount of data is exceeded, a `OversizedHeaderListError ` exception will be raised. At this point the connection should be shut down, as the HPACK state will no longer be usable. Defaults to 64kB. :type max_header_list_size: ``int`` c V^8dQhRRRR/#)rmax_header_list_sizer*rr^r)rs"rrDecoder.__annotate__s@@S@TX@rc f\4VnWnVPPVnR#ra)rrbrromax_allowed_table_size)rfrs&&rrgDecoder.__init__s*'M %9!'+&7&7&?&?#rcV^8dQhRR/#rjr)rs"rrrrkrc .VPP#rmrnres&rrpDecoder.header_table_sizerrrc V^8dQhRRRR/#rtr)rs"rrrs**s*t*rc &WPnR#rarnrws&&rrprs$)!rc$V^8dQhRRRRRR/#)rr9r"rrrzIterable[HeaderTuple]r)rs"rrrs'Q3Q35Q3tQ38MQ3rc |\PRV4\V4p.p\V4p^p^pWu8Ed3W,p\ V^,4p \ V^@,4p \ V^ ,4p V 'dVP W7R4wrMfV 'dVP W7R4wrMHV 'd,V'dRp\V4hVPW7R4p Rp MVPW7R4wrV 'd^VPV 4V\V ^,V ^,4, pW`P8dRVP R2p\V4hW}, pEK9VP4VUu.uFp\W4NK up#uupi \ dpRp\T4ThRp?ii;i)a Takes an HPACK-encoded header block and decodes it into a header set. :param data: A bytestring representing a complete HPACK-encoded header block. :param raw: (optional) Whether to return the headers as tuples of raw byte strings or to decode them as UTF-8 before returning them. The default value is False, which returns tuples of Unicode strings :returns: A list of two-tuples of ``(name, value)`` representing the HPACK-encoded headers, in the order they were decoded. :raises HPACKDecodingError: If an error is encountered while decoding the header block. z Decoding %sNz/Table size update not at the start of the blockzA header list larger than z has been receivedz!Unable to decode headers as UTF-8)r/r0 memoryviewrr_decode_indexed_decode_literal_indexr_update_encoding_context_decode_literal_no_indexr3rrr_assert_valid_table_sizer'UnicodeDecodeError)rfr9rdata_memrydata_len inflated_size current_indexcurrentindexed literal_indexencoding_updaterconsumedr4hrAs&&& rr$Decoder.decodes -&d#%'t9  &)G7T>*G!40M#7T>2O#'#7#7^,$ #'#=#=^,$ !KC,S1188^,$(#@#@^,$ v&!1&)VAY!GG  #<#<<6t7P7P6QQcdC2377  %M %%' 38?@1&q.@ @@! 35C$S)s 2 3s*=FFFF F;(F66F;cV^8dQhRR/#r]r)rs"rrrs--$-rc VVPVP8dRp\V4hR#)z[ Check that the table size set by the encoder is lower than the maximum we expect to have. z3Encoder did not shrink table size to within the maxN)rprr)rfr4s& rr Decoder._assert_valid_table_sizes.  ! !D$?$? ?GC', , @rc V^8dQhRRRR/#)rr9r"rr*r)rs"rrr's  U s rc h\V^4wr#W P8dRp\V4hW nV#)z3 Handles a byte that updates the encoding context. z)Encoder exceeded max allowable table size)rBrrrp)rfr9new_sizerr4s&& rr Decoder._update_encoding_context's: ,D!4 11 1=C', ,!)rc V^8dQhRRRR/#rr9r"rtuple[HeaderTuple, int]r)rs"rrr3s  E .E rc \V^4wr#\VPPV4!p\P RWC4WC3#)z@ Decodes a header represented using the indexed representation. zDecoded %s, consumed %d)rBr rb get_by_indexr/r0)rfr9r<rrs&& rrDecoder._decode_indexed3sE)q1d//<rc V^8dQhRRRR/#rr)rs"rrr<s>>U>7N>rc (VPVRR7#)F should_index_decode_literalrfr9s&&rr Decoder._decode_literal_no_index<s##Du#==rc V^8dQhRRRR/#rr)rs"rrr?s==%=4K=rc (VPVRR7#)Trrrs&&rrDecoder._decode_literal_index?s##Dt#<LH!MQI$t+LH T!12M ,T>"5)E 8++ ,T9F -F     ! !$ . =     %%r)rbrprrNr)rrrrrDEFAULT_MAX_HEADER_LIST_SIZErgrrprr$rrrrrrrrrrrrsm*4P@8)) **Q3f-  >=L&L&rri)+r __future__rloggingtypingrr exceptionsrrrrzrhuffman_constantsr r huffman_tabler structr r rtablerrcollections.abcr getLoggerrr/ INDEX_NONErrranger2rr'r7rBrTrHr[r)is0rrs#%[[#B)KK0( !    27q:AAFa<<: ' )>$N$& !vvr@&@&e ;s5C