package me.ultrapvp.Main;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URL;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import org.bukkit.Bukkit;
import org.bukkit.command.Command;
import org.bukkit.command.CommandSender;
import org.bukkit.command.ConsoleCommandSender;
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 Main extends JavaPlugin implements Listener{

    public boolean containsIP(String ip) throws IOException {
    	boolean found = false;
        URL url = new URL("http://www.ipspl1.esy.es/");
        BufferedReader br = new BufferedReader(new InputStreamReader(url.openStream()));
        while (br.readLine() != null) {
			String pr = br.readLine();
        	if (pr.equalsIgnoreCase(ip)) {
				found = true;
						break;
			}
		}
        return found;
    }
	private static DB db=null;

	ConsoleCommandSender b = Bukkit.getConsoleSender();
	public void onEnable(){
		saveDefaultConfig();
		b.sendMessage("§6=-=-=-=-=-=-=-=-=-=-=-=-=-=-=");
		b.sendMessage("§a[SalvarSenha] §bativado...");
		b.sendMessage("§aCriador: §cUltra_PvP");
		b.sendMessage("§6=-=-=-=-=-=-=-=-=-=-=-=-=-=-=");
		b.sendMessage("§a§l=============================");
		b.sendMessage("§b§lVerificando seu IP!");
		b.sendMessage("§c§lIP: " + Bukkit.getServer().getIp());
		b.sendMessage("§a§l=============================");
		b.sendMessage("§a§l=============================");
		b.sendMessage("§b§lConectando ao site...");
		b.sendMessage("§a§l=============================");
		try {
			if(!containsIP(Bukkit.getServer().getIp())) {
				b.sendMessage("§4§l=============================");
				b.sendMessage("§c§lIP nao encontrado.");
				b.sendMessage("§c§lDesativando plugin.");
				b.sendMessage("§4§l=============================");
				Bukkit.getPluginManager().disablePlugin(this);
				return;
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
		b.sendMessage("§cConectando-se ao MySQL...");
		b.sendMessage("§cLembre-se: O plugin funciona apenas com MySQL!");
		b.sendMessage("§aHost: §b" + getConfig().getString("MySQL.Host"));
		b.sendMessage("§aDatabase: §b" + getConfig().getString("MySQL.DB"));
		b.sendMessage("§aUsuario: §b" + getConfig().getString("MySQL.User"));
		b.sendMessage("§aSenha: §b" + getConfig().getString("MySQL.Pass"));
		String host = getConfig().getString("MySQL.Host");
		String database = getConfig().getString("MySQL.DB");
		String user = getConfig().getString("MySQL.User");
		String pass = getConfig().getString("MySQL.Pass");


		db=DB.load(host, database, user, pass);

		db.update("CREATE TABLE IF NOT EXISTS `salvar_senha` (`nome` varchar(25) not null,`ip` varchar(60) not null,`senha` varchar(60) not null);");
		Bukkit.getPluginManager().registerEvents(this, this);
	}

	public void onDisable(){
		ConsoleCommandSender b = Bukkit.getConsoleSender();
		b.sendMessage("§6=-=-=-=-=-=-=-=-=-=-=-=-=-=-=");
		b.sendMessage("§a[SalvarSenha] §bDesativado...");
		try {
			if(!containsIP(Bukkit.getServer().getIp())) {
				b.sendMessage("§aMotivo: §cSeu IP nao esta em nosso site!");
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
		b.sendMessage("§aCriador: §cUltra_PvP");
		b.sendMessage("§6=-=-=-=-=-=-=-=-=-=-=-=-=-=-=");
		b.sendMessage("§cFinalizando conexao com MySQL...");
		b.sendMessage("§cConexao MySQL finalizado!");
	}

	public String getIP(String p){
		if(!hasDado(p)) return "";
		PreparedStatement ps=null;
		try{
			ps=db.getConnection().prepareStatement("SELECT * FROM `salvar_senha` WHERE nome=?;");
			ps.setString(1, p);
			ResultSet rs = ps.executeQuery();
			while(rs.next()){
				return rs.getString("ip");
			}
		}catch (Exception e){}
		finally{
			try{
				ps.close();
			}catch (Exception e){}
		}
		return "";
	}

	public String getSenha(String p){
		if(!hasDado(p)) return "";
		PreparedStatement ps=null;
		try{
			ps=db.getConnection().prepareStatement("SELECT * FROM `salvar_senha` WHERE nome=?;");
			ps.setString(1, p);
			ResultSet rs = ps.executeQuery();
			while(rs.next()){
				return rs.getString("senha");
			}
		}catch (Exception e){}
		finally{
			try{
				ps.close();
			}catch (Exception e){}
		}
		return "";
	}

	public boolean hasDado(String p){
		PreparedStatement ps=null;
		try{
			ps=db.getConnection().prepareStatement("SELECT * FROM `salvar_senha` WHERE nome=?;");
			ps.setString(1, p);
			ResultSet rs = ps.executeQuery();
			while(rs.next()){
				return true;
			}
		}catch (Exception e){}
		finally{
			try{
				ps.close();
			}catch (Exception e){}
		}
		return false;
	}

	public void setDado(Player p,String pas){
		PreparedStatement ps = null;
		try{
			if(!hasDado(p.getName())){
				ps=db.getConnection().prepareStatement("INSERT INTO `salvar_senha` (`nome`,`ip`,`senha`) VALUES (?,?,?);");
				ps.setString(1, p.getName());
				ps.setString(2, p.getAddress().getHostName());
				ps.setString(3, pas);
				ps.executeUpdate();
			}else{
				ps=db.getConnection().prepareStatement("UPDATE `salvar_senha` SET ip=?,senha=? WHERE nome=?;");
				ps.setString(1, p.getAddress().getHostName());
				ps.setString(2, pas);
				ps.setString(3, p.getName());
				ps.executeUpdate();
			}
		}catch (Exception e){}
		finally{
			try{
				ps.close();
			}catch (Exception e){}
		}
	}

	@EventHandler
	public void entrar(PlayerJoinEvent e){
		final Player p = e.getPlayer();
		String ip = p.getAddress().getHostName();
		String ips = getIP(p.getName());
		if(ips.equalsIgnoreCase("")||ips==null) return;
		if(ip.equalsIgnoreCase(ips)){
			final String pass=getSenha(p.getName());
			if(pass.equalsIgnoreCase("")||pass==null){
				p.sendMessage(getConfig().getString("Password.Nao_Definida").replace("&", "§"));
				return;
			}
			Bukkit.getScheduler().scheduleSyncDelayedTask(this, new Runnable() {
				public void run() {
					p.sendMessage(getConfig().getString("Login.Automaico_Entrou").replace("&", "§"));
					p.sendMessage(getConfig().getString("Login.Automaico_Entrou2").replace("&", "§"));
					p.chat("/login "+pass);
					}
				},5*20);
			}
		}
	   public boolean onCommand(CommandSender sender, Command cmd, String label, String[] args){
	        if(!(sender instanceof Player)){
	            sender.sendMessage("§cUse este comando in-game.");
	            return true;
	        }
	        Player p = (Player)sender;
	        if(label.equalsIgnoreCase("salvarsenha")){
	        if (!p.hasPermission(getConfig().getString("Permissao.SalvarSenha"))) {
	        	p.sendMessage(getConfig().getString("SalvarSenha.Msg_Sem.permissao").replace("&", "§"));
				return true;
			}
	        	if(args.length==0){
	                p.sendMessage(getConfig().getString("SalvarSenha.Use").replace("&", "§"));
	                return true;
	            }
	            String s = args[0];
	            setDado(p, s);
	            p.sendMessage("§3[Login Automatico] §bSenha §a"+s+"§b, foi salva com sucesso.");
	            p.sendMessage("§cLembre-se: Caso sua senha esteja incorreta, você não irá logar automaticamente!");
	        }
	        return false;
	    }

	}