?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/aio/__pycache__/protocol.cpython-39.pyc
???????
a ��Jh(1 � @ s� d Z dgZddlZddlmZmZmZmZmZ ddl m Z m Z ddl m Z mZmZ ddlmZ dd lmZmZmZ dd lmZmZmZmZ dd lm Z m Z d d l m Z d dl m!Z!m"Z" d dl#m$Z$ G dd� de�ZdS )z,Implements the MySQL Client/Server protocol.� MySQLProtocol� N)�Any�Dict�List�Optional�Tuple� )� ClientFlag� ServerCmd)�InterfaceError�ProgrammingError� get_exception)�logger)�DEFAULT_CHARSET_ID�DEFAULT_MAX_ALLOWED_PACKETr )�BinaryProtocolType�DescriptionType� EofPacketType� HandShakeType)�lc_int�read_lc_string_list� )� MySQLSocket)�MySQLAuthPlugin�get_auth_plugin)�"MySQLCachingSHA2PasswordAuthPluginc @ s2 e Zd ZdZedeeeeee eee ee f e ee f d�dd��Z edededdddddf eeeee eeeee ee ee eef eeee ee f e ee f d�d d ��Zdeee eeee e ee ed f ee f d�dd�Zdee ed f eee e ee ee d f ee f d�dd�ZdS )r zSImplements MySQL client/server protocol. Create and parses MySQL packets. NF)� auth_data�username�password� auth_plugin�auth_plugin_class� ssl_enabled� plugin_config�returnc C s� |s |dkr dt |||d�fS |du r*i }z*t||�|||d�}|j| fi |��}W n8 ttfy� } z td| � ��| �W Y d} ~ n d} ~ 0 0 |du r�td|j� ���tt|��| }||fS )a Prepare the first authentication response. Args: auth_data: Authorization data from initial handshake. username: Account's username. password: Account's password. client_flags: Integer representing client capabilities flags. auth_plugin: Authorization plugin name. auth_plugin_class: Authorization plugin class (has higher precedence than the authorization plugin name). ssl_enabled: Whether SSL is enabled or not. plugin_config: Custom configuration to be passed to the auth plugin when invoked. The parameters defined here will override the ones defined in the auth plugin itself. Returns: auth_response: Authorization plugin response. auth_strategy: Authorization plugin instance created based on the provided `auth_plugin` and `auth_plugin_class` parameters. Raises: InterfaceError: If authentication fails or when got a NULL auth response. � � )r! NzFailed authentication: z8Got NULL auth response while authenticating with plugin )r r � auth_response� TypeErrorr �namer �len) r r r r r r! r" � auth_strategyr& �err� r, �Q/home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/aio/protocol.py�auth_plugin_first_response: s* " ��&��z(MySQLProtocol.auth_plugin_first_responser )� handshaker r �database�charset� client_flags�max_allowed_packetr r � conn_attrs�is_change_user_requestr! r" r# c C s� |� � } g }| rt�d� t�d� | du r6td�d�| �d�du rNtd�d�z|pZ| d }W n: ttfy� } z td|� d ��d�W Y d}~n d}~0 0 t�d |� | r�|�t� d t | �� d �t j | �� n,d }|�t� d|� t | �� d �|||| �� t j| d ||||| | d�\}}|�|� |�t �||�� | �rN|�t� d|�� |tj@ �rl|�|� � d � |tj@ �r�| du�r�|�t �| �� d�|�|fS )a� Make a MySQL Authentication packet. Args: handshake: Initial handshake. username: Account's username. password: Account's password. database: Initial database name for the connection charset: Client charset (see [2]), only the lower 8-bits. client_flags: Integer representing client capabilities flags. max_allowed_packet: Maximum packet size. auth_plugin: Authorization plugin name. auth_plugin_class: Authorization plugin class (has higher precedence than the authorization plugin name). conn_attrs: Connection attributes. is_change_user_request: Whether is a `change user request` operation or not. ssl_enabled: Whether SSL is enabled or not. plugin_config: Custom configuration to be passed to the auth plugin when invoked. The parameters defined here will override the one defined in the auth plugin itself. Returns: handshake_response: Handshake response as per [1]. auth_strategy: Authorization plugin instance created based on the provided `auth_plugin` and `auth_plugin_class`. Raises: ProgrammingError: Handshake misses authentication info. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_handshake_response.html [2]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_basic_character_set.html#a_protocol_character_set zGot a `change user` requestz Starting authorization phaseNzGot a NULL handshaker z$Handshake misses authentication infor z-Handshake misses authentication plugin info (�)z#The provided initial strategy is %sz<BZsxZxxxxxxxxxxxxxxxxxxxxxxxz<IIB)r r r r r r! r" z<Hr% � )�encoder �debugr �getr' �KeyError�append�struct�packr) r Z CHANGE_USERr r. Zconnect_with_dbr Z PLUGIN_AUTHZ CONNECT_ARGSZmake_conn_attrs�join)r/ r r r0 r1 r2 r3 r r r4 r5 r! r" Z b_usernameZresponse_payloadr+ Zfillerr& r* r, r, r- � make_authw sl 3 �� ���� � zMySQLProtocol.make_authr �utf-8.)�sock�columns�countr1 � read_timeoutr# c � s� g }d}d}d} |s�| |kr q�|� |�I dH } | d dkrJ| �| �}d}n&| d dkrpd}| �|| dd� |�}|du r�|dur�|�|� n|du r�|du r�t| ��| d7 } q||fS )zxRead MySQL binary protocol result. Reads all or given number of binary resultset rows from the socket. Nr � � � r )�read� parse_eofZ_parse_binary_valuesr< r ) �selfrB rC rD r1 rE �rows�eof�values�i�packetr, r, r- �read_binary_result� s& z MySQLProtocol.read_binary_result)rB �versionrD rE r# c � s: |}g }d}d}d} |s | |kr$�q2|� |�I dH } | �d�r�| dd� g} |� |�I dH } | �d�r�| �| dd� � |� |�I dH } q\| �| dd� � td�| ��}n@| d dkr�| d dk r�| �| �}d}nd}tt| dd� ��}|du �r |du�r |�|� n |du �r(|du �r(t| ��| d7 } q||fS ) z�Read MySQL text result. Reads all or given number of rows from the socket. Returns a tuple with 2 elements: a list with all rows and the EOF packet. Nr s ���rF r7 rG � r )rI � startswithr< r r? rJ �bytesr ) rK rB rR rD rE �_rL rM ZrowdatarO rP Zdatasr, r, r- �read_text_result s6 z MySQLProtocol.read_text_result)NFN)r rA N)r N)�__name__� __module__� __qualname__�__doc__� staticmethodrU �strr �boolr r r r r. r r r �intr@ r r r r r rQ rW r, r, r, r- r 4 s� � �<� �~ ���� ) � ���)%r[ �__all__r= �typingr r r r r � constantsr r �errorsr r r r �protocolr r r Z_MySQLProtocol�typesr r r r �utilsr r �networkr Zpluginsr r Z plugins.caching_sha2_passwordr r, r, r, r- �<module> s
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????