← back to Atmos Game

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

87 lines

�

c�bj86���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�)�AsyncNetworkStream)�ConnectionNotAvailable�LocalProtocolError�RemoteProtocolError�
WriteError�map_exceptions)�Origin�Request�Response)�	AsyncLock�AsyncShieldCancellation)�Trace�)�AsyncConnectionInterfacezhttpcore.http11c��eZdZdZdZdZdZy)�HTTPConnectionStaterrr�N)�__name__�
__module__�__qualname__�NEW�ACTIVE�IDLE�CLOSED���m/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/httpcore/_async/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)&�AsyncHTTP11Connectionii�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__zAsyncHTTP11Connection.__init__/sa�����%���/?���(,���)�-�-���$�;�������.�.��Z�Z�&*�&D�&D�
��rc	��hK�|j|jj�s/td|jj�d|j����|j
4�d{���|jtjtjfvr2|xjdz
c_
tj|_d|_n
t��ddd��d{���	d|i}	tdt||�4�d{���}|j di|���d{���ddd��d{���tdt||�4�d{���}|j"di|���d{���ddd��d{���tdt||�4�d{���}|j&di|���d{���\}}}}}||||f|_ddd��d{���|j*}	dk(s|j,d	k(rd
|cxkrdkrnnt/|	�}	t1|t3||�|	d��
�S7���7��E#1�d{���7swY��VxYw7��=7��&7��#1�d{���7swY��*xYw7��7��7��#1�d{���7swY��xYw#t$$rY��wxYw7��7��7��#1�d{���7swY��xYw#t4$r�}
t7�5tdt|�4�d{���7}|j9��d{���7ddd��d{���7n#1�d{���7swYnxYwddd�|
�#1swY|
�xYwd}
~
wwxYw�w)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�AsyncHTTP11UpgradeStreamr
�HTTP11ConnectionByteStream�
BaseExceptionr�_response_closed)r1r7�kwargs�tracer=r@r>rA�
trailing_datar?�excs           r�handle_async_requestz*AsyncHTTP11Connection.handle_async_requestAs������&�&�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����4�$�4�4�>�v�>�>�>���!�!4�f�g�v�N�N�RW�1�$�1�1�;�F�;�;�;�O�N��*�F�G�V����9�$�8�8�B�6�B�B�
� ��!��!�!��!��	&��"���""�1�1�N��#�
����:�-�C�6�4G�C�4G�!9�.�-�!X�����2�4��A�$0�%2�&4��		�	
�e$��#��#�#�#����?��������O��;��O��N�N�N���
��

����C��������F�	�(�*� �!2�F�G�D�D���/�/�1�1�1�E�D�D�D�D��+��I�+��I��		�s��A%L2�'H!�(L2�+A)H'�L2�H$� L2�%J$�*I9�H=�I9�I�I�I�I9�*I�+I9�I�I9�	I#�I� I#�$I9�/I!�0I9�4J$�
J	�J$�J�$J�%J�:J$�J
�AJ$� L2�$L2�'H:�-H0�.H:�5L2�=I9�I�I9�I�I�
I�	I9�I#�!I9�#I6�)I,�*I6�1I9�9	J�J$�J�J$�J�
J$�J!�J�J!�J$�$	L/�-
L*�7L�
K
�L�K>�&K)
�'K>�,L�7K:�8L�>L�L�L�L�
L*�L'	�"L*�*L/�/L2c��K�|jjdi�}|jdd�}ttjti�5tj
|j|jj|j��}ddd�|j|���d{���y#1swY�%xYw7��w)N�timeout�write)rM�targetrA�rX)rC�getr
r,rrrMrFrZrA�_send_event�r1r7�timeoutsrX�events     rrIz+AsyncHTTP11Connection._send_request_headers�s������%�%�)�)�)�R�8���,�,�w��-��
�S�3�3�5G�H�
I��K�K��~�~��{�{�)�)�����E�J����u�g��6�6�6�
J�
I��	7�s+�AC�AB5�C�/C�0C�5B>�:Cc��K�|jjdi�}|jdd�}t|jtj
�sJ�|j23d{���}t
j|��}|j||���d{����;7�67�6|jt
j�|���d{���7y�w)NrXrY)�datar[)
rCr\�
isinstancer3�typing�
AsyncIterabler,�Datar]�EndOfMessage)r1r7r_rX�chunkr`s      rrJz(AsyncHTTP11Connection._send_request_body�s������%�%�)�)�)�R�8���,�,�w��-���'�.�.�&�*>�*>�?�?�?�"�>�>�	;�%��H�H�%�(�E��"�"�5�'�"�:�:�:�	;��:��*����s�/�/�1�7��C�C�C�sH�A!C�#B"�'B�(B"�+-C�B �C�B"� C�")C�C�Cc��K�|jj|�}|�&|jj||���d{���yy7��w)Nr[)r0�sendr&rY)r1r`rX�
bytes_to_sends    rr]z!AsyncHTTP11Connection._send_event�sG�������,�,�U�3�
��$��&�&�,�,�]�G�,�L�L�L�%�L�s�>A	�A�A	c���K�|jjdi�}|jdd�}	|j|���d{���}t|tj
�rn+t|tj�r|jdk(rn�`d|jz}|jj�}|jj\}}||j|j||fS7���w)NrX�readr[r;sHTTP/)rCr\�_receive_eventrcr,r
�InformationalResponse�status_coder=rA�	raw_itemsr0rT�reason)	r1r7r_rXr`r=rArT�_s	         rrKz/AsyncHTTP11Connection._receive_response_headers�s������%�%�)�)�)�R�8���,�,�v�t�,����-�-�g�-�>�>�E��%����.���5�#�";�";�<��%�%��,��� �%�"4�"4�4���-�-�)�)�+���?�?�8�8��
�q��U�.�.����g�}�T�T�#?�s�AC1�C/�B(C1c�^K�|jjdi�}|jdd�}	|j|���d{���}t|tj
�rt
|j����n+t|tjtjf�ry�y7�c�w)NrXrmr[)
rCr\rnrcr,rf�bytesrbrg�PAUSEDr^s     r�_receive_response_bodyz,AsyncHTTP11Connection._receive_response_body�s������%�%�)�)�)�R�8���,�,�v�t�,����-�-�g�-�>�>�E��%����*��E�J�J�'�'��E�C�$4�$4�c�j�j�#A�B���>�s�AB-�B+�A$B-c���K�	ttjti�5|jj	�}ddd�tj
ur�|jj|j|���d{���}|dk(r4|jjtjk(r
d}t|��|jj|�n|S��#1swY��xYw7�h�w)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     rrnz$AsyncHTTP11Connection._receive_event�s��������!8�!8�:M� N�O����2�2�4��P���
�
�%�!�1�1�6�6��'�'��7�����3�;�4�?�?�#>�#>�#�BS�BS�#S�K�C�-�c�2�2����,�,�T�2���1�O�O���s)�!C-�C�AC-�C+�AC-�C(�$C-c��K�|j4�d{���|jjtjur�|jj
tjurdtj|_|jj�|j�Atj�}||jz|_
n|j��d{���ddd��d{���y7��7�7�	#1�d{���7swYyxYw�w�N)r*r0�	our_stater,�DONEr|rrr)�start_next_cycler'�time�	monotonicr(�aclose)r1�nows  rrQz&AsyncHTTP11Connection._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��k�k�m�#�#�$�#�#��$��$��#�#�#�sW�D�C1�D�CC7�C3�C7� D�+C5�,D�3C7�5D�7D	�=D�>D	�Dc��~K�tj|_|jj	��d{���y7��wr�)rrr)r&r��r1s rr�zAsyncHTTP11Connection.aclose�s-����*�0�0����"�"�)�)�+�+�+�s�3=�;�=c� �||jk(Sr�)r%�r1r2s  rrEz(AsyncHTTP11Connection.can_handle_requests������%�%rc�<�|jtjk(Sr��r)rrr�s r�is_availablez"AsyncHTTP11Connection.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_expiredz!AsyncHTTP11Connection.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_idlezAsyncHTTP11Connection.is_idle s���{�{�1�6�6�6�6rc�<�|jtjk(Sr�)r)rrr�s r�	is_closedzAsyncHTTP11Connection.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�infozAsyncHTTP11Connection.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__zAsyncHTTP11Connection.__repr__-sZ���^�^�,�,�
��T�\�\�"���
�|�2�f�Z�r�$�+�+�*:�*:�);�<�"�1�1�2�"�
6�	
rc��K�|S�wr�rr�s r�
__aenter__z AsyncHTTP11Connection.__aenter__8s������s�c��@K�|j��d{���y7��wr�)r�)r1�exc_type�	exc_value�	tracebacks    r�	__aexit__zAsyncHTTP11Connection.__aexit__;s�����k�k�m���s���r�)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.AsyncIterator[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
7�	D�M�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|�4�d{���|jjdi|��23d{���}|����7�/7�6ddd��d{���7y#1�d{���7swYyxYw#t
$r@}t
�5|j��d{���7ddd�|�#1swY|�xYwd}~wwxYw�w)Nr7�receive_response_bodyr)r�rrHr�rwrPrr�)r1rRrhrUs    r�	__aiter__z$HTTP11ConnectionByteStream.__aiter__Js������T�]�]�+��
	��4�f�d�m�m�V�T�T�#J�4�#3�#3�#J�#J�#T�V�#T� �%��K�U�� ��#T�U�T�T�T�T���	�)�*��k�k�m�#�#�+��I�+��I��
	�s��C� B�A"�B�A9�A&�A$�A&�A9�"B�$A&�&A9�'B�2A5�3B�8C�9B�?B�B�B�
C�B�	C�
C�!C�5B8�6C�;
C�C	�
C�C�Cc��K�|js^d|_tdt|j�4�d{���|jj��d{���ddd��d{���yy7�87�7�
#1�d{���7swYyxYw�w)NTrD)r�rrHr�r�rQr�s rr�z!HTTP11ConnectionByteStream.acloseXsi�����|�|��D�L��.���
�
�F�F��&�&�7�7�9�9�9�G�F�F��F��9��G��F�F�F�sV�3B	�A.�B	�A4�A0�A4�B	�'A2�(B	�0A4�2B	�4B�:A=�;B�B	N)r�r!r7rr�r�)r�r�r�)rrrr5r�r�rrrrOrODs���
�:rrOc�T�eZdZdd�Zd	d
d�Zd	dd�Zdd�Z		d
							dd�Zdd�Zy)rNc� �||_||_yr�)�_stream�
_leading_data)r1r3�leading_datas   rr5z!AsyncHTTP11UpgradeStream.__init__`s�����)��rNc��K�|jr%|jd|}|j|d|_|S|jj||��d{���S7��wr�)r�r�rm)r1�	max_bytesrX�buffers    rrmzAsyncHTTP11UpgradeStream.readdsX��������'�'�
��3�F�!%�!3�!3�I�J�!?�D���M����*�*�9�g�>�>�>�>�s�AA�A�Ac��XK�|jj||��d{���y7��wr�)r�rY)r1r�rXs   rrYzAsyncHTTP11UpgradeStream.writels �����l�l� � ���1�1�1�s� *�(�*c��TK�|jj��d{���y7��wr�)r�r�r�s rr�zAsyncHTTP11UpgradeStream.acloseos�����l�l�!�!�#�#�#�s�(�&�(c��XK�|jj|||��d{���S7��wr�)r��	start_tls)r1�ssl_context�server_hostnamerXs    rr�z"AsyncHTTP11UpgradeStream.start_tlsrs'�����\�\�+�+�K��'�R�R�R�R�s�!*�(�*c�8�|jj|�Sr�)r�r�)r1r�s  rr�z'AsyncHTTP11UpgradeStream.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��*�?�2�$�'+� $�	S�#�S�$�S��	S�

�S�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�/�A��0�	��	�	�,�	-���|�|��K�K��H�H��������$�,�,��V�4�V�r:�:�61�1�1r