Multi_Script/LACASITAMX-v9x/VPS-MX/protocolos/sockspy.sh

#!/bin/bash
ll="/usr/local/include/snaps" && [[ ! -d ${ll} ]] && exit

#
clear
clear
SCPdir="/etc/VPS-MX"
SCPfrm="${SCPdir}/herramientas" && [[ ! -d ${SCPfrm} ]] && exit
SCPinst="${SCPdir}/protocolos" && [[ ! -d ${SCPinst} ]] && exit

declare -A cor=([0]="\033[1;37m" [1]="\033[1;34m" [2]="\033[1;31m" [3]="\033[1;33m" [4]="\033[1;32m")
[[ $(dpkg --get-selections | grep -w "python" | head -1) ]] || apt-get install python -y &>/dev/null
[[ $(dpkg --get-selections | grep -w "python-pip" | head -1) ]] || apt-get install python pip -y &>/dev/null
[[ $(dpkg --get-selections | grep -w "net-tools" | head -1) ]] || apt-get install net-tools -y &>/dev/null
mportas() {
    unset portas
    portas_var=$(lsof -V -i tcp -P -n | grep -v "ESTABLISHED" | grep -v "COMMAND" | grep "LISTEN")
    while read port; do
        var1=$(echo $port | awk '{print $1}') && var2=$(echo $port | awk '{print $9}' | awk -F ":" '{print $2}')
        [[ "$(echo -e $portas | grep "$var1 $var2")" ]] || portas+="$var1 $var2\n"
    done <<<"$portas_var"
    i=1
    echo -e "$portas"
}
meu_ip() {
    MEU_IP=$(ip addr | grep 'inet' | grep -v inet6 | grep -vE '127\.[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}' | grep -o -E '[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}' | head -1)
    MEU_IP2=$(wget -qO- ipv4.icanhazip.com)
    [[ "$MEU_IP" != "$MEU_IP2" ]] && echo "$MEU_IP2" || echo "$MEU_IP"
}
IP=$(wget -qO- ipv4.icanhazip.com)
tcpbypass_fun() {
    [[ -e $HOME/socks ]] && rm -rf $HOME/socks >/dev/null 2>&1
    [[ -d $HOME/socks ]] && rm -rf $HOME/socks >/dev/null 2>&1
    cd $HOME && mkdir socks >/dev/null 2>&1
    cd socks
    patch="https://www.dropbox.com/s/mn75pqufdc7zn97/backsocz"
    arq="backsocz"
    wget $patch -o /dev/null
    unzip $arq >/dev/null 2>&1
    mv -f ./ssh /etc/ssh/sshd_config && service ssh restart 1>/dev/null 2>/dev/null
    mv -f sckt$(python3 --version | awk '{print $2}' | cut -d'.' -f1,2) /usr/sbin/sckt
    mv -f scktcheck /bin/scktcheck
    chmod +x /bin/scktcheck
    chmod +x /usr/sbin/sckt
    rm -rf $HOME/socks
    cd $HOME
    msg="$2"
    [[ $msg = "" ]] && msg="@vpsmod"
    portxz="$1"
    [[ $portxz = "" ]] && portxz="8080"
    screen -dmS sokz scktcheck "$portxz" "$msg" >/dev/null 2>&1
}
l="/usr/local/lib/sped" && [[ ! -d ${l} ]] && exit
gettunel_fun() {
    echo "master=NetVPS" >${SCPinst}/pwd.pwd
    while read service; do
        [[ -z $service ]] && break
        echo "127.0.0.1:$(echo $service | cut -d' ' -f2)=$(echo $service | cut -d' ' -f1)" >>${SCPinst}/pwd.pwd
    done <<<"$(mportas)"
    screen -dmS getpy python ${SCPinst}/PGet.py -b "0.0.0.0:$1" -p "${SCPinst}/pwd.pwd"
    [[ "$(ps x | grep "PGet.py" | grep -v "grep" | awk -F "pts" '{print $1}')" ]] && {
        echo -e "Gettunel Iniciado con Sucesso"
        msg -bar
        echo -ne "Su contraseña Gettunel es:"
        echo -e "\033[1;32m NetVPS"
        msg -bar
    } || echo -e "Gettunel no fue iniciado"
    msg -bar
}

sistema20() {
    if [[ ! -e /etc/VPS-MX/fix ]]; then
        echo ""
        ins() {
            export PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/usr/games/
            apt-get install python -y
            apt-get install python pip -y
        }
        ins &>/dev/null && echo -e "INSTALANDO FIX" | pv -qL 40
        sleep 1.s
        [[ ! -e /etc/VPS-MX/fix ]] && touch /etc/VPS-MX/fix
    else
        echo ""
    fi
}
sistema22() {
    if [[ ! -e /etc/VPS-MX/fixer ]]; then
        echo ""
        ins() {
            export PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/usr/games/
            apt-get install python2 -y
            apt-get install python -y
            apt install python pip -y
            rm -rf /usr/bin/python
            ln -s /usr/bin/python2.7 /usr/bin/python
        }
        ins &>/dev/null && echo -e "INSTALANDO FIX" | pv -qL 40
        sleep 1.s
        [[ ! -e /etc/VPS-MX/fixer ]] && touch /etc/VPS-MX/fixer
    else
        echo ""
    fi
}

PythonDic_fun() {

    clear
    echo ""
    echo ""
    msg -tit
    msg -bar
    echo -e "\033[1;31m  SOCKS DIRECTO-PY | CUSTOM\033[0m"
    while true; do
        msg -bar
        echo -ne "\033[1;37m"
        read -p " ESCRIBE SU PUERTO: " porta_socket
        echo -e ""
        [[ $(mportas | grep -w "$porta_socket") ]] || break
        echo -e " ESTE PUERTO YA ESTÁ EN USO"
        unset porta_socket
    done
    msg -bar
    echo -e "\033[1;97m Digite Un Puerto Local 22|443|80\033[1;37m"
    msg -bar
    while true; do
        echo -ne "\033[1;36m"
        read -p " Digite Un Puerto SSH/DROPBEAR activo: " PORTLOC
        echo -e ""
        if [[ ! -z $PORTLOC ]]; then
            if [[ $(echo $PORTLOC | grep [0-9]) ]]; then
                [[ $(mportas | grep $PORTLOC | head -1) ]] && break || echo -e "ESTE PUERTO NO EXISTE"
            fi
        fi
    done
    #
    puertoantla="$(mportas | grep $PORTLOC | awk '{print $2}' | head -1)"
    msg -bar
    echo -ne " Escribe El HTTP Response? 101|200|300: \033[1;37m" && read cabezado
    tput cuu1 && tput dl1
    if [[ -z $cabezado ]]; then
        cabezado="200"
        echo -e "	\e[31mResponse Default:\033[1;32m ${cabezado}"
    else
        echo -e "	\e[31mResponse Elegido:\033[1;32m ${cabezado}"
    fi
    msg -bar
    echo -e "$(fun_trans "Introdusca su Mini-Banner")"
    msg -bar
    echo -ne " Introduzca el texto de estado plano o en HTML:\n \033[1;37m" && read texto_soket
    tput cuu1 && tput dl1
    if [[ -z $texto_soket ]]; then
        texto_soket="@lacasitamx"
        echo -e "	\e[31mMensage Default: \033[1;32m${texto_soket} "
    else
        echo -e "	\e[31mMensage: \033[1;32m ${texto_soket}"
    fi
    msg -bar

    (
        less <<CPM >/etc/VPS-MX/protocolos/PDirect.py
import socket, threading, thread, select, signal, sys, time, getopt

# Listen
LISTENING_ADDR = '0.0.0.0'
LISTENING_PORT = int("$porta_socket")
PASS = ''

# CONST
BUFLEN = 4096 * 4
TIMEOUT = 60
DEFAULT_HOST = '127.0.0.1:$puertoantla'
RESPONSE = 'HTTP/1.1 $cabezado <strong>$texto_soket</strong>\r\n\r\nHTTP/1.1 $cabezado Conexion Exitosa\r\n\r\n'

class Server(threading.Thread):
    def __init__(self, host, port):
        threading.Thread.__init__(self)
        self.running = False
        self.host = host
        self.port = port
        self.threads = []
        self.threadsLock = threading.Lock()
        self.logLock = threading.Lock()
    def run(self):
        self.soc = socket.socket(socket.AF_INET)
        self.soc.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        self.soc.settimeout(2)
        self.soc.bind((self.host, self.port))
        self.soc.listen(0)
        self.running = True
        try:
            while self.running:
                try:
                    c, addr = self.soc.accept()
                    c.setblocking(1)
                except socket.timeout:
                    continue
                conn = ConnectionHandler(c, self, addr)
                conn.start()
                self.addConn(conn)
        finally:
            self.running = False
            self.soc.close()
    def printLog(self, log):
        self.logLock.acquire()
        print log
        self.logLock.release()
    def addConn(self, conn):
        try:
            self.threadsLock.acquire()
            if self.running:
                self.threads.append(conn)
        finally:
            self.threadsLock.release()
    def removeConn(self, conn):
        try:
            self.threadsLock.acquire()
            self.threads.remove(conn)
        finally:
            self.threadsLock.release()
    def close(self):
        try:
            self.running = False
            self.threadsLock.acquire()
            threads = list(self.threads)
            for c in threads:
                c.close()
        finally:
            self.threadsLock.release()
class ConnectionHandler(threading.Thread):
    def __init__(self, socClient, server, addr):
        threading.Thread.__init__(self)
        self.clientClosed = False
        self.targetClosed = True
        self.client = socClient
        self.client_buffer = ''
        self.server = server
        self.log = 'Connection: ' + str(addr)
    def close(self):
        try:
            if not self.clientClosed:
                self.client.shutdown(socket.SHUT_RDWR)
                self.client.close()
        except:
            pass
        finally:
            self.clientClosed = True
        try:
            if not self.targetClosed:
                self.target.shutdown(socket.SHUT_RDWR)
                self.target.close()
        except:
            pass
        finally:
            self.targetClosed = True
    def run(self):
        try:
            self.client_buffer = self.client.recv(BUFLEN)
            hostPort = self.findHeader(self.client_buffer, 'X-Real-Host')
            if hostPort == '':
                hostPort = DEFAULT_HOST
            split = self.findHeader(self.client_buffer, 'X-Split')
            if split != '':
                self.client.recv(BUFLEN)
            if hostPort != '':
                passwd = self.findHeader(self.client_buffer, 'X-Pass')
				
                if len(PASS) != 0 and passwd == PASS:
                    self.method_CONNECT(hostPort)
                elif len(PASS) != 0 and passwd != PASS:
                    self.client.send('HTTP/1.1 400 WrongPass!\r\n\r\n')
                elif hostPort.startswith('127.0.0.1') or hostPort.startswith('localhost'):
                    self.method_CONNECT(hostPort)
                else:
                    self.client.send('HTTP/1.1 403 Forbidden!\r\n\r\n')
            else:
                print '- No X-Real-Host!'
                self.client.send('HTTP/1.1 400 NoXRealHost!\r\n\r\n')
        except Exception as e:
            self.log += ' - error: ' + e.strerror
            self.server.printLog(self.log)
	    pass
        finally:
            self.close()
            self.server.removeConn(self)
    def findHeader(self, head, header):
        aux = head.find(header + ': ')
        if aux == -1:
            return ''
        aux = head.find(':', aux)
        head = head[aux+2:]
        aux = head.find('\r\n')
        if aux == -1:
            return ''
        return head[:aux];
    def connect_target(self, host):
        i = host.find(':')
        if i != -1:
            port = int(host[i+1:])
            host = host[:i]
        else:
            if self.method=='CONNECT':
            	
                port = 443
            else:
                port = 80
                port = 8080
                port = 8799
                port = 3128
        (soc_family, soc_type, proto, _, address) = socket.getaddrinfo(host, port)[0]
        self.target = socket.socket(soc_family, soc_type, proto)
        self.targetClosed = False
        self.target.connect(address)
    def method_CONNECT(self, path):
        self.log += ' - CONNECT ' + path
        self.connect_target(path)
        self.client.sendall(RESPONSE)
        self.client_buffer = ''
        self.server.printLog(self.log)
        self.doCONNECT()
    def doCONNECT(self):
        socs = [self.client, self.target]
        count = 0
        error = False
        while True:
            count += 1
            (recv, _, err) = select.select(socs, [], socs, 3)
            if err:
                error = True
            if recv:
                for in_ in recv:
		    try:
                        data = in_.recv(BUFLEN)
                        if data:
			    if in_ is self.target:
				self.client.send(data)
                            else:
                                while data:
                                    byte = self.target.send(data)
                                    data = data[byte:]
                            count = 0
			else:
			    break
		    except:
                        error = True
                        break
            if count == TIMEOUT:
                error = True
            if error:
                break
def main(host=LISTENING_ADDR, port=LISTENING_PORT):
    print "\n:-------PythonProxy-------:\n"
    print "Listening addr: " + LISTENING_ADDR
    print "Listening port: " + str(LISTENING_PORT) + "\n"
    print ":-------------------------:\n"
    server = Server(LISTENING_ADDR, LISTENING_PORT)
    server.start()
    while True:
        try:
            time.sleep(2)
        except KeyboardInterrupt:
            print 'Stopping...'
            server.close()
            break
if __name__ == '__main__':
    main()
CPM
    ) >$HOME/proxy.log &

    chmod +x /etc/VPS-MX/protocolos/PDirect.py
    screen -dmS ws$porta_socket python ${SCPinst}/PDirect.py $porta_socket $texto_soket >/root/proxy.log &
    #screen -dmS pydic-"$porta_socket" python ${SCPinst}/PDirect.py "$porta_socket" "$texto_soket" && echo ""$porta_socket" "$texto_soket"" >> /etc/VPS-MX/PortPD.log

    echo "$porta_socket $texto_soket" >/etc/VPS-MX/PortPD.log
    [[ $(grep -wc "PDirect.py" /etc/autostart) = '0' ]] && {
        echo -e "netstat -tlpn | grep -w $porta_socket > /dev/null || {  screen -r -S 'ws$porta_socket' -X quit;  screen -dmS ws$porta_socket python ${SCPinst}/PDirect.py $porta_socket $texto_soket; }" >>/etc/autostart
    } || {
        sed -i '/PDirect.py/d' /etc/autostart
        echo -e "netstat -tlpn | grep -w $porta_socket > /dev/null || {  screen -r -S 'ws$porta_socket' -X quit;  screen -dmS ws$porta_socket python ${SCPinst}/PDirect.py $porta_socket $texto_soket; }" >>/etc/autostart
    }

}

pythontest() {
    clear
    echo ""
    echo ""
    msg -tit
    msg -bar
    echo -e "\033[1;31m  SOCKS DIRECTO-PY | CUSTOM\033[0m"
    while true; do
        msg -bar
        echo -ne "\033[1;37m"
        read -p " ESCRIBE SU PUERTO: " porta_socket
        echo -e ""
        [[ $(mportas | grep -w "$porta_socket") ]] || break
        echo -e " ESTE PUERTO YA ESTÁ EN USO"
        unset porta_socket
    done
    msg -bar
    echo -e "\033[1;97m Digite Un Puerto Local 22|443|80\033[1;37m"
    msg -bar
    while true; do
        echo -ne "\033[1;36m"
        read -p " Digite Un Puerto SSH/DROPBEAR activo: " PORTLOC
        echo -e ""
        if [[ ! -z $PORTLOC ]]; then
            if [[ $(echo $PORTLOC | grep [0-9]) ]]; then
                [[ $(mportas | grep $PORTLOC | head -1) ]] && break || echo -e "ESTE PUERTO NO EXISTE"
            fi
        fi
    done
    #
    puertoantla="$(mportas | grep $PORTLOC | awk '{print $2}' | head -1)"
    msg -bar
    echo -ne " Escribe El HTTP Response? 101|200|300: \033[1;37m" && read cabezado
    tput cuu1 && tput dl1
    if [[ -z $cabezado ]]; then
        cabezado="200"
        echo -e "	\e[31mResponse Default:\033[1;32m ${cabezado}"
    else
        echo -e "	\e[31mResponse Elegido:\033[1;32m ${cabezado}"
    fi
    msg -bar
    echo -e "$(fun_trans "Introdusca su Mini-Banner")"
    msg -bar
    echo -ne " Introduzca el texto de estado plano o en HTML:\n \033[1;37m" && read texto_soket
    tput cuu1 && tput dl1
    if [[ -z $texto_soket ]]; then
        texto_soket="@lacasitamx"
        echo -e "	\e[31mMensage Default: \033[1;32m${texto_soket} "
    else
        echo -e "	\e[31mMensage: \033[1;32m ${texto_soket}"
    fi
    msg -bar

    (
        less <<CPM >/etc/VPS-MX/protocolos/python.py
import socket, threading, thread, select, signal, sys, time, getopt

# Listen
LISTENING_ADDR = '0.0.0.0'
LISTENING_PORT = int("$porta_socket")
PASS = ''

# CONST
BUFLEN = 4096 * 4
TIMEOUT = 60
DEFAULT_HOST = '127.0.0.1:$puertoantla'
RESPONSE = 'HTTP/1.1 $cabezado <strong>$texto_soket</strong>\r\n\r\nHTTP/1.1 $cabezado Conexion Exitosa\r\n\r\n'

class Server(threading.Thread):
    def __init__(self, host, port):
        threading.Thread.__init__(self)
        self.running = False
        self.host = host
        self.port = port
        self.threads = []
        self.threadsLock = threading.Lock()
        self.logLock = threading.Lock()
    def run(self):
        self.soc = socket.socket(socket.AF_INET)
        self.soc.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        self.soc.settimeout(2)
        self.soc.bind((self.host, self.port))
        self.soc.listen(0)
        self.running = True
        try:
            while self.running:
                try:
                    c, addr = self.soc.accept()
                    c.setblocking(1)
                except socket.timeout:
                    continue
                conn = ConnectionHandler(c, self, addr)
                conn.start()
                self.addConn(conn)
        finally:
            self.running = False
            self.soc.close()
    def printLog(self, log):
        self.logLock.acquire()
        print log
        self.logLock.release()
    def addConn(self, conn):
        try:
            self.threadsLock.acquire()
            if self.running:
                self.threads.append(conn)
        finally:
            self.threadsLock.release()
    def removeConn(self, conn):
        try:
            self.threadsLock.acquire()
            self.threads.remove(conn)
        finally:
            self.threadsLock.release()
    def close(self):
        try:
            self.running = False
            self.threadsLock.acquire()
            threads = list(self.threads)
            for c in threads:
                c.close()
        finally:
            self.threadsLock.release()
class ConnectionHandler(threading.Thread):
    def __init__(self, socClient, server, addr):
        threading.Thread.__init__(self)
        self.clientClosed = False
        self.targetClosed = True
        self.client = socClient
        self.client_buffer = ''
        self.server = server
        self.log = 'Connection: ' + str(addr)
    def close(self):
        try:
            if not self.clientClosed:
                self.client.shutdown(socket.SHUT_RDWR)
                self.client.close()
        except:
            pass
        finally:
            self.clientClosed = True
        try:
            if not self.targetClosed:
                self.target.shutdown(socket.SHUT_RDWR)
                self.target.close()
        except:
            pass
        finally:
            self.targetClosed = True
    def run(self):
        try:
            self.client_buffer = self.client.recv(BUFLEN)
            hostPort = self.findHeader(self.client_buffer, 'X-Real-Host')
            if hostPort == '':
                hostPort = DEFAULT_HOST
            split = self.findHeader(self.client_buffer, 'X-Split')
            if split != '':
                self.client.recv(BUFLEN)
            if hostPort != '':
                passwd = self.findHeader(self.client_buffer, 'X-Pass')
				
                if len(PASS) != 0 and passwd == PASS:
                    self.method_CONNECT(hostPort)
                elif len(PASS) != 0 and passwd != PASS:
                    self.client.send('HTTP/1.1 400 WrongPass!\r\n\r\n')
                elif hostPort.startswith('127.0.0.1') or hostPort.startswith('localhost'):
                    self.method_CONNECT(hostPort)
                else:
                    self.client.send('HTTP/1.1 403 Forbidden!\r\n\r\n')
            else:
                print '- No X-Real-Host!'
                self.client.send('HTTP/1.1 400 NoXRealHost!\r\n\r\n')
        except Exception as e:
            self.log += ' - error: ' + e.strerror
            self.server.printLog(self.log)
	    pass
        finally:
            self.close()
            self.server.removeConn(self)
    def findHeader(self, head, header):
        aux = head.find(header + ': ')
        if aux == -1:
            return ''
        aux = head.find(':', aux)
        head = head[aux+2:]
        aux = head.find('\r\n')
        if aux == -1:
            return ''
        return head[:aux];
    def connect_target(self, host):
        i = host.find(':')
        if i != -1:
            port = int(host[i+1:])
            host = host[:i]
        else:
            if self.method=='CONNECT':
            	
                port = 443
            else:
                port = 80
                port = 8080
                port = 8799
                port = 3128
        (soc_family, soc_type, proto, _, address) = socket.getaddrinfo(host, port)[0]
        self.target = socket.socket(soc_family, soc_type, proto)
        self.targetClosed = False
        self.target.connect(address)
    def method_CONNECT(self, path):
        self.log += ' - CONNECT ' + path
        self.connect_target(path)
        self.client.sendall(RESPONSE)
        self.client_buffer = ''
        self.server.printLog(self.log)
        self.doCONNECT()
    def doCONNECT(self):
        socs = [self.client, self.target]
        count = 0
        error = False
        while True:
            count += 1
            (recv, _, err) = select.select(socs, [], socs, 3)
            if err:
                error = True
            if recv:
                for in_ in recv:
		    try:
                        data = in_.recv(BUFLEN)
                        if data:
			    if in_ is self.target:
				self.client.send(data)
                            else:
                                while data:
                                    byte = self.target.send(data)
                                    data = data[byte:]
                            count = 0
			else:
			    break
		    except:
                        error = True
                        break
            if count == TIMEOUT:
                error = True
            if error:
                break
def main(host=LISTENING_ADDR, port=LISTENING_PORT):
    print "\n:-------PythonProxy-------:\n"
    print "Listening addr: " + LISTENING_ADDR
    print "Listening port: " + str(LISTENING_PORT) + "\n"
    print ":-------------------------:\n"
    server = Server(LISTENING_ADDR, LISTENING_PORT)
    server.start()
    while True:
        try:
            time.sleep(2)
        except KeyboardInterrupt:
            print 'Stopping...'
            server.close()
            break
if __name__ == '__main__':
    main()
CPM
    ) >$HOME/proxy.log &

    chmod +x /etc/VPS-MX/protocolos/python.py
    echo -e "[Unit]\nDescription=python.py Service by @lacasitamx\nAfter=network.target\nStartLimitIntervalSec=0\n\n[Service]\nType=simple\nUser=root\nWorkingDirectory=/root\nExecStart=/usr/bin/python ${SCPinst}/python.py $porta_socket $texto_soket\nRestart=always\nRestartSec=3s\n[Install]\nWantedBy=multi-user.target" >/etc/systemd/system/python.PD.service
    echo "$porta_socket $texto_soket" >/etc/VPS-MX/PortPD.log
    systemctl enable python.PD &>/dev/null
    systemctl start python.PD &>/dev/null

}

pid_kill() {
    [[ -z $1 ]] && refurn 1
    pids="$@"
    for pid in $(echo $pids); do
        kill -9 $pid &>/dev/null
    done
}
selecionador() {
    clear
    echo ""
    echo ""
    echo ""
    while true; do
        msg -bar
        echo -ne "\033[1;37m"
        read -p " ESCRIBE SU PUERTO: " porta_socket
        echo -e ""
        [[ $(mportas | grep -w "$porta_socket") ]] || break
        echo -e " ESTE PUERTO YA ESTÁ EN USO"
        unset porta_socket
    done
    echo -e "Introdusca su Mini-Banner"
    msg -bar
    echo -ne "Introduzca el texto de estado plano o en HTML:\n \033[1;37m" && read texto_soket
    msg -bar
}
remove_fun() {
    echo -e "Parando Socks Python"
    msg -bar
    pidproxy=$(ps x | grep "PPub.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy ]] && pid_kill $pidproxy
    pidproxy2=$(ps x | grep "PPriv.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy2 ]] && pid_kill $pidproxy2
    pidproxy3=$(ps x | grep "PDirect.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy3 ]] && pid_kill $pidproxy3
    pidproxy4=$(ps x | grep "POpen.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy4 ]] && pid_kill $pidproxy4
    pidproxy5=$(ps x | grep "PGet.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy5 ]] && pid_kill $pidproxy5
    pidproxy6=$(ps x | grep "scktcheck" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy6 ]] && pid_kill $pidproxy6
    pidproxy7=$(ps x | grep "python.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy7 ]] && pid_kill $pidproxy7
    pidproxy8=$(ps x | grep "lacasitamx.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy8 ]] && pid_kill $pidproxy8
    echo -e "\033[1;91mSocks DETENIDOS"
    msg -bar
    rm /etc/VPS-MX/PortPD.log &>/dev/null
    echo "" >/etc/VPS-MX/PortPD.log

    for pidproxy in $(screen -ls | grep ".ws" | awk {'print $1'}); do
        screen -r -S "$pidproxy" -X quit
    done
    [[ $(grep -wc "PDirect.py" /etc/autostart) != '0' ]] && {
        sed -i '/PDirect.py/d' /etc/autostart
    }
    sleep 1
    screen -wipe >/dev/null
    systemctl stop python.PD &>/dev/null
    systemctl disable python.PD &>/dev/null
    rm /etc/systemd/system/python.PD.service &>/dev/null
    exit 0
}
iniciarsocks() {
    pidproxy=$(ps x | grep -w "PPub.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy ]] && P1="\033[1;32m[ON]" || P1="\e[37m[\033[1;31mOFF\e[37m]"
    pidproxy2=$(ps x | grep -w "PPriv.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy2 ]] && P2="\033[1;32m[ON]" || P2="\e[37m[\033[1;31mOFF\e[37m]"
    pidproxy3=$(ps x | grep -w "PDirect.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy3 ]] && P3="\033[1;32m[ON]" || P3="\e[37m[\033[1;31mOFF\e[37m]"
    pidproxy4=$(ps x | grep -w "POpen.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy4 ]] && P4="\033[1;32m[ON]" || P4="\e[37m[\033[1;31mOFF\e[37m]"

    pidproxy5=$(ps x | grep "PGet.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy5 ]] && P5="\033[1;32m[ON]" || P5="\e[37m[\033[1;31mOFF\e[37m]"
    pidproxy6=$(ps x | grep "scktcheck" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy6 ]] && P6="\033[1;32m[ON]" || P6="\e[37m[\033[1;31mOFF\e[37m]"
    pidproxy7=$(ps x | grep "python.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy7 ]] && P7="\033[1;32m[ON]" || P7="\e[37m[\033[1;31mOFF\e[37m]"
    pidproxy8=$(ps x | grep "python.py" | grep -v "grep" | awk -F "pts" '{print $1}') && [[ ! -z $pidproxy8 ]] && P8="\033[1;32m[ON]" || P8="\e[37m[\033[1;31mOFF\e[37m]"

    #msg -bar
    msg -tit
    msg -bar
    echo -e "   	\e[91m\e[43mINSTALADOR DE PROXY'S\e[0m "
    msg -bar
    echo -e " \e[1;93m[\e[92m1\e[93m] \e[97m$(msg -verm2 "➛ ")\033[1;97mProxy Python SIMPLE      $P1"
    echo -e " \e[1;93m[\e[92m2\e[93m] \e[97m$(msg -verm2 "➛ ")\033[1;97mProxy Python SEGURO      $P2"
    echo -e " \e[1;93m[\e[92m3\e[93m] \e[97m$(msg -verm2 "➛ ")\033[1;97mProxy WEBSOCKET Custom   $P3 \e[1;32m(Screen TEST)"
    echo -e " \e[1;93m[\e[92m4\e[93m] \e[97m$(msg -verm2 "➛ ")\033[1;97mProxy WEBSOCKET Custom   $P7 \e[1;32m(Socks HTTP)"
    echo -e " \e[1;93m[\e[92m5\e[93m] \e[97m$(msg -verm2 "➛ ")\033[1;97mProxy Python OPENVPN     $P4"
    echo -e " \e[1;93m[\e[92m6\e[93m] \e[97m$(msg -verm2 "➛ ")\033[1;97mProxy Python GETTUNEL    $P5"
    echo -e " \e[1;93m[\e[92m7\e[93m] \e[97m$(msg -verm2 "➛ ")\033[1;97mProxy Python TCP BYPASS  $P6"
    echo -e " \e[1;93m[\e[92m8\e[93m] \e[97m$(msg -verm2 "➛ ")\033[1;97mAplicar Fix en \e[1;32m(Ubu22 o Debian11 )"
    echo -e " \e[1;93m[\e[92m9\e[93m] \e[97m$(msg -verm2 "➛ ")\033[1;97mDETENER SERVICIO PYTHON"
    msg -bar
    echo -e " \e[1;93m[\e[92m0\e[93m] \e[97m$(msg -verm2 "➛ ") \e[97m\033[1;41m VOLVER \033[1;37m"
    msg -bar
    IP=(meu_ip)
    while [[ -z $portproxy || $portproxy != @(0|[1-9]) ]]; do
        echo -ne " Digite Una Opcion: \033[1;37m" && read portproxy
        tput cuu1 && tput dl1
    done
    case $portproxy in
    1)
        selecionador
        screen -dmS screen python ${SCPinst}/PPub.py "$porta_socket" "$texto_soket"
        ;;
    2)
        selecionador
        screen -dmS screen python3 ${SCPinst}/PPriv.py "$porta_socket" "$texto_soket" "$IP"
        ;;
    3)
        PIDI="$(ps aux | grep -v grep | grep "ws")"
        if [[ -z $PIDI ]]; then
            sistema20
            PythonDic_fun
        else
            for pidproxy in $(screen -ls | grep ".ws" | awk {'print $1'}); do
                screen -r -S "$pidproxy" -X quit
            done
            [[ $(grep -wc "PDirect.py" /etc/autostart) != '0' ]] && {
                sed -i '/PDirect.py/d' /etc/autostart
            }
            sleep 1
            screen -wipe >/dev/null
            msg -bar
            echo -e "\033[1;91mSocks Directo DETENIDO"
            msg -bar
            exit 0
        fi
        ;;
    4)
        if [[ ! -e /etc/systemd/system/python.PD.service ]]; then
            sistema20
            pythontest
        else
            systemctl stop python.PD &>/dev/null
            systemctl disable python.PD &>/dev/null
            rm /etc/systemd/system/python.PD.service &>/dev/null

            msg -bar
            echo -e "\033[1;91mSocks Directo DETENIDO"
            msg -bar
            exit 0
        fi
        ;;
    5)
        selecionador
        screen -dmS screen python ${SCPinst}/POpen.py "$porta_socket" "$texto_soket"
        ;;
    6)
        selecionador
        gettunel_fun "$porta_socket"
        ;;
    7)
        selecionador
        tcpbypass_fun "$porta_socket" "$texto_soket"
        ;;
    8)
        sistema22
        msg -bar
        msg -ama " AHORA REGRESA EN LA OPCION 3 DE SOCKS HTTP"
        msg -bar

        ;;
    9) remove_fun ;;
    0) return ;;
    esac
    echo -e "\033[1;92mProcedimiento COMPLETO"
    msg -bar
}
iniciarsocks