Team Ai
Datasetpublic

codekingpro/portable-devtools

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

2��jW2���SrSSKrSSKrSSKJrJrJrJrJrJ	r	J3r4JrJr SSK
Jr SSKJr SSKJr SSKJr SS	KJr SS5KJr SrSrS
\R6s=:*=(a S:Os r\R6S:r\=(d \r"SS\65r\"SS5r \"SS5r!\\\"/\S4r#\\S/\S4r$"SS\5r%S\&S\&4Sjr'S\&SSS\"4Sjr(\(r)SSK*J+r+ \+RRr,\(d\,r)gg!\-a gf=f)z"Http related parsers and protocol.�N)	�
TYPE_CHECKING�Any�	Awaitable�Callable�Iterable�List�7NamedTuple�Optional�Union)�CIMultiDict�)�AbstractStreamWriter)�BaseProtocol)�ClientConnectionResetError)�ZLibCompressor)�
NO_EXTENSIONS)�StreamWriter�HttpVersion�
HttpVersion10�
HttpVersion11i)��
r)rr�)r��	c�*�\rSrSr%\\S'\\S'Srg)r�'�major�minor�N)�__name__�8__module__�__qualname__�__firstlineno__�int�__annotations__�__static_attributes__r ��YD:\code\apps\devtools\python\user_packages\Python313\site-packages\aiohttp/http_writer.pyrr's���J��Jr(r�CIMultiDict[str]c���\rSrSr%Sr\\\S'Sr\	\S'Sr9\	\S'Sr\\\S'S,S\
S	\RS10\S\SS411S
jjr\S\\R(4Sj5r\S\
4Sj5rS-SjrS.S\S\\SS4SjjrS\\\\4SS4SjrS\\SS4Sjr S\\\SS4SS4Sjr!S\\\SS4S\	SS4Sjr"SSS.S\\\\4S \	S!\SS4S"jjr#S#\S$S%SS4S&jr$S-S'jr%S-S(jr&S/S\SS4S)jjr'S-S*jr(S+r)g)0r�4N�lengthF�chunked�_eof�	_compress�protocol�loop�
on_chunk_sent�on_headers_sent�returnc�P�XlX lX0lX@lSUlSUlg)NF)�	_protocolr2�_on_chunk_sent�_on_headers_sent�_headers_buf�_headers_written)�selfr1r2r3r4s     r)�__init__�StreamWriter.__init__;s*��"���	�.;��2A��-1���&+��r(c�.�URR$�N)r7�	transport�r<s r)rA�StreamWriter.transportIs���~�~�'�'�'r(c��UR$r@)r7rBs r)r1�StreamWriter.protocolMs���~�~�r(c��SUlg)NT)r.rBs r)�enable_chunking�StreamWriter.enable_chunkingQs	����r(�encoding�strategyc� �[XS9Ulg)N)rIrJ)rr0)r<rIrJs   r)�enable_compression�StreamWriter.enable_compressionTs��(��M��r(�chunkc��[U5nU=RU-
slU=RU-
slURRnUbUR5(a[
S5eURU5 g)N�!Cannot write to closing transport)�len�buffer_size�output_sizer7rA�12is_closingr�write)r<rN�sizerAs    r)�_write�StreamWriter._writeYsh���5�z�����D� �����D� ���N�N�,�,�	���	� 4� 4� 6� 6�,�-P�Q�Q�����r(�chunksc��SnUHnU[U5-
nM U=RU-
slU=RU-
slURRnUbUR5(a[
S5e[(d13U[:a!URSRU55 gURU5 g)NrrPr()rQrRrSr7rArTr�SKIP_WRITELINES�MIN_PAYLOAD_FOR_WRITELINESrU�join�14writelines)r<rYrVrNrAs     r)�_writelines�StreamWriter._writelinesbs������E��C��J��D�����D� �����D� ���N�N�,�,�	���	� 4� 4� 6� 6�,�-P�Q�Q��?�d�%?�?��O�O�C�H�H�V�,�-�� � ��(r(zmemoryview[int]zmemoryview[bytes]c�f�[U5SS3RS5nURX!S45 g)z+Write a chunk with proper chunked encoding.�x�
15�ascii�
16N)rQ�encoder_)r<rN�
chunk_len_pres   r)�_write_chunked_payload�#StreamWriter._write_chunked_payloadps4���u�:�a�.��-�4�4�W�=�
����-��8�9r(�is_eofc���SUlURnSUl[(aUceUR(d,U(aUR	X145 gURU5 gU(aO[
U5SS3RS5nU(aUR	X4US45 gUR	X4US45 gU(aUR	US45 gURU5 g)	zASend buffered headers with payload, coalescing into single write.TNrbrcrd�
170
18
19re�0
20
21)r;r:rr.r_rWrQrf)r<rNrj�headers_bufrgs     r)�_send_headers_with_payload�'StreamWriter._send_headers_with_payloadws���!%����'�'�� ����=��*�*�*��|�|��� � �+�!5�6�
����K�(���"�5�z�!�n�D�1�8�8��A�M��� � �+�e�EU�!V�W�� � �+�e�W�!M�N�
����k�<�8�9��K�K��$r(Ti)�drain�LIMITrqrrc���# �URbURU5IShv�N [U[5(a*UR[	U5:waURS5nURb+URRU5IShv�NnU(dgURbN[	U5nURU:�aURU-22UlOUSURnSUlU(dgUR(aZUR(dIURUS5 U(a/URU:�aSUlUR5IShv�N gU(amUR(aURU5 OUR!U5 U(a1URU:�a SUlUR5IShv�N ggggGN�GNKN�N7f)z�23Writes chunk of data to a stream.24 25write_eof() indicates end of stream.26writer can't be used after write_eof() method being called.27write() return drain future.28N�crF)r8�29isinstance�30memoryview�nbytesrQ�castr0�compressr-r:r;rorRrqr.rhrW)r<rNrqrr�	chunk_lens     r)rU�StreamWriter.write�s|������*��%�%�e�,�,�,��e�Z�(�(��|�|�s�5�z�)��31�32�3����>�>�%��.�.�1�1�%�8�8�E����;�;�"��E�33�I��{�{�i�'�"�k�k�I�5����m����,����������T�%:�%:��+�+�E�5�9���)�)�E�1�#$�� ��j�j�l�"�"����|�|��+�+�E�2����E�"���)�)�E�1�#$�� ��j�j�l�"�"�2�u�
�=
-�9�&#�#�sH�"G%�G�A.G%�G�CG%� G!�!A1G%�G#�	G%�G%�!G%�#G%�status_line�headersr*c��# �URbURU5IShv�N [X5nSUlX0lgN7f)zWrite headers to the stream.NF)r9�_serialize_headersr;r:)r<r|r}�bufs    r)�
write_headers�StreamWriter.write_headers�sD���� � �,��'�'��0�0�0� ��6�� %�����	
1�s�"A�A�Ac���UR(aUR(agSUlURnSUl[(aUceURU5 g)z3Force sending buffered headers if not already sent.NT)r:r;rrW�r<rns  r)�send_headers�StreamWriter.send_headers�sN��� � �D�$9�$9�� $����'�'�� ����=��*�*�*����K� r(c��UR(agUR(arUR(daSUlURnSUl[(aUceUR(aURUS45 OEUR
U5 O3UR(a"UR(aUR
S5 SUlg)z&Indicate that the message is complete.NTrm)r/r:r;rr.r_rWr�s  r)�set_eof�StreamWriter.set_eof�s����9�9�����T�%:�%:�$(�D�!��+�+�K� $�D���}�"�.�.�.��|�|�� � �+�|�!<�=����K�(�
�\�\�d�3�3��K�K��%���	r(c��# �UR(agU(a&URbURU5IShv�N UR(Ga�/nSnU(aFURRU5IShv�N=n(a[	U5nURU5 URR
5nU[	U5-
nURU5 U(deUR(a�UR(d�SUlURnSUlUR(a-USS3RS5nURXg/UQSP75 OURU/UQ75 UR5IShv�N SUlgUR(a-USS3RS5nURU/UQSP75 O5[	U5S:�aURU5 OURUS5 UR5IShv�N SUlgUR(aCUR(d2URUS5 UR5IShv�N SUlgUR(aiU(a1UR[	U5SS3RS5US45 OURS5 UR5IShv�N SUlgU(a)URU5 UR5IShv�N SUlgGN�GN�GN�GNN�NRN7f)	NrTrbrcrdrlr
rm)r/r8r0ryrQ�append�flushr:r;r.rfr_rqrWro)r<rNrY�34chunks_len�compressed_chunk�flush_chunkrnrgs        r)�	write_eof�StreamWriter.write_eofs�����9�9���T�(�(�4��%�%�e�,�,�,��>�>�>�"$�F��J��D�N�N�4K�4K�E�4R�.R�R�*�R� �!1�2�35��
�
�.�/��.�.�.�.�0�K��#�k�*�*�J��M�M�+�&���:�� � ��)>�)>�(,��%�"�/�/��$(��!��<�<�'1�!�n�D�$9�$@�$@��$I�M��$�$�$�O�f�O�>N�O��36�$�$�k�%;�F�%;�<��j�j�l�"�"� ��	���|�|�#-�a�.�� 5� <� <�W� E�
�� � �-�!K�&�!K�:J�!K�L��V��q��� � ��(����F�1�I�&��*�*�,����D�I�����T�%:�%:��+�+�E�4�8��*�*�,����D�I���<�<��� � ��E�37�1�~�T�*�1�1�'�:�E�CS�T�����L�)��*�*�,����D�I����K�K����*�*�,�����	�O
-�/S�0#�
�
�
�
�s�;M�L/�?M�=L2�>DM�	L5�38BM�L8�AM�0L;�1A9M�*L=�+7M�"L?�#
M�2M�5M�8M�;M�=M�?Mc��# �URnURb+UR(aUR5IShv�N gggN7f)z_Flush the write buffer.39 40The intended use is to write41 42  await w.write(data)43  await w.drain()44N)r7rA�_paused�
_drain_helper)r<r1s  r)rq�StreamWriter.drainUsA����>�>�����)�h�.>�.>��(�(�*�*�*�/?�)�*�s�>A45�A�A46)r0r/r:r;r8r9r7rRr.r-r2)NN)r5N)�deflateN)r()*r!r"r#r$r-r47r%r&r.�boolr/r0rr�asyncio�AbstractEventLoop�_T_OnChunkSent�_T_OnHeadersSentr=�property�	TransportrAr1rG�strrLr�bytes�	bytearrayrvrWrr_rhrorUr�r�r�r�rqr'r r(r)rr4s��� �F�H�S�M� ��G�T���D�$��*.�I�x��'�.�)-�,0�,��,��'�'�,�&�	,�48*�,�49�
,��(�8�G�$5�$5�6�(��(���,�����DH�N��N�3;�C�=�N�	
�N�50�E�%��J�">�?��D��)�(�5�/�)�d�)�:��5�)�->�@S�S�T�:�	
�:�"%��U�I�'8�:M�M�N�"%��"%�51�	"%�P��5#��U�I�z�1�2�5#��	5#�52�5#�53�
5#�n	 ��	 �);�	 �	
�	 �
!��6L�U�L�T�L�\54+r(r�stringr5c�@�SU;dSU;dSU;a[S5eU$)N�
�55�z^Newline, carriage return, or null byte detected in headers. Potential header injection attack.)�56ValueError)r�s r)�_safe_headerr�bs/���v�~����6�V�+;��
1�57�	58��Mr(r|r}c��[U5 SUR55nUS-SRU5-S-nURS5$)Nc3�Z# �UH!up[U5S-[U5-v� M# g7f)z: N)r�)�.0�k�vs   r)�	<genexpr>�(_py_serialize_headers.<locals>.<genexpr>ms$���X����<��?�T�)�L��O�;��s�)+rcz
59
60zutf-8)r��itemsr]rf)r|r}�headers_gen�lines    r)�_py_serialize_headersr�ksF�����X��
�
��X�K����&�+�+�k�":�:�Z�G�D��;�;�w��r().�__doc__r��sys�typingrrrrrrr	r61r�	multidictr�abcr�
base_protocolr�client_exceptionsr�compression_utilsr�helpersr�__all__r\�version_info�IS_PY313_BEFORE_313_2�IS_PY_BEFORE_312_9r[rrrr�r�r�rr�r�r�r�aiohttp._http_writer�_http_writer�_c_serialize_headers�ImportErrorr r(r)�<module>r�sL��(��62�63�64�65�"�%�'�9�-�"�66K��"��"�c�&6�&6�C�C��C���%�%�67�2��'�=�+=���*��68�A�q�!�
��A�q�!�
��(�E�7�I�d�O�#;�<�=���H�&8�%9�9�T�?�%J�K�L��k+�'�k+�\	����� �s� �5G� �E� �+��	�/�'�:�:���1�����	��	�s�C:�:D�D
codekingpro/portable-devtools · Team Ai