?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/aio/__pycache__/network.cpython-39.pyc
???????
a ��Jh�n � @ sR d Z ddgZddlZddlZddlZz"ddlZejejejej d�Z W n e y\ dZY n0 ddl m Z mZ ddlmZ ddlmZmZmZmZmZ d d lmZmZmZmZm Z m Z d d l m Z m Z m!Z!m"Z" d d l#m$Z$m%Z% e&e'd�dd�Z(G dd� de �Z)G dd� de)�Z*G dd� de*�Z+G dd� de �Z,G dd� de,�Z-G dd� de,�Z.dS )zFModule implementing low-level socket communication with MySQL servers.�MySQLTcpSocket�MySQLUnixSocket� N)�TLSv1�TLSv1.1�TLSv1.2�TLSv1.3)�ABC�abstractmethod)�deque)�Any�Deque�List�Optional�Tuple� )�InterfaceError�NotSupportedError�OperationalError�ProgrammingError�ReadTimeoutError�WriteTimeoutError)� COMPRESSED_PACKET_HEADER_LENGTH�MAX_PAYLOAD_LENGTH�MIN_COMPRESS_LENGTH�PACKET_HEADER_LENGTH� )� StreamWriter�open_connection)�err�returnc C s | j st| �S | j � d| j� �S )z`Reformat the IOError error message. This function reformats the IOError error message. � )�errno�str�strerror)r � r$ �P/home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/aio/network.py� _strioerrorI s r& c @ s\ e Zd ZdZed eeeee ee ee dd�dd��Z ed e j eee e d�dd��ZdS ) � NetworkBrokeraP Broker class interface. The network object is a broker used as a delegate by a socket object. Whenever the socket wants to deliver or get packets to or from the MySQL server it needs to rely on its network broker (netbroker). The netbroker sends `payloads` and receives `packets`. A packet is a bytes sequence, it has a header and body (referred to as payload). The first `PACKET_HEADER_LENGTH` or `COMPRESSED_PACKET_HEADER_LENGTH` (as appropriate) bytes correspond to the `header`, the remaining ones represent the `payload`. The maximum payload length allowed to be sent per packet to the server is `MAX_PAYLOAD_LENGTH`. When `send` is called with a payload whose length is greater than `MAX_PAYLOAD_LENGTH` the netbroker breaks it down into packets, so the caller of `send` can provide payloads of arbitrary length. Finally, data received by the netbroker comes directly from the server, expect to get a packet for each call to `recv`. The received packet contains a header and payload, the latter respecting `MAX_PAYLOAD_LENGTH`. N��writer�address�payload� packet_number�compressed_packet_number� write_timeoutr c � s dS )a� Send `payload` to the MySQL server. If provided a payload whose length is greater than `MAX_PAYLOAD_LENGTH`, it is broken down into packets. Args: sock: Object holding the socket connection. address: Socket's location. payload: Packet's body to send. packet_number: Sequence id (packet ID) to attach to the header when sending plain packets. compressed_packet_number: Same as `packet_number` but used when sending compressed packets. write_timeout: Timeout in seconds before which sending a packet to the server should finish else WriteTimeoutError is raised. Raises: :class:`OperationalError`: If something goes wrong while sending packets to the MySQL server. Nr$ )�selfr) r* r+ r, r- r. r$ r$ r% �writei s zNetworkBroker.write��readerr* � read_timeoutr c � s dS )aM Get the next available packet from the MySQL server. Args: sock: Object holding the socket connection. address: Socket's location. read_timeout: Timeout in seconds before which reading a packet from the server should finish. Returns: packet: A packet from the MySQL server. Raises: :class:`OperationalError`: If something goes wrong while receiving packets from the MySQL server. :class:`ReadTimeoutError`: If the time to receive a packet from the server takes longer than `read_timeout`. :class:`InterfaceError`: If something goes wrong while receiving packets from the MySQL server. Nr$ )r/ r2 r* r3 r$ r$ r% �read� s zNetworkBroker.read)NNN)N)�__name__� __module__� __qualname__�__doc__r r r" �bytesr �intr0 �asyncio� StreamReader� bytearrayr4 r$ r$ r$ r% r' Q s, �� ��r' c @ s� e Zd ZdZdd�dd�Zeeeeef d�dd��Z de e dd �d d �Z e e edd �d d�Zdejee e ed�dd�Zde e ee e e e e e dd�dd�Zd eje e e ed�dd�ZdS ) �NetworkBrokerPlain�,Broker class for MySQL socket communication.N�r c C s d| _ d S �N�����_pktnr�r/ r$ r$ r% �__init__� s zNetworkBrokerPlain.__init__��pktr c C sB t | �tk rtd��t�d| dd� d �d | d }}||fS )�-Recover the header information from a packet.�3Can't recover header info from an incomplete packet�<Ir � � )�lenr � ValueError�struct�unpack)rH �pll�seqidr$ r$ r% � get_header� s �z NetworkBrokerPlain.get_header��next_idr c C s0 |du r| j d7 _ n|| _ | j d; _ dS �z:Set the given packet id, if any, else increment packet id.Nr � rC �r/ rV r$ r$ r% �_set_next_pktnr� s z"NetworkBrokerPlain._set_next_pktnr�r) r* rH r c � s� z |� |� |�� I dH W nh tyV } z"td|t|�fd�|�W Y d}~n8d}~0 ty� } ztdd�|�W Y d}~n d}~0 0 dS )z!Write packet to the comm channel.N� �r! �valuesi� �r! )r0 �drain�IOErrorr r& �AttributeError)r/ r) r* rH r r$ r$ r% � _write_pkt� s ��z NetworkBrokerPlain._write_pktr )r2 �sizer3 r c � s� zRt d�}t|�|k rNt�|�|t|� �|�I dH }|sDtdd��||7 }q |W S tjtjfy� } ztdd�|�W Y d}~n d}~0 0 dS )z(Read `size` bytes from the comm channel.� Ni� r_ �� ) r= rN r; �wait_forr4 r �CancelledError� TimeoutErrorr )r/ r2 rd r3 rH �chunkr r$ r$ r% � _read_chunk� s � z NetworkBrokerPlain._read_chunkr( c � s� | � |� d}z�tt|�t �D ]N}t�| �||dt�d| j � |||t � �|�I dH | � � |t7 }q t�| �||t�dt|�| �dd� t�d| j � ||d� �|�I dH W n8 tj tj fy� } zt dd�| �W Y d} ~ n d} ~ 0 0 dS ) z�Send payload to the MySQL server. If provided a payload whose length is greater than `MAX_PAYLOAD_LENGTH`, it is broken down into packets. r � ����<BNrK rL rf r_ ) rZ �rangerN r r; rg rc rP �packrD rh ri r ) r/ r) r* r+ r, r- r. �offset�_r r$ r$ r% r0 � s@ ���� � ��� zNetworkBrokerPlain.writer1 c � s~ z>| � |t|�I dH }| �|�\}| _|| � |||�I dH W S tyx } z"td|t|�fd�|�W Y d}~n d}~0 0 dS )z+Receive `one` packet from the MySQL server.Nr\ r] )rk r rT rD ra r r& )r/ r2 r* r3 �headerZ payload_lenr r$ r$ r% r4 s ��zNetworkBrokerPlain.read)N)r N)NNN)N)r5 r6 r7 r8 rF � staticmethodr9 r r: rT r rZ r r" rc r; r< r= rk r0 r4 r$ r$ r$ r% r> � sJ � �� �� 3 ��r> c s� e Zd ZdZdd�� fdd� Zeeeee d�dd��Z eee eeef d �d d ��Z de e dd �d d�Z eeedd�� fdd� Zd eeee e e e e e dd�� fdd� Zd ejee e dd�� fdd� Zd ejee e ed�� fdd� Z� ZS ) �NetworkBrokerCompressedr? Nr@ c s t � �� d| _t� | _d S rA )�superrF �_compressed_pktnrr � _queue_readrE �� __class__r$ r% rF - s z NetworkBrokerCompressed.__init__)r+ �pktnrr c C s� d}g }t t| �t �D ]>}|�dt�d|� | ||t � � |d d }|t7 }q|�t�dt| �| �dd� t�d|� | |d� � |S ) z2Prepare a payload for sending to the MySQL server.r rl rm r rX rK rL N)rn rN r �appendrP ro )r+ rz rp Zpktsrq r$ r$ r% �_prepare_packets2 s( ��� � ��z(NetworkBrokerCompressed._prepare_packetsrG c C sb t | �tk rtd��t�d| dd� d �d | d t�d| dd� d �d }}}|||fS )rI rJ rK r rL rM � � )rN r rO rP rQ )rH �compressed_pllrS �uncompressed_pllr$ r$ r% rT K s � z"NetworkBrokerCompressed.get_headerrU c C s0 |du r| j d7 _ n|| _ | j d; _ dS rW )rv rY r$ r$ r% �_set_next_compressed_pktnrY s z2NetworkBrokerCompressed._set_next_compressed_pktnrr[ c � sb t �|�}t�dt|��dd� t�d| j� t�dt|��dd� | }t� �|||�I dH S )z1Compress packet and write it to the comm channel.rK r rL rm N)�zlib�compressrP ro rN rv ru rc )r/ r) r* rH �compressed_pktrx r$ r% rc a s ����z"NetworkBrokerCompressed._write_pktr( c � s| | � |� | �|� �z&td��| �|| j��}t|�tt kr�d}t t|�t �D ]<} t � | � |||||t � �|�I dH | �� |t7 }qTt � | � ||||d� �|�I dH n�t|�t kr�t � | � |||�|�I dH nXt � t� � ||t�dt|��dd� t�d| j� t�dd�dd� | �|�I dH W n: t jt jf�yv } ztdd�| �W Y d} ~ n d} ~ 0 0 dS ) z�Send `payload` as compressed packets to the MySQL server. If provided a payload whose length is greater than `MAX_PAYLOAD_LENGTH`, it is broken down into packets. re r NrK rL rm rf r_ )rZ r� r= �joinr| rD rN r r rn r; rg rc r ru rP ro rv rh ri r ) r/ r) r* r+ r, r- r. Z payload_preprp rq r rx r$ r% r0 q sV ��� � � ����� z NetworkBrokerCompressed.write)r2 r r3 r c � s� t t�t� �|||�I dH ��}d}|t|�k r�t�d|||t d � d �d }t| t|�| kr�t� �|t |�I dH }| � |�\}| _ }t� �|||�I dH } ||dkr�| nt�| �7 }| j � |||t | � � |t| 7 }q$dS )z&Handle reading of a compressed packet.Nr rK r rM )r= r� � decompressru rk rN rP rQ r r rT rv rw r{ ) r/ r2 r r3 rH rp rR rr r� r� rx r$ r% �_read_compressed_pkt� s> �� ��� �� �� z,NetworkBrokerCompressed._read_compressed_pktr1 c � s� | j s�zht� �|t|�I dH }| �|�\}| _}|dkrX| j �t� �|||�I dH � n| �|||�I dH W n: ty� } z"t d|t |�fd�|�W Y d}~n d}~0 0 | j s�dS | j � � }|d | _ |S )z{Receive `one` or `several` packets from the MySQL server, enqueue them, and return the packet at the head. Nr r\ r] rL ) rw ru rk r rT rv r{ r� ra r r& �popleftrD ) r/ r2 r* r3 rr r r� r rH rx r$ r% r4 � s8 � ��� �� z NetworkBrokerCompressed.read)N)NNN)N)N)r5 r6 r7 r8 rF rs r9 r: r r| r rT r r� r r" rc r0 r; r< r� r= r4 � __classcell__r$ r$ rx r% rt * sL � ��M ��3 ��rt c @ s e Zd ZdZdd�dd�Zeed�dd��Zee dd�d d ��Z dd�d d �Z e d�d d�Z edd�dd�Zdd�dd�Zejdd�dd�Zd!eee ee ee dd�dd�Zd"ee ed�dd �Zdddd d g g fee ee ee ee ee eee eee ejd �d d �ZdS )#� MySQLSocketz�MySQL socket communication interface. Examples: Subclasses: network.MySQLTCPSocket and network.MySQLUnixSocket. Nr@ c C s* d| _ d| _d| _d| _t� | _d| _dS )zsNetwork layer where transactions are made with plain (uncompressed) packets is enabled by default. NF)�_reader�_writer�_connection_timeout�_addressr> � _netbroker� _is_connectedrE r$ r$ r% rF s zMySQLSocket.__init__c C s | j S )zSocket location.)r� rE r$ r$ r% r* + s zMySQLSocket.address��kwargsr c � s dS )zOpen the socket.Nr$ �r/ r� r$ r$ r% r 0 s zMySQLSocket.open_connectionc � sl | j rbz6| j �� | j jdur*| j j�� | j �� I dH W n$ ty` } z W Y d}~n d}~0 0 d| _dS )zClose the connection.NF)r� �close� transport�abort� wait_closed� Exceptionr� )r/ rq r$ r$ r% �close_connection4 s z MySQLSocket.close_connectionc C s | j S )z�Check if the socket is connected. Return: bool: Returns `True` if the socket is connected to MySQL server. )r� rE r$ r$ r% � is_connectedC s zMySQLSocket.is_connected)�timeoutr c C s || _ dS )zSet the connection timeout.N)r� )r/ r� r$ r$ r% �set_connection_timeoutK s z"MySQLSocket.set_connection_timeoutc C s t � | _dS )zIEnable network layer where transactions are made with compressed packets.N)rt r� rE r$ r$ r% �switch_to_compressed_modeO s z%MySQLSocket.switch_to_compressed_mode)� ssl_contextr c � sD | j dusJ �| j j�d�}|jdkr.td��| j �|�I dH dS )a? Upgrade an existing stream-based connection to TLS. The `start_tls()` method from `asyncio.streams.StreamWriter` is only available in Python 3.11. This method is used as a workaround. The MySQL TLS negotiation happens in the middle of the TCP connection. Therefore, passing a socket to open connection will cause it to negotiate TLS on an existing connection. Args: ssl_context: The SSL Context to be used. Raises: RuntimeError: If the transport does not expose the socket instance. N�socketr z,SSL is not supported when using Unix sockets)r� r� �get_extra_info�familyr � start_tls)r/ r� r� r$ r$ r% � switch_to_sslS s zMySQLSocket.switch_to_ssl)r+ r, r- r. r c � s& | j j| j| j||||d�I dH dS )z!Send packets to the MySQL server.)r, r- r. N)r� r0 r� r* )r/ r+ r, r- r. r$ r$ r% r0 l s �zMySQLSocket.write)r3 r c � s | j �| j| j|�I dH S )z#Read packets from the MySQL server.N)r� r4 r� r* )r/ r3 r$ r$ r% r4 } s zMySQLSocket.readF)�ssl_ca�ssl_cert�ssl_key�ssl_verify_cert�ssl_verify_identity� tls_versions�tls_cipher_suitesr c C s d}| j stdd��tdu r$td���z�|r�|jdd� |d }t| } t�| �} |dkr�d |vrr| jtjO _d |vr�| jtj O _d |vr�| jtj O _nt� � } || _ |r�tj | _n|r�tj| _ntj| _| �� |�r0z| �|� W n< ttjf�y. } z td | � ��| �W Y d} ~ n d} ~ 0 0 |�r�z| �||� W n< ttjf�y� } z td | � ��| �W Y d} ~ n d} ~ 0 0 |�r�|d k�r�| �d�|�� | W S t�y� } ztd�| �W Y d} ~ nHd} ~ 0 tttjtjf�y } ztt | ��| �W Y d} ~ n d} ~ 0 0 dS )zBuild a SSLContext.Ni r_ z&Python installation has no SSL supportT)�reverser r r r r zInvalid CA Certificate: zInvalid Certificate/Key: �:) r� r �ssl� RuntimeError�sort� TLS_VERSIONS� SSLContext�options� OP_NO_TLSv1_2� OP_NO_TLSv1_1� OP_NO_TLSv1�create_default_context�check_hostname� CERT_REQUIRED� verify_mode� CERT_OPTIONAL� CERT_NONE�load_default_certs�load_verify_locationsra �SSLError�load_cert_chain� set_ciphersr� � NameErrorr �NotImplementedError�CertificateErrorr" ) r/ r� r� r� r� r� r� r� Z tls_version� ssl_protocol�contextr r$ r$ r% �build_ssl_context� s` && �z MySQLSocket.build_ssl_context)NNN)N)r5 r6 r7 r8 rF �propertyr" r* r r r r� �boolr� r: r� r� r� r� r� r9 r r0 r= r4 r r� r$ r$ r$ r% r� sN �� � �r� c s< e Zd ZdZd eeed�� fdd� Zedd �d d �Z � Z S ) r z�MySQL socket class using TCP/IP. Args: host: MySQL host name. port: MySQL port. force_ipv6: Force IPv6 usage. � 127.0.0.1�� F)�host�port� force_ipv6c s0 t � �� || _|| _|| _|� d|� �| _d S )Nr� )ru rF �_host�_portZ _force_ipv6r� )r/ r� r� r� rx r$ r% rF � s zMySQLTcpSocket.__init__Nr� c � s0 t f | j| jd�|��I dH \| _| _d| _dS )zOpen TCP/IP connection.)r� r� NT)r r� r� r� r� r� r� r$ r$ r% r � s ��z MySQLTcpSocket.open_connection)r� r� F) r5 r6 r7 r8 r" r: r� rF r r r� r$ r$ rx r% r � s �� c s8 e Zd ZdZd ed�� fdd� Zedd�dd �Z� ZS ) r zbMySQL socket class using UNIX sockets. Args: unix_socket: UNIX socket file path. �/tmp/mysql.sock)� unix_socketc s t � �� || _d S )N)ru rF r� )r/ r� rx r$ r% rF � s zMySQLUnixSocket.__init__Nr� c � s. t jf d| ji|��I dH \| _| _d| _dS )z Open UNIX socket connection.�pathNT)r; �open_unix_connectionr� r� r� r� r� r$ r$ r% r � s �� �z MySQLUnixSocket.open_connection)r� ) r5 r6 r7 r8 r" rF r r r� r$ r$ rx r% r � s )/r8 �__all__r; rP r� r� �PROTOCOL_TLSv1�PROTOCOL_TLSv1_1�PROTOCOL_TLSv1_2� PROTOCOL_TLSr� � ImportError�abcr r � collectionsr �typingr r r r r �errorsr r r r r r �networkr r r r �utilsr r ra r" r& r' r> rt r� r r r$ r$ r$ r% �<module> s: � T p 4
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????