G)f0dZdgZddlZddlmZmZmZmZmZddl m Z m Z ddl m Z mZmZddlmZdd lmZmZmZdd lmZmZmZmZdd lmZmZd d lmZd dl m!Z!m"Z"d dl#m$Z$GddeZy)z,Implements the MySQL Client/Server protocol. MySQLProtocolN)AnyDictListOptionalTuple) ClientFlag ServerCmd)InterfaceErrorProgrammingError get_exception)logger)DEFAULT_CHARSET_IDDEFAULT_MAX_ALLOWED_PACKETr)BinaryProtocolTypeDescriptionType EofPacketType HandShakeType) int1storeread_lc_string_list) MySQLSocket)MySQLAuthPluginget_auth_plugin)"MySQLCachingSHA2PasswordAuthPluginc eZdZdZe ddededededed eed e d ee ee fd e ee ffd Zedededdddddf dedededeededededeed eedee eefde d e d ee ee fd e ee ffdZ ddedeededed e ee edfeeff dZ ddede edfded e ee eedfeeffdZy) rzSImplements MySQL client/server protocol. Create and parses MySQL packets. NF auth_datausernamepassword client_flags auth_pluginauth_plugin_class ssl_enabled plugin_configreturncf|sdt|||fS|i} t|||||}|j|fi|} | t d|j |t jzrtt| | zn| dz} | |fS#ttf$r} t d| | d} ~ wwxYw)aPrepare 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 ) rr auth_response TypeErrorr namer SECURE_CONNECTIONrlen) rrr r!r"r#r$r% auth_strategyr)errs Y/var/www/html/flask-app/venv/lib/python3.12/site-packages/mysql/connector/aio/protocol.pyauth_plugin_first_responsez(MySQLProtocol.auth_plugin_first_response:sF>(    M KKOK9JK( M8M77 S]SM   ',,-/ j::: c-( )M 9(  m++>* K #:3%!@As J Ks(B B0B++B0r handshakedatabasecharsetmax_allowed_packet conn_attrsis_change_user_requestc ^|j} g}| rtjdtjd| tdd|j d tdd |xs|d}tjd || rB|jtjd t| d tj| n9d }|jtjd|t| d |||| tj|d|||||| | \}}|j||jtj||| r%|jtjd||t j"zr"|j|jdz|t j$zr&| $|jtj'| dj)||fS#t t f$r}td|d dd}~wwxYw)aMake 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` requestzStarting authorization phaseNzGot a NULL handshakerz$Handshake misses authentication infor"z-Handshake misses authentication plugin info ()z#The provided initial strategy is %sz ? *00 0  # #K$6$6$87$B C :22 2 8N  # #M$A$A*$M Nxx()=88o8$ "?uAF  s+ HH,H''H,sockcolumnscount.c6Kg}d}d}d} |s||k(r ||fS|jd{} | ddk(r|j| }d}n | ddk(rd}|j|| dd|}|||j|n| | t | |dz }7kw)zxRead MySQL binary protocol result. Reads all or given number of binary resultset rows from the socket. Nrr)read parse_eof_parse_binary_valuesrAr) selfrNrOrPr4rowseofvaluesipackets r0read_binary_resultz MySQLProtocol.read_binary_results a5jc{ 99;&FayCnnV,a227F12JP{v1 F##F++ FA's)BBA,BversioncK|}g}d}d}d} |s||k(r ||fS|jd{} | jdr| ddg} |jd{} | jdr>| j| dd|jd{} | jdr>| j| ddtt dj | }n4| ddk(r| ddkr|j | }d}nd}t| dd}|||j|n| | t| |dz }:777w) zRead 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. NrsrRr<rSr)rU startswithrAr bytearrayrIrVr) rXrNr_rP_rYrZrowdatar\r]datass r0read_text_resultzMySQLProtocol.read_text_resultsg  a5j*Sy) 99;&F  1 #yy{*''8LL,#'99;.F''8 VABZ(-in.A.A%.HIc!fQi!mnnV,-fQRj9{w2 G$#F++ FA-'+/s:+EE.EE r}sT:3   33-DD VU2 5MLNLr<