Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes14kdownloads
_readers.cpython-313.pyc61 linesDownload Raw Back to __pycache__
1�

2�j�!��|�%SSKrSSKJrJrJrJrJrJrJrJ	r	J3r4 SSKJrJ
r
JrJr SSKJrJrJrJrJr SSKJr SSKJrJrJrJrJrJrJrJ r  SSK!J"r"J#r#J$r$J%r% S	/r&\RN"\
RP"S555r)\RN"S5r*S\\+S
\\+4Sjr,S\\+S
\\\+\+44Sjr-\RN"\RP"S655r.S\S
\\4Sjr/\RN"\RP"S755r0S\S
\8\\S44Sjr1"SS5r2\RN"\RP"S955r3"SS5r4"SS5r5S\S
S4Sjr6\\10\	\$\\	\$\	\$44\11\S\4\\7\S\4444r8\\4\/\ \4\1\ \4\1\\4\6\\4\6\\4\6\ \4\6\ \4\6\ \4\6\\4\2\5S.012r9\8\:S	'g)�N)	�Any�Callable�Dict�Iterable�NoReturn�Optional�Tuple�Type�Union�)�chunk_header�header_field�request_line�status_line)�Data�EndOfMessage�InformationalResponse�Request�Response)�
ReceiveBuffer)�CLIENT�CLOSED�DONE�IDLE�13MUST_CLOSE�	SEND_BODY�
SEND_RESPONSE�SERVER)�LocalProtocolError�RemoteProtocolError�Sentinel�validate�READERS�asciis[ \t]+�lines�returnc#�&# �[U5nSnUHrn[RU5nU(aJUc[S5e[	U[145(d[U5nUS-
nX#UR
5S-
nMiUbUv� UnMt UbUv� gg7f)Nz%continuation line at start of headers� )�iter�obs_fold_re�matchr�15isinstance�	bytearray�end)r%�it�last�liner+s     �RD:\code\apps\devtools\python\user_packages\Python313\site-packages\h11/_readers.py�_obsolete_line_foldr3+s����	
�e��B� �D����!�!�$�'����|�(�)P�Q�Q��d�I�.�.� �����D�L�D�������'�'�D����16��D�����17��s�BBc#�l# �[U5H!n[[USU5nUSUS4v� M# g7f)Nzillegal header line: {!r}�18field_name�field_value)r3r"�header_field_re)r%r1�matchess   r2�_decode_header_linesr9@s<���$�E�*���?�D�2M�t�T���|�$�g�m�&<�=�=�+�s�24�bufc19��UR5nUc!UR5(a[S5egU(d[S5e[[USSUS5n[S[
[USS55SS.UD6$)	N�illegal request linezno request line receivedrzillegal request line: {!r}rT)�headers�_parsed�)�maybe_extract_lines�+is_next_line_obviously_invalid_request_linerr"�request_line_rer�listr9)r:r%r8s   r2�maybe_read_from_IDLE_clientrDKs����#�#�%�E��}��:�:�<�<�$�%;�<�<��� �!;�<�<����q��#?��q���G����)�%���)�4�5�t��GN���c	�p�UR5nUc!UR5(a[S5egU(d[S5e[[USSUS5nUScSOUSnUScSOUSn[US	5nUS20:a[O[nU"[[USS55SUUUS
9$)Nr<zno response line receivedrzillegal status line: {!r}�http_versions1.1�reasonrE�status_code��rT)r=r>rIrHrG)21r@rArr"�status_line_re�intrrrCr9)r:r%r8rGrHrI�class_s       r2�$maybe_read_from_SEND_RESPONSE_serverrN^s���
�#�#�%�E��}��:�:�<�<�$�%;�<�<��� �!<�=�=��~�u�Q�x�1L�e�TU�h�W�G��.�)�1��w�~�7N���H�%�-�S�7�8�3D�F��g�m�,�-�K�!,�s�!2������)�%���)�4�5����!��rEc�R�\rSrSrS\SS4SjrS\S\\\	S44Sjr22S\4SjrS	r
g)23�ContentLengthReader�z�lengthr&Nc��XlXlg�N��_length�24_remaining)�selfrRs  r2�__init__�ContentLengthReader.__init__{s���� �rEr:c���URS:Xa25[5$URUR5nUcgU=R[U5-sl[	US9$)Nr��data)rWr�maybe_extract_at_most�lenr�rXr:r]s   r2�__call__�ContentLengthReader.__call__sN���?�?�a���>�!��(�(����9���<�����3�t�9�$�����rEc�z�[SRURUR-26UR55e)Nz]peer closed connection without sending complete message body (received {} bytes, expected {}))r �formatrVrW�rXs r2�read_eof�ContentLengthReader.read_eof�s4��!�
/�/5�v����t���.����0�27�	28rErU)�__name__�29__module__�__qualname__�__firstlineno__rLrYrrrrrarrf�__static_attributes__r?rEr2rPrPzs@��!�s�!�t�!��M��e�D�,��4L�.M��30�(�31rErPc�J�\rSrSrS	SjrS\S\\\S44Sjr	S\324SjrSrg)33�
ChunkedReader�r&Nc�.�SUlSUlSUlg)NrrEF��_bytes_in_chunk�_bytes_to_discard�_reading_trailerres r2rY�ChunkedReader.__init__�s�� ���"%��� %��rEr:c��UR(a/UR5nUcg[[[	U55S9$UR34(a�UR
[UR3555nUcgX0R36S[U5:wa[SU<SUR37<S35eUR38[U5SUlUR39(agUR40S:XdeURS:XaZUR5nUcg[[USU5n[USS	S419Ul	URS:XaSUlU"U5$SnOSnURS:�deUR
UR5nUcgU=R[U5-sl	URS:Xa42S
UlSnOSn[X6US9$)N)r=zmalformed chunk footer: z (expected �)rErzillegal chunk header: {!r}�43chunk_size�)�baseTFs
44)r]�chunk_start�	chunk_end)rtr@rrCr9rsr^r_rrr�maybe_extract_next_liner"�chunk_header_rerLr)rXr:r%r]r
r8r{r|s        r2ra�ChunkedReader.__call__�s���� � ��+�+�-�E��}����-A�%�-H�(I�J�J��!�!��,�,�S��1G�1G�-H�I�D��|���-�-�k��D�	�:�:�(�.�t�h�k�$�BX�BX�A[�[\�]���&*�%;�%;�C��I�K�%H�D�"��%�%���%�%��,�,�,����1�$��6�6�8�L��#�����,��	�G�$'�w�|�'<�2�#F�D� ��#�#�q�(�(,��%��C�y� ��K��K��#�#�a�'�'�'��(�(��)=�)=�>���<������D�	�)�����1�$�%,�D�"��I��I���)�L�LrEc��[S5e)NzVpeer closed connection without sending complete message body (incomplete chunked read))r res r2rf�ChunkedReader.read_eof�s��!�
(�45�	46rErq)r&N)
rhrirjrkrYrrrrrarrfrlr?rEr2rnrn�s6��&�0M�M�0M�e�D�,��4L�.M�0M�d47�(�48rErnc�:�\rSrSrS\S\\4SjrS\4Sjr	Sr49g)�Http10Reader��r:r&c�>�URS5nUcg[US9$)Ni�ɚ;r\)r^rr`s   r2ra�Http10Reader.__call__�s$���(�(��3���<�����rEc��[5$rT)rres r2rf�Http10Reader.read_eof�s50���~�rEr?N)rhrirjrkrrrrarrfrlr?rEr2r�r��s%���M��h�t�n���,�rEr�c�(�U(a[S5eg)NzGot data when expecting EOF)r)r:s r2�expect_nothingr��s��51� �!>�?�?�rE.)�chunkedzcontent-lengthzhttp/1.0);�re�typingrrrrrrr	r52r�_abnfr
rrr�_eventsrrrrr�_receivebufferr�_staterrrrrrrr�_utilrr r!r"�__all__�compile�encoder7r*�bytesr3r9rBrDrKrNrPr~rnr�r��str�ReadersTyper#�__annotations__r?rEr2�<module>r�s>��&53�X�X�X�H�H�Q�Q�)�	�	�	�O�N��+���*�*�\�0�0��9�:���j�j��$���x����8�E�?��*>��E�?�>�
�e�E�5�L�!�"�>��*�*�\�0�0��9�:��
�]�
�x��7H�
� ���K�.�.�w�7�8���	��54� �(�D�0�1��855�56�.�*�*�\�0�0��9�:��>57�>58�B���
��$���	�$�x�.�%��X���X�� >�?�59?�@�	�(�3��8�60�d�3���c��(:�#:�;�61;�<�>����T�N�/��T�N�8��]��A��T�N�N��Z��.��V��n��T�N�N��Z��.��V��n�
� �-� �����rE
codekingpro/portable-devtools · Team Ai