i51dZdgZddlZddlmZmZmZmZmZddl 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) int1storeread_lc_string_list) MySQLSocket)MySQLAuthPluginget_auth_plugin)"MySQLCachingSHA2PasswordAuthPluginc 6eZdZdZe ddededededed eed e d ee ee fd e ee ffd Zedededdddddf dedededeededededeed eedee eefde d e d ee ee fd e ee ffdZ d dedeededed e ee edfeeff dZ d!dede edfded e ee eedfeeffdZdS)"rzSImplements MySQL client/server protocol. Create and parses MySQL packets. NF auth_datausernamepassword client_flags auth_pluginauth_plugin_class ssl_enabled plugin_configreturnc|sdt|||fS|i} t|||||}|j|fi|} n,#ttf$r} t d| | d} ~ wwxYw| t d|j|t jzrtt| | zn| dz} | |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 namer SECURE_CONNECTIONrlen) rrr r!r"r#r$r% auth_strategyr)errs V/var/www/cyber-strat/venv/lib/python3.11/site-packages/mysql/connector/aio/protocol.pyauth_plugin_first_responsez(MySQLProtocol.auth_plugin_first_response:sBF >(    M KKOK9JKK( M8M7 SS]SSMM>* K K K !@3!@!@AAs J K   /',// j:: )Ic-(( ) )M 9 9(  m++s*AA0A++A0r handshakedatabasecharsetmax_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.cnKg}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) selfrOrPrQr4rowseofvaluesipackets r0read_binary_resultz MySQLProtocol.read_binary_results   a5jj99;;&&&&&&FayCnnV,,a227F122JPP{v1 F#####F+++ FA c{r<versionc6K|}g}d}d}d} |s||krn|d{V} | dr| ddg} |d{V} | drL| | dd|d{V} | dL| | 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. NrTsrSr<rTr)rV startswithrArrIrWbytesr) rYrOr`rQ_rZr[rowdatar]r^datass r0read_text_resultzMySQLProtocol.read_text_results    a5jj99;;&&&&&&F  11 A #yy{{******''88/LL,,,#'99;;......F''88/ VABBZ(((-chhuoo>>c!!fQi!mmnnV,,-eF122J.?.?@@{w2 G$$$$#F+++ FA- .Syr<)NFN)rrN)r)__name__ __module__ __qualname____doc__ staticmethodrdstrintrboolrrrrr1rrrrMrrrrrr_rhr<r0rr4s ,0!26?,?,?,?,?, ?,  ?, $C= ?,?, S#X/?, uo% &?,?,?,\?,B #')"<%)+//3',!26x9x9 x9x9x93- x9  x9  x9 x9c]x9$C=x9T#s(^,x9!%x9x9 S#X/x9 uo% &x9x9x9\x9~ !!!o&! !  !  U%s* +, !  !!!!JIJ****/S/*BE*  U8E?C' () ! ******r<)%rl__all__rBtypingrrrrr constantsr r errorsr r rrprotocolrrr_MySQLProtocoltypesrrrrutilsrrnetworkrpluginsrrplugins.caching_sha2_passwordrrqr<r0r}s{:32   33333333333333--------DDDDDDDDDD VUUUUUUUUUUU22222222 55555555MMMMMMRRRRRNRRRRRr<