Das deutsche Python-Forum

Code: Alles auswählen

from time import sleep
import threading
import socket
from urlparse import urlparse
from random import randrange

def mkq():
	a = "123a4e56i7a890poiuaieztraeewiaqasdfghjkilmanbevcxy"
	ges = ""
	for i in range(randrange(5)+3):
		ges += a[randrange(len(a[:-1])+1)]
	return ges

def rmTwice(resp):
	resp = dict(zip(resp, resp)).keys()
	return resp

	
def filter(resp):
	index = 0
	l1 = []
	l2 = []
	urls = []
	while index is not -1:
		index = resp.find('<a class=l', index + 1)
		l1.append(index)
		l2 = []
	for i in range(len(l1)):
		index = resp.find('">', l1[i])
		l2.append(index)
	for i in range(len(l1) - 1): # spaeter nachgicken wegen den -1.......
		match = resp[l1[i]:l2[i]].replace('<a class=l href=', '').replace('"', '')
		url = urlparse(match)[1]
		urls.append(url)
	return urls

	
	
def scan(resp):
	ftps = ""
	for host in resp:
		try:
			s2 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
			s2.settimeout(1)
			s2.connect((host, 21))
			resp2 = s2.recv(128)
			print host, ":\n", resp2
			if resp2: ftps += host + ':\n' + resp2 + '\n--=000000=--\n'
		except:
			pass
	#print "writing in file..."
	f.write(ftps)

	
def google():
	global f
	f = open('ftpsLog.txt', 'a')
	while 1:
		jetzt = True
		start = 0
		B = "foobar"
		s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
		s.connect(('www.google.pl', 80))
		keyword = mkq()
		while 1:
			#print "sending google req: GET /search?num=100&start=" + str(start) + "&q=" + keyword + " HTTP/1.1"
			s.send("GET /search?num=100&start=" + str(start) + "&q=" + keyword + " HTTP/1.1\n")
			s.send('Host: www.google.pl')
			s.send('\n\n')
			start += 100
			resp = ""
			while not '</html>' in resp:
				resp += s.recv(1024)
			resp = filter(resp)
			if jetzt:
				A = resp[:20]
			else:
				B = resp[:20]
			jetzt = not jetzt
			if not A == B:
				resp = rmTwice(resp)
				#print len(resp), "hosts wurden gefunden"
				scan(resp)
			else:
				start = 0
				break
	
for i in range(1000):
	t = threading.Thread(target = google)
	t.setDaemon(1)
	t.start()
	#t.join()
	#print "thread wurde gesteratet"
	sleep(0.1)
print 'ende mit mking threads'


try:
	while 1:
		sleep(100)
except:
	f.close()