Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes15kdownloads
http_parser.cpython-313.pyc222 linesDownload Raw Back to __pycache__
1�

2��j}�����%SSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ	r	J3r4JrJrJ
r
JrJrJrJrJrJrJrJrJr SSKJrJrJr SSKJr SSKJr SS	KJ r  SS5K!J"r"J#r#J$r$J%r%J&r&J'r' SSK(J)r)J*r*J+r+J,r,J-r-J.r.J/r/ SSK0J1r1J2r2J3r3J4r4J5r5J6r6J7r7J8r8J9r9J:r: SS
K;J<r<J=r= SSK>J?r?J@r@ SSKAJBrB SrC\SrD\E"\R�5rG\\\H\IS'\R�"S5rK\\H\IS'\R�"S\KS35rM\\\H\IS'\R�"S5rN\\\H\IS'\R�"S\R�5rP\\\H\IS'\R�"S\R�5rQ\\\H\IS'\R�"S5rR\\\S\IS'\T"1S k5rU\\T\H\IS!'"S"S#\5rV"S$S%\5rW\"S&\V\W5rX"S'S(\5rY"S)S*\5rZ"S+S,5r[S-\\HS.\\4S/jr]"S0S1\R�\\X5r_"S2S3\_\V5r`"S4S5\_\W5ra"S6S75rb"S8S95rc\`rd\are\Vrf\Wrg\-(dSS:KhJ`r`JaraJVrVJWrW \`ri\arj\Vrk\Wrlgg!\ma gf=f);�N)�suppress)�IntEnum)�Any�ClassVar�Final�Generic�List�Literal�6NamedTuple�Optional�Pattern�Set�Tuple�Type�TypeVar�Union)�CIMultiDict�CIMultiDictProxy�istr)�URL�)�hdrs)�BaseProtocol)�DEFAULT_MAX_DECOMPRESS_SIZE�7HAS_BROTLI�HAS_ZSTD�BrotliDecompressor�ZLibDecompressor�ZSTDDecompressor)�
_EXC_SENTINEL�DEBUG�EMPTY_BODY_METHODS�EMPTY_BODY_STATUS_CODES�
NO_EXTENSIONS�BaseTimerContext�
set_exception)8�BadHttpMessage�
BadHttpMethod�
BadStatusLine�ContentEncodingError�ContentLengthError�DecompressSizeError�
InvalidHeader�InvalidURLError�LineTooLong�TransferEncodingError)�HttpVersion�
HttpVersion10)�
EMPTY_PAYLOAD�StreamReader)�9RawHeaders)�
HeadersParser�10HttpParser�HttpRequestParser�HttpResponseParser�RawRequestMessage�RawResponseMessage)�
11�12�ASCIISETz!#$%&'*+-.^_`|~�_TCHAR_SPECIALSz13[0-9A-Za-zz]+�TOKENREz[\x00-\x08\x0a-\x1f\x7f]�_FIELD_VALUE_FORBIDDEN_CTL_REzHTTP/(\d)\.(\d)�VERSREz\d+�DIGITSs[0-9a-fA-F]+�	HEXDIGITS>14�etag�host�server�15user-agent�content-type�max-forwards�
content-range�content-length�content-location�transfer-encoding�SINGLETON_HEADERSc��\rSrSr%\\S'\\S'\\S'S\S'\\S'\\S'\	\\S	'\\S16'\\S'\17\S'S
rg)r:�q�method�path�version�CIMultiDictProxy[str]�headers�raw_headers�should_close�compression�upgrade�chunked�url�N)�__name__�18__module__�__qualname__�__firstlineno__�str�__annotations__r1r5�boolrr�__static_attributes__r]��YD:\code\apps\devtools\python\user_packages\Python313\site-packages\aiohttp/http_parser.pyr:r:qs=���K�19
�I�
��
$�$������#���
�M�
�M�	�Hrfr:c�|�\rSrSr%\\S'\\S'\\S'\\\S'\	\S'\20\S'\\\S'\21\S	'\22\S23'Srg)
r;�~rT�code�reasonrVrWrXrYrZr[r]N)
r^r_r`rar1rc�intrbrr5rdrrer]rfrgr;r;~s=��
��24
�I��K�
�c�
"�"������#���
�M�
�Mrfr;�_MsgTc�$�\rSrSrSrSrSrSrSrg)�25ParseState�rr��r]N)	r^r_r`ra�26PARSE_NONE�PARSE_LENGTH�
PARSE_CHUNKED�PARSE_UNTIL_EOFrer]rfrgroro�s���J��L��M��Orfroc�(�\rSrSrSrSrSrSrSrSr	g)	�27ChunkState�rrrqrr�r]N)28r^r_r`ra�PARSE_CHUNKED_SIZE�PARSE_CHUNKED_CHUNK�PARSE_CHUNKED_CHUNK_EOF�PARSE_MAYBE_TRAILERS�PARSE_TRAILERSrer]rfrgrxrx�s�����������Nrfrxc�`�\rSrSrS
S\S\S\S\SS429SjjrS	\\S\	S30\3144SjrSrg)r6��
max_line_size�max_headers�max_field_size�lax�returnNc�4�XlX lX0lX@lg�N)r�r�r��_lax)�selfr�r�r�r�s     rg�__init__�HeadersParser.__init__�s��+��&��,���	rf�linesrUc�d�[5n/nSnXn[U5nU(Ga\URSS5upx[U5S:Xa[	U5eUSUS1SS1-(a[	U5eURS5nUR
SS	5n	[RU	5(d[	U5eUS-
nXnUR=(a U=(a USS32;n33U34(a�[U5nU/nU35(a�U[U5-
nX�R:�a3US-SRU5-n
[U
SS
S-UR5eURU5 US-
nXF:aXnU(aUSS36;n37OSnO	U38(aM�SRU5nURS5nUR
SS	5nUR(aSU;dSU;dSU;a[	U5eO%[R!U5(a[	U5eUR(d,X�;a'U	R#5[$;a['SU	S35eUR)X�5 URXx45 U(aGM\[+U5[-U54$![a
 [	U5Sef=f)Nr�:r������ �	s 	�utf-8�surrogateescape)r�r�s: rf�d�...�39�
�zDuplicate 'z' header found.)r�len�split�40ValueErrorr-�lstrip�decoder@�	fullmatchr�r��joinr/�append�striprA�search�lowerrOr'�addr�tuple)r�r�rVrW�	lines_idx�line�41line_count�bname�bvalue�name�continuation�
header_length�42bvalue_lst�header_line�values               rg�
parse_headers�HeadersParser.parse_headers�s���%0�M�����	������Z�43��
4� $�44�45�4�� 3�
���5�z�Q��#�E�*�*��a��%��)�$��A�w�.�#�D�)�)��]�]�6�*�F��<�<��):�;�D��$�$�T�*�*�#�E�*�*�
��N�I��#�D� �9�9�D��D�$�q�'�W�2D�L�� #�F��
�$�X�46�"�!�S��Y�.�M�$�':�':�:�&+�e�m�c�h�h�z�6J�&J��)�'���-��6��8K�8K����%�%�d�+���N�I� �-�$�/���+/��7�g�+=�L��"���##�l�$���*�-���\�\�&�)�F��M�M�'�+<�=�E��y�y��5�=�D�E�M�V�u�_�'��/�/�6E�.�5�5�e�<�<�#�F�+�+��9�9���T�Z�Z�\�EV�5V�$�{�4�&��%H�I�I��K�K��$������/��d�B!��)�5��+=�>�>��{�
4�#�D�)�t�3�
4�s�J�J/)r�r�r�r�)��i�r�F)
r^r_r`rarlrdr�r	�bytesrr5r�rer]rfrgr6r6�sl��"� �"��47��48��49��	50�51�52�53�
54�L?��%�[�L?�	�&�55�2�	3�L?rfr6rVr�c��UR[RS5nUR5=(a UR	5S;$)z)Check if the upgrade header is supported.�>�tcp�	websocket)�getr�UPGRADE�isasciir�)rV�us  rg�_is_supported_upgrader��s3�����D�L�L�"�%�A��9�9�;�<�1�7�7�9�(<�<�<rfc��\rSrSr%Sr\\\S'S'S\\	S\\56RS\S\S	\S57\S\\
S\\S
\\S\\\S\S\S\SS4Sjjr\R&S\\S\4Sj5r\R&S\S\4Sj5rS\\4SjrSS\R6\R8\R:4S\S\S\S\S\S \S\ \\ \\!4\\44S!jjr"S\\S\ S"\#\\\\\\44S#jr$S$\SS4S%jr%S&r&g)(r7�Fr�N�protocol�loop�limitr�r�r��timerrjrR�payload_exception�response_with_body�read_until_eof�auto_decompressr�c�(�XlX lX@lXPlX`lXPlXplX�lX�lX�lX�l	X�l58/UlSUlSUl
SUlSUlX�lX0l[%XEX`R&5Ulg)NrfF)r�r�r�r�r�r�rjrRr�r�r��_lines�_tail�	_upgraded�_payload�_payload_parser�_auto_decompress�_limitr6r��_headers_parser)r�r�r�r�r�r�r�r�rjrRr�r�r�r�s              rgr��HttpParser.__init__s��� !�
��	�*��&��,��&���59��	���!2��"4��,��#%�����60������
�<@��� /����,����� 61��rfr�c��gr�r])r�r�s  rg�
parse_message�HttpParser.parse_message+s��:=rf�tec��gr�r]�r�r�s  rg�_is_chunked_te�HttpParser._is_chunked_te.s��/2rfc���URb"URR5 SUlgUR(a%URR	UR5 UR(abURSS:waURR	S5 [[5 URUR5sSSS5 $g!,(df   g=f)Nr�z
62rf)r��feed_eofr�r�r�r�	Exceptionr��r�s rgr��HttpParser.feed_eof1s������+�� � �)�)�+�#'�D� ���z�z����"�"�4�:�:�.��{�{��;�;�r�?�f�,��K�K�&�&�s�+��i�(��-�-�d�k�k�:�)�(��)�(��s�4C�63C(r<rf�data�SEP�EMPTY�CONTENT_LENGTH�METH_CONNECT�SEC_WEBSOCKET_KEY1c�
^^�/nUR(aURU-Ssol[U5nSn	URn64URnSnX�:Ga�URGcUR65(Gd�UR
X)5n
X�:Xa!UR(dU
[U5-n	M]X�:�GacU(a[S5eXU
nUS:XaURS5n[U5U:�a[USSS-U5eURRU5 URn[UR5UR:�a[S	5eU
[U5-n	URS66U:XGa�UR[UR5-67nURUR5mURR5 S[ ["4UU4SjjnU"5nUTR$;a['U5eTR(=(a [+TR$5Ul[-TS
UR.5n[-TSS5nUR0ceU[2;=(d [5U=(a	 U[6;5nU(d�UbUS:�dTR8(a�UR68(d�[;UR0UR<U69UR>S9n[AUUTR8UTRBURDURFURHURJURLURURUS9
nURN(dUUlGO~UU:Xa�[QT[R5(de[;UR0UR<U70UR>S9nSUl[AUTR.TRBURHURJURLURURUS9	UlO�U(d�Uc�URT(a�[;UR0UR<U71UR>S9n[AUUTR8UTRBURDURFURHURJURLURURUS9
nURN(dUUlO[VnURTU45 TRXnO�XSUl[UR5UR:�a&[URSSS-UR5eUnO�URc%UR72(aUR(aeOxU(ahX�:acUR(aeURceURR[XSU5unnU(aSn	[U5nSUlGM�OOX�:aGM�U(a73X�:aXSnOUnXpR74U4$!URR5 f=f![\atnUnUR^bUR_[aU55n[cURRdUU5 SnSn[QU[&[f45(aeSnAN�SnAff=f)NrfrFzData after `Connection: close`r=�
r�r�zToo many headers receivedr�r�c�>�TRRT5nUcg[RU5(d[	T5e[U5$r�)rVr�rCr�r-rl)�75length_hdrr��msgs ��rg�get_content_length�0HttpParser.feed_data.<locals>.get_content_length}sF���),������)H�J�)�1�'+�76$*�#3�#3�J�#?�#?�&3�N�&C� C�#&�z�?�2rfrRrj)r�r�r�)�lengthr[rRrYrjr�r�r��headers_parserr�r��max_trailersT)rRrYr�r�r�r�r�r�)4r�r�r�r�r�r��findr�r'�rstripr/r�r�r�r��clearrrlrVr-rZr��getattrrRr�r#rdr"r[r4r�r��HttpPayloadParserrYrjr�r�r�r��done�77isinstancer:r�r3rX�	feed_data�
BaseExceptionr�rbr&�payloadr0)r�r�r�r�r�r�r��messages�data_len�	start_posr��max_line_lengthrX�posr�r�r�r�rRrj�78empty_bodyr��payload_parser�eof�underlying_exc�reraised_excr�s    `                     @rgr��HttpParser.feed_dataAs�������:�:�#�z�z�D�0�#��D�*��t�9���	��y�y���,�,�����"��#�#�+�D�N�N�N��i�i��/���#�D�K�K� #�c�#�h��I���#�#�,�-M�N�N� �#�.�D��e�|�#�{�{�5�1���4�y�?�2�)�$�t��*�v�*=��O�O��K�K�&�&�t�,�&*�&9�&9�O��4�;�;�'�$�*:�*:�:�,�-H�I�I� #�c�#�h��I��{�{�2��%�/�'+�'7�'7�#�d�k�k�:J�'J��0�)-�);�);�D�K�K�)H�C� �K�K�-�-�/�3�H�S�M�3�3�"4�!5��-����<�"/�0B�"C�C�),���*�9N��K�K�:���")��h����!D��&�s�F�A�6��#�}�}�8�8�8�%)�-D�%D�&��"�C�v�1C�'C�I�79� *�$�0�V�a�Z�C�K�K�$(�N�N�&2� $�
�
�&*�j�j�%)�&*�k�k�	'�G�.?� '�'-�(+���'-�,/�O�O�%)�Y�Y�37�3J�3J�04�0E�0E�$(�H�H�/3�/C�/C�.2�.@�.@�/3�/B�/B�-9�.�N�$2�#6�#6�7E�� 4��#�|�3�#-�c�3D�#E�#E�E�#E�&2� $�
�
�&*�j�j�%)�&*�k�k�	'�G�.2�D�N�3D� '�'*�z�z�,/�O�O�04�0E�0E�$(�H�H�/3�/C�/C�.2�.@�.@�/3�/B�/B�-9�804�D�0�",���4�CV�CV�&2� $�
�
�&*�j�j�%)�&*�k�k�	'�G�.?� '�'-�(+���'-�,/�O�O�%)�Y�Y�37�3J�3J�04�0E�0E�$(�H�H�/3�/C�/C�.2�.@�.@�/3�/B�/B�-9�.�N�$2�#6�#6�7E�� 4��&3�G� ����g��7�'*�'7�'7���!%�j�!1�D�J��4�:�:���);�);�;�)�$�*�*�T�c�*:�V�*C�T�EW�EW�X�X� �D���%�%�-�$�.�.��;�;�&����)�.��;�;�&���+�+�7�7�7�� $� 4� 4� >� >�t�J�?O�QT� U�I�C��&� !�I�"�4�y�H�+/�D�(��	��{�"�~�I�(��81�#�D��D�����-�-��!�K�K�-�-�/��@%��#1�L��-�-�9�'+�'=�'=�c�.�>Q�'R��!��,�,�4�4�$�&���C��D�!�&��8M�(N�������s%�X9�!Y�9Y�82[�"A*[�[rUc�6�URRU5up#SnSnSnSnUR[RS5nU(a�UV	V83s1sHSn	SU	RS55H3n84U85(dMU86R
5(dM#U87R5iM5 MU nn	n88SU;aSnOSU;aSnS	U;a&UR[R5(aSnUR[RS895nUR
5(aUR5S;aUnUR[R5n
U
b7URU
5(aSn[RU;a[S5eX#XEXg4$s sn90n	f)
z�Parses RFC 5322 headers from a stream.91 92Line continuations are supported. Returns list of header name93and value pairs. Header name is in upper case.94NFr]c3�B# �UHoRS5v� M g7f)� 	N)r�)�.0�parts  rg�	<genexpr>�+HttpParser.parse_headers.<locals>.<genexpr>3s���R�<Q�D�j�j��/�/�<Q�s��,�closeTz95keep-aliverZr�>�br�gzip�zstd�deflatez6Transfer-Encoding can't be present with Content-Length)r�r��getallr�96CONNECTIONr�r�r�r�r��CONTENT_ENCODING�TRANSFER_ENCODINGr�r�r')r�r�rVrW�97close_conn�encodingrZr[�conn_values�98conn_value�token�conn_tokens�encr�s              rgr��HttpParser.parse_headerss{�� $�3�3�A�A�%�H����99��������n�n�T�_�_�b�9���#.��"-�J�R�J�<L�<L�S�<Q�R�E���#�]�]�_�����
�R��"-�
���+�%�!�100���,�"�101��K�'�G�K�K����,E�,E����k�k�$�/�/��4���;�;�=�=�S�Y�Y�[�,M�M��H��[�[��/�/�
0��
�>��"�"�2�&�&����"�"�g�-�$�L����j�G�M�M��As�'F�=F�F�valc��Xlg)zJSet connection upgraded (to websocket) mode.102 103:param bool val: new state.104N)r�)r�rs  rg�set_upgraded�HttpParser.set_upgradedRs	��105�rf)r�r�r�r�r�r�r�r�rjr�r�r�r�rRr�r�r�r�r�)
NNir��r�NNNNTFT)'r^r_r`rar�rrdrcrr�asyncio�AbstractEventLooprlr%rbrr�r��abc�abstractmethodr	r�rmr�r�r�rr�r�r��_SEPrrr4r�r5r�r rer]rfrgr7r7s!���C��$���,0�48��!��"�,0�"� $�;?�#'�$� $�&106��<�(�&107��w�0�0�1�&108��	&109�110�&111��
&112��&113��(�)�&114��s�m�&115���
�&116�$�D��$7�8�&117�!�&118��&119��&120�121�&122�P	���=�4��;�=�5�=��=����2��2��2��2��(�5�/��&��#�2�2� �-�-�#'�#:�#:�Y.��Y.��Y.��	Y.�123�Y.��
Y.�!�Y.�124�t�E�%��-�.�/��u�<�	=�Y.�v4N��%�[�4N�	���X�d�^�X�c�]�D�RV�V�125�4N�l����rfr7c�B�\rSrSrSrS\\S\4SjrS\	S\1264SjrSrg	)127r8iZz�Read request status line.128 129Exception .http_exceptions.BadStatusLine130could be raised in case of any errors in status line.131Returns RawRequestMessage.132r�r�c��USRSS5nURSSS9up4n[RU5(d[U5e[RU5nUc[U5e[[URS55[URS555nUS:Xa[R"US	S1339nO�URS5(a@URS5up�nU	RS
5up�n
[R"U	U
US	S9nOXUS:XaUS:Xa[US	S9nOA[US	S9nURS:Xa'[!UR#SS9RS55eUR%USS5unnnnnnUcU[&::aS	nOSn[)UUUUUUUUUU5134$![a
 [U5Sef=f)Nrr�r�� rq��maxsplitr�CONNECTT)�	authority�encoded�/�#�?)rS�query_string�fragmentr/�*�OPTIONS)r/r�)�errors�latin1F)r�r�r�r(r@r�rBr)r1rl�groupr�build�135startswith�	partition�schemer.�encoder�r2r:)r�r�r�rRrSrT�match�	version_or\�	path_part�_hash_separator�url_fragment�_question_mark_separator�qs_partrVrWr
rYrZr[s                    rgr��HttpRequestParser.parse_messagebs����Q�x���w�(9�:��	0�$(�J�J�s�Q�J�$?�!�F�'�136� � ��(�(���'�'�� � ��)���=���%�%���E�K�K��N� 3�S����Q��5H�I�	��Y���)�)�d�D�9�C�
�_�_�S�
!�
!�8<�~�~�c�7J�4�I��;D�;N�;N�s�;S�8�I���)�)��$�%��	�C��S�[�V�y�0��d�D�)�C��d�D�)�C��z�z�R��%��K�K�'8�K�9�@�@��J���
���u�Q�R�y�)�	137��������=��M�)����� �����������138�	139��}�	0���%�4�/�	0�s�F9�9Gr�c��URSSS9SRS5nUR5(aUR5S:Xag[	S5e)	Nrrr+r�rr[Tz'Request has invalid `Transfer-Encoding`)�rsplitr�r�r�r'r�s  rgr�� HttpRequestParser._is_chunked_te�sK��
�Y�Y�s�Q�Y�
'��
+�
1�
1�%�
8��
�:�:�<�<�B�H�H�J�)�3���F�G�Grfr]N)
r^r_r`ra�__doc__r	r�r:r�rbrdr�rer]rfrgr8r8Zs9���N140�4��;�N141�3D�N142�`H��H��Hrfr8c�^�\rSrSrSr\(+rSS\S\\	S\143S\144S\\\\
\4\\44145U4SjjjrS	\\S\
4S146jrS\S\4SjrS
rU=r$)r9i�z�Read response status line and headers.147 148BadStatusLine could be raised in case of any errors in status line.149Returns RawResponseMessage.150r�r��args�kwargsr�c�P>�Uc[(aSOSn[TU]"X/UQ70UD6$)Nr<r=)r!�superr�)r�r�r�rLrM�	__class__s     �rgr��HttpResponseParser.feed_data�s/����;�"�U�'��C��w� ��<�T�<�V�<�<rfr�c�L�USRSS5nURSS9up4URSS9upE[151R
U5nUc[U5e[[URS55[URS555n[U5S:wd[R
U5(d[U5e[U5nURUSS5un	n152nnn
nUcRU[::aS	nOES153Us=::aS:dO US;aS
nO-[RU	;d[R U	;aS
nOS	n[#UUUR	5U	U154UUU
U5	$![a
 [U5Sef=f![a UR	5nSnGNhf=f)Nrr�r�rr+r�rqrrTr���>�0��F)r�r�r�r)r�rBr�r1rlr9r�rCr�r2rr�rr;)r�r�r�rT�statusrkr?r@�status_irVrWr
rYrZr[s               rgr�� HttpResponseParser.parse_message�s����Q�x���w�(9�:��	0�"�j�j�!�j�4�O�G�	�#�\�\�1�\�5�N�F�� � ��)���=���%�%���E�K�K��N� 3�S����Q��5H�I�	��v�;�!��6�#3�#3�F�#;�#;���%�%��v�;��
���u�Q�R�y�)�	155��������=��M�)�����&�3�&�(�j�*@����$�$��/�4�3I�3I�W�3T�����!����L�L�N�������156157�158	159��U�	0���%�4�/�	0��160�	��\�\�^�F��F�	�s�E)�F�)F�F#�"F#r�c�h�URSSS9SRS5R5S:H$)Nrrr+r�rr[)rHr�r�r�s  rgr��!HttpResponseParser._is_chunked_te161s3���y�y��q�y�)�"�-�3�3�E�:�@�@�B�i�O�Orfr]r�)r^r_r`rarJr!r�r�rr'rrr	r;r4rdr�r�rbr�re�
__classcell__)rPs@rgr9r9�s������)�C�162#�	=��	=��d�^�	=��		=�163�	=�164�t�E�,�l�:�;�<�d�E�I�	J�
	=�	=�8165�4��;�8166�3E�8167�tP��P��P�Prfr9c���\rSrSrSSSSS.S\S\\S\S	\\S168\\S\\S\S
\S\S\	S\S\S\SS4Sjjjr169SSjrSS\S\
S\S\\\44SjjrSrg)r�iNr�r")r�r�r�r�r�r[rYrjrRr�r�r�r�r�r�r�r�c170�x�SUl[RUl[R171UlSUlSUlX�l	X�l172X�lX�lX�l
X�l/UlSUlU(a$U(aUR(a[#X5nOUnU(d-[R$UlUR'5 SUlObU(a[R(UlOEUbB[R*UlX lURS:XaUR'5 SUlX�lg)NrrfFT)�_lengthrorv�_typerxr{�_chunk�_chunk_size�_chunk_tailr�r�r��_max_line_size�_max_field_size�
_max_trailers�_trailer_linesr��
DeflateBufferrsr�rurtr�)r�r�r�r[rYrjrRr�r�r�r�r�r�r��real_payloads               rgr��HttpPayloadParser.__init__s���"����/�/��173� �3�3��������� /���	�-��+��-��)��+-�����	��+�$�2G�2G�?L��@�L�#�L�"�#�.�.�D�J��!�!�#��D�I�
�#�1�1�D�J�
�
�#�0�0�D�J�!�L��|�|�q� ��%�%�'� ��	�#�rfc��UR[R:XaURR	5 gUR[R174:Xa[
S5eUR[R:Xa[S5eg)Nz1Not enough data to satisfy content length header.z2Not enough data to satisfy transfer length header.)	r_rorvr�r�rtr+rur0r�s rgr��HttpPayloadParser.feed_eofHso���:�:��3�3�3��L�L�!�!�#�
�Z�Z�:�2�2�
2�$�C��
��Z�Z�:�3�3�
3�'�D��
�4rf�chunkr��	CHUNK_EXTc�V
�UR[R:Xa�URn[	U5nXE:�aQXE-175UlUR176R
X5 URS:XaUR177R5 ggSUlUR178R
USUU5 UR179R5 SXS4$UR[R:XGaWUR(a�UR[R:wdeURnUR[R:XaURn[	UR5U:�a[!URSSS-U5eURU-nSUl	U(Ga�UR[R":XGa�UR%U5nUS:�GaoUR%USU5nUS:�a7USUn	SXU=n180;a'['SU181<35n[)UR182U5 UeOUSUn	UR*(aU	R-5n	[.R0"[2U	5(d6['USUR5S	S18355n[)UR184U5 Ue[7[9U	5S5nX[	U5-SnUS:XaB[RUl185UR*(aUR;S5(aUS
SnO=[RUl186X�lUR187R?5 OXl	gUR[R:Xa�UR<n[	U5nXE:�a%XE-188UlUR189R
X5 gSUlUR190R
USUU5 XSn[R@Ul191UR192RC5 UR[R@:Xa�UR*(aUR;S5(aUS
SnUS[	U5U:Xa$U[	U5Sn[R"Ul193OS[	U5[	U5:�dXS[	U5:wa#['S5n[)UR194U5 UeXl	gUR[R:XGa;UR%U5nUS:aXl	gUSUn
X[	U5-SnUS:XaU
RES5n
[	U
5UR:�a[!U
SSS-UR5eURFRIU
5 [	URF5URJ:�a[MS5eURFSS:Xa`URNRQURF5up�URFRS5 UR195R5 SU4$U(aGM�gUR[RT:Xa%UR196R
U[	U55 g!URFRS5 f=f)Nr)TrfTr�r�rfr=z"Unexpected LF in chunk-extension: �asciir��r�r)Frfz3Chunk size mismatch: expected CRLF after chunk datazToo many trailers receivedr�)+r_rortr^r�r�r�r�rurbr`rxr|rcrrdr/r{r�r0r&r�r��rer�rDr�rlr�r;ra�begin_http_chunk_receivingr}�end_http_chunk_receivingr�rfr�rer'r�r�r�rv)r�rlr�rm�required�	chunk_lenr�r��i�size_b�ext�exc�sizer��trailers�raw_trailerss                rgr��HttpPayloadParser.feed_dataTs����:�:��0�0�0��|�|�H��E�197�I��$�'�3������&�&�u�8��<�<�1�$��L�L�)�)�+�$�%�P�I !������&�&�u�Y�h�'7��B����%�%�'��U�9�-�-�-��Z�Z�:�3�3�
3�����{�{�j�&D�&D�D�D�D�"&�"5�"5���;�;�*�";�";�;�&*�&:�&:�O��t�'�'�(�?�:�%�d�&6�&6�t��&<�v�&E��W�W��(�(�5�0��#&�� ���;�;�*�"?�"?�?��*�*�S�/�C��a�x�!�J�J�y�!�S�9����6�%*�2�A�Y�F�$����)<��=�&;�&H���$P�'"��!.�d�l�l�C� @�&)�	� >�&+�4�C�[�F��9�9�%+�\�\�^�F�!�|�|�I�v�>�>�"7� %�d�s�� 2� 2�7�<M� N�#�C�*�$�,�,��<�"%�I�"�5��=�"�5�� %�C��H�n�&6� 7���1�9�*4�*C�*C�D�K�#�y�y�U�-=�-=�e�-D�-D�(-�a�b�	���*4�*H�*H�D�K�/3�,� �L�L�C�C�E�+0�(�)��;�;�*�"@�"@�@�#�/�/�H� #�E�198�I��+�+3�+?��(����.�.�u�@�)�+,��(����.�.�u�Y�h�/?��J� %�i� 0��&0�&H�&H������=�=�?��;�;�*�"D�"D�D��y�y�U�%5�%5�e�%<�%<� %�a�b�	���Z�s�3�x�(�C�/� %�c�#�h�j� 1��&0�&C�&C����U��s�3�x�/�5��#�e�*�<M�3M�3�Q���&�d�l�l�C�8�!�	�+0�(�)��;�;�*�";�";�;��*�*�S�/�C��Q�w�+0�(�)� ��#�;�D�!��C��.�"2�3�E��e�|�#�{�{�5�1���4�y�4�#7�#7�7�)�$�t��*�v�*=�t�?S�?S�T�T��'�'�.�.�t�4��4�.�.�/�$�2D�2D�D�,�-I�J�J��*�*�2�.�#�5�8�59�5I�5I�5W�5W� $� 3� 3�6�2�H�!�/�/�5�5�7����-�-�/�#�U�{�*�U�%�`��Z�Z�:�5�5�
5��L�L�"�"�5�#�e�*�5���!�/�/�5�5�7�s�'Z�Z()r�r`rarbr�r�r^rdrcrerfr_r�r�)NFNNNTTF�r�N)r<�;)r^r_r`rar4rrlrdrbr6r�r�r�r'rr�rer]rfrgr�r�s��!%��%)�"� $�#'� $��6$�"�"��6$��6$���
�6$��	6$�199�c�]�6$��s�m�
6$���
�6$�!�6$��6$��6$�&�6$��6$��6$��6$� 200�!6$�p201�EI�S��S�!%�S�<A�S�	�t�U�{�	�S�Srfr�c	��\rSrSr%Sr\\S'\4S\S\	\202S\SS4S	jjr\
4S203\S\SS4SjjrS
\S\SS4SjrSSjrSSjrSSjrSrg)rgi�zDDeflateStream decompress stream and feed data into specified stream.�decompressor�outr�max_decompress_sizer�Nc�6�XlSUlURUlX lSUlU US:Xa&[204(d[
S5e[5UlO:US:Xa&[(d[
S5e[5UlO[US9UlX0lg)NrFrzECan not decode content-encoding: brotli (br). Please install `Brotli`rzRCan not decode content-encoding: zstandard (zstd). Please install `backports.zstd`)r)
r�rz�total_compressed_bytesr�_started_decodingrr*rr�rrr�_max_decompress_size)r�r�rr�s    rgr��DeflateBuffer.__init__�s�������	�%)�Y�Y��"� �
�!&�����t���:�*�.���!3� 4�D��
��
��8�*�6���!1� 2�D�� 0�(� C�D��$7�!rfry�	exc_causec�0�[URX5 gr�)r&r�)r�ryr�s   rgr&�DeflateBuffer.set_exceptions��205	�d�h�h��/rfrlrzc�d�U(dgU=RU-
slURURlUR(d5URS:Xa%USS-S:wa[URSS9UlURRXRS-S9nSUl[U5UR:�a[S206UR-5eU(a&URRU[U55 gg![a [S	UR-5ef=f)Nrr��T)r�suppress_deflate_headerr)�207max_lengthz#Can not decode content-encoding: %sz:Decompressed data exceeds the configured limit of %d bytes)rzr�r�r�rrr��decompress_syncr�r�r*r�r,r�)r�rlrzs   rgr��DeflateBuffer.feed_datas�����	�	�T��	�*.�)�)����'��&�&��
�
��*��a��3��!�#�!1�����!�D��	��%�%�5�5��";�";�a�"?�6��E�"&����u�:��1�1�1�%�L��+�+�,��
�208��H�H���u�c�%�j�1����	�&�5��
�
�E��
�	�s�&D�#D/c�P�URR5nU(dURS:�a[URR	U[U55 URS:Xa&URR(d[S5eURR5 g)Nrr)209r��flushrzr�r�r�rrr*r�)r�rls  rgr��DeflateBuffer.feed_eofAsp���!�!�'�'�)���D�I�I��M��H�H���u�c�%�j�1��}�}�	�)�$�2C�2C�2G�2G�*�9�5�5������rfc�8�URR5 gr�)r�rrr�s rgrr�(DeflateBuffer.begin_http_chunk_receivingKs�����+�+�-rfc�8�URR5 gr�)r�rsr�s rgrs�&DeflateBuffer.end_http_chunk_receivingNs�����)�)�+rf)r�r�r�rr�rzr~)r^r_r`rarJrrcrr4rrbrlr�r r�r&r�r�r�rrrsrer]rfrgrgrg�s���N���$?�	8�
�8��3�-�8�!�	8�210211�8�F$1�0�
�0�!�0�212�	0�)2�u�)2�C�)2�D�)2�V�.�,rfrg)r8r9r:r;)nr%r#rq�string�213contextlibr�enumr�typingrrrrr	r214rrr
rrrrr�	multidictrrr�yarlrr�r�
base_protocolr�compression_utilsrrrrrr�helpersr r!r"r#r$r%r&�http_exceptionsr'r(r)r*r+r,r-r.r/r0�http_writerr1r2�streamsr3r4�typedefsr5�__all__r'�set�	printabler>rbrc�escaper?�compiler@rA�ASCIIrBrCrDr��	frozensetrOr:r;rmrorxr6rdr��ABCr7r8r9r�rg�HttpRequestParserPy�HttpResponseParserPy�RawRequestMessagePy�RawResponseMessagePy�_http_parser�HttpRequestParserC�HttpResponseParserC�RawRequestMessageC�RawResponseMessageC�ImportErrorr]rfrg�<module>r�s���215��	�
�������":�9���'���������4�0� ����~����� 0� 0�1��%��C��/�1�!�i�i�(9�:���s��:�!�z�z�J��6G�r�*J�K���w�s�|�	�K�57�Z�Z��6��u�W�S�\�2��!�j�j�);�R�X�X�F���g�c�l��F� �j�j�����:���g�c�l��:�#%�:�:�.>�#?�	�5���� �?�,5��
,��5��3��(�
� 216
�217�218
�	��	�	��*�,>�?��������Y?�Y?�x=�#3�C�#8�=�T�=�W����'�%�.�W�t219^H�220�#4�5�^H�BQP��$6�7�QP�hX�X�ve,�e,�P(��)��'��)��	��	221�	222�/��0��.��0�����	��	�s�I#�#I,�+I,
codekingpro/portable-devtools · Team Ai