package fr.enoviah.brumalore;

import org.bukkit.Bukkit;
import org.bukkit.command.CommandExecutor;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.PlayerInteractEntityEvent;
import org.bukkit.plugin.java.JavaPlugin;

import java.sql.*;
import java.util.UUID;
import java.util.logging.Level;
import java.util.logging.Logger;

public final class Brumalore extends JavaPlugin implements Listener, CommandExecutor {

    public static Brumalore instance;

    Connection con = null;
    Statement st = null;
    ResultSet rs = null;

    String url = "jdbc:mysql://ssh.enoviah.fr:3306/burmazur";
    String user = "testorder";
    String password = "abcdabcd";

    public static Brumalore getInstance() {
        return (instance);
    }

    @Override
    public void onEnable() {
        this.instance = this;
        this.getLogger().info("Enabled.");
        Bukkit.getServer().getPluginManager().registerEvents(this, this);
        getCommand("lore").setExecutor(new CommandLore());
        initConnector();
    }

    @Override
    public void onDisable() {
        this.getLogger().info("Disabled.");
    }

    @EventHandler
    public void PlayerRightClick(PlayerInteractEntityEvent event) {
        if (event.getRightClicked() instanceof Player) {
            Player clicked = (Player) event.getRightClicked();
            printLore(event.getRightClicked().getUniqueId(), event.getPlayer());
        }
    }

    public void createLore(String lore, UUID uuid) {
        try {
            lore = lore.replaceAll("&", "§");
            if (isPresent(uuid.toString()) == false) {
                st.executeUpdate("INSERT INTO `burmazur`.`brumalore` (`UUID`, `lore`) VALUES (\"" + uuid.toString() + "\",\"" + lore + "\")");
            } else
                st.executeUpdate("UPDATE `burmazur`.`brumalore` SET `lore` = \"" + lore + "\" WHERE UUID = \"" + uuid.toString() + "\"");
            initConnector();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private boolean isPresent(String uuid) {
        if (this.rs != null) {
            try {
                while (this.rs.next()) {
                    if (this.rs.getString(2).equals(uuid)) {
                        return (true);
                    }
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        try {
            this.rs.beforeFirst();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return (false);
    }

    private void initConnector() {
        try {
            // table : brumalore ; content : (String UUID, String Text)
            con = DriverManager.getConnection(url, user, password);
            st = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                    ResultSet.CONCUR_READ_ONLY);
            rs = st.executeQuery("SELECT * FROM brumalore");
        } catch (SQLException ex) {
            Logger lgr = this.getLogger();
            lgr.log(Level.SEVERE, ex.getMessage(), ex);
        }
    }

    private void printLore(UUID uuid, Player p) {
        boolean sended = false;
        if (this.rs != null) {
            try {
                while (this.rs.next()) {
                    if (this.rs.getString(2).equals(uuid.toString())) {
                        p.sendMessage(this.rs.getString(3));
                        sended = true;
                        break;
                    }
                }

                if (!sended)
                    p.sendMessage("No Lore.");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        try {
            this.rs.beforeFirst();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}