← back to Atmos Game

assets/gen/.venv/lib/python3.12/site-packages/httpcore/_sync/__pycache__/http11.cpython-312.pyc

86 lines

�

c�bj�4���ddlmZddlZddlZddlZddlZddlZddlZddlZddl	m
Z
ddlmZm
Z
mZmZmZddlmZmZmZddlmZmZddlmZd	d
lmZej8d�Zej<ej&ej>ej@fZ!Gd�d
ejD�Z#Gd�de�Z$Gd�d�Z%Gd�de
�Z&y)�)�annotationsN�)�
NetworkStream)�ConnectionNotAvailable�LocalProtocolError�RemoteProtocolError�
WriteError�map_exceptions)�Origin�Request�Response)�Lock�ShieldCancellation)�Trace�)�ConnectionInterfacezhttpcore.http11c��eZdZdZdZdZdZy)�HTTPConnectionStaterrr�N)�__name__�
__module__�__qualname__�NEW�ACTIVE�IDLE�CLOSED���l/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/httpcore/_sync/http11.pyrr$s��
�C�
�F��D�
�Frrc���eZdZdZdZ	d							dd�Zdd�Zdd�Zdd�Zddd�Z					dd	�Z
				dd
�Z	d			dd�Zdd�Z
dd
�Zd d�Zd!d�Zd!d�Zd!d�Zd!d�Zd"d�Zd"d�Zd#d�Z			d$							d%d�Zy)&�HTTP11Connectionii�Nc���||_||_||_d|_tj
|_t�|_d|_	tjtj|j��|_y)Nr)�our_role�max_incomplete_event_size)�_origin�_network_stream�_keepalive_expiry�
_expire_atrr�_stater�_state_lock�_request_count�h11�
Connection�CLIENT�MAX_INCOMPLETE_EVENT_SIZE�
_h11_state)�self�origin�stream�keepalive_expirys    r�__init__zHTTP11Connection.__init__/sa�����%���/?���(,���)�-�-����6�������.�.��Z�Z�&*�&D�&D�
��rc	���|j|jj�s/td|jj�d|j����|j
5|jtjtjfvr2|xjdz
c_
tj|_d|_n
t��	ddd�	d|i}	tdt||�5}|j di|��ddd�tdt||�5}|j"di|��ddd�tdt||�5}|j&di|��\}}}}}||||f|_ddd�|j*}	dk(s|j,d	k(rd
|cxkrdkrnnt/|	�}	t1|t3||�|	d��
�S#1swY��xYw#1swY��xYw#1swY��xYw#t$$rY��wxYw#1swY��xYw#t4$r^}
t7�5tdt|�5}|j9�ddd�n#1swYnxYwddd�|
�#1swY|
�xYwd}
~
wwxYw)NzAttempted to send request to z on connection to r�request�send_request_headers�send_request_body�receive_response_headers�esCONNECT��i,)�http_version�
reason_phrase�network_stream)�status�headers�content�
extensions�response_closedr)�can_handle_request�urlr2�RuntimeErrorr%r*r)rrrr+rr(rr�logger�_send_request_headers�_send_request_bodyr	�_receive_response_headers�return_valuer&�method�HTTP11UpgradeStreamr
�HTTP11ConnectionByteStream�
BaseExceptionr�_response_closed)r1r7�kwargs�tracer=r@r>rA�
trailing_datar?�excs           r�handle_requestzHTTP11Connection.handle_requestAsp���&�&�w�{�{�'9�'9�:��/����0B�0B�/C�D��l�l�^�%��
�
�
�
��{�{�2�6�6�8K�8P�8P�Q�Q��#�#�q�(�#�1�8�8���"&���,�.�.� �	�8	���)�F�

��*�F�G�V���.�D�.�.�8��8���.����H�E�+�D�+�+�5�f�5�I��*�F�G�V���3�D�2�2�<�V�<�
� ��!��!�!��!��	&��"��""�1�1�N��#�
����:�-�C�6�4G�C�4G�!4�^�]�!S�����2�4��A�$0�%2�&4��		�	
�e�
�����I�H���
��

�����F�	�#�%��,�f�g�>�%��)�)�+�?�>�>��&��I�&��I��		�s��!A)G�H�G,�+G�>G,�G �+G,�3H�$G;�)AH�G�G�G,� G)�%G,�,	G8�5H�7G8�8H�;H�H�	I.�
I)�I�,I�=	I�I�I�
I)�I&	�!I)�)I.c�n�|jjdi�}|jdd�}ttjti�5tj
|j|jj|j��}ddd�|j|��y#1swY�xYw)N�timeout�write)rM�targetrA�rX)rC�getr
r,rrrMrFrZrA�_send_event�r1r7�timeoutsrX�events     rrIz&HTTP11Connection._send_request_headers�s����%�%�)�)�)�R�8���,�,�w��-��
�S�3�3�5G�H�
I��K�K��~�~��{�{�)�)�����E�J�	
������0�
J�
I�s
�AB+�+B4c�j�|jjdi�}|jdd�}t|jtj
�sJ�|jD]+}t
j|��}|j||���-|jt
j�|��y)NrXrY)�datar[)
rCr\�
isinstancer3�typing�Iterabler,�Datar]�EndOfMessage)r1r7r_rX�chunkr`s      rrJz#HTTP11Connection._send_request_body�s����%�%�)�)�)�R�8���,�,�w��-���'�.�.�&�/�/�:�:�:��^�^�E��H�H�%�(�E����U�G��4�$�	
����)�)�+�W��=rc�z�|jj|�}|�|jj||��yy)Nr[)r0�sendr&rY)r1r`rX�
bytes_to_sends    rr]zHTTP11Connection._send_event�s:�����,�,�U�3�
��$�� � �&�&�}�g�&�F�%rc���|jjdi�}|jdd�}	|j|��}t|tj
�rn+t|tj�r|jdk(rn�Xd|jz}|jj�}|jj\}}||j|j||fS)NrX�readr[r;sHTTP/)rCr\�_receive_eventrcr,r
�InformationalResponse�status_coder=rA�	raw_itemsr0rT�reason)	r1r7r_rXr`r=rArT�_s	         rrKz*HTTP11Connection._receive_response_headers�s����%�%�)�)�)�R�8���,�,�v�t�,����'�'��'�8�E��%����.���5�#�";�";�<��%�%��,��� �%�"4�"4�4���-�-�)�)�+���?�?�8�8��
�q��U�.�.����g�}�T�Trc#�HK�|jjdi�}|jdd�}	|j|��}t|tj
�rt
|j���n+t|tjtjf�ry�p�w)NrXrmr[)
rCr\rnrcr,rf�bytesrbrg�PAUSEDr^s     r�_receive_response_bodyz'HTTP11Connection._receive_response_body�s������%�%�)�)�)�R�8���,�,�v�t�,����'�'��'�8�E��%����*��E�J�J�'�'��E�C�$4�$4�c�j�j�#A�B���s�B B"c���	ttjti�5|jj	�}ddd�tj
ur||jj|j|��}|dk(r4|jjtjk(r
d}t|��|jj|�n|S��#1swY��xYw)Nr[rz/Server disconnected without sending a response.)r
r,rr0�
next_event�	NEED_DATAr&rm�READ_NUM_BYTES�their_state�
SEND_RESPONSE�receive_data)r1rXr`rb�msgs     rrnzHTTP11Connection._receive_event�s������!8�!8�:M� N�O����2�2�4��P���
�
�%��+�+�0�0��'�'��1����3�;�4�?�?�#>�#>�#�BS�BS�#S�K�C�-�c�2�2����,�,�T�2���1�O�O�s�C�Cc���|j5|jjtjur�|jj
tjurdtj|_|jj�|j�9tj�}||jz|_
n|j�ddd�y#1swYyxYw�N)r*r0�	our_stater,�DONEr|rrr)�start_next_cycler'�time�	monotonicr(�close)r1�nows  rrQz!HTTP11Connection._response_closed�s���
�
�
����)�)�S�X�X�5��O�O�/�/�3�8�8�;�1�6�6������0�0�2��)�)�5��.�.�*�C�&)�D�,B�,B�&B�D�O��
�
���
�
�s�CC�C c�b�tj|_|jj	�yr�)rrr)r&r��r1s rr�zHTTP11Connection.close�s#��*�0�0������"�"�$rc� �||jk(Sr�)r%�r1r2s  rrEz#HTTP11Connection.can_handle_requests������%�%rc�<�|jtjk(Sr��r)rrr�s r�is_availablezHTTP11Connection.is_availables��
�{�{�1�6�6�6�6rc���tj�}|jduxr||jkD}|jtj
k(xr|jjd�}|xs|S)N�is_readable)r�r�r(r)rrr&�get_extra_info)r1r��keepalive_expired�server_disconnecteds    r�has_expiredzHTTP11Connection.has_expiredsm���n�n��� �O�O�4�7�Q�C�$�/�/�<Q��
�K�K�.�3�3�3�
C��$�$�3�3�M�B�	�
!�7�$7�7rc�<�|jtjk(Sr�r�r�s r�is_idlezHTTP11Connection.is_idle s���{�{�1�6�6�6�6rc�<�|jtjk(Sr�)r)rrr�s r�	is_closedzHTTP11Connection.is_closed#s���{�{�1�8�8�8�8rc�|�t|j�}|�d|jj�d|j��S)Nz, HTTP/1.1, �, Request Count: )�strr%r)�namer+r�s  r�infozHTTP11Connection.info&sA���T�\�\�"���j��T�[�[�%5�%5�$6�7�"�1�1�2�
4�	
rc	��|jj}t|j�}d|�d|�d|jj
�d|j�d�	S)N�<z [z, r�z]>)�	__class__rr�r%r)r�r+)r1�
class_namer2s   r�__repr__zHTTP11Connection.__repr__-sZ���^�^�,�,�
��T�\�\�"���
�|�2�f�Z�r�$�+�+�*:�*:�);�<�"�1�1�2�"�
6�	
rc��|Sr�rr�s r�	__enter__zHTTP11Connection.__enter__8s���rc�$�|j�yr�)r�)r1�exc_type�	exc_value�	tracebacks    r�__exit__zHTTP11Connection.__exit__;s
��	
�
�
�rr�)r2rr3rr4�float | None�return�None)r7rr�r
)r7rr�r�)r`z	h11.EventrXr�r�r�)r7rr�z:tuple[bytes, int, bytes, list[tuple[bytes, bytes]], bytes])r7rr��typing.Iterator[bytes])rXr�r�zh11.Event | type[h11.PAUSED]�r�r�)r2rr��bool)r�r�)r�r�)r�r!)NNN)r�ztype[BaseException] | Noner�zBaseException | Noner�ztypes.TracebackType | Noner�r�)rrrr{r/r5rVrIrJr]rKrwrnrQr�rEr�r�r�r�r�r�r�r�rrrr!r!+s���N� *��*.�	
��
��
�'�	
�

�
�$G�V
1�	>�G�U��U�	C�U�4���	��'+��#��	%��:� %�&�7�8�7�9�
�
��
04�*.�04�	�,��(��.�	�

�rr!c�$�eZdZdd�Zdd�Zdd�Zy)rOc�.�||_||_d|_y)NF)�_connection�_request�_closed)r1�
connectionr7s   rr5z#HTTP11ConnectionByteStream.__init__Es��%�����
���rc#�^K�d|ji}	tdt|j|�5|jjdi|��D]}|���	ddd�y#1swYyxYw#t
$r7}t
�5|j�ddd�|�#1swY|�xYwd}~wwxYw�w)Nr7�receive_response_bodyr)r�rrHr�rwrPrr�)r1rRrhrUs    r�__iter__z#HTTP11ConnectionByteStream.__iter__Js������T�]�]�+��
	��.���
�
�v�N�D�T�-�-�D�D�N�v�N�E��K�O�O�N�N���	�$�%��
�
��&��I�&��I��
	�sc�B-�A*�&A�A*�B-�A'�#A*�&B-�'A*�*	B*�3
B%�=B�
B%�B"	�B%�%B*�*B-c���|jsFd|_tdt|j�5|jj�ddd�yy#1swYyxYw)NTrD)r�rrHr�r�rQr�s rr�z HTTP11ConnectionByteStream.closeXsH���|�|��D�L��(�&�$�-�-�@�� � �1�1�3�A�@��@�@�s�A�AN)r�r!r7rr�r�)r�r�r�)rrrr5r�r�rrrrOrODs���
�4rrOc�T�eZdZdd�Zd	d
d�Zd	dd�Zdd�Z		d
							dd�Zdd�Zy)rNc� �||_||_yr�)�_stream�
_leading_data)r1r3�leading_datas   rr5zHTTP11UpgradeStream.__init__`s�����)��rNc��|jr%|jd|}|j|d|_|S|jj||�Sr�)r�r�rm)r1�	max_bytesrX�buffers    rrmzHTTP11UpgradeStream.readdsN������'�'�
��3�F�!%�!3�!3�I�J�!?�D���M��<�<�$�$�Y��8�8rc�<�|jj||�yr�)r�rY)r1r�rXs   rrYzHTTP11UpgradeStream.writels�������6�7�+rc�8�|jj�yr�)r�r�r�s rr�zHTTP11UpgradeStream.closeos�������rc�<�|jj|||�Sr�)r��	start_tls)r1�ssl_context�server_hostnamerXs    rr�zHTTP11UpgradeStream.start_tlsrs���|�|�%�%�k�?�G�L�Lrc�8�|jj|�Sr�)r�r�)r1r�s  rr�z"HTTP11UpgradeStream.get_extra_infozs���|�|�*�*�4�0�0r)r3rr�rur�r�r�)r��intrXr�r�ru)r�rurXr�r�r�r�)NN)r�zssl.SSLContextr�z
str | NonerXr�r�r)r�r�r�z
typing.Any)	rrrr5rmrYr�r�r�rrrrNrN_sS��*�9�,��'+� $�	M�#�M�$�M��	M�

�M�1rrN)'�
__future__r�enum�logging�sslr��typesrdr,�_backends.baser�_exceptionsrrrr	r
�_modelsrrr
�_synchronizationrr�_tracer�
interfacesr�	getLoggerrH�Unionrfrg�H11SendEvent�IntEnumrr!rOrNrrr�<module>r�s���"���
���
�
�*���0�/�7��+�	��	�	�,�	-���|�|��K�K��H�H��������$�,�,��V�*�V�r4�4�61�-�1r