package me.xikeon.OpenAccount;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.logging.Logger;

import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.event.Event;
import org.bukkit.plugin.PluginManager;
import org.bukkit.plugin.java.JavaPlugin;

public class OpenAccount extends JavaPlugin {
    Logger log = Logger.getLogger("Minecraft");
    PluginManager pm = null;
    private final OpenAccountPlayerListener playerListener = new OpenAccountPlayerListener(this);
    protected FileConfiguration config;

    boolean isEnabled;

    Connection conn = null;

    private OpenAccountCommandExecutorOpencraft ExecutorOpencraft;
    private OpenAccountCommandExecutorOcpassword ExecutorOcpassword;
    @Override
    public void onEnable() {
        log.info("OpenAccount has been enabled!");

        pm = getServer().getPluginManager();
        config = getConfig();
        if (!config.contains("enabled")) {
            config.set("enabled", false);
            config.set("mysql.host", "localhost");
            config.set("mysql.database", "default");
            config.set("mysql.username", "root");
            config.set("mysql.password", "pwd");
            saveConfig();
        }

        boolean isEnabled = config.getBoolean("enabled", false);

        if (isEnabled) {
            init();
        } else {
            log.info("OpenAccount commands not set, config has disabled plugin.");
        }
    }

    public void onDisable() {
        //saveConfig();
        // save causes changes to be deleted when doing reload..
        if (conn != null)
        {
            try
            {
                conn.close ();
            }
            catch (Exception e) { }
        }
        log.info("OpenAccount has been disabled.");
    }

    public void init() {
        initMySQL();
        initEvents();
        initcommands();
    }

    public void initEvents() {
        pm.registerEvent(Event.Type.PLAYER_JOIN, playerListener, Event.Priority.Normal, this);
    }

    public void initcommands() {
        ExecutorOpencraft = new OpenAccountCommandExecutorOpencraft(this);
        ExecutorOcpassword = new OpenAccountCommandExecutorOcpassword(this);
        getCommand("opencraft").setExecutor(ExecutorOpencraft);
        getCommand("ocpassword").setExecutor(ExecutorOcpassword);
    }

    public void initMySQL() {
        try {
            Class.forName("com.mysql.jdbc.Driver").newInstance();
            conn = DriverManager.getConnection(
                "jdbc:mysql://" + config.getString("mysql.host") + "/" + config.getString("mysql.database"),
                config.getString("mysql.username"),
                config.getString("mysql.password", "")
            );
        } catch (Exception e) {
            log.info("MySQL failed!");
        }

        if (conn != null) {
            Statement s = null;
            try {
                s = conn.createStatement();
                s.executeUpdate(
                    "CREATE TABLE IF NOT EXISTS users ("
                    + "username CHAR(40) NOT NULL,"
                    + "PRIMARY KEY (username),"
                    + "password CHAR(100))"
                );
            } catch (SQLException e) {
                log.info(e.getMessage().toString());
                log.info("Error creating table...");
            } finally {
                if (s != null) {
                    try
                    {
                        s.close();
                    } catch (Exception e) { }
                }
            }
        }
    }
}