@i)WdZddlZddlZddlZddlZddlZddlmZ ddlZejejejdZ e edr ejn eje d<e edxr ej Zdd lmZmZmZmZmZmZd d lmZd d lmZmZmZd d l m!Z!d dl"m#Z#de$de%fdZ&de'de(dee'fdZ)GddZ*Gdde*Z+Gdde*Z,y#e$rdZYkwxYw)zGModule implementing low-level socket communication with MySQL servers. N)deque)TLSv1TLSv1.1TLSv1.2 PROTOCOL_TLSTLSv1.3 HAS_TLSv1_3F)AnyDequeListOptionalTupleUnion)MAX_PACKET_LENGTH)InterfaceErrorNotSupportedErrorOperationalError)StrOrBytesPath)init_bytearrayerrreturncf|js t|S|jd|jS)z_Reformat the IOError error message This function reformats the IOError error message.  )errnostrstrerror)rs Q/var/www/html/aiagents/fe/lib/python3.12/site-packages/mysql/connector/network.py _strioerrorrEs- 993xii[#,, ((bufpktnrcLg}t|}t}||kDrI|jdtjd|z|d|z||d}t|}|dz}||kDrI|jtjd|ddtjd|z|z|S)z0Prepare a packet for sending to the MySQL server>ZiPQ)*oC  )   KK D%(1- D%0HH3NO Kr cDeZdZdZddZdefdZdefdZdefdZ defdZ dd Z dd Z dd Z d d ed eedeeddfdZeZ d d ed eedeeddfdZdefdZeZdeddfdZdeefdZdeeddfdZ d!dedededededeedeeeddfdZy)"BaseMySQLSocketaBase class for MySQL socket communication This class should not be used directly but overloaded, changing the at least the open_connection()-method. Examples of subclasses are mysql.connector.network.MySQLTCPSocket mysql.connector.network.MySQLUnixSocket rNcvd|_d|_d|_d|_t |_d|_d|_y)Ni )sock_connection_timeout_packet_number_compressed_packet_numberr _packet_queue server_hostrecvsizeselfs r__init__zBaseMySQLSocket.__init__fs:-1 26 #%.0&/4w*.! r cn|jdz|_|jdkDrd|_|jS)zIncrements the packet numberrr)r6r;s rnext_packet_numberz"BaseMySQLSocket.next_packet_numberps7"11A5    $"#D """r cn|jdz|_|jdkDrd|_|jS)z'Increments the compressed packet numberrr?r)r7r;s rnext_compressed_packet_numberz-BaseMySQLSocket.next_compressed_packet_numberws7)-)G)G!)K&  ) )C /-.D *---r ct)zOpen the socketNotImplementedErrorr;s ropen_connectionzBaseMySQLSocket.open_connection~!!r ct)zGet the location of the socketrDr;s r get_addresszBaseMySQLSocket.get_addressrGr c |jjtj|jj |`y#t tf$rYywxYw)z&Shut down the socket before closing itN)r4shutdownsocket SHUT_RDWRcloser8AttributeErrorOSErrorr;s rrKzBaseMySQLSocket.shutdownsJ  II  v// 0 IIOO "(   sAAAAch |jj|`y#ttf$rYywxYw)zClose the socketN)r4rNr8rOrPr;s rclose_connectionz BaseMySQLSocket.close_connections2  IIOO "(   s 11c$|jyN)rKr;s r__del__zBaseMySQLSocket.__del__s  r r! packet_numbercompressed_packet_numberc P|}||jn||_t||j}|D]} |jj | y#t $r,}t d|jt|f|d}~wt$r}t d|d}~wwxYw)z Send packets to the MySQL serverNrvaluesr) r@r6r/r4sendallIOErrorrrIrrO)r<r!rVrW_packetspacketrs r send_plainzBaseMySQLSocket.send_plains %   # # %"/D "3(;(;< ddg} t=j>|j6}| jA|dg|d zd}g}| D]4} tjB|jjE|d}n|s7|jj-tddjM|yy#t(tj*f$r.} |jj-td | | d} ~ wwxYw#t(tj*f$r.} |jj-td| | d} ~ wwxYw#tjF$r%} |jItK| Yd} ~ 9d} ~ wwxYw#tN$r} tQd| d} ~ wtj*t(f$r,} td|jStU| f| d} ~ wtjF$r} ttK| | d} ~ wtV$r} ttK| | d} ~ wwxYw)zSwitch the socket to use SSLir]NFT)reverserrrrrrzInvalid CA Certificate: zInvalid Certificate/Key: r9)server_hostnament localhost 127.0.0.1z"Unable to verify server identity: z, z&Python installation has no SSL supportrYrZ),r4rssl CERT_REQUIRED CERT_OPTIONAL CERT_NONEcreate_default_contextcheck_hostnamesortTLS_V1_3_SUPPORTEDr( TLS_VERSIONS SSLContextoptions OP_NO_TLSv1_2 OP_NO_TLSv1_1 OP_NO_TLSv1 verify_modeload_default_certsload_verify_locationsr_SSLErrorrNload_cert_chain set_ciphershasattr wrap_socketr9osnamerL gethostbyaddrrxmatch_hostname getpeercertCertificateErrorr)rrg NameErrorrrIrrE)r<rrrrrrr cert_reqscontext tls_version ssl_protocolr hostnamesaliases match_founderrshostnames r switch_to_sslzBaseMySQLSocket.switch_to_sslsyy t, ,_ 4--  -- MM #<446&-2G*!!$!/*1o *#y0L)A-".q/K+K8 ..6)+ 43+<+<< 43+<+<<l23??:%*G ""+G   & & (T11"5U++D#6##M2t]+#//IIt/?/?0 $// : )-&=A=M=M(8(8'9SU 77d?t'7'7;'F!,k :I$2243C3CDG$$gaj\GAJ%>?#  ) H  **499+@+@+BHM '+  #IIOO%(N=.L5)L00L55N=8M?)M::M??N=N:N5/N=5N::N== Q& OQ&.'PQ&+Q Q& Q!!Q&rN)NN)FFNN)__name__ __module__ __qualname____doc__r=intr@rBr rFrIrKrRrUbytesr rcsendrprurrvrrrrboolrr rr rr1r1]s"#C#.s."""S" (,26 < < }<#+3- <  <0 D (,26 Q< Q< }Q<#+3- Q<  Q)>>J)!4JX*hsm**" %'+,0m4 m4m4 m4  m4  m4 }m4tCy)m4 m4r r1cVeZdZdZd deddffd ZdefdZd dZded eddfd Z xZ S) MySQLUnixSocketzoMySQL socket class using UNIX sockets Opens a connection through the UNIX socket of the MySQL Server. unix_socketrNc0t|||_yrT)superr=r)r<r __class__s rr=zMySQLUnixSocket.__init__s  +r c|jSrT)rr;s rrIzMySQLUnixSocket.get_addresssr c tjtjtj|_|jj |j |jj |jy#t$r,}td|jt|f|d}~wt$r}tt||d}~wwxYw)NirZ)rLAF_UNIX SOCK_STREAMr4rr5connectrr_rrIr Exceptionr)r<rs rrFzMySQLUnixSocket.open_connections 4  2 2DI II !9!9 : II  d.. /  D$4$4$6 C8H#I  4 S* 3 4s$BB C 'B44 CCCargskwargsc8tjdty)zSwitch the socket to use SSL.z2SSL is disabled when using unix socket connectionsN)warningswarnWarning)r<rrs rrzMySQLUnixSocket.switch_to_ssls  @  r )z/tmp/mysql.sockr) rrrrrr=rIrFr r __classcell__rs@rrrsI ,C,, S  4  $'  r rc LeZdZdZ d dedededdffd ZdefdZd d Z xZ S) MySQLTCPSocketzXMySQL socket class using TCP/IP Opens a TCP/IP connection to the MySQL Server. hostport force_ipv6rNcZt|||_||_||_d|_y)Nr)rr=r9 server_portr_family)r<rrrrs rr=zMySQLTCPSocket.__init__s.  $ $ * r c8|jd|jS)N:)r9rr;s rrIzMySQLTCPSocket.get_address(s!""#1T%5%5$677r c d} tj|j|jdtjtj }|D]B}|j r|dtjk(r|}n|dtjk(s@|}n|j r|dtd|j|d|d}|\|_ }}}} tj|j|||_|jj|j |jj#|y#t$r,}td|jt|f|d}~wwxYw#t$r3}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 irZ)rL getaddrinfor9rrSOL_TCPrAF_INET6AF_INETrr_rIrrr4rr5rrrr) r<addrinfo addrinfosinforsocktypeprotor`sockaddrs rrFzMySQLTCPSocket.open_connection+s +  **    "" I" ??tAw&//'A#H7fnn,#H  8A;#6$'A$BRBRAS%TUU{"$Q< 8@4x8 6 dllHeDDI II !9!9 : II  h '  D$4$4$6 C8H#I    $$$$$  6"3s8,# 5 6sCB D<8D<A&E4< E1'E,,E14 G=.F++ G7G  G)ri Fr) rrrrrrrr=rIrFrrs@rrrsE MR-0EI 8S886r r)-rrrLr*rrh collectionsrrPROTOCOL_TLSv1PROTOCOL_TLSv1_1PROTOCOL_TLSv1_2rrrPROTOCOL_SSLv23r r ImportErrortypingr r r r rr constantsrerrorsrrrtypesrutilsrr_rrrrr/r1rrrr rrs>  ##''''L 3 '    !m4H <;(GG!!)W)) %  U T4T4n " o" JJ6_J6AsA#C##C-,C-