package fr.jsonarray.skyhandreward;

import fr.jsonarray.skyhandreward.commands.SkyHandRewardCommands;
import fr.jsonarray.skyhandreward.configurations.PlayerDataConfiguration;
import fr.jsonarray.skyhandreward.data.RewardData;
import fr.jsonarray.skyhandreward.data.SHRPlayer;
import fr.jsonarray.skyhandreward.listeners.PlayerListeners;
import fr.jsonarray.skyhandreward.runnable.SkyHandRewardRunnable;
import fr.jsonarray.skyhandreward.sql.PlayerDataSQL;
import fr.jsonarray.skyhandreward.sql.SQLConnection;
import fr.jsonarray.skyhandreward.utils.FileManager;
import org.bukkit.Bukkit;
import org.bukkit.entity.Player;
import org.bukkit.plugin.java.JavaPlugin;

import java.util.Arrays;

public class SkyHandReward extends JavaPlugin {

    private static SkyHandReward instance;
    public FileManager fileManager;
    public SQLConnection sqlConnection;

    public void onEnable() {
        instance = this;
        fileManager = new FileManager(this);
        sqlConnection = new SQLConnection();

        registerListeners();

        PlayerDataConfiguration.setupConfig();
        getConfig().options().copyDefaults(false);
        saveDefaultConfig();

        setConfigType();

        getCommand("SkyHandReward").setExecutor(new SkyHandRewardCommands());
        getCommand("SkyHandReward").setAliases(Arrays.asList("shr"));

        setupPlayers();
        RewardData.loadRewardData();
        connectDatabase();

        new SkyHandRewardRunnable().runTaskTimer(this, 20, 20);

        System.out.println("SkyHandReward > Enabled !");
    }

    public void onDisable() {
        Bukkit.getScheduler().cancelTasks(this);
        RewardData.getRewardData().clear();


        for (Player pls : Bukkit.getOnlinePlayers()) {
            SHRPlayer.get(pls).saveData();
        }


        PlayerDataConfiguration.getDataConfig().reload();
        PlayerDataConfiguration.getDataConfig().save();

        saveDefaultConfig();
        disconnectDatabase();
        System.out.println("SkyHandReward > Disabled !");
    }

    public void setupPlayers() {
        for (Player pls : Bukkit.getOnlinePlayers()) {
            SHRPlayer shrPlayer = SHRPlayer.get(pls);
            shrPlayer.createAccount();
            shrPlayer.loadData();
        }
    }

    private void registerListeners() {
        Bukkit.getPluginManager().registerEvents(new PlayerListeners(), this);
    }

    private void setConfigType() {
        if (getConfig().getBoolean("mysql.enabled") == true) {
            CacheType.setType(CacheType.MYSQL);
            System.out.println("SkyHandReward is using MySQL configuration.");
            try {
                sqlConnection.playersql = new PlayerDataSQL("jdbc:mysql://", getConfig().getString("mysql.hostname"), getConfig().getString("mysql.database"), getConfig().getString("mysql.username"),
                        getConfig().getString("mysql.password"), getConfig().getString("mysql.playerstable"));
                sqlConnection.playersql.createTable();
            } catch (Exception e) {
                System.out.println("[WARNING] DATABASE CONNECTION > FAILED !");
            }
        }
        if (getConfig().getBoolean("mysql.enabled") == false) {
            CacheType.setType(CacheType.YAML);
            System.out.println("SkyHandReward is using YAML configuration.");
        }
    }


    public void connectDatabase() {
        if (CacheType.isType(CacheType.MYSQL)) {
            sqlConnection.connection();
        }
    }

    public void disconnectDatabase() {
        if (CacheType.isType(CacheType.MYSQL)) {
            sqlConnection.disconnect();
        }
    }


    public static SkyHandReward get() {
        return instance;
    }
}