package com.rickert.atm;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;

import org.bukkit.Bukkit;
import org.bukkit.OfflinePlayer;
import org.bukkit.plugin.PluginManager;
import org.bukkit.plugin.java.JavaPlugin;

import com.rickert.atm.commands.Commands;
import com.rickert.atm.database.PlayerData;
import com.rickert.atm.events.InventoryClick;
import com.rickert.atm.events.PlayerInteract;
import com.rickert.atm.events.PlayerJoin;
import com.rickert.atm.sql.Tables;
import com.rickert.atm.utils.MessageFile;

public class Main extends JavaPlugin {

	private static Main plugin;

	private static Connection c;
	private String host, database, username, password;
	private int port;

	private static Map<UUID, PlayerData> playerdata = new HashMap<UUID, PlayerData>();
	private static List<UUID> registeredPlayers = new ArrayList<UUID>();

	public void onEnable() {
		plugin = this;

		registerConfig();

		System.out.println("------------------------------");
		System.out.println(" ATM Plugin Enabled");
		System.out.println(" Version 1.0");
		System.out.println(" Made by Rickert");
		System.out.println("------------------------------");

		host = "";
		port = 3306;
		database = "";
		username = "";
		password = "";

		try {
			openConnection();
			Tables.TablePlayerData();
		} catch (SQLException | ClassNotFoundException e) {
			e.printStackTrace();
		}
		try {
			for (OfflinePlayer p : Bukkit.getOfflinePlayers()) {
				playerdata.put(p.getUniqueId(), new PlayerData(p));
			}
			Statement statement = c.createStatement();
			ResultSet res = statement.executeQuery("SELECT * FROM ATM_PlayerData");
			while (res.next()) {
				String uuid = res.getString("PlayerUUID");
				registeredPlayers.add(UUID.fromString(uuid));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}

		PluginManager pm = Bukkit.getPluginManager();
		pm.registerEvents(new PlayerJoin(), this);
		pm.registerEvents(new PlayerInteract(), this);
		pm.registerEvents(new InventoryClick(), this);

		getCommand("atm").setExecutor(new Commands());
	}

	public void onDisable() {

		System.out.println("------------------------------");
		System.out.println(" ATM Plugin Disabled");
		System.out.println(" Version 1.0");
		System.out.println(" Made by Rickert");
		System.out.println("------------------------------");

		for (OfflinePlayer p : Bukkit.getOfflinePlayers()) {
			playerdata.remove(p.getUniqueId()).save();
		}
	}

	public void registerConfig() {
		getConfig().options().copyDefaults(true);
		saveConfig();
		MessageFile.loadConfig();
	}

	public static Main getMain() {
		return plugin;
	}

	public static Connection getConnection() {
		return c;
	}

	public static Map<UUID, PlayerData> getPlayerData() {
		return playerdata;
	}

	public static List<UUID> getRegisteredPlayer() {
		return registeredPlayers;
	}

	private void openConnection() throws SQLException, ClassNotFoundException {
		if (c != null && !c.isClosed()) {
			return;
		}

		synchronized (this) {
			if (c != null && !c.isClosed()) {
				return;
			}
			Class.forName("com.mysql.jdbc.Driver");
			c = DriverManager.getConnection("jdbc:mysql://" + this.host + ":" + this.port + "/" + this.database,
					this.username, this.password);
		}
	}

}