import os
import time
import frida
from frida.application import Reactor
import sys
import threading

jscode = """
'use strict';

var username;
var password;

function main() {
    console.log("Username: " + username);
    console.log("Password: " + password);
}

rpc.exports = {
    login: function (username, password) {
        this.username = username;
        this.password = password;
    }
};

setImmediate(main);

"""

device = frida.get_usb_device()

while True:
    package_name = 'com.tinder'
    script = None

    done = threading.Event()

    def wait_for_done(reactor):
        done.wait()

    reactor = Reactor(wait_for_done)
    def on_message(message, data):
        if message['type'] == 'send':
            if message['payload']['type'] == 'done':
                print("Done!")
                time.sleep(3)
                done.set()
            elif message['payload']['type'] == 'timedout':
                print("TIMEDOUT!")
                time.sleep(3)
                done.set()
        else:
            print(message)
    try:
        device.kill(package_name)
    except:
        pass
    try:
        os.system("adb shell pm clear " + package_name)
        input = [package_name]
        pid = device.spawn(input)
        time.sleep(5)
        session = device.attach(pid)
        script = session.create_script(jscode)
        device.resume(pid)
        reactor.schedule(lambda: script.on('message', on_message)),
        script.load()
        print('[*] Starting reactor')
        script.exports.login("test@gmail.com", "a12345678")
        reactor.run()
        session.detach()
    except:
        pass
    count = count + 1
    print("Total loops: " + str(count))
    time.sleep(7)
    print("DONE")
    print("---------------------------------------------")