import org.osbot.rs07.listener.LoginResponseCodeListener;
import org.osbot.rs07.script.Script;
import org.osbot.rs07.script.ScriptManifest;
import util.LoginEvent;

import java.sql.*;

@ScriptManifest(author = "Sibbernski", name = "sibbernskiAccountLocker", info = "hekkoi", version = 0.1, logo = "")

public class sibbernskiLocker extends Script implements LoginResponseCodeListener {

    private boolean locked = false;

    private String[] params;
    private String username;
    private String password;
    private String proxyId;
    private LoginEvent loginEvent;


    @Override
    public void onStart() {
        params = getParameters().split("/");
        username = params[0];
        password = params[1];
        proxyId = params[2];
        loginEvent = new LoginEvent(username, password);
        execute(loginEvent);
    }

    @Override
    public int onLoop() throws InterruptedException {
        if (!client.isLoggedIn()) {
            execute(loginEvent);
        } else {
            updateJobStatus();
            if (locked) {
                this.stop(true);
                System.exit(0);
            }
        }
        return 0;
    }

    private void updateJobStatus() {
        try {
            String host = "localhost:3306";
            String db = "muling";
            String user = "root";
            String pass = "";
            String connStr = String.format("jdbc:mysql://%s/%s?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC", host, db);
            Connection conn = DriverManager.getConnection(connStr, user, pass);
            ResultSet result = conn.createStatement().executeQuery("SELECT * FROM newaccs WHERE AccountName='" + username + "'");
            if (result.next()) {
                String query = "UPDATE newaccs set AccountLocked='yes' WHERE AccountName='" + username + "'";
                PreparedStatement preparedStmt = conn.prepareStatement(query);
                preparedStmt.executeUpdate();
                log("Account was locked, updated db.");
                locked = true;
            }
        } catch (SQLException e) {
            log(e);
        }
    }

    @Override
    public final void onResponseCode(final int responseCode) throws InterruptedException {

        log("test");

        switch (responseCode){
            case 1:
                log("something");
                break;
            case 18:
                log("something");
                break;
        }

    }


}