package mertero.coinapi;

import java.sql.ResultSet;
import java.sql.SQLException;

import org.bukkit.Bukkit;
import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.AsyncPlayerPreLoginEvent;
import org.bukkit.plugin.java.JavaPlugin;


public class CoinsAPI extends JavaPlugin implements Listener {


	public static CoinsAPI coinsapi;
	public static MySQL mysql;


	public void onEnable() {
		Bukkit.getPluginManager().registerEvents(this, this);
		loadConfig();
		ConnectMySQL();
	}

	public void onDisable(){
		mysql.close();
	}

	public void loadConfig() {
		FileConfiguration cfg = this.getConfig();
		cfg.addDefault("mysql.default", "true");
		String msg = cfg.getString("mysql.default");
		if(msg == "true"){
			cfg.addDefault("mysql.host", "LOCALHOST");
            cfg.addDefault("mysql.database", "DATABASE");
            cfg.addDefault("mysql.user", "USER");
            cfg.addDefault("mysql.password", "PASSWORD");
            cfg.options().copyDefaults(true);
            saveConfig();
		} else {
			cfg.options().copyDefaults(false);
			saveConfig();
		}




	}

	private void ConnectMySQL() {
	        FileConfiguration mcfg = this.getConfig();
            String host = mcfg.getString("mysql.host");
            String database = mcfg.getString("mysql.database");
            String user = mcfg.getString("mysql.user");
            String password = mcfg.getString("mysql.password");
            mysql = new MySQL(host, database, user, password);
            mysql.connect();
            mysql.update("CREATE TABLE IF NOT EXISTS coins(name varchar(100) UNIQUE, coins int)");
     }

	public static int getCoins(String name) {

		ResultSet rs = CoinsAPI.mysql.query("SELECT coins FROM coins WHERE name = '" + name + "' LIMIT 1");

		try {
			while (rs.next()){
			return rs.getInt("coins"); }
		} catch (SQLException e) {
		}
		return -1;
	}

	public static void setCoins(String name, int amount) {
		CoinsAPI.mysql.update("UPDATE coins SET coins = " + amount + " WHERE name = '" + name + "'");
	}


	public static boolean isRegistered(String name) {

		ResultSet rs = CoinsAPI.mysql.query("SELECT * FROM coins WHERE name = '" + name + "' LIMIT 1");
		System.out.println(rs == null);
		try {
			return rs.next();
		} catch (SQLException e) {
		}
		return false;
	}

	public static void register(String name) {
		CoinsAPI.mysql.update("INSERT INTO coins (name, coins) VALUES ('" + name + "', 0)");

	}

	@EventHandler
	public void onJoin(AsyncPlayerPreLoginEvent e) {
		if (!isRegistered(e.getName())) {
			register(e.getName());
		}


	}

}