package me.shawshark.votecount;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

import org.bukkit.Bukkit;
import org.bukkit.ChatColor;
import org.bukkit.command.Command;
import org.bukkit.command.CommandSender;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.PlayerJoinEvent;
import org.bukkit.plugin.java.JavaPlugin;

public class VoteCount extends JavaPlugin implements Listener {

    public static Connection con;
    public static String hostname, username, password, database;

    public void onEnable() {
        saveDefaultConfig();
        Bukkit.getPluginManager().registerEvents(this, this);

        hostname = getConfig().getString("mysql_hostname");
        username = getConfig().getString("mysql_username");
        password = getConfig().getString("mysql_password");
        database = getConfig().getString("mysql_database");

        try {
            con = DriverManager.getConnection("jdbc:mysql://" + hostname + ":3306/" + database, username, password);
        } catch (SQLException SQLException) {
            SQLException.printStackTrace();
        }

        startConnection();
    }

    public void startConnection() {
        Statement str;
           try {
                String votecount = "votecount";
                str = con.createStatement();
                String query = "CREATE TABLE IF NOT EXISTS `"+votecount+"` ("
                + "  `player` varchar(100) NOT NULL,"
                + "  `count` varchar(100) NOT NULL,"
                + "  UNIQUE KEY `player` (`player`)"
                + ") ENGINE=InnoDB DEFAULT CHARSET=latin1;";

                str.executeUpdate(query);
                str.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
    }

    @Override
    public boolean onCommand(CommandSender sender, Command command, String label, String[] args) {

        CommandSender console = sender;


        if(command.getName().equalsIgnoreCase("votecount")) {
            if(console.hasPermission("vote.count")) {
                if(args[0].equalsIgnoreCase(args[0])){
                    API.addVotes(Bukkit.getPlayer(args[0]).getUniqueId().toString().replace("-", ""), 1);
                }
            }
        }

        else if(command.getName().equalsIgnoreCase("votecheck")) {
            if(args[0].equalsIgnoreCase(args[0])) {
               sender.sendMessage(ChatColor.GOLD + "" + args[0] + " has voted " +
                       API.getVotes(Bukkit.getPlayer(args[0]).toString().replace("-", "")) + " times!");
            }
        }
        return true;
    }

    @EventHandler
    public void onPlayerJoin(PlayerJoinEvent e) throws SQLException {
        Player p = e.getPlayer();

        Statement str = con.createStatement();
        String query = String.format("INSERT IGNORE INTO "+"votecount"+" (player)VALUES('"+p.getName()+"');");
        str.executeUpdate(query);
        str.close();
    }
}