| Server IP : 209.209.40.120 / Your IP : 216.73.217.112 Web Server : Microsoft-IIS/10.0 System : Windows NT NEWWWW 10.0 build 17763 (Windows Server 2019) i586 User : NEWWWW$ ( 0) PHP Version : 8.3.30 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : C:/Program Files/MySQL/MySQL Workbench 6.3 CE/workbench/ |
Upload File : |
�
�"�Xc @ s� d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m Z d e j f d � � YZ d e f d � � YZ
d e j f d � � YZ d
e f d � � YZ d e f d
� � YZ
d S( i����N( t TCPServer( t BaseRequestHandlert TCPCommandListenerc B s e Z d Z d � Z d � Z RS( s�
This listener is to use a SocketServer.TCPServer on the logic for listening commands
the advantage of this version is that is basically a server shipped with python so
more error prone.
It requires the implementation of a Handler class which will contain all the handshaking
logic that was implemented on the original SocketServer (below).
There's a specific TODO on this version: need to find the way to tell the server to stop
once the command execution has completed.
c s� t j j � � d j d � t d � D� � � _ d j d � t d � D� � � _ t d � � f d � t � � _ � j j
� � j j d � _ d S(
Nt c s s( | ] } t j t j t j � Vq d S( N( t randomt choicet stringt ascii_uppercaset digits( t .0t x( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pys <genexpr>* s i c s s( | ] } t j t j t j � Vq d S( N( R R R R R ( R R
( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pys <genexpr>+ s s 127.0.0.1i c s" t | | | � j � j f � � S( N( t HandShakeHandlert handshaket close_key( t rt ct s( t output_handlert self( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyt <lambda>- s i ( s 127.0.0.1i (
t threadingt Threadt __init__t joint rangeR R
R t Falset _servert server_bindt server_addresst port( R R ( ( R R sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR ' s ""!
c C s | j j � | j j � d S( N( R t server_activatet
serve_forever( R ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyt run3 s
( t __name__t
__module__t __doc__R R ( ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR s R c B s; e Z d Z d � Z d � Z d � Z d � Z d � Z RS( s
This is the command handler needed when using the TCPServer distributed in the python standard library
It is basically a port of the logic contained on the initial SocketServer class (below) that was
created for the management of the command executions.
c C sp | d | _ | d | _ | j r) t n t | _ t | _ d | _ t | _ | | _ t
j | | | | � d S( Ni i ( t
_handshaket
_close_keyt TrueR t _wait_for_right_clientt _client_connectedt Nonet _pingert _closed_by_clientt _output_handlerR R ( R t requestt client_addresst servert handshake_keysR ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR ? s
c C sU | | j k r+ | j j d � t | _ n& | j j d � | j j � t | _ d S( Nt OKt ERROR( R$ R- t sendR R' t closeR( ( R R ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyt authenticate_clientL s
c C s� | j r| y9 | j j d � t j d | j � | _ | j j � Wq| t k
rx } d | _ t
| � | _ t | _ q| Xn d S( Nt .i (
R( R- R3 R t Timert _pingR* t startt Exceptiont exit_statust reprt exit_messageR ( R t e( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR8 U s c C s� t } t j d | j � | _ | j j � t | _ x� | j r� yr | j j d � } | r� | j rt | j
| � q� | j r� | j | k r� t | _ t
| _ q� | j | � n Wq7 t k
r� } d G| GHq7 Xq7 Wd S( Ni i s EXCEPTION : ( R& R R7 R8 R* R9 R( R- t recvR' R5 R% R+ R t process_dataR: ( R t
keep_alivet dataR> ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyt handlef s
c C s | j | � d S( N( R, ( R RB ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR@ � s ( R! R" R# R R5 R8 RC R@ ( ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR 7 s
0t SocketServerc B sM e Z d Z d d d � Z e d � Z d � Z d � Z d � Z d � Z RS( sY
Custom socket server class handling:
- optional handshake with connected client
- optional server shutdown based on close_key received by the client
This class is currently used to manage the command execution through the
admin helper script which communicates to this server by using an instance of
the SocketClient class below
R c C s� t j j | � | | _ | | _ | | _ | | _ | j rC t n t | _ t | _
d | _ t | _
t | _ d | _ d | _ t j t j t j � | _ d S( Ni R ( R R R t hostR R$ R% R& R R' R( R) R* R+ t _boundR; R= t sockett AF_INETt SOCK_STREAMt _socket( R RE R R R
( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR � s c C sv | | _ y; | j j | j | j f � | j j � | _ t | _ Wn+ t k
rq } d | _ t | � | _
n Xd S( Ni ( R RJ t bindRE t getsocknameR& RF R: R; R< R= ( R R t catch_errorR> ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyRK � s
c C sU | | j k r+ | j j d � t | _ n& | j j d � | j j � t | _ d S( NR1 R2 ( R$ t _connectionR3 R R' R4 R( ( R R ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR5 � s
c C s� | j r| y9 | j j d � t j d | j � | _ | j j � Wq| t k
rx } d | _ t
| � | _ t | _ q| Xn d S( NR6 i (
R( RN R3 R R7 R8 R* R9 R: R; R< R= R ( R R> ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR8 � s c C s� y�| j s" | j | j t � n t } x�| j r�| j j d � | j j � \ | _ | _
t | _ t j
d | j � | _ | j j � x | j r�y� | j j d � } | rt| j r� | j | � qt| j rd| j | j � d k rdt | _ t | _ | j j � | j d d � \ } } | j d � sq| j d d � \ } } d | _ | | _ qqqt| j | � n Wq� t k
r�} d | _ t | � | _ t | _ q� Xq� Wq+ WWn. t j k
r�} d | _ t | � | _ n Xd S( Ni i i t t 0( RF RK R R R& R' RJ t listent acceptRN t _addressR( R R7 R8 R* R9 R? R5 R% t findR+ R4 t splitt
startswithR; R= R@ R: R< RG t error( R RA RB t keyt return_datat ret_codeRW R> ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR � sB
!
c C s d S( N( ( R RB ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR@ s (
R! R" R# R R& RK R5 R8 R R@ ( ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyRD � s
Ft CustomCommandListenerc B s e Z d Z d � Z d � Z RS( s)
This is the implementationn of a socket server which will be listening for commands
executed as admin in local windows, the output is received through a socket
it is used only when the output is required and all the received data will be sent
to the configured output handler
c C s� d j d � t d � D� � | _ d j d � t d � D� � | _ t j | d d | j | j � t j | d � | j j � \ | _ | _
| | _ d S( NR c s s( | ] } t j t j t j � Vq d S( N( R R R R R ( R R
( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pys <genexpr>, s i c s s( | ] } t j t j t j � Vq d S( N( R R R R R ( R R
( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pys <genexpr>- s s 127.0.0.1i ( R R R R
RD R RK RJ RL RE R t _handler( R R ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR * s "" c C s | j | � d S( N( R\ ( R RB ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR@ 7 s ( R! R" R# R R@ ( ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR[ # s
t SocketClientc B s> e Z d Z d d d � Z d � Z d � Z d d d � Z RS( s�
Custom socket client class handling:
- optional handshake with server
- optional server shutdown based on close_key sent by the client
R c C s: | | _ | | _ | | _ | | _ t | _ d | _ d S( N( t _hostt _portR$ R% R t
_connectedR) t _authenticated( R RE R R R
( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR B s c C s� t j t j t j � | _ y� | j j | j | j f � t | _ | j r� | j j
| j � d } x_ | j d k r� | j j
d � } | rh | d k | _ | j s� t | _ | j � q� qh qh Wn Wn- t j k
r� } | j d k r� | GHq� n X| j S( Ni R1 iM' ( RG RH RI RJ t connectR^ R_ R& R` R$ R3 R) Ra R? R R4 RW t errno( R t validatedt responseR> ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR9 K s$ c C s | j r | j j | � n d S( N( R` RJ R3 ( R RB ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR3 l s i c C sx | j rt t j d � | j r[ | j r[ d | j | | f } | j � | j j | � n | j j � t | _ n d S( Ni s %s %d %s(
R` t timet sleepR% Ra t stripRJ R3 R4 R ( R R; t msgt closing_message( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR4 q s
( R! R" R# R R9 R3 R4 ( ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyR] ; s
! ( RG R Rf R R RD R R R R R R[ t objectR] ( ( ( sD C:\Program Files\MySQL\MySQL Workbench 6.3 CE\workbench\tcp_utils.pyt <module> s b�