>ijg(1dZdgZddlZddlmZmZmZmZmZddl m Z m Z ddl m Z mZmZddlmZdd lmZmZmZdd lmZmZmZmZdd lmZmZd d lmZd dl m!Z!m"Z"d dl#m$Z$GddeZdS)z,Implements the MySQL Client/Server protocol. MySQLProtocolN)AnyDictListOptionalTuple) ClientFlag ServerCmd)InterfaceErrorProgrammingError get_exception)logger)DEFAULT_CHARSET_IDDEFAULT_MAX_ALLOWED_PACKETr)BinaryProtocolTypeDescriptionType EofPacketType HandShakeType)lc_intread_lc_string_list) MySQLSocket)MySQLAuthPluginget_auth_plugin)"MySQLCachingSHA2PasswordAuthPluginc VeZdZdZe d dededededeed ed ee ee fd e ee ffd Z eded eddddddf dedededeededededeedeedee eefded ed ee ee fd e ee ffdZ d!dedeedededeed e ee edfeeff dZ d"dede edfdedeed e ee eedfeeff dZdS)#rzSImplements MySQL client/server protocol. Create and parses MySQL packets. NF auth_datausernamepassword auth_pluginauth_plugin_class ssl_enabled plugin_configreturncj|s|dkrdt|||fS|i} t|||||}|j|fi|}n,#ttf$r} t d| | d} ~ wwxYw|t d|jt t||z}||fS)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 namerlen) rrr r!r"r#r$ auth_strategyr)errs Z/var/www/html/mpstechhub/venv/lib/python3.11/site-packages/mysql/connector/aio/protocol.pyauth_plugin_first_responsez(MySQLProtocol.auth_plugin_first_response:s-D K2-->(    M KKOK9JKK( M8M7 SS]SSMM>* K K K !@3!@!@AAs J K   /',//  s=1122]B m++s*A A6A11A6r handshakedatabasecharset client_flagsmax_allowed_packet conn_attrsis_change_user_requestc |} g}| rtjdtjd|tdd|dtdd |p|d}n-#t t f$r}td|d dd}~wwxYwtjd || rE|tj d t| d tj | n@d }|tj d|t| d |||| t|d||||| | \}}|||t||| r(|tj d||t jzr*||dz|t jzr/| -|t| d||fS)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$> ? ? ? *0 0 D  # #K$6$6$8$87$B C C C :2 2 O 8N  # #M$A$A*$M$M N N Nxx())=88s9 BB.B))B.rutf-8sockcolumnscount read_timeout.cpKg}d}d}d} |s| |krn||d{V} | ddkr|| }d}n-| ddkr!d}||| dd|}||||n||t | | dz } ||fS)zxRead MySQL binary protocol result. Reads all or given number of binary resultset rows from the socket. NrTr)read parse_eof_parse_binary_valuesrAr) selfrOrPrQr3rRrowseofvaluesipackets r/read_binary_resultz MySQLProtocol.read_binary_results   a5jj99\22222222FayCnnV,,a227F122JPP{v1 F#####F+++ FA c{r<versionc<K|}g}d}d}d} |s| |krn||d{V} | dr| ddg} ||d{V} | drM| | dd||d{V} | dM| | ddtd| }nV| ddkr$| ddkr|| }d}n&d}tt | dd}||||n||t| | d z } ||fS) 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. NrTsrTr<rUr)rW startswithrArrIrXbytesr) rZrOrarQrR_r[r\rowdatar^r_datass r/read_text_resultzMySQLProtocol.read_text_results$    a5jj99\22222222F  11 A #yy66666666''88;LL,,,#'99\#:#:::::::F''88; VABBZ(((-chhuoo>>c!!fQi!mmnnV,,-eF122J.?.?@@{w2 G$$$$#F+++ FA- .Syr<)NFN)rrNN)rN)__name__ __module__ __qualname____doc__ staticmethodrestrrboolrrrrr0rrrintrMrrrrrr`rir<r/rr4s  ,0!26:,:,:,:,:, :, $C= :,  :, S#X/:, uo% &:,:,:,\:,x #')"<%)+//3',!26w9w9 w9w9w93- w9  w9  w9 w9c]w9$C=w9T#s(^,w9!%w9w9 S#X/w9 uo% &w9w9w9\w9|&* """o&" "  " sm "  U%s* +, ! """"R&* ...sCx. . sm .  U8E?C' () !  ......r<)%rm__all__rBtypingrrrrr constantsr r errorsr r rrprotocolrrr_MySQLProtocoltypesrrrrutilsrrnetworkrpluginsrrplugins.caching_sha2_passwordrrrr<r/r~s{:32   33333333333333--------DDDDDDDDDD VUUUUUUUUUUU//////// 55555555MMMMMMQQQQQNQQQQQr<