>ijg1vdZddlZddlZddlZddlZddlmZmZddlm Z ddl m Z m Z m Z mZmZmZ ddlZejejejejdZeedoejZn#e$rdZdZYnwxYwd d lmZmZmZmZm Z m!Z!m"Z"d Z#d Z$d Z%dZ&de'de(fdZ)GddeZ*Gdde*Z+Gdde+Z,GddeZ-Gdde-Z.Gdde-Z/dS)zGModule implementing low-level socket communication with MySQL servers. N)ABCabstractmethod)deque)AnyDequeListOptionalTupleUnion)TLSv1TLSv1.1TLSv1.2TLSv1.3 HAS_TLSv1_3F)ConnectionTimeoutErrorInterfaceErrorNotSupportedErrorOperationalErrorProgrammingErrorReadTimeoutErrorWriteTimeoutError2ierrreturncR|jst|nd|jd|jS)z`Reformat the IOError error message. This function reformats the IOError error message. zErrno z: )errnostrstrerror)rs U/var/www/html/mpstechhub/venv/lib/python3.11/site-packages/mysql/connector/network.py _strioerrorr#Js0 9 N3s888*N39*N*N *N*NNceZdZdZe d dejdededee dee ddf d Z edejdede fd Z dS) NetworkBrokeraPBroker 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`. Nsockaddresspayload packet_numbercompressed_packet_numberrcdS)aSend `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. Raises: :class:`OperationalError`: If something goes wrong while sending packets to the MySQL server. N)selfr'r(r)r*r+s r"sendzNetworkBroker.sendjr$cdS)a)Get the next available packet from the MySQL server. Args: sock: Object holding the socket connection. address: Socket's location. Returns: packet: A packet from the MySQL server. Raises: :class:`OperationalError`: If something goes wrong while receiving packets from the MySQL server. :class:`InterfaceError`: If something goes wrong while receiving packets from the MySQL server. Nr-)r.r'r(s r"recvzNetworkBroker.recvr0r$NN) __name__ __module__ __qualname____doc__rsocketr bytesr intr/ bytearrayr2r-r$r"r&r&Rs. (,26   m     }  #+3-      ^ 6      ^   r$r&c eZdZdZddZddZdejdededdfd Z ddejd e de fd Z ddejded ede e de e ddf dZdejdede fdZdS)NetworkBrokerPlain,Broker class for MySQL socket communication.rNcd|_dSN_pktnrr.s r"__init__zNetworkBrokerPlain.__init__s  r$c*|jdzdz|_dSzIncrement packet id.rNrBrDs r"_set_next_pktnrz"NetworkBrokerPlain._set_next_pktnrs{Q#- r$r'r(pktc( ||dS#tjtf$r}t d|d}~wt $r&}t d|t|f|d}~wt$r}t d|d}~wwxYw)z!Write packet to the comm channel. rNrvaluesi) sendallr8timeout TimeoutErrorrIOErrorrr#AttributeError)r.r'r(rJrs r" _send_pktzNetworkBrokerPlain._send_pkts 8 LL      - 9 9 9#$///S 8   "G[-=-=#>  8 8 8"...C 7 8s,BA B !A.. B;B  Brsizect|}t|}|rC|||}|dkr|dkrtd||d}||z}|C|S)z(Read `size` bytes from the comm channel.rirMN)r; memoryview recv_intor)r.r'rWrJpkt_viewreads r" _recv_chunkzNetworkBrokerPlain._recv_chunks|ooc?? >>(D11DqyyTAXX$40000H DLD    r$r)r*r+c X||n||_t|tkrd}t t|tzD]e}|||dt jd|jz|||tzz||tz }f||d}|||t jdt|ddt jd|jz|zdS)zSend payload to the MySQL server. If provided a payload whose length is greater than `MAX_PAYLOAD_LENGTH`, it is broken down into packets. Nr> - -#k$ 445fv0B'BBCD$$&&&,,fgg&G    Kc'll + +AaC 0k$ ,, -      r$c ||t}tjd|dddzd|dc}|_||||zS#t jtf$r}td|j |d}~wt$r&}td |t|f |d}~wwxYw) z+Receive `one` packet from the MySQL server.rWrarrbrL)rmsgNrNrO) r]PACKET_HEADER_LENGTHrfunpackrCr8rRrSrr!rTrr#)r.r'r(header payload_lenrs r"r2zNetworkBrokerPlain.recvs %%d1E%FFF dF1Q3K'$9::1=q  %K D,,T ,DDD D - J J J"3<@@@c I   "G[-=-=#>  s$A)A,,C B C &!CC rN)rr3)r4r5r6r7rErIr8r r9rVr:r;r]r r/r2r-r$r"r=r=s566.... 8fm 8c 8 8$ 8 8 8 8   S     "(,26 * * m* *  *  } * #+3- *  * * * * Xr$r=c eZdZdZdfd ZedededeefdZ ddZ d e j d e d eddffd Z dd e j d e ded eedeeddf fd Zd e j dededdffd Zd e j d e deffd ZxZS)NetworkBrokerCompressedr>rNc|td|_t|_dSr@)superrE_compressed_pktnrr _queue_read)r. __class__s r"rEz NetworkBrokerCompressed.__init__s3 !#-2WWr$r)pktnrcg}t|tkrd}tt|tzD]R}|dt jd|z|||tzz|dzdz}|tz }S||d}|t jdt|ddt jd|z|z|S) z2Prepare a payload for sending to the MySQL server.rr_r`rrHNrarb)rcrdreappendrfrg)r)rzpktsrhris r"_prepare_packetsz(NetworkBrokerCompressed._prepare_packetss w<<- - -F3w<<+==>> - - #k$../fv0B'BBCD c),,fgg&G Kc'll + +AaC 06;tU3K3K Kg U    r$c*|jdzdz|_dSrG)rwrDs r"_set_next_compressed_pktnrz2NetworkBrokerCompressed._set_next_compressed_pktnr s"&"81"<!Cr$r'r(rJcXtj|}tjdt |ddtjd|jztjdt |ddz|z}t |||S)z1Compress packet and write it to the comm channel.rarrbr`)zlibcompressrfrgrcrwrvrV)r.r'r(rJcompressed_pktrys r"rVz!NetworkBrokerCompressed._send_pkt$ss++ Kc.11 2 21Q3 7k$ 677 8k$C))!A#. /  ww  w444r$r*r+c ||n||_||n||_t d|||j}t|ttz krd}tt|tzD]G}| |||||tz||tz }H| ||||ddSt|tkr| |||dSt ||tjdt|ddtjd|jztjddddz|zdS)zSend `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. Nr$rrarbr`)rIrCrrwr;joinr~rcrdrnrerVMIN_COMPRESS_LENGTHrvrfrg) r.r'r(r)r*r+ payload_preprhrirys r"r/zNetworkBrokerCompressed.send/s   " " " "'DK # +  + + - - - -%=D " ~~**4+@+@$++V+VWW w<<-0DD D DF3|,,0BBCC - -'<BT9T0T#U//111,, NN4,vww*? @ @ @ @ @ 7||111tWl;;;;;!!Kc,&7&7881=k$(>??@k$**1Q3/0##r$compressed_plluncompressed_pllct||}|dkr|n ttj|}d}|t |krdt jd|||tzdz dzd}t|zt ||z krt|t}t jd|dddzd|dt jd|dddzd c}|_ }t||}||dkr|ntj|z }|j |||tz|z|t|zz }|t |kbd Sd S) z&Handle reading of a compressed packet.rkrrarrlrbrrN) rvr]r;r decompressrcrfrornCOMPRESSED_PACKET_HEADER_LENGTHrwrxr|) r.r'rrrrJrhpllrprys r"_recv_compressed_pktz,NetworkBrokerCompressed._recv_compressed_pktls,,T,GG 1$$ N4?>::;; s3xx-c&6,@#@1#DDEOC$c)CHHv,===,,T8W,XXM$qs g(=>>qA1IM$qs g(=>>qA "*$ "'!4!4T!4!O!O'1,,#N88   # #C:N1NQT1T(T$U V V V *S0 0F?s3xxr$cf|js t|t}t jd|dddzd|dt jd|dddzd c}|_}||||n]#tj tf$r}td |d }~wt$r&}td |t|f |d }~wwxYw|jsd S|j}|d|_|S) z{Receive `one` or `several` packets from the MySQL server, enqueue them, and return the packet at the head. rkrarrbrlrrrLrMNrNrO)rxrvr]rrfrorwrr8rRrSrrTrr#popleftrC) r.r'r(rprrrrJrys r"r2zNetworkBrokerCompressed.recvsb  ,,T8W,XXM$qs g(=>>qA1IM$qs g(=>>qA "*$ ))$@PQQQQNL1 < < <&T222;   &S1A1A'B   4&&((!f  s$BB%%C?;C  C?!C::C?rrr3)r4r5r6r7rE staticmethodr9r:rr~rr8r rVr r/rr;r2 __classcell__rys@r"rtrts66555555 %U \2DDDD 5fm 5c 5 5$ 5 5 5 5 5 5 (,26 ;;m;; ;  } ; #+3- ; ;;;;;;z.1M.136.1JM.1 .1.1.1.1.1.1`!!!!!!!!!!!!!r$rtceZdZdZd dZd dZd dZd dZd dZd e e ddfd Z d e d e ddfd Z d!de e de e de e de ede ede ee de ee de fdZ d"dede e de e de e ddf dZd#de e defdZed dZeede fdZdS)$ MySQLSocketzMySQL socket communication interface. Examples: Subclasses: network.MySQLTCPSocket and network.MySQLUnixSocket. rNcVd|_d|_d|_t|_dS)zsNetwork layer where transactions are made with plain (uncompressed) packets is enabled by default. N)r'_connection_timeout server_hostr= _netbrokerrDs r"rEzMySQLSocket.__init__s, .2 26 *.);)=)=r$c,t|_dS)zIEnable network layer where transactions are made with compressed packets.N)rtrrDs r"switch_to_compressed_modez%MySQLSocket.switch_to_compressed_modes133r$c |jtj|jdS#t t f$rYdSwxYw)z'Shut down the socket before closing it.N)r'shutdownr8 SHUT_RDWRcloserUOSErrorrDs r"rzMySQLSocket.shutdowns_  I  v/ 0 0 0 IOO     (    DD s=AAAcj |jdS#ttf$rYdSwxYw)zClose the socket.N)r'rrUrrDs r"close_connectionzMySQLSocket.close_connectionsF  IOO     (    DD s 22c.|dSN)rrDs r"__del__zMySQLSocket.__del__s r$rRcZ||_|jr|j|dSdS)zSet the connection timeout.N)rr' settimeout)r.rRs r"set_connection_timeoutz"MySQLSocket.set_connection_timeouts:#* 9 * I  ) ) ) ) ) * *r$ ssl_contexthostc:|jJ|jjdkrtdtt d ||j||_dS#t $r}t d|d}~wtjtf$r+}td|j t|f|d}~wtj $r"}tt||d}~wt$r"}tt||d}~wwxYw)aUpgrade an existing connection to TLS. Args: ssl_context (ssl.SSLContext): The SSL Context to be used. host (str): Server host name. Returns: None. Raises: ProgrammingError: If the transport does not expose the socket instance. NotSupportedError: If Python installation has no SSL support. Nrz,SSL is not supported when using Unix sockets&Python installation has no SSL support)server_hostnamerNrO)r'familyrsslr wrap_socket NameErrorSSLErrorrTrr(r#CertificateErrorr NotImplementedError)r.rrrs r" switch_to_sslzMySQLSocket.switch_to_sslsFy$$$ 9 q "#QRR R ;#$LMM M 4#// 4/PPDIII W W W#$LMMSV V g&    DL+c2B2B#C # 4 4 4 S** 3" 4 4 4 S** 3 4s<!A## D-A==D&B<<DC++ D8DDFssl_cassl_certssl_keyssl_verify_certssl_verify_identity tls_versionstls_cipher_suitescd}|jstdttd|g}|g} |r|d|d}t |} tj| } |dkrZd |vr| xjtjzc_d |vr| xjtj zc_d |vr| xjtj zc_ntj } || _ |rtj | _n%|rtj| _ntj| _| |rH | |n1#t&tjf$r} td | | d} ~ wwxYw|rI | ||n1#t&tjf$r} td | | d} ~ wwxYw|r.|d kr(| d|| S#t0$r} td| d} ~ wt&t2tjtjf$r"} tt7| | d} ~ wwxYw)aBuild a SSLContext. Args: ssl_ca: Certificate authority, opptional. ssl_cert: SSL certificate, optional. ssl_key: Private key, optional. ssl_verify_cert: Verify the SSL certificate if `True`. ssl_verify_identity: Verify host identity if `True`. tls_versions: TLS protocol versions, optional. tls_cipher_suites: Set of steps that helps to establish a secure connection. Returns: ssl_context (ssl.SSLContext): An SSL Context ready be used. Raises: NotSupportedError: Python installation has no SSL support. InterfaceError: Socket undefined or invalid ssl data. NirMrT)reverserrrr r zInvalid CA Certificate: zInvalid Certificate/Key: :)r'rrrsort TLS_VERSIONS SSLContextoptions OP_NO_TLSv1_2 OP_NO_TLSv1_1 OP_NO_TLSv1create_default_contextcheck_hostname CERT_REQUIRED verify_mode CERT_OPTIONAL CERT_NONEload_default_certsload_verify_locationsrTrload_cert_chain set_ciphersrrrrr ) r.rrrrrrr tls_version ssl_protocolcontextrs r"build_ssl_contextzMySQLSocket.build_ssl_contexts8&* y - t,,, , ;#$LMM M  L  $ " 6 4 7!!$!///*1o +K8 .66)++ 443+<< 443+<<l223?:466%8G " 4&)&7##$ 4&)&7##&)m#  & & ( ( ( TT11&9999.TTT()IC)I)IJJPSST UU++Hg>>>>.UUU()JS)J)JKKQTTU ! A[I%=%=##CHH->$?$?@@@N W W W#$LMMSV V    L   4 4 4 !S** 3  4slD H EH F 1FF  H F&%H &G<GG4H I/H##*I/ I**I/r)r*r+ write_timeoutc |js2|j+|j|rt|ndn#t$r }Yd}~nd}~wwxYw|j|j|j|||dS)atSend `payload` to the MySQL server. NOTE: if `payload` is an instance of `bytearray`, then `payload` might be changed by this method - `bytearray` is similar to passing a variable by reference. If you're sure you won't read `payload` after invoking `send()`, then you can use `bytearray.` Otherwise, you must use `bytes`. N)r*r+)rr'rfloatrrr/r()r.r)r*r+rris r"r/zMySQLSocket.sendss  , V151F $$]%TU=%9%9%9PTUUU    DDDD   I L '%=      9< A A read_timeoutc |js2|j+|j|rt|ndn#t$r }Yd}~nd}~wwxYw|j|j|jS)z.Get packet from the MySQL server comm channel.N)rr'rrrrr2r()r.rris r"r2zMySQLSocket.recvs , T151F $$L%RU<%8%8%8dSSS    DDDD ##DIt|<<>>>4444*hsm***** "4"4C"4D"4"4"4"4L!%"&!%*/.3,015`4`4 `43-`4# `4 "$ `4 &d^ `4tCy)`4$DI.`4 `4`4`4`4J(,26'+     } #+3-   }       @ = =# =) = = = =^....^X...r$rcfeZdZdZd deddffd ZedefdZd dZd e d e ddfd Z xZ S)MySQLUnixSocketzpMySQL socket class using UNIX sockets. Opens a connection through the UNIX socket of the MySQL Server. /tmp/mysql.sock unix_socketrNcdt||_||_dSr)rvrEr_address)r.rrys r"rEzMySQLUnixSocket.__init__s,  +( r$c|jSrrrDs r"r(zMySQLUnixSocket.address }r$c" tjtjtj|_|j|j|j|jdS#tjtf$r+}td|j t|f|d}~wt$r+}td|j t|f|d}~wt$r"}tt!||d}~wwxYw)NrO)r8AF_UNIX SOCK_STREAMr'rrconnectrrRrSrr(r#rTr Exceptionr )r.rs r"rzMySQLUnixSocket.open_connections- 4 "DI I !9 : : : I  d. / / / / / -   (L$$       DL+c2B2B#C  4 4 4 S** 3 4s0A,A00D&B,, D9&C D,D  Dargskwargsc:tjdtdS)zSwitch the socket to use SSL.z2SSL is disabled when using unix socket connectionsN)warningswarnWarning)r.rrs r"rzMySQLUnixSocket.switch_to_ssls(  @      r$)rrr) r4r5r6r7r rErr(rrrrrs@r"rrs ))C))))))) X44440  $'         r$rc `eZdZdZ d dedededd ffd Zedefd Z dd Z xZ S)MySQLTCPSocketzYMySQL socket class using TCP/IP. Opens a TCP/IP connection to the MySQL Server. 127.0.0.1 Frport force_ipv6rNct||_||_||_d|_|d||_dS)Nrr)rvrEr server_portr_familyr)r.rrrrys r"rEzMySQLTCPSocket.__init__sR  $ $ * $--t-- r$c|jSrrrDs r"r(zMySQLTCPSocket.addressrr$c  d} tj|j|jdtjtj}|D]=}|jr|dtjkr|}n|dtjkr|}n>|jr|dtd|j|d|d}n>#t$r1}td|j|jt|f|d}~wwxYw|\|_ }}}} tj|j |||_ |j |j|j |dS#tjt$f$r1}t'd|j|jt|f|d}~wt$r1}td|j|jt|f|d}~wt($r"}t+t-||d}~wwxYw)z/Open the TCP/IP connection to the MySQL server.)NNNNNrNzNo IPv6 address found for irOr)r8 getaddrinforrrSOL_TCPrAF_INET6AF_INETrrTr#rr'rrrrRrSrrrr ) r.addrinfo addrinfosinforsocktypeprotorisockaddrs r"rzMySQLTCPSocket.open_connectionst +  *  " I"  ?tAw&/'A'A#HE7fn,,#HE- V8A;#6$%T$BR%T%TUUU{"$Q<    ($*:Krs:   ########;;;;;;;;;;;;;;;; JJJ#''# L !m44H CCC "#OWOOOOOD D D D D CD D D NbbbbbbbbJ0Df.f.f.f.f.#f.f.f.R. . . . . k. . . bY6Y6Y6Y6Y6[Y6Y6Y6Y6Y6s2A%% A10A1