*huSrSSKrSSKrSSKrSSKrSSKJrJr SSKJ r SSK J r J r J r JrJrJr SSKr\R$\R&\R(\R*S.r\"\S5=(a \R0rS S KJrJrJrJrJ r J!r!J"r" S r#S r$S r%Sr&S\'S\(4Sjr)"SS\5r*"SS\*5r+"SS\+5r,"SS\5r-"SS\-5r."SS\-5r/g!\a SrSrNrf=f)zFModule implementing low-level socket communication with MySQL servers.N)ABCabstractmethod)deque)AnyDequeListOptionalTupleUnion)TLSv1TLSv1.1TLSv1.2TLSv1.3 HAS_TLSv1_3F)ConnectionTimeoutErrorInterfaceErrorNotSupportedErrorOperationalErrorProgrammingErrorReadTimeoutErrorWriteTimeoutError2ierrreturncrUR(d [U5$SURSUR3$)zXReformat the IOError error message. This function reformats the IOError error message. zErrno z: )errnostrstrerror)rs O/var/www/auris/envauris/lib/python3.13/site-packages/mysql/connector/network.py _strioerrorr#Is. 993s8NF399+R ~*NNc\rSrSrSr\S S\R S\S\S\ \ S\ \ S S4 S jj5r \S\R S\S \ 4S j5r S rg) NetworkBrokerQaBroker 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_numberrcg)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"sendNetworkBroker.sendir$cg)aGet 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"recvNetworkBroker.recvr2r$r.NN)__name__ __module__ __qualname____firstlineno____doc__rsocketr bytesr intr0 bytearrayr4__static_attributes__r.r$r"r&r&Qs. (,26  mm     }  #+3-     6     r$r&c \rSrSrSrSSjrSSjrS\RS\S \ SS4S jr SS\RS \ S\ 4S jjr SS\RS\S \ S\\ S\\ SS4 SjjrS\RS\S\ 4SjrSrg)NetworkBrokerPlain,Broker class for MySQL socket communication.rNcSUlgN_pktnrr/s r"__init__NetworkBrokerPlain.__init__s  r$c2URS-S-UlgzIncrement packet id.rNrHrJs r"_set_next_pktnr"NetworkBrokerPlain._set_next_pktnrs{{Q#- r$r(r)pktcURU5 g![R[4an[ SS9UeSnAf[ an[ SU[U54S9UeSnAf[an[ SS9UeSnAff=f)z!Write packet to the comm channel. rNrvaluesi) sendallr<timeout TimeoutErrorrIOErrorrr#AttributeError)r/r(r)rRrs r" _send_pktNetworkBrokerPlain._send_pktsy 8 LL  - 9#$/S 8 "G[-=#>  8".C 7 8s*A7 8 A7A A7( A22A7sizec[U5n[U5nU(a7URXB5nUS:XaUS:a [SS9eXESnX%-nU(aM7U$)z(Read `size` bytes from the comm channel.rirUN)r? memoryview recv_intor)r/r(r`rRpkt_viewreads r" _recv_chunkNetworkBrokerPlain._recv_chunks[oc?>>(1DqyTAX$400H LD d  r$r*r+r,c UcUR5 OX@l[U5[:aSn[ [U5[-5H]nUR UUS[ R"SUR5-X6U[--5 UR5 U[- nM_ X6SnUR UU[ R"S[U55SS[ R"SUR5-U-5 g)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#kk$ 45v0B'BCD$$&,,?g&G    KKc'l +Aa 0kk$ , -  r$cVURU[S9n[R"SUSSS-5SUSso@lX0RXS9-$![ R [4an[SURS9UeSnAf[an[S U[U54S 9UeSnAff=f) z+Receive `one` packet from the MySQL server.r`rkrrlrT)rmsgNrVrW) rfPACKET_HEADER_LENGTHrpunpackrIr<rZr[rr!r\rr#)r/r(r)header payload_lenrs r"r4NetworkBrokerPlain.recvs %%d1E%FF dF1QK'$9:1=q  %K ,,T,DD D - J"3<<@c I "G[-=#>  s$AAB(+B B( B##B(rHrN)rr6)r7r8r9r:r;rKrPr<r r=r^r>r?rfr r0r4r@r.r$r"rBrBs6. 8fmm 8c 8 8$ 8  S  "(,26 * mm* *  *  } * #+3- *  * Xr$rBc H^\rSrSrSrSU4Sjjr\S\S\S\ \4Sj5r SS jr S \ RS \ S \SS4U4S jjrSS \ RS \ S\S\\S\\SS4 U4SjjjrS \ RS\S\SS4U4SjjrS \ RS \ S\4U4SjjrSrU=r$)NetworkBrokerCompressedrDrNcN>[TU]5 SUl[5UlgrF)superrK_compressed_pktnrr _queue_read)r/ __class__s r"rK NetworkBrokerCompressed.__init__s  !#-2Wr$r*pktnrc/n[U5[:anSn[[U5[-5HInURS[R "SU5-XU[--5 US-S-nU[- nMK XSnUR[R "S[U55SS[R "SU5-U-5 U$) z2Prepare a payload for sending to the MySQL server.rrirjrrONrkrl)rmrnroappendrprq)r*rpktsrrrss r"_prepare_packets(NetworkBrokerCompressed._prepare_packetss w<- -F3w<+==> #kk$./v0B'BCD c),,?g&G KKc'l +Aa 06;;tU3K Kg U  r$c2URS-S-UlgrN)rrJs r"_set_next_compressed_pktnr2NetworkBrokerCompressed._set_next_compressed_pktnrs"&"8"81"<!Cr$r(r)rRc(>[R"U5n[R"S[ U55SS[R"SUR 5-[R"S[ U55SS-U-n[ TU]XU5$)z1Compress packet and write it to the comm channel.rkrrlrj)zlibcompressrprqrmrrr^)r/r(r)rRcompressed_pktrs r"r^!NetworkBrokerCompressed._send_pkt#ss+ KKc.1 21Q 7kk$ 6 67 8kk$C)!A. /  w 44r$r+r,c >UcUR5 OX@lUcUR5 OXPl[ S5R UR X0R55n[U5[[- :amSn[[U5[-5H7nURXXgU[-5 UR5 U[- nM9 URXXgS5 g[U5[:aURXU5 g[T U]-UU[R"S[U55SS[R"SUR5-[R"SS5SS-U-5 g)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$rrkrlrj)rPrIrrr?joinrrmrnryror^MIN_COMPRESS_LENGTHrrprq) r/r(r)r*r+r, payload_preprrrsrs r"r0NetworkBrokerCompressed.send.sb   "'K # +  + + -%= " ~**4+@+@+++VW w<-0DD DF3|,0BBC<BT9T#U//1,, D NN4,w*? @ 7|11tl;!KKc,&781=kk$(>(>?@kk$*1Q/0##r$compressed_plluncompressed_pllc>[T U]XS9nUS:XaUO[[R"U55nSnU[ U5:Ga[ R"SXVU[-S- S-5Sn[U-[ U5U- :a[T U]U[S9n[ R"SUSSS-5SUS[ R"SUSSS-5SsnUl n[T U]XS9nUUS:XaUO[R"U5- nURRXVU[-U-5 U[U-- nU[ U5:aGMg g ) z&Handle reading of a compressed packet.rvrrkrrwrlrrN) rrfr?r decompressrmrprzryCOMPRESSED_PACKET_HEADER_LENGTHrrr) r/r(rrrrRrrpllr{rs r"_recv_compressed_pkt,NetworkBrokerCompressed._recv_compressed_pktks,T,G 1$ 4??>:; s3x--c6,@#@1#DEOC$c)CHv,==,T8W,XMM$q g(=>qA1IMM$q g(=>qA "*$ "'!4T!4!O'1,#8    # #C:N1NQT1T$U V *S0 0F?s3xr$c>UR(dq[TU] U[S9n[R "SUSSS-5SUS[R "SUSSS-5SsnUlnURXU5 UR(dg URR5nUSUlU$![R[4an[SS 9UeS nAf[an[S U[U54S 9UeS nAff=f) zkReceive `one` or `several` packets from the MySQL server, enqueue them, and return the packet at the head. rvrkrrlrwrrrTrUNrVrW)rrrfrrprzrrr<rZr[rr\rr#popleftrI) r/r(r)r{rrrrRrs r"r4NetworkBrokerCompressed.recvs ,T8W,XMM$q g(=>qA1IMM$q g(=>qA "*$ ))$@PQ&&(!f  NNL1 <&T2; &S1A'B s$A0B<<D C  D-DD)rrIrr~r6)r7r8r9r:r;rK staticmethodr=r>rrrr<r r^r r0rr?r4r@ __classcell__rs@r"rrs 65 %U 2D 5fmm 5c 5 5$ 5 (,26 ;mm;; ;  } ; #+3- ; ;;z.1MM.136.1JM.1 .1`!!!!!r$rcv\rSrSrSrS!SjrS!SjrS!SjrS!SjrS!S jr S \ \ SS4S jr S \ S \SS4SjrS"S\ \S\ \S\ \S\ \S\ \S\ \\S\ \\S\ 4SjjrS#S\S\ \ S\ \ S\ \ SS4 SjjrS$S\ \ S\4Sjjr\S!Sj5r\\S\4Sj55rS rg)% MySQLSocketizuMySQL socket communication interface. Examples: Subclasses: network.MySQLTCPSocket and network.MySQLUnixSocket. rNcLSUlSUlSUl[5Ulg)zcNetwork layer where transactions are made with plain (uncompressed) packets is enabled by default. N)r(_connection_timeout server_hostrB _netbrokerrJs r"rKMySQLSocket.__init__s% .2 26 *.);)=r$c"[5Ulg)zIEnable network layer where transactions are made with compressed packets.N)rrrJs r"switch_to_compressed_mode%MySQLSocket.switch_to_compressed_modes 13r$cURR[R5 URR 5 g![ [ 4a gf=f)z'Shut down the socket before closing it.N)r(shutdownr< SHUT_RDWRcloser]OSErrorrJs r"rMySQLSocket.shutdownsD  II  v// 0 IIOO (   sAAAAcfURR5 g![[4a gf=f)zClose the socket.N)r(rr]rrJs r"close_connectionMySQLSocket.close_connections,  IIOO (   s 00c$UR5 gN)rrJs r"__del__MySQLSocket.__del__s  r$rZcjXlUR(aURRU5 gg)zSet the connection timeout.N)rr( settimeout)r/rZs r"set_connection_timeout"MySQLSocket.set_connection_timeouts&#* 99 II  ) r$ ssl_contexthostc"URceURRS:Xa [S5e[c [ S5eUR URUS9Ulg![ an[ S5UeSnAf[R[4a%n[SUR[U54S9UeSnAf[Ran[[U55UeSnAf[an[[U55UeSnAff=f)a9Upgrade 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_hostnamerVrW)r(familyrsslr wrap_socket NameErrorSSLErrorr\rr)r#CertificateErrorr NotImplementedError)r/rrrs r" switch_to_sslMySQLSocket.switch_to_sslsyy$$$ 99  q "#QR R ;#$LM M 4#// 4/PDI W#$LMSV V g&  DLL+c2B#C ## 4 S* 3" 4 S* 3 4s<A(( D2 A>>D B;;DC'' D4D  Dssl_cassl_certssl_keyssl_verify_certssl_verify_identity tls_versionstls_cipher_suitesc.SnUR(d [SS9e[c [S5eUc/nUc/nU(aUR SS9 USn[ Un [R "U 5n US:Xa{S U;a#U =R[R-slS U;a#U =R[R-slS U;a#U =R[R-slO[R"5n XZl U(a[RU lO2U(a[RU lO[R U lU R#5 U(aU R%U5 U(aU R+X#5 U(a&US :Xa U R-SR/U55 U $![&[R(4an [S U 35U eSn A ff=f![&[R(4an [S U 35U eSn A ff=f![0an [S5U eSn A f[&[2[R4[R(4an [[7U 55U eSn A ff=f)aZBuild 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. NirUrT)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_locationsr\rload_cert_chain set_ciphersrrrrr ) r/rrrrrrr tls_version ssl_protocolcontextrs r"build_ssl_contextMySQLSocket.build_ssl_contexts;8&* yy t, , ;#$LM M  L  $ " 6 4!!$!/*1o +K8 ..6)+ 43+<+<< 43+<+<<l23??:446%8 "&)&7&7#$&)&7&7#&)mm#  & & (T11&9U++H> ![I%=##CHH->$?@N .T(+CC5)IJPSST  .U(+DSE)JKQTTU W#$LMSV V    LL   4 !S* 3  4slD=H38G H3H".H3G?+G::G??H3H0H++H00H33 J= I  1J:JJr*r+r, write_timeoutc,UR(d:URb-URRU(a [U5OS5 UR R URURUUUS9 g![a nSnANASnAff=f)aDSend `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(rfloatrrr0r))r/r*r+r,rrss r"r0MySQLSocket.sendrsz  ,,1F $$]U=%9PTU  II LL '%=     sA A?? BB read_timeoutc(UR(d:URb-URRU(a [U5OS5 UR R URUR5$![a nSnAN?SnAff=f)z.Get packet from the MySQL server comm channel.N)rr(rrrrr4r))r/rrss r"r4MySQLSocket.recvsj ,,1F $$LU<%8dS##DIIt||<<   sA A== B Bcg)zOpen the socket.Nr.rJs r"open_connectionMySQLSocket.open_connectionr2r$cg)zGet the location of the socket.Nr.rJs r"r)MySQLSocket.addressr2r$)rrrr(r~)NNNFFNN)NNNr)r7r8r9r:r;rKrrrrr r>rrr rboolrrr=r0r?r4rrpropertyr)r@r.r$r"rrs >4*hsm** "4"4C"4D"4L!%"&!%*/.3,015`4 `43-`4# `4 "$ `4 &d^ `4tCy)`4$DI.`4 `4J(,26'+    } #+3-   }    @ =# =) =...r$rct^\rSrSrSrS S\SS4U4Sjjjr\S\4Sj5rSSjr S \ S \ SS4S jr S r U=r $)MySQLUnixSocketizhMySQL socket class using UNIX sockets. Opens a connection through the UNIX socket of the MySQL Server. unix_socketrNc:>[TU]5 XlXlgr)rrKr_address)r/rrs r"rKMySQLUnixSocket.__init__s  +( r$cUR$rrrJs r"r)MySQLUnixSocket.address }}r$c,[R"[R[R5UlURR UR 5 URR UR5 g![R[4a%n[SUR[U54S9UeSnAf[a%n[SUR[U54S9UeSnAf[an[[!U55UeSnAff=f)NirW)r<AF_UNIX SOCK_STREAMr(rrconnectrrZr[rr)r#r\r Exceptionr )r/rs r"rMySQLUnixSocket.open_connections 4 ""DI II !9!9 : II  d.. / - (LL$     DLL+c2B#C  4 S* 3 4s0BBD B?? D C,, D9DDargskwargsc:[R"S[5 g)zSwitch the socket to use SSL.z2SSL is disabled when using unix socket connectionsN)warningswarnWarning)r/rrs r"rMySQLUnixSocket.switch_to_ssls  @  r$)rr(r)z/tmp/mysql.sockr~)r7r8r9r:r;r rKrr)rrrr@rrs@r"rrsb )C))) 40  $'   r$rc l^\rSrSrSrS S\S\S\SS4U4Sjjjr\ S\4S j5r S S jr S r U=r $)MySQLTCPSocketizQMySQL socket class using TCP/IP. Opens a TCP/IP connection to the MySQL Server. rport force_ipv6rNcl>[TU]5 XlX lX0lSUlUSU3Ulg)Nrr)rrKr server_portr_familyr)r/rrrrs r"rKMySQLTCPSocket.__init__s:  $ $ * $vQtf- r$cUR$rrrJs r"r)MySQLTCPSocket.addressr r$c ^Sn[R"URURS[R[R 5nUHJnUR (aUS[R:XaUn OUS[R:XdMHUn O UR (aUSc[SUR35eUScUSnUuUl pVpx[R"URXV5Ul URRUR5 URR!U5 g![a0n[SURUR[U54S9UeSnAff=f![R"[$4a0n['SURUR[U54S9UeSnAf[a0n[SURUR[U54S9UeSnAf[(an[[+U55UeSnAff=f)z/Open the TCP/IP connection to the MySQL server.)NNNNNrNzNo IPv6 address found for irW)r< getaddrinforrr SOL_TCPrAF_INET6AF_INETrr\r#rr(rrr rZr[rrr ) r/addrinfo addrinfosinforsocktypeprotorssockaddrs r"rMySQLTCPSocket.open_connections +  **    "" I"??tAw&//'A#H7fnn,#H "8A;#6$'A$BRBRAS%TUU{"$Q<8@4x 4 dllHDDI II !9!9 : II  h '  (($*:*:KrrKrr)rr@rrs@r"rrsh  . . . .  . .;4;4r$r)0r;r<rprrabcrr collectionsrtypingrrrr r r rPROTOCOL_TLSv1PROTOCOL_TLSv1_1PROTOCOL_TLSv1_2 PROTOCOL_TLSrhasattrrTLS_V1_3_SUPPORTED ImportErrorerrorsrrrrrrrrrnryrr\r r#r&rBrrrrr.r$r"r8s&:M  #;; ##''''## L !m4H "#OWOOD CD NbbJ0Df.#f.R. k. bR4[R4K CsAC'' C43C4