import socket
import urllib2
import threading
import sys
import Queue
import socket

socket.setdefaulttimeout(7)

print "Bobng's proxy checker. Using %s second timeout"%(socket.getdefaulttimeout())

#input_file = sys.argv[1]
#proxy_type = sys.argv[2] #options: http,s4,s5
#output_file = sys.argv[3]
input_file = 'proxylist.txt'
proxy_type = 'http'
output_file = 'proxy_alive.txt'

url = "www.seemyip.com" # Don't put http:// in here, or any /'s

check_queue = Queue.Queue()
output_queue = Queue.Queue()
threads = 20

def writer(f,rq):
    while True:
        line = rq.get()
        f.write(line+'\n')

def checker(q,oq):
    while True:
        proxy_info = q.get() #ip:port
        if proxy_info == None:
            print "Finished"
            #quit()
            return
        #print "Checking %s"%proxy_info
        if proxy_type == 'http':
            try:

                listhandle = open("proxylist.txt").read().split('\n')

                for line in listhandle:
                    saveAlive = open("proxy_alive.txt", 'a')

                    details = line.split(':')
                    email = details[0]
                    password = details[1].replace('\n', '')


                    proxy_handler = urllib2.ProxyHandler({'http':proxy_info})
                    opener = urllib2.build_opener(proxy_handler)
                    opener.addheaders = [('User-agent','Mozilla/5.0')]
                    urllib2.install_opener(opener)
                    req = urllib2.Request("http://www.google.com")
                    sock=urllib2.urlopen(req, timeout= 7)
                    rs = sock.read(1000)
                    if '<title>Google</title>' in rs:
                        oq.put(proxy_info)
                        print '[+] alive proxy' , proxy_info
                        saveAlive.write(line)
                saveAlive.close()
            except urllib2.HTTPError,e:
                print 'url open error? slow?'
                pass
            except Exception,detail:
                print '[-] bad proxy' ,proxy_info

        else:
            # gotta be socks
            try:
                s = socks.socksocket()
                if proxy_type == "s4":
                    t = socks.PROXY_TYPE_SOCKS4
                else:
                    t = socks.PROXY_TYPE_SOCKS5
                ip,port = proxy_info.split(':')
                s.setproxy(t,ip,int(port))
                s.connect((url,80))
                oq.put(proxy_info)
                print proxy_info
            except Exception,error:
                print proxy_info
# Building the input_queue
for line in open(input_file).readlines():
    check_queue.put(line.strip('\n'))
print "File reading done"
#Building the output queue
for i in xrange(threads):
    threading.Thread(target=checker,args=(check_queue,output_queue)).start()
#Writing the output queue to the file
threading.Thread(target=writer,args=(open(output_file,"wb"),output_queue)).start()
raw_input("PRESS ENTER TO QUIT")
sys.exit(0)