package nl.RamonPeek;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import net.md_5.bungee.api.ChatColor;
import net.md_5.bungee.api.ProxyServer;
import net.md_5.bungee.api.connection.ProxiedPlayer;

public class RealmsDB {
   private static Connection connection;
   public static String IP = "62.210.168.132";
   public static String PORT = "3306";
   public static String DATABASE = "realmsdb";
   public static String USER = "realmsdb";
   public static String PASSWORD = "realmsww";

   public static Connection getConnection() {
      return connection;
   }

   public static synchronized void openConnection() {
      try {
         connection = DriverManager.getConnection("jdbc:mysql://" + IP + ":" + PORT + "/" + DATABASE + "?user=" + USER + "&password=" + PASSWORD + "&autoReconnect=true");
      } catch (Exception var1) {
         var1.printStackTrace();
      }

   }

   public static synchronized void closeConnection() {
      try {
         connection.close();
      } catch (Exception var1) {
         var1.printStackTrace();
      }

   }

   public static synchronized boolean dbContains(String name) {
      try {
         PreparedStatement sql = getConnection().prepareStatement("SELECT * FROM `" + DATABASE + "` WHERE servername=?;");
         sql.setString(1, name);
         ResultSet resultSet = sql.executeQuery();
         boolean containsServer = resultSet.next();
         sql.close();
         resultSet.close();
         return containsServer;
      } catch (Exception var4) {
         var4.printStackTrace();
         return false;
      }
   }

   public String getType(String servername) {
      openConnection();
      String type = "";

      try {
         if (!dbContains(servername)) {
            return null;
         }

         PreparedStatement sql = getConnection().prepareStatement("SELECT servertype FROM `" + DATABASE + "` WHERE servername=?;");
         sql.setString(1, servername);
         ResultSet result = sql.executeQuery();
         result.next();
         type = result.getString("servertype");
         sql.close();
         result.close();
         String var6 = type;
         return var6;
      } catch (Exception var9) {
         var9.printStackTrace();
      } finally {
         closeConnection();
      }

      return null;
   }

   public List<String> getServers() {
      openConnection();

      try {
         PreparedStatement sql = getConnection().prepareStatement("SELECT servername FROM `" + DATABASE + "` WHERE servertype=?;");
         sql.setString(1, "server");
         ResultSet result = sql.executeQuery();
         ArrayList servers = new ArrayList();

         while(result.next()) {
            String sname = result.getString(1);
            servers.add(sname.toLowerCase());
         }

         sql.close();
         result.close();
         ArrayList var6 = servers;
         return var6;
      } catch (Exception var9) {
         var9.printStackTrace();
      } finally {
         closeConnection();
      }

      return null;
   }

   public List<String> getRealms() {
      openConnection();

      try {
         PreparedStatement sql = getConnection().prepareStatement("SELECT servername FROM `" + DATABASE + "` WHERE servertype=?;");
         sql.setString(1, "realm");
         ResultSet result = sql.executeQuery();
         ArrayList servers = new ArrayList();

         while(result.next()) {
            String sname = result.getString(1);
            servers.add(sname.toLowerCase());
         }

         sql.close();
         result.close();
         ArrayList var6 = servers;
         return var6;
      } catch (Exception var9) {
         var9.printStackTrace();
      } finally {
         closeConnection();
      }

      return null;
   }

   public void setType(String servername, String servertype) {
      openConnection();

      try {
         PreparedStatement typeUpdate;
         if (dbContains(servername)) {
            typeUpdate = getConnection().prepareStatement("UPDATE `" + DATABASE + "` SET servertype=? WHERE servername=?");
            typeUpdate.setString(1, servertype);
            typeUpdate.setString(2, servername);
            typeUpdate.executeUpdate();
            typeUpdate.close();
         } else {
            typeUpdate = getConnection().prepareStatement("INSERT INTO `" + DATABASE + "` (`servername`, `servertype`) VALUES (?, ?)");
            typeUpdate.setString(1, servername);
            typeUpdate.setString(2, servertype);
            typeUpdate.executeUpdate();
            typeUpdate.close();
         }
      } catch (Exception var7) {
         var7.printStackTrace();
      } finally {
         closeConnection();
      }

   }

   public void remove(String servername) {
      openConnection();

      try {
         PreparedStatement typeUpdate = getConnection().prepareStatement("DELETE FROM `" + DATABASE + "` WHERE `servername`=?");
         typeUpdate.setString(1, servername);
         typeUpdate.executeUpdate();
         typeUpdate.close();
      } catch (Exception var6) {
         var6.printStackTrace();
      } finally {
         closeConnection();
      }

   }

   public static void sendToServer(ProxiedPlayer p, String targetServer) {
      if (ProxyServer.getInstance().getServerInfo(targetServer) != null) {
         p.sendMessage(ChatColor.GREEN + "Trying to connect to realm, if you haven't been send within 3 seconds, the realm is offline.");
         p.connect(ProxyServer.getInstance().getServerInfo(targetServer));
      } else {
         p.sendMessage(ChatColor.RED + "The server you tried to join isn't available at the moment.");
      }

   }
}