← back to Atmos Game

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

66 lines

�

c�bj)����ddlmZddlZddlZddlZddlZddlZddlmZm	Z	m
Z
mZmZm
Z
mZmZddlmZddlmZmZmZGd�d	e�ZGd
�de�ZGd�d
e�Zy)�)�annotationsN�)�ConnectError�ConnectTimeout�ExceptionMapping�	ReadError�ReadTimeout�
WriteError�WriteTimeout�map_exceptions)�is_socket_readable�)�
SOCKET_OPTION�NetworkBackend�
NetworkStreamc��eZdZdZdZ		d							dd�Z				d
d�Zddd�Zddd�Zdd�Z			d							dd	�Z
dd
�Zy)�TLSinTLSStreamz�
    Because the standard `SSLContext.wrap_socket` method does
    not work for `SSLSocket` objects, we need this class
    to implement TLS stream using an underlying `SSLObject`
    instance in order to support TLS on top of TLS.
    i@Nc�P�||_tj�|_tj�|_|j|j|j|��|_|jj|�|j|jj�y)N)�incoming�outgoing�server_hostname)
�_sock�ssl�	MemoryBIO�	_incoming�	_outgoing�wrap_bio�ssl_obj�
settimeout�_perform_io�do_handshake)�self�sock�ssl_contextr�timeouts     �n/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/httpcore/_backends/sync.py�__init__zTLSinTLSStream.__init__"sy����
�������������"�+�+��^�^��^�^�+�,�
���	
�
�
���g�&�������2�2�3�c���d}	d}	|�}|jj|jj��|tjk(r]|jj|j�}|r|jj|�n|jj�|�|S��#tjtjf$r}|j}Yd}~��d}~wwxYw�N)r�SSLWantReadError�SSLWantWriteError�errnor�sendallr�read�SSL_ERROR_WANT_READ�recv�TLS_RECORD_SIZEr�write�	write_eof)r"�func�retr-�e�bufs      r&r zTLSinTLSStream._perform_io6s�������E�
 ��f��
�J�J���t�~�~�2�2�4�5���/�/�/��j�j�o�o�d�&:�&:�;����N�N�(�(��-��N�N�,�,�.��}��
�#���(�(�#�*?�*?�@�
 ������
 �s�B6�6#C/�C*�*C/c
�\�tjttti}t|�5|jj|�tjt|jtj|jj|���cddd�S#1swYyxYwr*)�socketr%r	�OSErrorrrrr�typing�cast�bytesr �	functools�partialrr/�r"�	max_bytesr%�exc_maps    r&r/zTLSinTLSStream.readOsm��%+�^�^�[�'�9�$U��
�G�
$��J�J�!�!�'�*��;�;��t�'�'�	�(9�(9�$�,�,�:K�:K�Y�(W�X��%�
$�
$�s�A,B"�"B+c�@�tjttti}t|�5|jj|�|rA|jtj|jj|��}||d}|r�Addd�y#1swYyxYwr*)
r:r%rr;r
rrrr r?r@rr3)r"�bufferr%rC�nsents     r&r3zTLSinTLSStream.writeWst��%+�^�^�\�7�J�$W��
�G�
$��J�J�!�!�'�*���(�(��):�):�4�<�<�;M�;M�v�)V�W��������%�
$�
$�s�AB�Bc�8�|jj�yr*�r�close�r"s r&rIzTLSinTLSStream.close_����
�
���r(c��t��r*)�NotImplementedError)r"r$rr%s    r&�	start_tlszTLSinTLSStream.start_tlsbs
��"�#�#r(c���|dk(r|jS|dk(r|jj�S|dk(r|jj�S|dk(r|jS|dk(rt	|j�Sy�N�
ssl_object�client_addr�server_addrr:�is_readable)rr�getsockname�getpeernamer
�r"�infos  r&�get_extra_infozTLSinTLSStream.get_extra_infojsv���<���<�<���=� ��:�:�)�)�+�+��=� ��:�:�)�)�+�+��8���:�:���=� �%�d�j�j�1�1�r(�NN)r#�
socket.socketr$�ssl.SSLContextr�
str | Noner%�float | None)r5z typing.Callable[..., typing.Any]�return�
typing.Anyr*�rB�intr%r^r_r>�rEr>r%r^r_�None�r_rd�r$r\rr]r%r^r_r�rX�strr_r`)�__name__�
__module__�__qualname__�__doc__r2r'r r/r3rIrNrY�r(r&rrs�����O�'+� $�4��4�$�4�$�	4�
�4�(�.��
��2�(��'+� $�	$�#�$�$�$��	$�

�$�r(rc�T�eZdZdd�Zd	d
d�Zd	dd�Zdd�Z		d
							dd�Zdd�Zy)�
SyncStreamc��||_yr*)r)r"r#s  r&r'zSyncStream.__init__ys	����
r(Nc���tjttti}t|�5|jj|�|jj|�cddd�S#1swYyxYwr*)	r:r%r	r;rrrrr1rAs    r&r/zSyncStream.read|sJ��%+�^�^�[�'�9�$U��
�G�
$��J�J�!�!�'�*��:�:�?�?�9�-�%�
$�
$�s�6A,�,A5c�
�|sytjttti}t|�5|r>|jj|�|jj|�}||d}|r�>ddd�y#1swYyxYwr*)	r:r%rr;r
rrr�send)r"rEr%rC�ns     r&r3zSyncStream.write�se����%+�^�^�\�7�J�$W��
�G�
$���
�
�%�%�g�.��J�J�O�O�F�+��������%�
$�
$�s�AA9�9Bc�8�|jj�yr*rHrJs r&rIzSyncStream.close�rKr(c���tjttti}t|�5	t
|jtj�r!t|j|||�cddd�S|jj|�|j|j|��}	ddd�t|�S#t$r}|j�|�d}~wwxYw#1swYt�SxYw)N)r)r:r%rr;rr�
isinstancerr�	SSLSocketrr�wrap_socket�	ExceptionrIro)r"r$rr%rCr#�excs       r&rNzSyncStream.start_tls�s���
�N�N�N��\�%
���G�
$�
��d�j�j�#�-�-�8�*��
�
�K��'��
%�
$��J�J�)�)�'�2�&�2�2��
�
�O�3��D�%�"�$�����
��
�
���	��
��%�"�$���s.�C"�;B?�38B?�?	C�C�C�C"�"C5c�T�|dk(r:t|jtj�r|jjS|dk(r|jj�S|dk(r|jj
�S|dk(r|jS|dk(rt|j�SyrP)rwrrrx�_sslobjrUrVr
rWs  r&rYzSyncStream.get_extra_info�s����<��J�t�z�z�3�=�=�$I��:�:�%�%�%��=� ��:�:�)�)�+�+��=� ��:�:�)�)�+�+��8���:�:���=� �%�d�j�j�1�1�r()r#r[r_rdr*rarcrerZrfrg)	rirjrkr'r/r3rIrNrYrmr(r&roroxsN���.�	$��'+� $�	 �#� �$� ��	 �

� �:r(roc�N�eZdZ			d											dd�Z		d							dd�Zy)�SyncBackendNc��|�g}||f}|�dn|df}tjttti}t|�5tj|||��}	|D]}
|	j|
��|	jtjtjd�ddd�t|	�S#1swYt	�SxYw)Nr)�source_addressr)r:r%rr;rr�create_connection�
setsockopt�IPPROTO_TCP�TCP_NODELAYro)r"�host�portr%�
local_address�socket_options�addressr�rCr#�options           r&�connect_tcpzSyncBackend.connect_tcp�s����!��N���,��!.�!6��]�A�<N���N�N�N��\�%
��
�G�
$��+�+���-��D�
)�������(�)��O�O�F�.�.��0B�0B�A�F�%��$���%��$���s�AB-�-Cc���tjdk(rtd��|�g}tjt
tti}t|�5tjtjtj�}|D]}|j|��|j|�|j|�ddd�t|�S#1swYt�SxYw)N�win32z:Attempted to connect to a UNIX socket on a Windows system.)�sys�platform�RuntimeErrorr:r%rr;rr�AF_UNIX�SOCK_STREAMr�r�connectro)r"�pathr%r�rCr#r�s       r&�connect_unix_socketzSyncBackend.connect_unix_socket�s����<�<�7�"��L��
��!��N�
�N�N�N��\�%
���G�
$��=�=�����1C�1C�D�D�(�������(�)��O�O�G�$��L�L���%��$���
%��$���s
�A+C�C)NNN)r�rhr�rbr%r^r�r]r��%typing.Iterable[SOCKET_OPTION] | Noner_rrZ)r�rhr%r^r�r�r_r)rirjrkr�r�rmr(r&rr�s���
!%�$(�@D�
 �� �� ��	 �
"� �>�
 �
� �B!%�@D�	 �� �� �>�	 �

� r(r)�
__future__rr?r:rr�r<�_exceptionsrrrrr	r
rr�_utilsr
�baserrrrrorrmr(r&�<module>r�s[��"��
�
�
�
�	�	�	�(�>�>�^�]�^�B@��@�F6 �.�6 r(