Adding bstats functionality and fixing version

- Whitelisted players would not actually return as whitelisted from the database because of use the getFetchSize parameter, which was not used as it was intended.
- The same reasoning as above is why the alertsState would not function.

Assembly/dependency-reduced-pom.xml

@@ -3,7 +3,7 @@
   <parent>
     <artifactId>AntiVPN</artifactId>
     <groupId>dev.brighten.antivpn</groupId>
-    <version>1.1.1</version>
+    <version>1.5.0</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
   <artifactId>Assembly</artifactId>

Assembly/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>AntiVPN</artifactId>
         <groupId>dev.brighten.antivpn</groupId>
-        <version>1.1.1</version>
+        <version>1.5.0</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -50,6 +50,12 @@
             <version>${version}</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>dev.brighten.antivpn</groupId>
+            <artifactId>Velocity</artifactId>
+            <version>${version}</version>
+            <scope>compile</scope>
+        </dependency>
         <dependency>
             <groupId>dev.brighten.antivpn</groupId>
             <artifactId>Bukkit</artifactId>

Bukkit/dependency-reduced-pom.xml

@@ -3,10 +3,49 @@
   <parent>
     <artifactId>AntiVPN</artifactId>
     <groupId>dev.brighten.antivpn</groupId>
-    <version>1.1.1</version>
+    <version>1.5.0</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
   <artifactId>Bukkit</artifactId>
+  <build>
+    <resources>
+      <resource>
+        <filtering>true</filtering>
+        <directory>src/main/resources</directory>
+      </resource>
+    </resources>
+    <plugins>
+      <plugin>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <version>3.7.0</version>
+        <configuration>
+          <source>8</source>
+          <target>8</target>
+          <compilerArgument>-XDignore.symbol.file</compilerArgument>
+        </configuration>
+      </plugin>
+      <plugin>
+        <artifactId>maven-shade-plugin</artifactId>
+        <version>3.1.0</version>
+        <executions>
+          <execution>
+            <phase>package</phase>
+            <goals>
+              <goal>shade</goal>
+            </goals>
+          </execution>
+        </executions>
+        <configuration>
+          <relocations>
+            <relocation>
+              <pattern>org.bstats</pattern>
+              <shadedPattern>dev.brighten.antivpn.bukkit.org.bstats</shadedPattern>
+            </relocation>
+          </relocations>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
   <dependencies>
     <dependency>
       <groupId>org.github.spigot</groupId>
@@ -14,6 +53,12 @@
       <version>1.13.2</version>
       <scope>provided</scope>
     </dependency>
+    <dependency>
+      <groupId>dev.brighten.antivpn</groupId>
+      <artifactId>Common</artifactId>
+      <version>1.5.0</version>
+      <scope>provided</scope>
+    </dependency>
     <dependency>
       <groupId>cc.funkemunky.utils</groupId>
       <artifactId>lombok</artifactId>

Bukkit/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>AntiVPN</artifactId>
         <groupId>dev.brighten.antivpn</groupId>
-        <version>1.1.1</version>
+        <version>1.5.0</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -23,6 +23,28 @@
                     <compilerArgument>-XDignore.symbol.file</compilerArgument>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-shade-plugin</artifactId>
+                <version>3.1.0</version>
+                <configuration>
+                    <relocations>
+                        <relocation>
+                            <pattern>org.bstats</pattern>
+                            <!-- Replace this with your package! -->
+                            <shadedPattern>dev.brighten.antivpn.bukkit.org.bstats</shadedPattern>
+                        </relocation>
+                    </relocations>
+                </configuration>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>shade</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
         </plugins>
         <resources>
             <resource>
@@ -47,9 +69,15 @@
         <dependency>
             <groupId>dev.brighten.antivpn</groupId>
             <artifactId>Common</artifactId>
-            <version>1.1.1</version>
+            <version>1.5.0</version>
             <scope>provided</scope>
         </dependency>
+        <dependency>
+            <groupId>org.bstats</groupId>
+            <artifactId>bstats-bukkit</artifactId>
+            <version>2.2.1</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
 </project>

Bukkit/src/main/java/dev/brighten/antivpn/bukkit/BukkitCommandExecutor.java

@@ -1,9 +1,15 @@
 package dev.brighten.antivpn.bukkit;
 
+import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.api.APIPlayer;
+import dev.brighten.antivpn.api.PlayerExecutor;
 import dev.brighten.antivpn.command.CommandExecutor;
 import lombok.RequiredArgsConstructor;
 import org.bukkit.ChatColor;
 import org.bukkit.command.CommandSender;
+import org.bukkit.entity.Player;
+
+import java.util.Optional;
 
 @RequiredArgsConstructor
 public class BukkitCommandExecutor implements CommandExecutor {
@@ -19,4 +25,16 @@ public class BukkitCommandExecutor implements CommandExecutor {
     public boolean hasPermission(String permission) {
         return sender.hasPermission(permission);
     }
+
+    @Override
+    public Optional<APIPlayer> getPlayer() {
+        if(!isPlayer()) return Optional.empty();
+
+        return AntiVPN.getInstance().getPlayerExecutor().getPlayer(((Player)sender).getUniqueId());
+    }
+
+    @Override
+    public boolean isPlayer() {
+        return sender instanceof Player;
+    }
 }

Bukkit/src/main/java/dev/brighten/antivpn/bukkit/BukkitConfig.java

@@ -2,17 +2,52 @@ package dev.brighten.antivpn.bukkit;
 
 import dev.brighten.antivpn.api.VPNConfig;
 import dev.brighten.antivpn.bukkit.util.ConfigDefault;
+import org.bukkit.Bukkit;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
 
 public class BukkitConfig implements VPNConfig {
     private final ConfigDefault<String> licenseDefault = new ConfigDefault<>("",
             "license", BukkitPlugin.pluginInstance), kickStringDefault =
-            new ConfigDefault<>("Proxies are not allowed on our server",
-                    "kickMessage", BukkitPlugin.pluginInstance);
+                    new ConfigDefault<>("Proxies are not allowed on our server",
+                    "kickMessage", BukkitPlugin.pluginInstance),
+            defaultDatabaseType = new ConfigDefault<>("MySQL",
+                    "database.type", BukkitPlugin.pluginInstance),
+            defaultDatabaseName = new ConfigDefault<>("kaurivpn",
+                    "database.database", BukkitPlugin.pluginInstance),
+            defaultUsername = new ConfigDefault<>("root",
+                    "database.username", BukkitPlugin.pluginInstance),
+            defaultPassword = new ConfigDefault<>("password",
+                    "database.password", BukkitPlugin.pluginInstance),
+            defaultAuthDatabase = new ConfigDefault<>("admin",
+                    "database.auth", BukkitPlugin.pluginInstance),
+            defaultIp = new ConfigDefault<>("localhost", "database.ip", BukkitPlugin.pluginInstance),
+            defaultAlertMsg = new ConfigDefault<>("&8[&6KauriVPN&8] &e%player% &7has joined on a VPN/proxy" +
+                    " &8(&f%reason%&8) &7in location &8(&f%city%&7, &f%country%&8)", "alerts.message",
+                    BukkitPlugin.pluginInstance);
     private final ConfigDefault<Boolean> cacheResultsDefault = new ConfigDefault<>(true,
-            "cachedResults", BukkitPlugin.pluginInstance);
+            "cachedResults", BukkitPlugin.pluginInstance),
+            defaultDatabaseEnabled = new ConfigDefault<>(false, "database.enabled",
+                    BukkitPlugin.pluginInstance), defaultCommandsEnable = new ConfigDefault<>(false,
+            "commands.enabled", BukkitPlugin.pluginInstance), defaultKickPlayers
+            = new ConfigDefault<>(true, "kickPlayers", BukkitPlugin.pluginInstance),
+            defaultAlertToStaff = new ConfigDefault<>(true, "alerts.enabled",
+                    BukkitPlugin.pluginInstance),
+            defaultMetrics = new ConfigDefault<>(true, "bstats", BukkitPlugin.pluginInstance);
+    private final ConfigDefault<Integer>
+            defaultPort = new ConfigDefault<>(-1, "database.port", BukkitPlugin.pluginInstance);
+    private final ConfigDefault<List<String>> prefixWhitelistsDefault = new ConfigDefault<>(new ArrayList<>(),
+            "prefixWhitelists", BukkitPlugin.pluginInstance), defaultCommands = new ConfigDefault<>(
+            Collections.singletonList("kick %player% VPNs are not allowed on our server!"), "commands.execute",
+            BukkitPlugin.pluginInstance);
 
-    private String license, kickMessage;
-    private boolean cacheResults;
+    private String license, kickMessage, databaseType, databaseName, username, password, ip, alertMsg;
+    private List<String> prefixWhitelists, commands;
+    private int port;
+    private boolean cacheResults, databaseEnabled, commandsEnabled, kickPlayers, alertToStaff, metrics;
 
     @Override
     public String getLicense() {
@@ -29,9 +64,105 @@ public class BukkitConfig implements VPNConfig {
         return kickMessage;
     }
 
+    @Override
+    public String alertMessage() {
+        return alertMsg;
+    }
+
+    @Override
+    public boolean alertToStaff() {
+        return alertToStaff;
+    }
+
+    @Override
+    public boolean runCommands() {
+        return commandsEnabled;
+    }
+
+    @Override
+    public List<String> commands() {
+        return commands;
+    }
+
+    @Override
+    public boolean kickPlayersOnDetect() {
+        return kickPlayers;
+    }
+
+    @Override
+    public List<String> getPrefixWhitelists() {
+        return prefixWhitelists;
+    }
+
+    @Override
+    public boolean isDatabaseEnabled() {
+        return databaseEnabled;
+    }
+
+    @Override
+    public String getDatabaseType() {
+        return databaseType;
+    }
+
+    @Override
+    public String getDatabaseName() {
+        return databaseName;
+    }
+
+    @Override
+    public String getUsername() {
+        return username;
+    }
+
+    @Override
+    public String getPassword() {
+        return password;
+    }
+
+    @Override
+    public String getIp() {
+        return ip;
+    }
+
+    @Override
+    public int getPort() {
+        if(port == -1) {
+            switch (getDatabaseType().toLowerCase()) {
+                case "mongodb":
+                case "mongo":
+                case "mongod":
+                    return 27017;
+                case "sql":
+                case "mysql":
+                    return 3306;
+            }
+        }
+
+        return port;
+    }
+
+    @Override
+    public boolean metrics() {
+        return metrics;
+    }
+
     public void update() {
         license = licenseDefault.get();
         kickMessage = kickStringDefault.get();
         cacheResults = cacheResultsDefault.get();
+        prefixWhitelists = prefixWhitelistsDefault.get();
+        databaseEnabled = defaultDatabaseEnabled.get();
+        databaseType = defaultDatabaseType.get();
+        databaseName = defaultDatabaseName.get();
+        username = defaultUsername.get();
+        password = defaultPassword.get();
+        ip = defaultIp.get();
+        port = defaultPort.get();
+        commandsEnabled = defaultCommandsEnable.get();
+        commands = defaultCommands.get();
+        kickPlayers = defaultKickPlayers.get();
+        alertToStaff = defaultAlertToStaff.get();
+        alertMsg = defaultAlertMsg.get();
+        metrics = defaultMetrics.get();
     }
 }

Bukkit/src/main/java/dev/brighten/antivpn/bukkit/BukkitListener.java

@@ -1,14 +1,20 @@
 package dev.brighten.antivpn.bukkit;
 
 import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.api.APIPlayer;
 import dev.brighten.antivpn.api.VPNExecutor;
+import dev.brighten.antivpn.message.VpnString;
+import lombok.val;
 import org.bukkit.Bukkit;
 import org.bukkit.ChatColor;
+import org.bukkit.entity.Player;
 import org.bukkit.event.Event;
 import org.bukkit.event.EventHandler;
 import org.bukkit.event.HandlerList;
 import org.bukkit.event.Listener;
 import org.bukkit.event.player.AsyncPlayerPreLoginEvent;
+import org.bukkit.event.player.PlayerJoinEvent;
+import org.bukkit.event.player.PlayerLoginEvent;
 import org.bukkit.scheduler.BukkitRunnable;
 import org.bukkit.scheduler.BukkitTask;
 
@@ -42,23 +48,61 @@ public class BukkitListener extends VPNExecutor implements Listener {
     }
 
     @EventHandler
-    public void onListener(final AsyncPlayerPreLoginEvent event) {
+    public void onJoin(final PlayerJoinEvent event) {
+        AntiVPN.getInstance().getPlayerExecutor().getPlayer(event.getPlayer().getUniqueId())
+                .ifPresent(player -> {
+                    AntiVPN.getInstance().getDatabase().alertsState(player.getUuid(), enabled -> {
+                        if(enabled) {
+                            System.out.println("Enabled");
+                            player.setAlertsEnabled(true);
+                            player.sendMessage(AntiVPN.getInstance().getMessageHandler()
+                                    .getString("command-alerts-toggled")
+                                    .getFormattedMessage(new VpnString.Var<>("state", true)));
+                        } else System.out.println("Not enabled");
+                    });
+                });
+    }
+
+    @EventHandler
+    public void onListener(final PlayerLoginEvent event) {
+        //If they're exempt, don't check.
+        if(AntiVPN.getInstance().getExecutor().isWhitelisted(event.getPlayer().getUniqueId())) return;
         checkIp(event.getAddress().getHostAddress(), AntiVPN.getInstance().getConfig().cachedResults(), result -> {
             if(result.isSuccess() && result.isProxy()) {
-                event.setLoginResult(AsyncPlayerPreLoginEvent.Result.KICK_OTHER);
-                event.setKickMessage(ChatColor.translateAlternateColorCodes('&',
-                        AntiVPN.getInstance().getConfig().getKickString()));
-                Optional.ofNullable(Bukkit.getPlayer(event.getUniqueId())).ifPresent(player -> {
-                    new BukkitRunnable() {
-                        public void run() {
-                            if(!player.hasPermission("antivpn.bypass"))
-                            player.kickPlayer(ChatColor.translateAlternateColorCodes('&',
-                                    AntiVPN.getInstance().getConfig().getKickString()));
-                            System.out.println(player.getPlayer().getName()
-                                    + " joined on a VPN/Proxy (" + result.getMethod() + ")");
+                new BukkitRunnable() {
+                    public void run() {
+                        Player player = event.getPlayer();
+
+                        if(!player.hasPermission("antivpn.bypass") //Has bypass permission
+                                //Or has a name that starts with a certain prefix. This is for Bedrock exempting.
+                                || AntiVPN.getInstance().getConfig().getPrefixWhitelists().stream()
+                                .anyMatch(prefix -> player.getName().startsWith(prefix))) {
+                            if (AntiVPN.getInstance().getConfig().kickPlayersOnDetect())
+                                player.kickPlayer(ChatColor.translateAlternateColorCodes('&',
+                                        AntiVPN.getInstance().getConfig().getKickString()));
+
+                            //Ensuring the user wishes to alert to staff
+                            if(AntiVPN.getInstance().getConfig().alertToStaff())
+                                AntiVPN.getInstance().getPlayerExecutor().getOnlinePlayers().stream()
+                                        .filter(APIPlayer::isAlertsEnabled)
+                                        .forEach(pl -> pl.sendMessage(AntiVPN.getInstance().getConfig()
+                                                .alertMessage().replace("%player%", event.getPlayer().getName())
+                                                .replace("%reason%", result.getMethod())
+                                                .replace("%country%", result.getCountryName())
+                                                .replace("%city%", result.getCity())));
+
+                            //In case the user wants to run their own commands instead of using the built in kicking
+                            if(AntiVPN.getInstance().getConfig().runCommands())
+                                for (String command : AntiVPN.getInstance().getConfig().commands()) {
+                                    Bukkit.dispatchCommand(Bukkit.getConsoleSender(),
+                                            ChatColor.translateAlternateColorCodes('&',
+                                                    command.replace("%player%", event.getPlayer().getName())));
+                                }
                         }
-                    }.runTask(BukkitPlugin.pluginInstance);
-                });
+                        Bukkit.getLogger().info(player.getPlayer().getName()
+                                + " joined on a VPN/Proxy (" + result.getMethod() + ")");
+                    }
+                }.runTask(BukkitPlugin.pluginInstance);
             } else if(!result.isSuccess()) {
                 Bukkit.getLogger().log(Level.WARNING,
                         "The API query was not a success! " +

Bukkit/src/main/java/dev/brighten/antivpn/bukkit/BukkitPlayerExecutor.java

@@ -3,14 +3,16 @@ package dev.brighten.antivpn.bukkit;
 import dev.brighten.antivpn.api.APIPlayer;
 import dev.brighten.antivpn.api.PlayerExecutor;
 import org.bukkit.Bukkit;
+import org.bukkit.OfflinePlayer;
 import org.bukkit.entity.Player;
 
-import java.util.List;
-import java.util.Optional;
-import java.util.UUID;
+import java.util.*;
 import java.util.stream.Collectors;
 
 public class BukkitPlayerExecutor implements PlayerExecutor {
+
+    private final Map<Player, BukkitPlayer> cachedPlayers = new WeakHashMap<>();
+
     @Override
     public Optional<APIPlayer> getPlayer(String name) {
         final Player player = Bukkit.getPlayer(name);
@@ -19,7 +21,7 @@ public class BukkitPlayerExecutor implements PlayerExecutor {
             return Optional.empty();
         }
 
-        return Optional.of(new BukkitPlayer(player));
+        return Optional.of(cachedPlayers.computeIfAbsent(player, BukkitPlayer::new));
     }
 
     @Override
@@ -30,11 +32,15 @@ public class BukkitPlayerExecutor implements PlayerExecutor {
             return Optional.empty();
         }
 
-        return Optional.of(new BukkitPlayer(player));
+        return Optional.of(cachedPlayers.computeIfAbsent(player, BukkitPlayer::new));
     }
 
+
     @Override
     public List<APIPlayer> getOnlinePlayers() {
-        return Bukkit.getOnlinePlayers().stream().map(BukkitPlayer::new).collect(Collectors.toList());
+        return Bukkit.getOnlinePlayers().stream()
+                .map(pl -> cachedPlayers.computeIfAbsent(pl, BukkitPlayer::new))
+                .collect(Collectors.toList());
     }
+
 }

Bukkit/src/main/java/dev/brighten/antivpn/bukkit/BukkitPlugin.java

@@ -1,15 +1,20 @@
 package dev.brighten.antivpn.bukkit;
 
 import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.bukkit.util.ConfigDefault;
 import dev.brighten.antivpn.command.Command;
 import lombok.val;
 import net.md_5.bungee.api.ChatColor;
+import org.bstats.bukkit.Metrics;
+import org.bstats.charts.MultiLineChart;
+import org.bstats.charts.SingleLineChart;
 import org.bukkit.Bukkit;
 import org.bukkit.command.CommandSender;
 import org.bukkit.command.SimpleCommandMap;
 import org.bukkit.event.HandlerList;
 import org.bukkit.plugin.SimplePluginManager;
 import org.bukkit.plugin.java.JavaPlugin;
+import org.bukkit.scheduler.BukkitRunnable;
 
 import java.lang.reflect.Field;
 import java.util.ArrayList;
@@ -23,18 +28,33 @@ public class BukkitPlugin extends JavaPlugin {
     public static BukkitPlugin pluginInstance;
     private SimpleCommandMap commandMap;
     private List<org.bukkit.command.Command> registeredCommands = new ArrayList<>();
+    private SingleLineChart vpnDetections, ipsChecked;
 
     public void onEnable() {
         pluginInstance = this;
 
         //Loading config
-        System.out.println("Loading config...");
+        Bukkit.getLogger().info("Loading config...");
         saveDefaultConfig();
 
-        System.out.println("Starting AntiVPN services...");
+        Bukkit.getLogger().info("Starting AntiVPN services...");
         AntiVPN.start(new BukkitConfig(), new BukkitListener(), new BukkitPlayerExecutor());
 
-        System.out.println("Setting up and registering commands...");
+        if(AntiVPN.getInstance().getConfig().metrics()) {
+            Bukkit.getLogger().info("Starting bStats metrics...");
+            Metrics metrics = new Metrics(this, 12615);
+            metrics.addCustomChart(vpnDetections = new SingleLineChart("vpn_detections",
+                    () -> AntiVPN.getInstance().detections));
+            metrics.addCustomChart(ipsChecked = new SingleLineChart("ips_checked",
+                    () -> AntiVPN.getInstance().checked));
+            new BukkitRunnable() {
+                public void run() {
+                    AntiVPN.getInstance().checked = AntiVPN.getInstance().detections = 0;
+                }
+            }.runTaskTimerAsynchronously(this, 12000, 12000);
+        }
+
+        Bukkit.getLogger().info("Setting up and registering commands...");
         if (pluginInstance.getServer().getPluginManager() instanceof SimplePluginManager) {
             SimplePluginManager manager = (SimplePluginManager) pluginInstance.getServer().getPluginManager();
             try {
@@ -56,7 +76,8 @@ public class BukkitPlugin extends JavaPlugin {
 
                     if(children.length > 0 && args.length > 0) {
                         for (Command child : children) {
-                            if(child.name().equalsIgnoreCase(args[0])) {
+                            if(child.name().equalsIgnoreCase(args[0])  || Arrays.stream(child.aliases())
+                                    .anyMatch(alias2 -> alias2.equalsIgnoreCase(args[0]))) {
                                 return child.tabComplete(new BukkitCommandExecutor(sender), alias, IntStream
                                         .range(0, args.length - 1)
                                         .mapToObj(i -> args[i + 1]).toArray(String[]::new));
@@ -78,7 +99,8 @@ public class BukkitPlugin extends JavaPlugin {
 
                     if(children.length > 0 && args.length > 0) {
                         for (Command child : children) {
-                            if(child.name().equalsIgnoreCase(args[0])) {
+                            if(child.name().equalsIgnoreCase(args[0])  || Arrays.stream(child.aliases())
+                                    .anyMatch(alias -> alias.equalsIgnoreCase(args[0]))) {
                                 if(!sender.hasPermission("antivpn.command.*")
                                         && !sender.hasPermission(child.permission())) {
                                     sender.sendMessage(ChatColor.RED + "No permission.");
@@ -104,14 +126,24 @@ public class BukkitPlugin extends JavaPlugin {
             registeredCommands.add(newCommand);
             commandMap.register(pluginInstance.getName(), newCommand);
         }
+
+        AntiVPN.getInstance().getMessageHandler().initStrings(vpnString -> new ConfigDefault<>
+                (vpnString.getDefaultMessage(), "messages." + vpnString.getKey(), BukkitPlugin.pluginInstance)
+                .get());
+        //TODO Finish system before implementing on startup
+        /*Bukkit.getLogger().info("Getting strings...");
+        AntiVPN.getInstance().getMessageHandler().initStrings(vpnString -> new ConfigDefault<>
+                (vpnString.getDefaultMessage(), "messages." + vpnString.getKey(), BukkitPlugin.pluginInstance)
+                .get());
+        AntiVPN.getInstance().getMessageHandler().reloadStrings();*/
     }
 
     @Override
     public void onDisable() {
-        System.out.println("Stopping plugin services...");
+        Bukkit.getLogger().info("Stopping plugin services...");
         AntiVPN.getInstance().stop();
 
-        System.out.println("Unregistering commands...");
+        Bukkit.getLogger().info("Unregistering commands...");
         try {
             Field field = SimpleCommandMap.class.getDeclaredField("knownCommands");
             field.setAccessible(true);
@@ -124,10 +156,10 @@ public class BukkitPlugin extends JavaPlugin {
             e.printStackTrace();
         }
 
-        System.out.println("Unregistering listeners...");
+        Bukkit.getLogger().info("Unregistering listeners...");
         HandlerList.unregisterAll(this);
 
-        System.out.println("Cancelling any running tasks...");
+        Bukkit.getLogger().info("Cancelling any running tasks...");
         Bukkit.getScheduler().cancelTasks(this);
     }
 }

Bungee/dependency-reduced-pom.xml

@@ -3,11 +3,56 @@
   <parent>
     <artifactId>AntiVPN</artifactId>
     <groupId>dev.brighten.antivpn</groupId>
-    <version>1.1.1</version>
+    <version>1.5.0</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
   <artifactId>Bungee</artifactId>
+  <build>
+    <resources>
+      <resource>
+        <filtering>true</filtering>
+        <directory>src/main/resources</directory>
+      </resource>
+    </resources>
+    <plugins>
+      <plugin>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <version>3.7.0</version>
+        <configuration>
+          <source>8</source>
+          <target>8</target>
+          <compilerArgument>-XDignore.symbol.file</compilerArgument>
+        </configuration>
+      </plugin>
+      <plugin>
+        <artifactId>maven-shade-plugin</artifactId>
+        <version>3.1.0</version>
+        <executions>
+          <execution>
+            <phase>package</phase>
+            <goals>
+              <goal>shade</goal>
+            </goals>
+          </execution>
+        </executions>
+        <configuration>
+          <relocations>
+            <relocation>
+              <pattern>org.bstats</pattern>
+              <shadedPattern>dev.brighten.antivpn.bungee.org.bstats</shadedPattern>
+            </relocation>
+          </relocations>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
   <dependencies>
+    <dependency>
+      <groupId>dev.brighten.antivpn</groupId>
+      <artifactId>Common</artifactId>
+      <version>1.5.0</version>
+      <scope>provided</scope>
+    </dependency>
     <dependency>
       <groupId>org.github.bungee</groupId>
       <artifactId>BungeeCord-1.8</artifactId>

Bungee/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>AntiVPN</artifactId>
         <groupId>dev.brighten.antivpn</groupId>
-        <version>1.1.1</version>
+        <version>1.5.0</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -23,6 +23,28 @@
                     <compilerArgument>-XDignore.symbol.file</compilerArgument>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-shade-plugin</artifactId>
+                <version>3.1.0</version>
+                <configuration>
+                    <relocations>
+                        <relocation>
+                            <pattern>org.bstats</pattern>
+                            <!-- Replace this with your package! -->
+                            <shadedPattern>dev.brighten.antivpn.bungee.org.bstats</shadedPattern>
+                        </relocation>
+                    </relocations>
+                </configuration>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>shade</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
         </plugins>
         <resources>
             <resource>
@@ -41,7 +63,7 @@
         <dependency>
             <groupId>dev.brighten.antivpn</groupId>
             <artifactId>Common</artifactId>
-            <version>1.1.1</version>
+            <version>1.5.0</version>
             <scope>provided</scope>
         </dependency>
         <dependency>
@@ -50,6 +72,12 @@
             <version>1.8</version>
             <scope>provided</scope>
         </dependency>
+        <dependency>
+            <groupId>org.bstats</groupId>
+            <artifactId>bstats-bungeecord</artifactId>
+            <version>2.2.1</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
 </project>

Bungee/src/main/java/dev/brighten/antivpn/bungee/BungeeCommandExecutor.java

@@ -1,24 +1,41 @@
 package dev.brighten.antivpn.bungee;
 
+import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.api.APIPlayer;
 import dev.brighten.antivpn.command.CommandExecutor;
 import lombok.RequiredArgsConstructor;
 import net.md_5.bungee.api.ChatColor;
 import net.md_5.bungee.api.CommandSender;
 import net.md_5.bungee.api.chat.TextComponent;
+import net.md_5.bungee.api.connection.ProxiedPlayer;
+
+import java.util.Optional;
 
 @RequiredArgsConstructor
 public class BungeeCommandExecutor implements CommandExecutor {
 
-    private final CommandSender executor;
+    private final CommandSender sender;
 
     @Override
     public void sendMessage(String message) {
-        executor.sendMessage(TextComponent.fromLegacyText(ChatColor
+        sender.sendMessage(TextComponent.fromLegacyText(ChatColor
                 .translateAlternateColorCodes('&', message)));
     }
 
     @Override
     public boolean hasPermission(String permission) {
-        return executor.hasPermission(permission);
+        return sender.hasPermission(permission);
+    }
+
+    @Override
+    public Optional<APIPlayer> getPlayer() {
+        if(!isPlayer()) return Optional.empty();
+
+        return AntiVPN.getInstance().getPlayerExecutor().getPlayer(((ProxiedPlayer) sender).getUniqueId());
+    }
+
+    @Override
+    public boolean isPlayer() {
+        return sender instanceof ProxiedPlayer;
     }
 }

Bungee/src/main/java/dev/brighten/antivpn/bungee/BungeeConfig.java

@@ -3,16 +3,49 @@ package dev.brighten.antivpn.bungee;
 import dev.brighten.antivpn.api.VPNConfig;
 import dev.brighten.antivpn.bungee.util.ConfigDefault;
 
-public class BungeeConfig implements VPNConfig { ;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+public class BungeeConfig implements VPNConfig {
     private final ConfigDefault<String> licenseDefault = new ConfigDefault<>("",
             "license", BungeePlugin.pluginInstance), kickStringDefault =
             new ConfigDefault<>("Proxies are not allowed on our server",
-                    "kickMessage", BungeePlugin.pluginInstance);
+                    "kickMessage", BungeePlugin.pluginInstance),
+            defaultDatabaseType = new ConfigDefault<>("MySQL",
+                    "database.type", BungeePlugin.pluginInstance),
+            defaultDatabaseName = new ConfigDefault<>("kaurivpn",
+                    "database.database", BungeePlugin.pluginInstance),
+            defaultUsername = new ConfigDefault<>("root",
+                    "database.username", BungeePlugin.pluginInstance),
+            defaultPassword = new ConfigDefault<>("password",
+                    "database.password", BungeePlugin.pluginInstance),
+            defaultAuthDatabase = new ConfigDefault<>("admin",
+                    "database.auth", BungeePlugin.pluginInstance),
+            defaultIp = new ConfigDefault<>("localhost", "database.ip", BungeePlugin.pluginInstance),
+            defaultAlertMsg = new ConfigDefault<>("&8[&6KauriVPN&8] &e%player% &7has joined on a VPN/proxy" +
+                    " &8(&f%reason%&8) &7in location &8(&f%city%&7, &f%country%&8)", "alerts.message",
+                    BungeePlugin.pluginInstance);
     private final ConfigDefault<Boolean> cacheResultsDefault = new ConfigDefault<>(true,
-            "cachedResults", BungeePlugin.pluginInstance);
+            "cachedResults", BungeePlugin.pluginInstance),
+            defaultDatabaseEnabled = new ConfigDefault<>(false, "database.enabled",
+                    BungeePlugin.pluginInstance), defaultCommandsEnable = new ConfigDefault<>(false,
+            "commands.enabled", BungeePlugin.pluginInstance), defaultKickPlayers
+            = new ConfigDefault<>(true, "kickPlayers", BungeePlugin.pluginInstance),
+            defaultAlertToStaff = new ConfigDefault<>(true, "alerts.enabled",
+                    BungeePlugin.pluginInstance),
+            defaultMetrics = new ConfigDefault<>(true, "bstats", BungeePlugin.pluginInstance);
+    private final ConfigDefault<Integer>
+            defaultPort = new ConfigDefault<>(-1, "database.port", BungeePlugin.pluginInstance);
+    private final ConfigDefault<List<String>> prefixWhitelistsDefault = new ConfigDefault<>(new ArrayList<>(),
+            "prefixWhitelists", BungeePlugin.pluginInstance), defaultCommands = new ConfigDefault<>(
+            Collections.singletonList("kick %player% VPNs are not allowed on our server!"), "commands.execute",
+            BungeePlugin.pluginInstance);
 
-    private String license, kickMessage;
-    private boolean cacheResults;
+    private String license, kickMessage, databaseType, databaseName, username, password, ip, alertMsg;
+    private List<String> prefixWhitelists, commands;
+    private int port;
+    private boolean cacheResults, databaseEnabled, commandsEnabled, kickPlayers, alertToStaff, metrics;
 
     @Override
     public String getLicense() {
@@ -29,9 +62,105 @@ public class BungeeConfig implements VPNConfig { ;
         return kickMessage;
     }
 
+    @Override
+    public String alertMessage() {
+        return alertMsg;
+    }
+
+    @Override
+    public boolean alertToStaff() {
+        return alertToStaff;
+    }
+
+    @Override
+    public boolean runCommands() {
+        return commandsEnabled;
+    }
+
+    @Override
+    public List<String> commands() {
+        return commands;
+    }
+
+    @Override
+    public boolean kickPlayersOnDetect() {
+        return kickPlayers;
+    }
+
+    @Override
+    public List<String> getPrefixWhitelists() {
+        return prefixWhitelists;
+    }
+
+    @Override
+    public boolean isDatabaseEnabled() {
+        return databaseEnabled;
+    }
+
+    @Override
+    public String getDatabaseType() {
+        return databaseType;
+    }
+
+    @Override
+    public String getDatabaseName() {
+        return databaseName;
+    }
+
+    @Override
+    public String getUsername() {
+        return username;
+    }
+
+    @Override
+    public String getPassword() {
+        return password;
+    }
+
+    @Override
+    public String getIp() {
+        return ip;
+    }
+
+    @Override
+    public int getPort() {
+        if(port == -1) {
+            switch (getDatabaseType().toLowerCase()) {
+                case "mongodb":
+                case "mongo":
+                case "mongod":
+                    return 27017;
+                case "sql":
+                case "mysql":
+                    return 3306;
+            }
+        }
+
+        return port;
+    }
+
+    @Override
+    public boolean metrics() {
+        return metrics;
+    }
+
     public void update() {
         license = licenseDefault.get();
         kickMessage = kickStringDefault.get();
         cacheResults = cacheResultsDefault.get();
+        prefixWhitelists = prefixWhitelistsDefault.get();
+        databaseEnabled = defaultDatabaseEnabled.get();
+        databaseType = defaultDatabaseType.get();
+        databaseName = defaultDatabaseName.get();
+        username = defaultUsername.get();
+        password = defaultPassword.get();
+        ip = defaultIp.get();
+        port = defaultPort.get();
+        commandsEnabled = defaultCommandsEnable.get();
+        commands = defaultCommands.get();
+        kickPlayers = defaultKickPlayers.get();
+        alertToStaff = defaultAlertToStaff.get();
+        alertMsg = defaultAlertMsg.get();
+        metrics = defaultMetrics.get();
     }
 }

Bungee/src/main/java/dev/brighten/antivpn/bungee/BungeeListener.java

@@ -1,12 +1,12 @@
 package dev.brighten.antivpn.bungee;
 
 import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.api.APIPlayer;
 import dev.brighten.antivpn.api.VPNExecutor;
 import net.md_5.bungee.BungeeCord;
 import net.md_5.bungee.api.ChatColor;
 import net.md_5.bungee.api.chat.TextComponent;
 import net.md_5.bungee.api.event.PostLoginEvent;
-import net.md_5.bungee.api.event.TabCompleteEvent;
 import net.md_5.bungee.api.plugin.Listener;
 import net.md_5.bungee.api.scheduler.ScheduledTask;
 import net.md_5.bungee.event.EventHandler;
@@ -42,21 +42,48 @@ public class BungeeListener extends VPNExecutor implements Listener {
 
     @EventHandler
     public void onListener(final PostLoginEvent event) {
-        if(event.getPlayer().hasPermission("antivpn.bypass")) return;
+        if(event.getPlayer().hasPermission("antivpn.bypass") //Has bypass permission
+                || AntiVPN.getInstance().getExecutor().isWhitelisted(event.getPlayer().getUniqueId()) //Is exempt
+                //Or has a name that starts with a certain prefix. This is for Bedrock exempting.
+                || AntiVPN.getInstance().getConfig().getPrefixWhitelists().stream()
+                .anyMatch(prefix -> event.getPlayer().getName().startsWith(prefix))) return;
+
         checkIp(event.getPlayer().getAddress().getAddress().getHostAddress(),
                 AntiVPN.getInstance().getConfig().cachedResults(), result -> {
             if(result.isSuccess() && result.isProxy()) {
+                if(AntiVPN.getInstance().getConfig().kickPlayersOnDetect())
                 event.getPlayer().disconnect(TextComponent.fromLegacyText(ChatColor
                         .translateAlternateColorCodes('&',
                                 AntiVPN.getInstance().getConfig().getKickString())));
-                System.out.println(event.getPlayer().getName()
+                BungeeCord.getInstance().getLogger().info(event.getPlayer().getName()
                         + " joined on a VPN/Proxy (" + result.getMethod() + ")");
+
+                if(AntiVPN.getInstance().getConfig().alertToStaff()) //Ensuring the user wishes to alert to staff
+                AntiVPN.getInstance().getPlayerExecutor().getOnlinePlayers().stream()
+                        .filter(APIPlayer::isAlertsEnabled)
+                        .forEach(pl -> pl.sendMessage(AntiVPN.getInstance().getConfig().alertMessage()
+                                .replace("%player%", event.getPlayer().getName())
+                                .replace("%reason%", result.getMethod())
+                                .replace("%country%", result.getCountryName())
+                                .replace("%city%", result.getCity())));
+
+                //In case the user wants to run their own commands instead of using the built in kicking
+                if(AntiVPN.getInstance().getConfig().runCommands()) {
+                    for (String command : AntiVPN.getInstance().getConfig().commands()) {
+                        BungeeCord.getInstance().getPluginManager()
+                                .dispatchCommand(BungeeCord.getInstance().getConsole(),
+                                        ChatColor.translateAlternateColorCodes('&',
+                                                command.replace("%player%", event.getPlayer().getName())));
+                    }
+                }
+                AntiVPN.getInstance().detections++;
             } else if(!result.isSuccess()) {
                 BungeeCord.getInstance().getLogger()
                         .log(Level.WARNING,
                                 "The API query was not a success! " +
                                         "You may need to upgrade your license on https://funkemunky.cc/shop");
             }
+            AntiVPN.getInstance().checked++;
         });
     }
 }

Bungee/src/main/java/dev/brighten/antivpn/bungee/BungeePlayerExecutor.java

@@ -5,20 +5,20 @@ import dev.brighten.antivpn.api.PlayerExecutor;
 import net.md_5.bungee.BungeeCord;
 import net.md_5.bungee.api.connection.ProxiedPlayer;
 
-import java.util.List;
-import java.util.Optional;
-import java.util.UUID;
+import java.util.*;
 import java.util.stream.Collectors;
 
 public class BungeePlayerExecutor implements PlayerExecutor {
 
+    private final Map<ProxiedPlayer, BungeePlayer> cachedPlayers = new WeakHashMap<>();
+
     @Override
     public Optional<APIPlayer> getPlayer(String name) {
         ProxiedPlayer player = BungeeCord.getInstance().getPlayer(name);
 
         if(player == null) return Optional.empty();
 
-        return Optional.of(new BungeePlayer(player));
+        return Optional.of(cachedPlayers.computeIfAbsent(player, BungeePlayer::new));
     }
 
     @Override
@@ -27,11 +27,13 @@ public class BungeePlayerExecutor implements PlayerExecutor {
 
         if(player == null) return Optional.empty();
 
-        return Optional.of(new BungeePlayer(player));
+        return Optional.of(cachedPlayers.computeIfAbsent(player, BungeePlayer::new));
     }
 
     @Override
     public List<APIPlayer> getOnlinePlayers() {
-        return BungeeCord.getInstance().getPlayers().stream().map(BungeePlayer::new).collect(Collectors.toList());
+        return BungeeCord.getInstance().getPlayers().stream()
+                .map(pl -> cachedPlayers.computeIfAbsent(pl, BungeePlayer::new))
+                .collect(Collectors.toList());
     }
 }

Bungee/src/main/java/dev/brighten/antivpn/bungee/BungeePlugin.java

@@ -2,6 +2,7 @@ package dev.brighten.antivpn.bungee;
 
 import dev.brighten.antivpn.AntiVPN;
 import dev.brighten.antivpn.bungee.util.Config;
+import dev.brighten.antivpn.bungee.util.ConfigDefault;
 import dev.brighten.antivpn.command.Command;
 import lombok.Getter;
 import lombok.val;
@@ -12,7 +13,11 @@ import net.md_5.bungee.api.chat.BaseComponent;
 import net.md_5.bungee.api.chat.ComponentBuilder;
 import net.md_5.bungee.api.chat.TextComponent;
 import net.md_5.bungee.api.plugin.Plugin;
+import org.bstats.bungeecord.Metrics;
+import org.bstats.charts.SingleLineChart;
 
+import java.util.Arrays;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.IntStream;
 
 public class BungeePlugin extends Plugin {
@@ -21,8 +26,9 @@ public class BungeePlugin extends Plugin {
 
     @Getter
     private Config config;
+    private SingleLineChart vpnDetections, ipsChecked;
 
-    private static BaseComponent[] noPermission = new ComponentBuilder("No permission").color(ChatColor.RED)
+    private static final BaseComponent[] noPermission = new ComponentBuilder("No permission").color(ChatColor.RED)
             .create();
 
     @Override
@@ -30,11 +36,26 @@ public class BungeePlugin extends Plugin {
         pluginInstance = this;
 
         //Setting up config
+        BungeeCord.getInstance().getLogger().info("Loading config...");
         config = new Config();
 
+
         //Loading plugin
+        BungeeCord.getInstance().getLogger().info("Starting AntiVPN services...");
         AntiVPN.start(new BungeeConfig(), new BungeeListener(), new BungeePlayerExecutor());
 
+        if(AntiVPN.getInstance().getConfig().metrics()) {
+            BungeeCord.getInstance().getLogger().info("Starting bStats metrics...");
+            Metrics metrics = new Metrics(this, 12616);
+            metrics.addCustomChart(vpnDetections = new SingleLineChart("vpn_detections",
+                    () -> AntiVPN.getInstance().detections));
+            metrics.addCustomChart(ipsChecked = new SingleLineChart("ips_checked",
+                    () -> AntiVPN.getInstance().checked));
+            BungeeCord.getInstance().getScheduler().schedule(this,
+                    () -> AntiVPN.getInstance().checked = AntiVPN.getInstance().detections = 0,
+                    10, 10, TimeUnit.MINUTES);
+        }
+
         //TODO Add command functionality for BungeeCord
         for (Command command : AntiVPN.getInstance().getCommands()) {
             BungeeCord.getInstance().getPluginManager().registerCommand(pluginInstance, new net.md_5.bungee.api.plugin
@@ -52,7 +73,8 @@ public class BungeePlugin extends Plugin {
 
                     if(children.length > 0 && args.length > 0) {
                         for (Command child : children) {
-                            if(child.name().equalsIgnoreCase(args[0])) {
+                            if(child.name().equalsIgnoreCase(args[0]) || Arrays.stream(child.aliases())
+                                    .anyMatch(alias -> alias.equalsIgnoreCase(args[0]))) {
                                 if(!sender.hasPermission("antivpn.command.*")
                                         && !sender.hasPermission(child.permission())) {
                                     sender.sendMessage(noPermission);
@@ -78,6 +100,17 @@ public class BungeePlugin extends Plugin {
                 }
             });
         }
+
+        BungeeCord.getInstance().getLogger().info("Getting strings...");
+        AntiVPN.getInstance().getMessageHandler().initStrings(vpnString -> new ConfigDefault<>
+                (vpnString.getDefaultMessage(), "messages." + vpnString.getKey(), BungeePlugin.pluginInstance)
+                .get());
+        //TODO Finish system before implementing on startup
+        /*BungeeCord.getInstance().getLogger().info("Getting strings...");
+        AntiVPN.getInstance().getMessageHandler().initStrings(vpnString -> new ConfigDefault<>
+                (vpnString.getDefaultMessage(), "messages." + vpnString.getKey(), BungeePlugin.pluginInstance)
+                .get());
+        AntiVPN.getInstance().getMessageHandler().reloadStrings();*/
     }
 
     @Override

Common/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>AntiVPN</artifactId>
         <groupId>dev.brighten.antivpn</groupId>
-        <version>1.1.1</version>
+        <version>1.5.0</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -16,4 +16,25 @@
         <maven.compiler.target>8</maven.compiler.target>
     </properties>
 
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.7.0</version>
+                <configuration>
+                    <source>8</source>
+                    <target>8</target>
+                    <compilerArgument>-XDignore.symbol.file</compilerArgument>
+                </configuration>
+            </plugin>
+        </plugins>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+                <filtering>true</filtering>
+            </resource>
+        </resources>
+    </build>
+
 </project>

Common/src/main/java/dev/brighten/antivpn/AntiVPN.java

@@ -5,7 +5,9 @@ import dev.brighten.antivpn.api.VPNConfig;
 import dev.brighten.antivpn.api.VPNExecutor;
 import dev.brighten.antivpn.command.Command;
 import dev.brighten.antivpn.command.impl.AntiVPNCommand;
-import dev.brighten.antivpn.command.impl.LookupCommand;
+import dev.brighten.antivpn.database.VPNDatabase;
+import dev.brighten.antivpn.database.sql.MySqlVPN;
+import dev.brighten.antivpn.message.MessageHandler;
 import dev.brighten.antivpn.utils.VPNResponse;
 import dev.brighten.antivpn.utils.json.JSONException;
 import dev.brighten.antivpn.utils.json.JSONObject;
@@ -26,7 +28,10 @@ public class AntiVPN {
     private VPNConfig config;
     private VPNExecutor executor;
     private PlayerExecutor playerExecutor;
+    private VPNDatabase database;
+    private MessageHandler messageHandler;
     private List<Command> commands = new ArrayList<>();
+    public int detections, checked;
 
     public static void start(VPNConfig config, VPNExecutor executor, PlayerExecutor playerExecutor) {
         //Initializing
@@ -40,12 +45,46 @@ public class AntiVPN {
         INSTANCE.executor.registerListeners();
         INSTANCE.config.update();
 
+        INSTANCE.messageHandler = new MessageHandler();
+
+        switch(INSTANCE.config.getDatabaseType().toLowerCase()) {
+            case "mysql":
+            case "sql":{
+                System.out.println("Using databaseType MySQL...");
+                INSTANCE.database = new MySqlVPN();
+                INSTANCE.database.init();
+                break;
+            }
+            case "mongo":
+            case "mongodb":
+            case "mongod": {
+                System.out.println("We currently do not support Mongo, but this is coming in future updates.");
+                break;
+            }
+            default: {
+                System.out.println("Could not find database type \"" + INSTANCE.config.getDatabaseType() + "\". " +
+                        "Options: [MySQL]");
+                break;
+            }
+        }
+
         //Registering commands
         INSTANCE.registerCommands();
+
+        //Turning on alerts of players who are already online.
+        playerExecutor.getOnlinePlayers().forEach(player -> {
+            //We want to make sure they even have permission to see alerts before we make a bunch
+            //of unnecessary database queries.
+            if(player.hasPermission("antivpn.command.alerts")) {
+                //Running database check for enabled alerts.
+                INSTANCE.database.alertsState(player.getUuid(), player::setAlertsEnabled);
+            }
+        });
     }
 
     public void stop() {
         executor.shutdown();
+        if(database != null) database.shutdown();
     }
 
     public static AntiVPN getInstance() {
@@ -65,6 +104,5 @@ public class AntiVPN {
 
     private void registerCommands() {
         commands.add(new AntiVPNCommand());
-        commands.add(new LookupCommand());
     }
 }

Common/src/main/java/dev/brighten/antivpn/api/APIPlayer.java

@@ -1,21 +1,39 @@
 package dev.brighten.antivpn.api;
 
+import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.message.VpnString;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
+import lombok.Setter;
 
 import java.net.InetAddress;
 import java.util.UUID;
 
 @Getter
-@RequiredArgsConstructor
 public abstract class APIPlayer {
     private final UUID uuid;
     private final String name;
     private final InetAddress ip;
+    private boolean alertsEnabled;
+
+    public APIPlayer(UUID uuid, String name, InetAddress ip) {
+        this.uuid = uuid;
+        this.name = name;
+        this.ip = ip;
+    }
 
     public abstract void sendMessage(String message);
 
     public abstract void kickPlayer(String reason);
 
     public abstract boolean hasPermission(String permission);
+
+    public void setAlertsEnabled(boolean alertsEnabled) {
+        this.alertsEnabled = alertsEnabled;
+    }
+
+    public void updateAlertsState() {
+        //Updating into database so its synced across servers and saved on logout.
+        AntiVPN.getInstance().getDatabase().updateAlertsState(uuid, alertsEnabled);
+    }
 }

Common/src/main/java/dev/brighten/antivpn/api/VPNConfig.java

@@ -1,5 +1,7 @@
 package dev.brighten.antivpn.api;
 
+import java.util.List;
+
 public interface VPNConfig {
 
     String getLicense();
@@ -8,6 +10,34 @@ public interface VPNConfig {
 
     String getKickString();
 
+    String alertMessage();
+
+    boolean alertToStaff();
+
+    boolean runCommands();
+
+    List<String> commands();
+
+    boolean kickPlayersOnDetect();
+
+    List<String> getPrefixWhitelists();
+
+    boolean isDatabaseEnabled();
+
+    String getDatabaseType();
+
+    String getDatabaseName();
+
+    String getUsername();
+
+    String getPassword();
+
+    String getIp();
+
+    int getPort();
+
+    boolean metrics();
+
     void update();
 
 }

Common/src/main/java/dev/brighten/antivpn/api/VPNExecutor.java

@@ -3,18 +3,21 @@ package dev.brighten.antivpn.api;
 import dev.brighten.antivpn.AntiVPN;
 import dev.brighten.antivpn.utils.VPNResponse;
 import dev.brighten.antivpn.utils.json.JSONException;
+import lombok.Getter;
 
 import java.io.IOException;
-import java.util.HashMap;
-import java.util.Map;
+import java.util.*;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
 import java.util.function.Consumer;
 
 public abstract class VPNExecutor {
     public static ExecutorService threadExecutor = Executors.newSingleThreadExecutor();
 
     private static final Map<String, VPNResponse> responseCache = new HashMap<>();
+    @Getter
+    private final Set<UUID> whitelisted = Collections.synchronizedSet(new HashSet<>());
 
     public abstract void registerListeners();
 
@@ -26,13 +29,32 @@ public abstract class VPNExecutor {
 
     public abstract void shutdown();
 
+    public boolean isWhitelisted(UUID uuid) {
+        return whitelisted.contains(uuid);
+    }
+
     public void checkIp(String ip, boolean cachedResults, Consumer<VPNResponse> result) {
         threadExecutor.execute(() -> result.accept(responseCache.compute(ip, (key, val) -> {
             if(val == null) {
-                try {
-                    return AntiVPN.getVPNResponse(ip, AntiVPN.getInstance().getConfig().getLicense(), cachedResults);
-                } catch (JSONException | IOException e) {
-                    e.printStackTrace();
+                Optional<VPNResponse> cachedRes = AntiVPN.getInstance().getDatabase().getStoredResponse(ip);
+
+                if(cachedRes.isPresent()) return cachedRes.get();
+                else {
+                    try {
+                        VPNResponse response =  AntiVPN
+                                .getVPNResponse(ip, AntiVPN.getInstance().getConfig().getLicense(), cachedResults);
+
+                        if(response.isSuccess()) {
+                            AntiVPN.getInstance().getDatabase().cacheResponse(response);
+                        } else {
+                            System.out.println("Query to VPN API failed! Reason: " + response.getFailureReason());
+                        }
+
+                        return response;
+                    } catch (JSONException | IOException e) {
+                        System.out.println("Query to VPN API failed! Reason: Java Exception");
+                        e.printStackTrace();
+                    }
                 }
             }
 
@@ -43,10 +65,25 @@ public abstract class VPNExecutor {
     public VPNResponse checkIp(String ip, boolean cachedResults) {
         return responseCache.compute(ip, (key, val) -> {
             if(val == null) {
-                try {
-                    return AntiVPN.getVPNResponse(ip, AntiVPN.getInstance().getConfig().getLicense(), cachedResults);
-                } catch (JSONException | IOException e) {
-                    e.printStackTrace();
+                Optional<VPNResponse> cachedRes = AntiVPN.getInstance().getDatabase().getStoredResponse(ip);
+
+                if(cachedRes.isPresent()) return cachedRes.get();
+                else {
+                    try {
+                        VPNResponse response =  AntiVPN
+                                .getVPNResponse(ip, AntiVPN.getInstance().getConfig().getLicense(), cachedResults);
+
+                        if(response.isSuccess()) {
+                            threadExecutor.execute(() -> AntiVPN.getInstance().getDatabase().cacheResponse(response));
+                        } else {
+                            System.out.println("Query to VPN API failed! Reason: " + response.getFailureReason());
+                        }
+
+                        return response;
+                    } catch (JSONException | IOException e) {
+                        System.out.println("Query to VPN API failed! Reason: Java Exception");
+                        e.printStackTrace();
+                    }
                 }
             }
 

Common/src/main/java/dev/brighten/antivpn/command/CommandExecutor.java

@@ -1,8 +1,15 @@
 package dev.brighten.antivpn.command;
 
+import dev.brighten.antivpn.api.APIPlayer;
+import dev.brighten.antivpn.api.PlayerExecutor;
+
+import java.util.Optional;
+
 public interface CommandExecutor {
 
     void sendMessage(String message);
     boolean hasPermission(String permission);
+    Optional<APIPlayer> getPlayer();
+    boolean isPlayer();
 
 }

Common/src/main/java/dev/brighten/antivpn/command/impl/AlertsCommand.java

@@ -0,0 +1,68 @@
+package dev.brighten.antivpn.command.impl;
+
+import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.api.APIPlayer;
+import dev.brighten.antivpn.command.Command;
+import dev.brighten.antivpn.command.CommandExecutor;
+import dev.brighten.antivpn.message.VpnString;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.Optional;
+
+public class AlertsCommand extends Command {
+    @Override
+    public String permission() {
+        return "antivpn.command.alerts";
+    }
+
+    @Override
+    public String name() {
+        return "alerts";
+    }
+
+    @Override
+    public String[] aliases() {
+        return new String[] {"valerts", "vpnalerts"};
+    }
+
+    @Override
+    public String description() {
+        return "toggle VPN use alerts";
+    }
+
+    @Override
+    public String usage() {
+        return "";
+    }
+
+    @Override
+    public String parent() {
+        return "antivpn";
+    }
+
+    @Override
+    public Command[] children() {
+        return new Command[0];
+    }
+
+    @Override
+    public String execute(CommandExecutor executor, String[] args) {
+        Optional<APIPlayer> pgetter = executor.getPlayer();
+        if(!pgetter.isPresent()) return AntiVPN.getInstance().getMessageHandler()
+                .getString("command-misc-playerRequired").getMessage();
+
+        APIPlayer player = pgetter.get();
+
+        player.setAlertsEnabled(!player.isAlertsEnabled());
+        player.updateAlertsState();
+
+        return AntiVPN.getInstance().getMessageHandler().getString("command-alerts-toggled")
+                .getFormattedMessage(new VpnString.Var<>("state", player.isAlertsEnabled()));
+    }
+
+    @Override
+    public List<String> tabComplete(CommandExecutor executor, String alias, String[] args) {
+        return Collections.emptyList();
+    }
+}

Common/src/main/java/dev/brighten/antivpn/command/impl/AllowlistCommand.java

@@ -0,0 +1,113 @@
+package dev.brighten.antivpn.command.impl;
+
+import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.api.APIPlayer;
+import dev.brighten.antivpn.command.Command;
+import dev.brighten.antivpn.command.CommandExecutor;
+
+import java.util.*;
+import java.util.stream.Collectors;
+
+public class AllowlistCommand extends Command {
+
+    private static final String[] secondArgs = new String[] {"add", "remove"};
+
+    @Override
+    public String permission() {
+        return "antivpn.command.allowlist";
+    }
+
+    @Override
+    public String name() {
+        return "allowlist";
+    }
+
+    @Override
+    public String[] aliases() {
+        return new String[] {"whitelist"};
+    }
+
+    @Override
+    public String description() {
+        return "Add/remove players to/from exemption list.";
+    }
+
+    @Override
+    public String usage() {
+        return "<add/remove> <player/uuid>";
+    }
+
+    @Override
+    public String parent() {
+        return "antivpn";
+    }
+
+    @Override
+    public Command[] children() {
+        return new Command[0];
+    }
+
+    @Override
+    public String execute(CommandExecutor executor, String[] args) {
+        if(args.length == 0 || Arrays.stream(secondArgs).noneMatch(arg -> arg.equalsIgnoreCase(args[0]))) {
+            return "&cUsage: /antivpn allowlist <add/remove> <player>";
+        }
+
+        if(args.length == 1)
+            return "&cYou have to provide a player to allow or deny exemption.";
+
+        boolean databaseEnabled = AntiVPN.getInstance().getConfig().isDatabaseEnabled();
+
+        if(!databaseEnabled) executor.sendMessage("&cThe database is currently not setup, " +
+                "so any changes here will disappear after a restart.");
+
+        UUID uuid = null;
+        try {
+            uuid = UUID.fromString(args[1]);
+        } catch(IllegalArgumentException e) {
+            Optional<APIPlayer> player = AntiVPN.getInstance().getPlayerExecutor().getPlayer(args[1]);
+
+            if(!player.isPresent()) {
+                return "&cThe player \"" + args[1] + "\" is not online, so please provide a UUID.";
+            }
+
+            uuid = player.get().getUuid();
+        }
+
+        if(!databaseEnabled) {
+            if(args[0].equalsIgnoreCase("add")) {
+                AntiVPN.getInstance().getExecutor().getWhitelisted().add(uuid);
+                return String.format("&aAdded &6%s &auuid to the exemption allowlist.", uuid.toString());
+            } else {
+                AntiVPN.getInstance().getExecutor().getWhitelisted().remove(uuid);
+                return String.format("&cRemoved &6%s &cuuid from the exemption allowlist.", uuid.toString());
+            }
+        } else {
+            if(args[0].equalsIgnoreCase("add")) {
+                AntiVPN.getInstance().getDatabase().setWhitelisted(uuid, true);
+                return String.format("&aAdded &6%s &auuid to the exemption allowlist.", uuid.toString());
+            } else {
+                AntiVPN.getInstance().getDatabase().setWhitelisted(uuid, false);
+                return String.format("&cRemoved &6%s &cuuid from the exemption allowlist.", uuid.toString());
+            }
+        }
+    }
+
+    @Override
+    public List<String> tabComplete(CommandExecutor executor, String alias, String[] args) {
+        switch(args.length) {
+            case 1: {
+                return Arrays.stream(secondArgs)
+                        .filter(narg -> narg.toLowerCase().startsWith(args[0].toLowerCase()))
+                        .collect(Collectors.toList());
+            }
+            case 2: {
+                return AntiVPN.getInstance().getPlayerExecutor().getOnlinePlayers().stream()
+                        .map(APIPlayer::getName)
+                        .filter(name -> name.toLowerCase().startsWith(args[1].toLowerCase()))
+                        .collect(Collectors.toList());
+            }
+        }
+        return Collections.emptyList();
+    }
+}

Common/src/main/java/dev/brighten/antivpn/command/impl/AntiVPNCommand.java

@@ -4,7 +4,6 @@ import dev.brighten.antivpn.AntiVPN;
 import dev.brighten.antivpn.command.Command;
 import dev.brighten.antivpn.command.CommandExecutor;
 import dev.brighten.antivpn.utils.StringUtil;
-import jdk.nashorn.internal.lookup.Lookup;
 
 import java.util.*;
 import java.util.stream.Collectors;
@@ -42,7 +41,7 @@ public class AntiVPNCommand extends Command {
 
     @Override
     public Command[] children() {
-        return new Command[] {new LookupCommand()};
+        return new Command[] {new LookupCommand(), new AllowlistCommand(), new AlertsCommand()};
     }
 
     @Override
@@ -52,11 +51,17 @@ public class AntiVPNCommand extends Command {
         messages.add(StringUtil.line("&8"));
         messages.add("&6&lAntiVPN Help Page");
         messages.add("");
-        for (Command child : AntiVPN.getInstance().getCommands()) {
+        for (Command cmd : AntiVPN.getInstance().getCommands()) {
+            messages.add(String.format("&8/&f%s &8- &7&o%s", "&7" + cmd.parent()
+                    + (cmd.parent().length() > 0 ? " " : "") + "&f" + cmd.name() + " &7"
+                            + cmd.usage(), cmd.description()));
+        }
+        for (Command child : children()) {
             messages.add(String.format("&8/&f%s &8- &7&o%s", "&7" + child.parent()
                     + (child.parent().length() > 0 ? " " : "") + "&f" + child.name() + " &7"
-                            + child.usage(), description()));
+                    + child.usage(), child.description()));
         }
+
         messages.add(StringUtil.line("&8"));
 
         return String.join("\n", messages);

Common/src/main/java/dev/brighten/antivpn/database/VPNDatabase.java

@@ -0,0 +1,32 @@
+package dev.brighten.antivpn.database;
+
+import dev.brighten.antivpn.utils.VPNResponse;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
+import java.util.function.Consumer;
+
+public interface VPNDatabase {
+    Optional<VPNResponse> getStoredResponse(String ip);
+
+    void cacheResponse(VPNResponse toCache);
+
+    boolean isWhitelisted(UUID uuid);
+
+    void setWhitelisted(UUID uuid, boolean whitelisted);
+
+    List<UUID> getAllWhitelisted();
+
+    void getStoredResponseAsync(String ip, Consumer<Optional<VPNResponse>> result);
+
+    void isWhitelistedAsync(UUID uuid, Consumer<Boolean> result);
+
+    void alertsState(UUID uuid, Consumer<Boolean> result);
+
+    void updateAlertsState(UUID uuid, boolean state);
+
+    void init();
+
+    void shutdown();
+}

Common/src/main/java/dev/brighten/antivpn/database/sql/MySqlVPN.java

@@ -0,0 +1,268 @@
+package dev.brighten.antivpn.database.sql;
+
+import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.api.VPNExecutor;
+import dev.brighten.antivpn.database.VPNDatabase;
+import dev.brighten.antivpn.database.sql.utils.MySQL;
+import dev.brighten.antivpn.database.sql.utils.Query;
+import dev.brighten.antivpn.utils.VPNResponse;
+import lombok.SneakyThrows;
+
+import java.sql.*;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+import java.util.function.Consumer;
+
+public class MySqlVPN implements VPNDatabase {
+
+    private Thread whitelistedThread;
+
+    public MySqlVPN() {
+        whitelistedThread = new Thread(() -> {
+            try {
+                Thread.sleep(TimeUnit.SECONDS.toMillis(8));
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+            while (true) {
+                // Updating from database
+                if (AntiVPN.getInstance().getConfig().isDatabaseEnabled()) {
+                    AntiVPN.getInstance().getExecutor().getWhitelisted().clear();
+                    AntiVPN.getInstance().getExecutor().getWhitelisted()
+                            .addAll(AntiVPN.getInstance().getDatabase().getAllWhitelisted());
+                }
+                try {
+                    Thread.sleep(TimeUnit.SECONDS.toMillis(4));
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
+        });
+
+        whitelistedThread.start();
+    }
+
+    @Override
+    public Optional<VPNResponse> getStoredResponse(String ip) {
+        if (!AntiVPN.getInstance().getConfig().isDatabaseEnabled()|| MySQL.isClosed())
+            return Optional.empty();
+
+        ResultSet rs = Query.prepare("select * from `responses` where `ip` = ? limit 1").append(ip).executeQuery();
+
+        try {
+            if (rs != null && rs.next()) {
+                VPNResponse response = new VPNResponse(rs.getString("asn"), rs.getString("ip"),
+                        rs.getString("countryName"), rs.getString("countryCode"),
+                        rs.getString("city"), rs.getString("timeZone"),
+                        rs.getString("method"), rs.getString("isp"), "N/A",
+                        rs.getBoolean("proxy"), rs.getBoolean("cached"), true,
+                        rs.getDouble("latitude"), rs.getDouble("longitude"),
+                        System.currentTimeMillis(), -1);
+                return Optional.of(response);
+            }
+        } catch (SQLException throwables) {
+            throwables.printStackTrace();
+        }
+
+        return Optional.empty();
+    }
+
+    /*
+     * Query.
+     * prepare("create table if not exists `responses` (`ip` varchar(45) not null, "
+     * +
+     * "`countryName` varchar(64), `countryCode` varchar(10), `city` varchar(64), `timeZone` varchar(64), "
+     * +
+     * "`method` varchar(32), `isp` varchar(32), `proxy` boolean, `cached` boolean "
+     * + "`latitude` double, `longitude` double)");
+     */
+    @Override
+    public void cacheResponse(VPNResponse toCache) {
+        if (!AntiVPN.getInstance().getConfig().isDatabaseEnabled() || MySQL.isClosed())
+            return;
+
+        Query.prepare("insert into `responses` (`ip`,`asn`,`countryName`,`countryCode`,`city`,`timeZone`,"
+                + "`method`,`isp`,`proxy`,`cached`,`inserted`,`latitude`,`longitude`) values (?,?,?,?,?,?,?,?,?,?,?,?,?)")
+                .append(toCache.getIp()).append(toCache.getAsn()).append(toCache.getCountryName())
+                .append(toCache.getCountryCode()).append(toCache.getCity()).append(toCache.getTimeZone())
+                .append(toCache.getMethod()).append(toCache.getIsp()).append(toCache.isProxy())
+                .append(toCache.isCached()).append(new Timestamp(System.currentTimeMillis()))
+                .append(toCache.getLatitude()).append(toCache.getLongitude()).execute();
+    }
+
+    @SneakyThrows
+    @Override
+    public boolean isWhitelisted(UUID uuid) {
+        if (!AntiVPN.getInstance().getConfig().isDatabaseEnabled() || MySQL.isClosed())
+            return false;
+        ResultSet set = Query.prepare("select uuid from `whitelisted` where `uuid` = ? limit 1").append(uuid.toString())
+                .executeQuery();
+
+        return set != null && set.next() && set.getString("uuid") != null;
+    }
+
+    @Override
+    public void setWhitelisted(UUID uuid, boolean whitelisted) {
+        if(MySQL.isClosed()) return;
+
+        if (whitelisted) {
+            if (!isWhitelisted(uuid)) {
+                Query.prepare("insert into `whitelisted` (`uuid`) values (?)").append(uuid.toString()).execute();
+            }
+            AntiVPN.getInstance().getExecutor().getWhitelisted().add(uuid);
+        } else {
+            Query.prepare("delete from `whitelisted` where `uuid` = ?").append(uuid.toString()).execute();
+            AntiVPN.getInstance().getExecutor().getWhitelisted().remove(uuid);
+        }
+    }
+
+    @Override
+    public List<UUID> getAllWhitelisted() {
+        List<UUID> uuids = new ArrayList<>();
+
+        if(MySQL.isClosed()) return uuids;
+
+        ResultSet set = Query.prepare("select uuid from `whitelisted`").executeQuery();
+
+        try {
+            while (set.next()) {
+                uuids.add(UUID.fromString(set.getString("uuid")));
+            }
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+        return uuids;
+    }
+
+    @Override
+    public void getStoredResponseAsync(String ip, Consumer<Optional<VPNResponse>> result) {
+        if(MySQL.isClosed()) return;
+
+        VPNExecutor.threadExecutor.execute(() -> result.accept(getStoredResponse(ip)));
+    }
+
+    @Override
+    public void isWhitelistedAsync(UUID uuid, Consumer<Boolean> result) {
+        if(MySQL.isClosed()) return;
+
+        VPNExecutor.threadExecutor.execute(() -> result.accept(isWhitelisted(uuid)));
+    }
+
+    @Override
+    public void alertsState(UUID uuid, Consumer<Boolean> result) {
+        if(MySQL.isClosed()) return;
+
+        VPNExecutor.threadExecutor.execute(() -> {
+            ResultSet set = Query.prepare("select * from `alerts` where `uuid` = ? limit 1")
+                    .append(uuid.toString()).executeQuery();
+
+            try {
+                result.accept(set != null && set.next() && set.getString("uuid") != null);
+            } catch (SQLException e) {
+                e.printStackTrace();
+                result.accept(false);
+            }
+        });
+    }
+
+    @Override
+    public void updateAlertsState(UUID uuid, boolean enabled) {
+        if(MySQL.isClosed()) return;
+
+        if(enabled) {
+            //We want to make sure there isn't already a uuid inserted to prevent double insertions
+            alertsState(uuid, alreadyEnabled -> { //No need to make another thread execute, already async
+                if(!alreadyEnabled) {
+                    Query.prepare("insert into `alerts` (`uuid`) values (?)").append(uuid.toString())
+                            .execute();
+                } //No need to insert again of already enabled
+            });
+            //Removing any uuid from the alerts table will disable alerts globally.
+        } else VPNExecutor.threadExecutor.execute(() ->
+                Query.prepare("delete from `alerts` where `uuid` = ?")
+                        .append(uuid.toString())
+                        .execute());
+    }
+
+    @Override
+    public void init() {
+        if (!AntiVPN.getInstance().getConfig().isDatabaseEnabled())
+            return;
+        System.out.println("Initializing MySQL...");
+        MySQL.init();
+
+        System.out.println("Creating tables...");
+
+        //Running check for old table types to update
+        oldTableCheck: {
+            Query.prepare("select `DATA_TYPE` from INFORMATION_SCHEMA.COLUMNS " +
+                    "WHERE table_name = 'responses' AND COLUMN_NAME = 'isp';").execute(set -> {
+                        if(set.getObject("DATA_TYPE").toString().contains("varchar")) {
+                            System.out.println("Using old database format for storing responses! " +
+                                    "Dropping table and creating a new one...");
+                            if(Query.prepare("drop table `responses`").execute() > 0) {
+                                System.out.println("Successfully dropped table!");
+                            }
+                        }
+            });
+        }
+
+        Query.prepare("create table if not exists `whitelisted` (`uuid` varchar(36) not null)").execute();
+        Query.prepare("create table if not exists `responses` (`ip` varchar(45) not null, `asn` varchar(12),"
+                + "`countryName` text, `countryCode` varchar(10), `city` text, `timeZone` varchar(64), "
+                + "`method` varchar(32), `isp` text, `proxy` boolean, `cached` boolean, `inserted` timestamp,"
+                + "`latitude` double, `longitude` double)").execute();
+        Query.prepare("create table if not exists `alerts` (`uuid` varchar(36) not null)").execute();
+
+        System.out.println("Creating indexes...");
+        try {
+            // Ref:
+            // https://dba.stackexchange.com/questions/24531/mysql-create-index-if-not-exists
+            String query = "SELECT COUNT(1) IndexExists FROM INFORMATION_SCHEMA.STATISTICS WHERE table_schema=DATABASE() AND table_name='whitelisted' AND index_name='uuid_1';";
+            ResultSet rs = Query.prepare(query).executeQuery();
+            int id = 0;
+            while (rs.next()) {
+                id = rs.getInt("IndexExists");
+            }
+            if (id == 0) {
+                Query.prepare("create index `uuid_1` on `whitelisted` (`uuid`)").execute();
+            }
+            id = 0;
+            query = "SELECT COUNT(1) IndexExists FROM INFORMATION_SCHEMA.STATISTICS WHERE table_schema=DATABASE() AND table_name='responses' AND index_name='ip_1';";
+            rs = Query.prepare(query).executeQuery();
+            while (rs.next()) {
+                id = rs.getInt("IndexExists");
+            }
+            if (id == 0) {
+                Query.prepare("create index `ip_1` on `responses` (`ip`)").execute();
+            }
+            id = 0;
+            query = "SELECT COUNT(1) IndexExists FROM INFORMATION_SCHEMA.STATISTICS WHERE table_schema=DATABASE() AND table_name='responses' AND index_name='proxy_1';";
+            rs = Query.prepare(query).executeQuery();
+            while (rs.next()) {
+                id = rs.getInt("IndexExists");
+            }
+            if (id == 0) {
+                Query.prepare("create index `proxy_1` on `responses` (`proxy`)").execute();
+            }
+            id = 0;
+            query = "SELECT COUNT(1) IndexExists FROM INFORMATION_SCHEMA.STATISTICS WHERE table_schema=DATABASE() AND table_name='responses' AND index_name='inserted_1';";
+            rs = Query.prepare(query).executeQuery();
+            while (rs.next()) {
+                id = rs.getInt("IndexExists");
+            }
+            if (id == 0) {
+                Query.prepare("create index `inserted_1` on `responses` (`inserted`)").execute();
+            }
+        } catch (Exception e) {
+            System.err.println("MySQL Excepton created" + e.getMessage());
+        }
+    }
+
+    @Override
+    public void shutdown() {
+        if (!AntiVPN.getInstance().getConfig().isDatabaseEnabled())
+            return;
+        MySQL.shutdown();
+    }
+}

Common/src/main/java/dev/brighten/antivpn/database/sql/utils/ExecutableStatement.java

@@ -0,0 +1,138 @@
+package dev.brighten.antivpn.database.sql.utils;
+
+import dev.brighten.antivpn.utils.MiscUtils;
+import lombok.SneakyThrows;
+
+import java.sql.*;
+import java.util.UUID;
+
+public class ExecutableStatement {
+    private PreparedStatement statement;
+    private int pos = 1;
+
+    public ExecutableStatement(PreparedStatement statement) {
+        this.statement = statement;
+    }
+
+    @SneakyThrows
+    public Integer execute() {
+        try {
+            return statement.executeUpdate();
+        } finally {
+            MiscUtils.close(statement);
+        }
+    }
+
+    @SneakyThrows
+    public void execute(ResultSetIterator iterator) {
+        ResultSet rs = null;
+        try {
+            rs = statement.executeQuery();
+            while (rs.next()) iterator.next(rs);
+        } finally {
+            MiscUtils.close(statement, rs);
+        }
+    }
+
+    @SneakyThrows
+    public void executeSingle(ResultSetIterator iterator) {
+        ResultSet rs = null;
+        try {
+            rs = statement.executeQuery();
+            if (rs.next()) iterator.next(rs);
+            else iterator.next(null);
+        } finally {
+            MiscUtils.close(statement, rs);
+        }
+    }
+
+    @SneakyThrows
+    public ResultSet executeQuery() {
+        return statement.executeQuery();
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(Object obj) {
+        statement.setObject(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(String obj) {
+        statement.setString(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(UUID uuid) {
+        if (uuid != null) statement.setString(pos++, uuid.toString().replace("-", ""));
+        else statement.setString(pos++, null);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(Array obj) {
+        statement.setArray(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(Integer obj) {
+        statement.setInt(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(Short obj) {
+        statement.setShort(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(Long obj) {
+        statement.setLong(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(Float obj) {
+        statement.setFloat(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(Double obj) {
+        statement.setDouble(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(Date obj) {
+        statement.setDate(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(Timestamp obj) {
+        statement.setTimestamp(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(Time obj) {
+        statement.setTime(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(Blob obj) {
+        statement.setBlob(pos++, obj);
+        return this;
+    }
+
+    @SneakyThrows
+    public ExecutableStatement append(byte[] obj) {
+        statement.setBytes(pos++, obj);
+        return this;
+    }
+}

Common/src/main/java/dev/brighten/antivpn/database/sql/utils/MySQL.java

@@ -0,0 +1,63 @@
+package dev.brighten.antivpn.database.sql.utils;
+
+import dev.brighten.antivpn.AntiVPN;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+
+public class MySQL {
+    private static Connection conn;
+
+    public static void init() {
+        try {
+            if (conn == null || conn.isClosed()) {
+                conn = DriverManager.getConnection("jdbc:mysql://" + AntiVPN.getInstance().getConfig().getIp()
+                                + ":" + AntiVPN.getInstance().getConfig().getPort()
+                                + "/?useSSL=true&autoReconnect=true",
+                        AntiVPN.getInstance().getConfig().getUsername(),
+                        AntiVPN.getInstance().getConfig().getPassword());
+                conn.setAutoCommit(true);
+                Query.use(conn);
+                Query.prepare("CREATE DATABASE IF NOT EXISTS `"
+                        + AntiVPN.getInstance().getConfig().getDatabaseName() + "`").execute();
+                Query.prepare("USE `" + AntiVPN.getInstance().getConfig().getDatabaseName() + "`").execute();
+                System.out.println("Connection to MySQL has been established.");
+            }
+        } catch (Exception e) {
+            System.out.println("Failed to load mysql: " + e.getMessage());
+            e.printStackTrace();
+        }
+    }
+
+    public static void use() {
+        try {
+            init();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    public static void shutdown() {
+        try {
+            if(conn != null && !conn.isClosed()) {
+                conn.close();
+                conn = null;
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    public static boolean isClosed() {
+        if(conn == null)
+            return true;
+
+        try {
+            return conn.isClosed();
+        } catch (SQLException e) {
+            e.printStackTrace();
+            return true;
+        }
+    }
+}

Common/src/main/java/dev/brighten/antivpn/database/sql/utils/Query.java

@@ -0,0 +1,25 @@
+package dev.brighten.antivpn.database.sql.utils;
+
+import lombok.SneakyThrows;
+
+import java.sql.Connection;
+
+public class Query {
+    private static Connection conn;
+
+    public static void use(Connection conn) {
+        Query.conn = conn;
+    }
+
+    @SneakyThrows
+    public static ExecutableStatement prepare(String query) {
+        return new ExecutableStatement(conn.prepareStatement(query));
+    }
+
+
+
+    @SneakyThrows
+    public static ExecutableStatement prepare(String query, Connection con) {
+        return new ExecutableStatement(con.prepareStatement(query));
+    }
+}

Common/src/main/java/dev/brighten/antivpn/database/sql/utils/ResultSetIterator.java

@@ -0,0 +1,7 @@
+package dev.brighten.antivpn.database.sql.utils;
+
+import java.sql.ResultSet;
+
+public interface ResultSetIterator {
+    void next(ResultSet rs) throws Exception;
+}

Common/src/main/java/dev/brighten/antivpn/message/MessageHandler.java

@@ -0,0 +1,39 @@
+package dev.brighten.antivpn.message;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.function.Function;
+
+public class MessageHandler {
+    private final Map<String, VpnString> messages = new HashMap<>();
+
+    public VpnString getString(String key) {
+        if(!messages.containsKey(key)) {
+            throw new NullPointerException("There is no VpnString with the key \"" + key + "\"");
+        }
+
+        return messages.get(key);
+    }
+
+    public void reloadStrings() {
+        for (VpnString value : messages.values()) {
+            value.updateString();
+        }
+    }
+
+    public void clearStrings() {
+        messages.clear();
+    }
+
+    public void addString(VpnString string, Function<VpnString, String> getter) {
+        string.setConfigStringGetter(getter);
+        messages.put(string.getKey(), string);
+    }
+
+    public void initStrings(Function<VpnString, String> getter) {
+        addString(new VpnString("command-misc-playerRequired",
+                "&cYou must be a player to execute this command!"), getter);
+        addString(new VpnString("command-alerts-toggled",
+                "&7Your player proxy notifications have been set to: &e%state%"), getter);
+    }
+}

Common/src/main/java/dev/brighten/antivpn/message/VpnString.java

@@ -0,0 +1,58 @@
+package dev.brighten.antivpn.message;
+
+import dev.brighten.antivpn.api.APIPlayer;
+import lombok.*;
+
+import java.util.concurrent.Callable;
+import java.util.function.Consumer;
+import java.util.function.Function;
+
+@Getter
+public class VpnString {
+    private final String key;
+    private final String defaultMessage;
+    private String message;
+    @Setter
+    private Function<VpnString, String> configStringGetter;
+
+    public VpnString(String key, String defaultMessage) {
+        this.key = key;
+        this.defaultMessage = defaultMessage;
+        this.message = defaultMessage;
+    }
+
+    @SneakyThrows
+    public void updateString() {
+        if(configStringGetter == null) throw new Exception("The configStringGetter for string " + key + " is null!");
+
+        message = configStringGetter.apply(this);
+    }
+
+    public String getFormattedMessage(Var<String, Object>... replacements) {
+        String formatted = message;
+
+        for (Var<String, Object> replacement : replacements) {
+            formatted = formatted
+                    .replace("%" + replacement.getKey() + "%", replacement.getReplacement().toString());
+        }
+
+        return formatted;
+    }
+
+    public void sendMessage(APIPlayer player, Var<String, Object>... replacements) {
+        String formatted = message;
+
+        for (Var<String, Object> replacement : replacements) {
+            formatted = formatted
+                    .replace("%" + replacement.getKey() + "%", replacement.getReplacement().toString());
+        }
+        player.sendMessage(formatted);
+    }
+
+    @Getter
+    @RequiredArgsConstructor
+    public static class Var<S, O> {
+        private final String key;
+        private final Object replacement;
+    }
+}

Common/src/main/java/dev/brighten/antivpn/utils/MiscUtils.java

@@ -0,0 +1,23 @@
+package dev.brighten.antivpn.utils;
+
+import java.io.Closeable;
+
+public class MiscUtils {
+
+    public static void close(Closeable... closeables) {
+        try {
+            for (Closeable closeable : closeables) if (closeable != null) closeable.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    public static void close(AutoCloseable... closeables) {
+        try {
+            for (AutoCloseable closeable : closeables) if (closeable != null) closeable.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+}

Common/src/main/java/dev/brighten/antivpn/utils/VPNResponse.java

@@ -12,7 +12,7 @@ import lombok.Setter;
 @AllArgsConstructor
 @RequiredArgsConstructor
 public class VPNResponse {
-    private String asn, ip, countryName, countryCode, city, timeZone, method, isp;
+    private String asn, ip, countryName, countryCode, city, timeZone, method, isp, failureReason = "N/A";
     private boolean proxy, cached;
     private final boolean success;
     private double latitude, longitude;
@@ -41,14 +41,22 @@ public class VPNResponse {
     public static VPNResponse fromJson(String json) throws JSONException {
         JSONObject jsonObject = new JSONObject(json);
 
-        return new VPNResponse(jsonObject.getString("asn"), jsonObject.getString("ip"),
-                jsonObject.getString("countryName"), jsonObject.getString("countryCode"),
-                jsonObject.getString("city"), jsonObject.getString("timeZone"),
-                jsonObject.has("method") ? jsonObject.getString("method") : "N/A",
-                jsonObject.getString("isp"), jsonObject.getBoolean("proxy"),
-                jsonObject.getBoolean("cached"), jsonObject.getBoolean("success"),
-                jsonObject.getDouble("latitude"), jsonObject.getDouble("longitude"),
-                jsonObject.getLong("lastAccess"), jsonObject.getInt("queriesLeft"));
+        if(jsonObject.getBoolean("success")) {
+            return new VPNResponse(jsonObject.getString("asn"), jsonObject.getString("ip"),
+                    jsonObject.getString("countryName"), jsonObject.getString("countryCode"),
+                    jsonObject.getString("city"), jsonObject.getString("timeZone"),
+                    jsonObject.has("method") ? jsonObject.getString("method") : "N/A",
+                    jsonObject.getString("isp"), "N/A", jsonObject.getBoolean("proxy"),
+                    jsonObject.getBoolean("cached"), jsonObject.getBoolean("success"),
+                    jsonObject.getDouble("latitude"), jsonObject.getDouble("longitude"),
+                    jsonObject.getLong("lastAccess"), jsonObject.getInt("queriesLeft"));
+        } else {
+            VPNResponse response = new VPNResponse(false);
+
+            response.failureReason = jsonObject.getString("failureReason");
+
+            return response;
+        }
     }
 
     public static VPNResponse fromJson(JSONObject jsonObject) throws JSONException {
@@ -57,12 +65,16 @@ public class VPNResponse {
                     jsonObject.getString("countryName"), jsonObject.getString("countryCode"),
                     jsonObject.getString("city"), jsonObject.getString("timeZone"),
                     jsonObject.has("method") ? jsonObject.getString("method") : "N/A",
-                    jsonObject.getString("isp"), jsonObject.getBoolean("proxy"),
+                    jsonObject.getString("isp"), "N/A", jsonObject.getBoolean("proxy"),
                     jsonObject.getBoolean("cached"), jsonObject.getBoolean("success"),
                     jsonObject.getDouble("latitude"), jsonObject.getDouble("longitude"),
                     jsonObject.getLong("lastAccess"), jsonObject.getInt("queriesLeft"));
-        }
+        } else {
+            VPNResponse response = new VPNResponse(false);
 
-        return new VPNResponse(false);
+            response.failureReason = jsonObject.getString("failureReason");
+
+            return response;
+        }
     }
 }

LICENSE.md

@@ -0,0 +1,201 @@
+                                 Apache License
+                           Version 2.0, January 2004
+                        http://www.apache.org/licenses/
+
+   TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+   1. Definitions.
+
+      "License" shall mean the terms and conditions for use, reproduction,
+      and distribution as defined by Sections 1 through 9 of this document.
+
+      "Licensor" shall mean the copyright owner or entity authorized by
+      the copyright owner that is granting the License.
+
+      "Legal Entity" shall mean the union of the acting entity and all
+      other entities that control, are controlled by, or are under common
+      control with that entity. For the purposes of this definition,
+      "control" means (i) the power, direct or indirect, to cause the
+      direction or management of such entity, whether by contract or
+      otherwise, or (ii) ownership of fifty percent (50%) or more of the
+      outstanding shares, or (iii) beneficial ownership of such entity.
+
+      "You" (or "Your") shall mean an individual or Legal Entity
+      exercising permissions granted by this License.
+
+      "Source" form shall mean the preferred form for making modifications,
+      including but not limited to software source code, documentation
+      source, and configuration files.
+
+      "Object" form shall mean any form resulting from mechanical
+      transformation or translation of a Source form, including but
+      not limited to compiled object code, generated documentation,
+      and conversions to other media types.
+
+      "Work" shall mean the work of authorship, whether in Source or
+      Object form, made available under the License, as indicated by a
+      copyright notice that is included in or attached to the work
+      (an example is provided in the Appendix below).
+
+      "Derivative Works" shall mean any work, whether in Source or Object
+      form, that is based on (or derived from) the Work and for which the
+      editorial revisions, annotations, elaborations, or other modifications
+      represent, as a whole, an original work of authorship. For the purposes
+      of this License, Derivative Works shall not include works that remain
+      separable from, or merely link (or bind by name) to the interfaces of,
+      the Work and Derivative Works thereof.
+
+      "Contribution" shall mean any work of authorship, including
+      the original version of the Work and any modifications or additions
+      to that Work or Derivative Works thereof, that is intentionally
+      submitted to Licensor for inclusion in the Work by the copyright owner
+      or by an individual or Legal Entity authorized to submit on behalf of
+      the copyright owner. For the purposes of this definition, "submitted"
+      means any form of electronic, verbal, or written communication sent
+      to the Licensor or its representatives, including but not limited to
+      communication on electronic mailing lists, source code control systems,
+      and issue tracking systems that are managed by, or on behalf of, the
+      Licensor for the purpose of discussing and improving the Work, but
+      excluding communication that is conspicuously marked or otherwise
+      designated in writing by the copyright owner as "Not a Contribution."
+
+      "Contributor" shall mean Licensor and any individual or Legal Entity
+      on behalf of whom a Contribution has been received by Licensor and
+      subsequently incorporated within the Work.
+
+   2. Grant of Copyright License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      copyright license to reproduce, prepare Derivative Works of,
+      publicly display, publicly perform, sublicense, and distribute the
+      Work and such Derivative Works in Source or Object form.
+
+   3. Grant of Patent License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      (except as stated in this section) patent license to make, have made,
+      use, offer to sell, sell, import, and otherwise transfer the Work,
+      where such license applies only to those patent claims licensable
+      by such Contributor that are necessarily infringed by their
+      Contribution(s) alone or by combination of their Contribution(s)
+      with the Work to which such Contribution(s) was submitted. If You
+      institute patent litigation against any entity (including a
+      cross-claim or counterclaim in a lawsuit) alleging that the Work
+      or a Contribution incorporated within the Work constitutes direct
+      or contributory patent infringement, then any patent licenses
+      granted to You under this License for that Work shall terminate
+      as of the date such litigation is filed.
+
+   4. Redistribution. You may reproduce and distribute copies of the
+      Work or Derivative Works thereof in any medium, with or without
+      modifications, and in Source or Object form, provided that You
+      meet the following conditions:
+
+      (a) You must give any other recipients of the Work or
+          Derivative Works a copy of this License; and
+
+      (b) You must cause any modified files to carry prominent notices
+          stating that You changed the files; and
+
+      (c) You must retain, in the Source form of any Derivative Works
+          that You distribute, all copyright, patent, trademark, and
+          attribution notices from the Source form of the Work,
+          excluding those notices that do not pertain to any part of
+          the Derivative Works; and
+
+      (d) If the Work includes a "NOTICE" text file as part of its
+          distribution, then any Derivative Works that You distribute must
+          include a readable copy of the attribution notices contained
+          within such NOTICE file, excluding those notices that do not
+          pertain to any part of the Derivative Works, in at least one
+          of the following places: within a NOTICE text file distributed
+          as part of the Derivative Works; within the Source form or
+          documentation, if provided along with the Derivative Works; or,
+          within a display generated by the Derivative Works, if and
+          wherever such third-party notices normally appear. The contents
+          of the NOTICE file are for informational purposes only and
+          do not modify the License. You may add Your own attribution
+          notices within Derivative Works that You distribute, alongside
+          or as an addendum to the NOTICE text from the Work, provided
+          that such additional attribution notices cannot be construed
+          as modifying the License.
+
+      You may add Your own copyright statement to Your modifications and
+      may provide additional or different license terms and conditions
+      for use, reproduction, or distribution of Your modifications, or
+      for any such Derivative Works as a whole, provided Your use,
+      reproduction, and distribution of the Work otherwise complies with
+      the conditions stated in this License.
+
+   5. Submission of Contributions. Unless You explicitly state otherwise,
+      any Contribution intentionally submitted for inclusion in the Work
+      by You to the Licensor shall be under the terms and conditions of
+      this License, without any additional terms or conditions.
+      Notwithstanding the above, nothing herein shall supersede or modify
+      the terms of any separate license agreement you may have executed
+      with Licensor regarding such Contributions.
+
+   6. Trademarks. This License does not grant permission to use the trade
+      names, trademarks, service marks, or product names of the Licensor,
+      except as required for reasonable and customary use in describing the
+      origin of the Work and reproducing the content of the NOTICE file.
+
+   7. Disclaimer of Warranty. Unless required by applicable law or
+      agreed to in writing, Licensor provides the Work (and each
+      Contributor provides its Contributions) on an "AS IS" BASIS,
+      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+      implied, including, without limitation, any warranties or conditions
+      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+      PARTICULAR PURPOSE. You are solely responsible for determining the
+      appropriateness of using or redistributing the Work and assume any
+      risks associated with Your exercise of permissions under this License.
+
+   8. Limitation of Liability. In no event and under no legal theory,
+      whether in tort (including negligence), contract, or otherwise,
+      unless required by applicable law (such as deliberate and grossly
+      negligent acts) or agreed to in writing, shall any Contributor be
+      liable to You for damages, including any direct, indirect, special,
+      incidental, or consequential damages of any character arising as a
+      result of this License or out of the use or inability to use the
+      Work (including but not limited to damages for loss of goodwill,
+      work stoppage, computer failure or malfunction, or any and all
+      other commercial damages or losses), even if such Contributor
+      has been advised of the possibility of such damages.
+
+   9. Accepting Warranty or Additional Liability. While redistributing
+      the Work or Derivative Works thereof, You may choose to offer,
+      and charge a fee for, acceptance of support, warranty, indemnity,
+      or other liability obligations and/or rights consistent with this
+      License. However, in accepting such obligations, You may act only
+      on Your own behalf and on Your sole responsibility, not on behalf
+      of any other Contributor, and only if You agree to indemnify,
+      defend, and hold each Contributor harmless for any liability
+      incurred by, or claims asserted against, such Contributor by reason
+      of your accepting any such warranty or additional liability.
+
+   END OF TERMS AND CONDITIONS
+
+   APPENDIX: How to apply the Apache License to your work.
+
+      To apply the Apache License to your work, attach the following
+      boilerplate notice, with the fields enclosed by brackets "[]"
+      replaced with your own identifying information. (Don't include
+      the brackets!)  The text should be enclosed in the appropriate
+      comment syntax for the file format. We also recommend that a
+      file or class name and description of purpose be included on the
+      same "printed page" as the copyright notice for easier
+      identification within third-party archives.
+
+   Copyright [yyyy] [name of copyright owner]
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.

README.md

@@ -0,0 +1,8 @@
+# AntiVPN
+An antivpn plugin utilizing the KauriVPN API
+
+## The Fastest Available
+Just a simple plugin using an incredibly fast and accurate API.
+
+## SpigotMC Page
+Rate and support the project on SpigotMC: https://www.spigotmc.org/resources/kaurivpn-anti-proxy-tor-and-vpn-free-api.93355/

Velocity/pom.xml

@@ -0,0 +1,90 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>AntiVPN</artifactId>
+        <groupId>dev.brighten.antivpn</groupId>
+        <version>1.5.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>Velocity</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+    <repositories>
+        <repository>
+            <id>velocity</id>
+            <url>https://nexus.velocitypowered.com/repository/maven-public/</url>
+        </repository>
+    </repositories>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.velocitypowered</groupId>
+            <artifactId>velocity-api</artifactId>
+            <version>3.0.1</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>dev.brighten.antivpn</groupId>
+            <artifactId>Common</artifactId>
+            <version>1.5.0</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.bstats</groupId>
+            <artifactId>bstats-velocity</artifactId>
+            <version>2.2.1</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.7.0</version>
+                <configuration>
+                    <source>8</source>
+                    <target>8</target>
+                    <compilerArgument>-XDignore.symbol.file</compilerArgument>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-shade-plugin</artifactId>
+                <version>3.1.0</version>
+                <configuration>
+                    <relocations>
+                        <relocation>
+                            <pattern>org.bstats</pattern>
+                            <!-- Replace this with your package! -->
+                            <shadedPattern>dev.brighten.antivpn.velocity.org.bstats</shadedPattern>
+                        </relocation>
+                    </relocations>
+                </configuration>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>shade</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+                <filtering>true</filtering>
+            </resource>
+        </resources>
+    </build>
+
+</project>

Velocity/src/main/java/dev/brighten/antivpn/velocity/VelocityCommandExecutor.java

@@ -0,0 +1,39 @@
+package dev.brighten.antivpn.velocity;
+
+import com.velocitypowered.api.command.CommandSource;
+import com.velocitypowered.api.proxy.Player;
+import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.api.APIPlayer;
+import dev.brighten.antivpn.command.CommandExecutor;
+import lombok.RequiredArgsConstructor;
+import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer;
+
+import java.util.Optional;
+
+@RequiredArgsConstructor
+public class VelocityCommandExecutor implements CommandExecutor {
+
+    private final CommandSource sender;
+
+    @Override
+    public void sendMessage(String message) {
+        sender.sendMessage(LegacyComponentSerializer.builder().character('&').build().deserialize(message));
+    }
+
+    @Override
+    public boolean hasPermission(String permission) {
+        return sender.hasPermission(permission);
+    }
+
+    @Override
+    public Optional<APIPlayer> getPlayer() {
+        if(!isPlayer()) return Optional.empty();
+
+        return AntiVPN.getInstance().getPlayerExecutor().getPlayer(((Player) sender).getUniqueId());
+    }
+
+    @Override
+    public boolean isPlayer() {
+        return sender instanceof Player;
+    }
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/VelocityConfig.java

@@ -0,0 +1,166 @@
+package dev.brighten.antivpn.velocity;
+
+import dev.brighten.antivpn.api.VPNConfig;
+import dev.brighten.antivpn.velocity.util.ConfigDefault;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+public class VelocityConfig implements VPNConfig {
+    private final ConfigDefault<String> licenseDefault = new ConfigDefault<>("",
+            "license", VelocityPlugin.INSTANCE), kickStringDefault =
+            new ConfigDefault<>("Proxies are not allowed on our server",
+                    "kickMessage", VelocityPlugin.INSTANCE),
+            defaultDatabaseType = new ConfigDefault<>("MySQL",
+                    "database.type", VelocityPlugin.INSTANCE),
+            defaultDatabaseName = new ConfigDefault<>("kaurivpn",
+                    "database.database", VelocityPlugin.INSTANCE),
+            defaultUsername = new ConfigDefault<>("root",
+                    "database.username", VelocityPlugin.INSTANCE),
+            defaultPassword = new ConfigDefault<>("password",
+                    "database.password", VelocityPlugin.INSTANCE),
+            defaultAuthDatabase = new ConfigDefault<>("admin",
+                    "database.auth", VelocityPlugin.INSTANCE),
+            defaultIp = new ConfigDefault<>("localhost", "database.ip", VelocityPlugin.INSTANCE),
+            defaultAlertMsg = new ConfigDefault<>("&8[&6KauriVPN&8] &e%player% &7has joined on a VPN/proxy" +
+                    " &8(&f%reason%&8) &7in location &8(&f%city%&7, &f%country%&8)", "alerts.message",
+                    VelocityPlugin.INSTANCE);
+    private final ConfigDefault<Boolean> cacheResultsDefault = new ConfigDefault<>(true,
+            "cachedResults", VelocityPlugin.INSTANCE),
+            defaultDatabaseEnabled = new ConfigDefault<>(false, "database.enabled",
+                    VelocityPlugin.INSTANCE), defaultCommandsEnable = new ConfigDefault<>(false,
+            "commands.enabled", VelocityPlugin.INSTANCE), defaultKickPlayers
+            = new ConfigDefault<>(true, "kickPlayers", VelocityPlugin.INSTANCE),
+            defaultAlertToStaff = new ConfigDefault<>(true, "alerts.enabled",
+                    VelocityPlugin.INSTANCE),
+            defaultMetrics = new ConfigDefault<>(true, "bstats", VelocityPlugin.INSTANCE);
+    private final ConfigDefault<Integer>
+            defaultPort = new ConfigDefault<>(-1, "database.port", VelocityPlugin.INSTANCE);
+    private final ConfigDefault<List<String>> prefixWhitelistsDefault = new ConfigDefault<>(new ArrayList<>(),
+            "prefixWhitelists", VelocityPlugin.INSTANCE), defaultCommands = new ConfigDefault<>(
+            Collections.singletonList("kick %player% VPNs are not allowed on our server!"), "commands.execute",
+            VelocityPlugin.INSTANCE);
+
+    private String license, kickMessage, databaseType, databaseName, username, password, ip, alertMsg;
+    private List<String> prefixWhitelists, commands;
+    private int port;
+    private boolean cacheResults, databaseEnabled, commandsEnabled, kickPlayers, alertToStaff, metrics;
+
+    @Override
+    public String getLicense() {
+        return license;
+    }
+
+    @Override
+    public boolean cachedResults() {
+        return cacheResults;
+    }
+
+    @Override
+    public String getKickString() {
+        return kickMessage;
+    }
+
+    @Override
+    public String alertMessage() {
+        return alertMsg;
+    }
+
+    @Override
+    public boolean alertToStaff() {
+        return alertToStaff;
+    }
+
+    @Override
+    public boolean runCommands() {
+        return commandsEnabled;
+    }
+
+    @Override
+    public List<String> commands() {
+        return commands;
+    }
+
+    @Override
+    public boolean kickPlayersOnDetect() {
+        return kickPlayers;
+    }
+
+    @Override
+    public List<String> getPrefixWhitelists() {
+        return prefixWhitelists;
+    }
+
+    @Override
+    public boolean isDatabaseEnabled() {
+        return databaseEnabled;
+    }
+
+    @Override
+    public String getDatabaseType() {
+        return databaseType;
+    }
+
+    @Override
+    public String getDatabaseName() {
+        return databaseName;
+    }
+
+    @Override
+    public String getUsername() {
+        return username;
+    }
+
+    @Override
+    public String getPassword() {
+        return password;
+    }
+
+    @Override
+    public String getIp() {
+        return ip;
+    }
+
+    @Override
+    public int getPort() {
+        if(port == -1) {
+            switch (getDatabaseType().toLowerCase()) {
+                case "mongodb":
+                case "mongo":
+                case "mongod":
+                    return 27017;
+                case "sql":
+                case "mysql":
+                    return 3306;
+            }
+        }
+
+        return port;
+    }
+
+    @Override
+    public boolean metrics() {
+        return metrics;
+    }
+
+    public void update() {
+        license = licenseDefault.get();
+        kickMessage = kickStringDefault.get();
+        cacheResults = cacheResultsDefault.get();
+        prefixWhitelists = prefixWhitelistsDefault.get();
+        databaseEnabled = defaultDatabaseEnabled.get();
+        databaseType = defaultDatabaseType.get();
+        databaseName = defaultDatabaseName.get();
+        username = defaultUsername.get();
+        password = defaultPassword.get();
+        ip = defaultIp.get();
+        port = defaultPort.get();
+        commandsEnabled = defaultCommandsEnable.get();
+        commands = defaultCommands.get();
+        kickPlayers = defaultKickPlayers.get();
+        alertToStaff = defaultAlertToStaff.get();
+        alertMsg = defaultAlertMsg.get();
+        metrics = defaultMetrics.get();
+    }
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/VelocityListener.java

@@ -0,0 +1,91 @@
+package dev.brighten.antivpn.velocity;
+
+import com.velocitypowered.api.event.connection.LoginEvent;
+import com.velocitypowered.api.scheduler.ScheduledTask;
+import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.api.APIPlayer;
+import dev.brighten.antivpn.api.VPNExecutor;
+import dev.brighten.antivpn.velocity.util.StringUtils;
+import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer;
+
+import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
+
+public class VelocityListener extends VPNExecutor {
+
+    private ScheduledTask cacheResetTask;
+
+    @Override
+    public void registerListeners() {
+        VelocityPlugin.INSTANCE.getServer().getEventManager()
+                .register(VelocityPlugin.INSTANCE, this);
+
+        VelocityPlugin.INSTANCE.getServer().getEventManager().register(VelocityPlugin.INSTANCE, LoginEvent.class,
+                event -> {
+            if(event.getResult().isAllowed()) {
+                if(event.getPlayer().hasPermission("antivpn.bypass") //Has bypass permission
+                        || AntiVPN.getInstance().getExecutor().isWhitelisted(event.getPlayer().getUniqueId()) //Is exempt
+                        //Or has a name that starts with a certain prefix. This is for Bedrock exempting.
+                        || AntiVPN.getInstance().getConfig().getPrefixWhitelists().stream()
+                        .anyMatch(prefix -> event.getPlayer().getUsername().startsWith(prefix))) return;
+
+                checkIp(event.getPlayer().getRemoteAddress().getAddress().getHostAddress(),
+                        AntiVPN.getInstance().getConfig().cachedResults(), result -> {
+                            if(result.isSuccess() && result.isProxy()) {
+                                if(AntiVPN.getInstance().getConfig().kickPlayersOnDetect())
+                                    event.getPlayer().disconnect(LegacyComponentSerializer.builder().character('&')
+                                            .build().deserialize(AntiVPN.getInstance().getConfig().getKickString()));
+                                VelocityPlugin.INSTANCE.getLogger().info(event.getPlayer().getUsername()
+                                        + " joined on a VPN/Proxy (" + result.getMethod() + ")");
+
+                                if(AntiVPN.getInstance().getConfig().alertToStaff()) //Ensuring the user wishes to alert to staff
+                                    AntiVPN.getInstance().getPlayerExecutor().getOnlinePlayers().stream()
+                                            .filter(APIPlayer::isAlertsEnabled)
+                                            .forEach(pl -> pl.sendMessage(AntiVPN.getInstance().getConfig().alertMessage()
+                                                    .replace("%player%", event.getPlayer().getUsername())
+                                                    .replace("%reason%", result.getMethod())
+                                                    .replace("%country%", result.getCountryName())
+                                                    .replace("%city%", result.getCity())));
+
+                                //In case the user wants to run their own commands instead of using the built in kicking
+                                if(AntiVPN.getInstance().getConfig().runCommands()) {
+                                    for (String command : AntiVPN.getInstance().getConfig().commands()) {
+                                        VelocityPlugin.INSTANCE.getServer().getCommandManager()
+                                                .executeAsync(VelocityPlugin.INSTANCE.getServer()
+                                                                .getConsoleCommandSource(),
+                                                        StringUtils.translateAlternateColorCodes('&',
+                                                                command.replace("%player%",
+                                                                        event.getPlayer().getUsername())));
+                                    }
+                                }
+                                AntiVPN.getInstance().detections++;
+                            } else if(!result.isSuccess()) {
+                                VelocityPlugin.INSTANCE.getLogger()
+                                        .log(Level.WARNING,
+                                                "The API query was not a success! " +
+                                                        "You may need to upgrade your license on https://funkemunky.cc/shop");
+                            }
+                            AntiVPN.getInstance().checked++;
+                        });
+            }
+        });
+    }
+
+    @Override
+    public void runCacheReset() {
+        cacheResetTask = VelocityPlugin.INSTANCE.getServer().getScheduler()
+                .buildTask(VelocityPlugin.INSTANCE, this::resetCache)
+                .repeat(20, TimeUnit.MINUTES)
+                .schedule();
+    }
+
+    @Override
+    public void shutdown() {
+        if(cacheResetTask != null) {
+            cacheResetTask.cancel();
+            cacheResetTask = null;
+        }
+        threadExecutor.shutdown();
+        VelocityPlugin.INSTANCE.getServer().getEventManager().unregisterListener(VelocityPlugin.INSTANCE, this);
+    }
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/VelocityPlayer.java

@@ -0,0 +1,31 @@
+package dev.brighten.antivpn.velocity;
+
+import com.velocitypowered.api.proxy.Player;
+import dev.brighten.antivpn.api.APIPlayer;
+import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer;
+
+public class VelocityPlayer extends APIPlayer {
+
+    private final Player player;
+    public VelocityPlayer(Player player) {
+        super(player.getUniqueId(), player.getUsername(), player.getRemoteAddress().getAddress());
+
+        this.player = player;
+    }
+
+
+    @Override
+    public void sendMessage(String message) {
+        player.sendMessage(LegacyComponentSerializer.builder().character('&').build().deserialize(message));
+    }
+
+    @Override
+    public void kickPlayer(String reason) {
+        player.disconnect(LegacyComponentSerializer.builder().character('&').build().deserialize(reason));
+    }
+
+    @Override
+    public boolean hasPermission(String permission) {
+        return player.hasPermission(permission);
+    }
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/VelocityPlayerExecutor.java

@@ -0,0 +1,35 @@
+package dev.brighten.antivpn.velocity;
+
+import com.velocitypowered.api.proxy.Player;
+import dev.brighten.antivpn.api.APIPlayer;
+import dev.brighten.antivpn.api.PlayerExecutor;
+
+import java.util.*;
+import java.util.stream.Collectors;
+
+public class VelocityPlayerExecutor implements PlayerExecutor {
+
+    private final Map<Player, VelocityPlayer> cachedPlayers = new WeakHashMap<>();
+
+    @Override
+    public Optional<APIPlayer> getPlayer(String name) {
+        Optional<Player> player = VelocityPlugin.INSTANCE.getServer().getPlayer(name);
+
+        return player.map(value -> cachedPlayers.computeIfAbsent(value, VelocityPlayer::new));
+
+    }
+
+    @Override
+    public Optional<APIPlayer> getPlayer(UUID uuid) {
+        Optional<Player> player = VelocityPlugin.INSTANCE.getServer().getPlayer(uuid);
+
+        return player.map(value -> cachedPlayers.computeIfAbsent(value, VelocityPlayer::new));
+    }
+
+    @Override
+    public List<APIPlayer> getOnlinePlayers() {
+        return VelocityPlugin.INSTANCE.getServer().getAllPlayers().stream()
+                .map(pl -> cachedPlayers.computeIfAbsent(pl, VelocityPlayer::new))
+                .collect(Collectors.toList());
+    }
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/VelocityPlugin.java

@@ -0,0 +1,103 @@
+package dev.brighten.antivpn.velocity;
+
+import com.google.inject.Inject;
+import com.velocitypowered.api.command.CommandSource;
+import com.velocitypowered.api.command.SimpleCommand;
+import com.velocitypowered.api.event.Subscribe;
+import com.velocitypowered.api.event.proxy.ProxyInitializeEvent;
+import com.velocitypowered.api.plugin.Plugin;
+import com.velocitypowered.api.plugin.annotation.DataDirectory;
+import com.velocitypowered.api.proxy.ProxyServer;
+import dev.brighten.antivpn.AntiVPN;
+import dev.brighten.antivpn.command.Command;
+import dev.brighten.antivpn.velocity.util.Config;
+import lombok.Getter;
+import lombok.val;
+import net.kyori.adventure.text.Component;
+import net.kyori.adventure.text.format.TextColor;
+import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer;
+import org.bstats.velocity.Metrics;
+
+import java.nio.file.Path;
+import java.util.Arrays;
+import java.util.logging.Logger;
+import java.util.stream.IntStream;
+
+@Getter
+@Plugin(id = "kaurivpn", name = "KauriVPN", version = "1.5.0", authors = {"funkemunky"})
+public class VelocityPlugin {
+
+    private final ProxyServer server;
+    private final Logger logger;
+    private Metrics.Factory metricsFactory;
+
+    public static VelocityPlugin INSTANCE;
+
+    @Inject
+    @DataDirectory
+    private Path configDir;
+
+    private Config config;
+
+    @Inject
+    public VelocityPlugin(ProxyServer server, Logger logger, Metrics.Factory metricsFactory) {
+        this.server = server;
+        this.logger = logger;
+        this.metricsFactory = metricsFactory;
+    }
+
+    @Subscribe
+    public void onInit(ProxyInitializeEvent event) {
+        INSTANCE = this;
+        logger.info("Loading config...");
+        config = new Config();
+
+        //Loading plugin
+        logger.info("Starting AntiVPN services...");
+        AntiVPN.start(new VelocityConfig(), new VelocityListener(), new VelocityPlayerExecutor());
+
+        if(AntiVPN.getInstance().getConfig().metrics()) {
+            logger.info("Starting metrics...");
+            Metrics metrics = metricsFactory.make(this, 12791);
+        }
+
+        logger.info("Registering commands...");
+        for (Command command : AntiVPN.getInstance().getCommands()) {
+            server.getCommandManager().register(server.getCommandManager().metaBuilder(command.name())
+                            .aliases(command.aliases()).build(), (SimpleCommand) invocation -> {
+                        CommandSource sender = invocation.source();
+                        if(!invocation.source().hasPermission("antivpn.command.*")
+                                && !invocation.source().hasPermission(command.permission())) {
+                            invocation.source().sendMessage(Component.text("No permission").toBuilder()
+                                    .color(TextColor.color(255,0,0)).build());
+                            return;
+                        }
+
+                        val children = command.children();
+
+                        String[] args = invocation.arguments();
+                        if(children.length > 0 && args.length > 0) {
+                            for (Command child : children) {
+                                if(child.name().equalsIgnoreCase(args[0]) || Arrays.stream(child.aliases())
+                                        .anyMatch(alias -> alias.equalsIgnoreCase(args[0]))) {
+                                    if(!sender.hasPermission("antivpn.command.*")
+                                            && !sender.hasPermission(child.permission())) {
+                                        invocation.source().sendMessage(Component.text("No permission")
+                                                .toBuilder().color(TextColor.color(255,0,0)).build());
+                                        return;
+                                    }
+                                    sender.sendMessage(LegacyComponentSerializer.builder().character('&').build()
+                                            .deserialize(child.execute(new VelocityCommandExecutor(sender),  IntStream
+                                                    .range(0, args.length - 1)
+                                                    .mapToObj(i -> args[i + 1]).toArray(String[]::new))));
+                                    return;
+                                }
+                            }
+                        }
+
+                        sender.sendMessage(LegacyComponentSerializer.builder().character('&').build()
+                                .deserialize(command.execute(new VelocityCommandExecutor(sender), args)));
+                    });
+        }
+    }
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/config/Configuration.java

@@ -0,0 +1,414 @@
+package dev.brighten.antivpn.velocity.config;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.LinkedHashMap;
+import java.util.LinkedHashSet;
+import java.util.List;
+import java.util.Map;
+
+public final class Configuration
+{
+
+    private static final char SEPARATOR = '.';
+    final Map<String, Object> self;
+    private final Configuration defaults;
+
+    public Configuration()
+    {
+        this( null );
+    }
+
+    public Configuration(Configuration defaults)
+    {
+        this( new LinkedHashMap<String, Object>(), defaults );
+    }
+
+    Configuration(Map<?, ?> map, Configuration defaults)
+    {
+        this.self = new LinkedHashMap<>();
+        this.defaults = defaults;
+
+        for ( Map.Entry<?, ?> entry : map.entrySet() )
+        {
+            String key = ( entry.getKey() == null ) ? "null" : entry.getKey().toString();
+
+            if ( entry.getValue() instanceof Map )
+            {
+                this.self.put( key, new Configuration( (Map) entry.getValue(), ( defaults == null ) ? null : defaults.getSection( key ) ) );
+            } else
+            {
+                this.self.put( key, entry.getValue() );
+            }
+        }
+    }
+
+    private Configuration getSectionFor(String path)
+    {
+        int index = path.indexOf( SEPARATOR );
+        if ( index == -1 )
+        {
+            return this;
+        }
+
+        String root = path.substring( 0, index );
+        Object section = self.get( root );
+        if ( section == null )
+        {
+            section = new Configuration( ( defaults == null ) ? null : defaults.getSection( root ) );
+            self.put( root, section );
+        }
+
+        return (Configuration) section;
+    }
+
+    private String getChild(String path)
+    {
+        int index = path.indexOf( SEPARATOR );
+        return ( index == -1 ) ? path : path.substring( index + 1 );
+    }
+
+    /*------------------------------------------------------------------------*/
+    @SuppressWarnings("unchecked")
+    public <T> T get(String path, T def)
+    {
+        Configuration section = getSectionFor( path );
+        Object val;
+        if ( section == this )
+        {
+            val = self.get( path );
+        } else
+        {
+            val = section.get( getChild( path ), def );
+        }
+
+        if ( val == null && def instanceof Configuration )
+        {
+            self.put( path, def );
+        }
+
+        return ( val != null ) ? (T) val : def;
+    }
+
+    public boolean contains(String path)
+    {
+        return get( path, null ) != null;
+    }
+
+    public Object get(String path)
+    {
+        return get( path, getDefault( path ) );
+    }
+
+    public Object getDefault(String path)
+    {
+        return ( defaults == null ) ? null : defaults.get( path );
+    }
+
+    public void set(String path, Object value)
+    {
+        if ( value instanceof Map )
+        {
+            value = new Configuration( (Map) value, ( defaults == null ) ? null : defaults.getSection( path ) );
+        }
+
+        Configuration section = getSectionFor( path );
+        if ( section == this )
+        {
+            if ( value == null )
+            {
+                self.remove( path );
+            } else
+            {
+                self.put( path, value );
+            }
+        } else
+        {
+            section.set( getChild( path ), value );
+        }
+    }
+
+    /*------------------------------------------------------------------------*/
+    public Configuration getSection(String path)
+    {
+        Object def = getDefault( path );
+        return (Configuration) get( path, ( def instanceof Configuration ) ? def : new Configuration( ( defaults == null ) ? null : defaults.getSection( path ) ) );
+    }
+
+    /**
+     * Gets keys, not deep by default.
+     *
+     * @return top level keys for this section
+     */
+    public Collection<String> getKeys()
+    {
+        return new LinkedHashSet<>( self.keySet() );
+    }
+
+    /*------------------------------------------------------------------------*/
+    public byte getByte(String path)
+    {
+        Object def = getDefault( path );
+        return getByte( path, ( def instanceof Number ) ? ( (Number) def ).byteValue() : 0 );
+    }
+
+    public byte getByte(String path, byte def)
+    {
+        Object val = get( path, def );
+        return ( val instanceof Number ) ? ( (Number) val ).byteValue() : def;
+    }
+
+    public List<Byte> getByteList(String path)
+    {
+        List<?> list = getList( path );
+        List<Byte> result = new ArrayList<>();
+
+        for ( Object object : list )
+        {
+            if ( object instanceof Number )
+            {
+                result.add( ( (Number) object ).byteValue() );
+            }
+        }
+
+        return result;
+    }
+
+    public short getShort(String path)
+    {
+        Object def = getDefault( path );
+        return getShort( path, ( def instanceof Number ) ? ( (Number) def ).shortValue() : 0 );
+    }
+
+    public short getShort(String path, short def)
+    {
+        Object val = get( path, def );
+        return ( val instanceof Number ) ? ( (Number) val ).shortValue() : def;
+    }
+
+    public List<Short> getShortList(String path)
+    {
+        List<?> list = getList( path );
+        List<Short> result = new ArrayList<>();
+
+        for ( Object object : list )
+        {
+            if ( object instanceof Number )
+            {
+                result.add( ( (Number) object ).shortValue() );
+            }
+        }
+
+        return result;
+    }
+
+    public int getInt(String path)
+    {
+        Object def = getDefault( path );
+        return getInt( path, ( def instanceof Number ) ? ( (Number) def ).intValue() : 0 );
+    }
+
+    public int getInt(String path, int def)
+    {
+        Object val = get( path, def );
+        return ( val instanceof Number ) ? ( (Number) val ).intValue() : def;
+    }
+
+    public List<Integer> getIntList(String path)
+    {
+        List<?> list = getList( path );
+        List<Integer> result = new ArrayList<>();
+
+        for ( Object object : list )
+        {
+            if ( object instanceof Number )
+            {
+                result.add( ( (Number) object ).intValue() );
+            }
+        }
+
+        return result;
+    }
+
+    public long getLong(String path)
+    {
+        Object def = getDefault( path );
+        return getLong( path, ( def instanceof Number ) ? ( (Number) def ).longValue() : 0 );
+    }
+
+    public long getLong(String path, long def)
+    {
+        Object val = get( path, def );
+        return ( val instanceof Number ) ? ( (Number) val ).longValue() : def;
+    }
+
+    public List<Long> getLongList(String path)
+    {
+        List<?> list = getList( path );
+        List<Long> result = new ArrayList<>();
+
+        for ( Object object : list )
+        {
+            if ( object instanceof Number )
+            {
+                result.add( ( (Number) object ).longValue() );
+            }
+        }
+
+        return result;
+    }
+
+    public float getFloat(String path)
+    {
+        Object def = getDefault( path );
+        return getFloat( path, ( def instanceof Number ) ? ( (Number) def ).floatValue() : 0 );
+    }
+
+    public float getFloat(String path, float def)
+    {
+        Object val = get( path, def );
+        return ( val instanceof Number ) ? ( (Number) val ).floatValue() : def;
+    }
+
+    public List<Float> getFloatList(String path)
+    {
+        List<?> list = getList( path );
+        List<Float> result = new ArrayList<>();
+
+        for ( Object object : list )
+        {
+            if ( object instanceof Number )
+            {
+                result.add( ( (Number) object ).floatValue() );
+            }
+        }
+
+        return result;
+    }
+
+    public double getDouble(String path)
+    {
+        Object def = getDefault( path );
+        return getDouble( path, ( def instanceof Number ) ? ( (Number) def ).doubleValue() : 0 );
+    }
+
+    public double getDouble(String path, double def)
+    {
+        Object val = get( path, def );
+        return ( val instanceof Number ) ? ( (Number) val ).doubleValue() : def;
+    }
+
+    public List<Double> getDoubleList(String path)
+    {
+        List<?> list = getList( path );
+        List<Double> result = new ArrayList<>();
+
+        for ( Object object : list )
+        {
+            if ( object instanceof Number )
+            {
+                result.add( ( (Number) object ).doubleValue() );
+            }
+        }
+
+        return result;
+    }
+
+    public boolean getBoolean(String path)
+    {
+        Object def = getDefault( path );
+        return getBoolean( path, ( def instanceof Boolean ) ? (Boolean) def : false );
+    }
+
+    public boolean getBoolean(String path, boolean def)
+    {
+        Object val = get( path, def );
+        return ( val instanceof Boolean ) ? (Boolean) val : def;
+    }
+
+    public List<Boolean> getBooleanList(String path)
+    {
+        List<?> list = getList( path );
+        List<Boolean> result = new ArrayList<>();
+
+        for ( Object object : list )
+        {
+            if ( object instanceof Boolean )
+            {
+                result.add( (Boolean) object );
+            }
+        }
+
+        return result;
+    }
+
+    public char getChar(String path)
+    {
+        Object def = getDefault( path );
+        return getChar( path, ( def instanceof Character ) ? (Character) def : '\u0000' );
+    }
+
+    public char getChar(String path, char def)
+    {
+        Object val = get( path, def );
+        return ( val instanceof Character ) ? (Character) val : def;
+    }
+
+    public List<Character> getCharList(String path)
+    {
+        List<?> list = getList( path );
+        List<Character> result = new ArrayList<>();
+
+        for ( Object object : list )
+        {
+            if ( object instanceof Character )
+            {
+                result.add( (Character) object );
+            }
+        }
+
+        return result;
+    }
+
+    public String getString(String path)
+    {
+        Object def = getDefault( path );
+        return getString( path, ( def instanceof String ) ? (String) def : "" );
+    }
+
+    public String getString(String path, String def)
+    {
+        Object val = get( path, def );
+        return ( val instanceof String ) ? (String) val : def;
+    }
+
+    public List<String> getStringList(String path)
+    {
+        List<?> list = getList( path );
+        List<String> result = new ArrayList<>();
+
+        for ( Object object : list )
+        {
+            if ( object instanceof String )
+            {
+                result.add( (String) object );
+            }
+        }
+
+        return result;
+    }
+
+    /*------------------------------------------------------------------------*/
+    public List<?> getList(String path)
+    {
+        Object def = getDefault( path );
+        return getList( path, ( def instanceof List<?> ) ? (List<?>) def : Collections.EMPTY_LIST );
+    }
+
+    public List<?> getList(String path, List<?> def)
+    {
+        Object val = get( path, def );
+        return ( val instanceof List<?> ) ? (List<?>) val : def;
+    }
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/config/ConfigurationProvider.java

@@ -0,0 +1,60 @@
+package dev.brighten.antivpn.velocity.config;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.Reader;
+import java.io.Writer;
+import java.util.HashMap;
+import java.util.Map;
+
+public abstract class ConfigurationProvider
+{
+
+    private static final Map<Class<? extends ConfigurationProvider>, ConfigurationProvider> providers = new HashMap<>();
+
+    static
+    {
+        try
+        {
+            providers.put( YamlConfiguration.class, new YamlConfiguration() );
+        } catch ( NoClassDefFoundError ex )
+        {
+            // Ignore, no SnakeYAML
+        }
+
+        try
+        {
+            providers.put( JsonConfiguration.class, new JsonConfiguration() );
+        } catch ( NoClassDefFoundError ex )
+        {
+            // Ignore, no Gson
+        }
+    }
+
+    public static ConfigurationProvider getProvider(Class<? extends ConfigurationProvider> provider)
+    {
+        return providers.get( provider );
+    }
+
+    /*------------------------------------------------------------------------*/
+    public abstract void save(Configuration config, File file) throws IOException;
+
+    public abstract void save(Configuration config, Writer writer);
+
+    public abstract Configuration load(File file) throws IOException;
+
+    public abstract Configuration load(File file, Configuration defaults) throws IOException;
+
+    public abstract Configuration load(Reader reader);
+
+    public abstract Configuration load(Reader reader, Configuration defaults);
+
+    public abstract Configuration load(InputStream is);
+
+    public abstract Configuration load(InputStream is, Configuration defaults);
+
+    public abstract Configuration load(String string);
+
+    public abstract Configuration load(String string, Configuration defaults);
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/config/JsonConfiguration.java

@@ -0,0 +1,114 @@
+package dev.brighten.antivpn.velocity.config;
+
+import com.google.common.base.Charsets;
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonSerializationContext;
+import com.google.gson.JsonSerializer;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStreamWriter;
+import java.io.Reader;
+import java.io.Writer;
+import java.lang.reflect.Type;
+import java.util.LinkedHashMap;
+import java.util.Map;
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor(access = AccessLevel.PACKAGE)
+public class JsonConfiguration extends ConfigurationProvider
+{
+
+    private final Gson json = new GsonBuilder().serializeNulls().setPrettyPrinting().registerTypeAdapter( Configuration.class, new JsonSerializer<Configuration>()
+    {
+        @Override
+        public JsonElement serialize(Configuration src, Type typeOfSrc, JsonSerializationContext context)
+        {
+            return context.serialize( ( (Configuration) src ).self );
+        }
+    } ).create();
+
+    @Override
+    public void save(Configuration config, File file) throws IOException
+    {
+        try ( Writer writer = new OutputStreamWriter( new FileOutputStream( file ), Charsets.UTF_8 ) )
+        {
+            save( config, writer );
+        }
+    }
+
+    @Override
+    public void save(Configuration config, Writer writer)
+    {
+        json.toJson( config.self, writer );
+    }
+
+    @Override
+    public Configuration load(File file) throws IOException
+    {
+        return load( file, null );
+    }
+
+    @Override
+    public Configuration load(File file, Configuration defaults) throws IOException
+    {
+        try ( FileInputStream is = new FileInputStream( file ) )
+        {
+            return load( is, defaults );
+        }
+    }
+
+    @Override
+    public Configuration load(Reader reader)
+    {
+        return load( reader, null );
+    }
+
+    @Override
+    @SuppressWarnings("unchecked")
+    public Configuration load(Reader reader, Configuration defaults)
+    {
+        Map<String, Object> map = json.fromJson( reader, LinkedHashMap.class );
+        if ( map == null )
+        {
+            map = new LinkedHashMap<>();
+        }
+        return new Configuration( map, defaults );
+    }
+
+    @Override
+    public Configuration load(InputStream is)
+    {
+        return load( is, null );
+    }
+
+    @Override
+    public Configuration load(InputStream is, Configuration defaults)
+    {
+        return load( new InputStreamReader( is, Charsets.UTF_8 ), defaults );
+    }
+
+    @Override
+    public Configuration load(String string)
+    {
+        return load( string, null );
+    }
+
+    @Override
+    @SuppressWarnings("unchecked")
+    public Configuration load(String string, Configuration defaults)
+    {
+        Map<String, Object> map = json.fromJson( string, LinkedHashMap.class );
+        if ( map == null )
+        {
+            map = new LinkedHashMap<>();
+        }
+        return new Configuration( map, defaults );
+    }
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/config/YamlConfiguration.java

@@ -0,0 +1,136 @@
+package dev.brighten.antivpn.velocity.config;
+
+import com.google.common.base.Charsets;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStreamWriter;
+import java.io.Reader;
+import java.io.Writer;
+import java.util.LinkedHashMap;
+import java.util.Map;
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+import org.yaml.snakeyaml.DumperOptions;
+import org.yaml.snakeyaml.Yaml;
+import org.yaml.snakeyaml.constructor.Constructor;
+import org.yaml.snakeyaml.nodes.Node;
+import org.yaml.snakeyaml.representer.Represent;
+import org.yaml.snakeyaml.representer.Representer;
+
+@NoArgsConstructor(access = AccessLevel.PACKAGE)
+public class YamlConfiguration extends ConfigurationProvider
+{
+
+    private final ThreadLocal<Yaml> yaml = new ThreadLocal<Yaml>()
+    {
+        @Override
+        protected Yaml initialValue()
+        {
+            Representer representer = new Representer()
+            {
+                {
+                    representers.put( Configuration.class, new Represent()
+                    {
+                        @Override
+                        public Node representData(Object data)
+                        {
+                            return represent( ( (Configuration) data ).self );
+                        }
+                    } );
+                }
+            };
+
+            DumperOptions options = new DumperOptions();
+            options.setDefaultFlowStyle( DumperOptions.FlowStyle.BLOCK );
+
+            return new Yaml( new Constructor(), representer, options );
+        }
+    };
+
+    @Override
+    public void save(Configuration config, File file) throws IOException
+    {
+        try ( Writer writer = new OutputStreamWriter( new FileOutputStream( file ), Charsets.UTF_8 ) )
+        {
+            save( config, writer );
+        }
+    }
+
+    @Override
+    public void save(Configuration config, Writer writer)
+    {
+        yaml.get().dump( config.self, writer );
+    }
+
+    @Override
+    public Configuration load(File file) throws IOException
+    {
+        return load( file, null );
+    }
+
+    @Override
+    public Configuration load(File file, Configuration defaults) throws IOException
+    {
+        try ( FileInputStream is = new FileInputStream( file ) )
+        {
+            return load( is, defaults );
+        }
+    }
+
+    @Override
+    public Configuration load(Reader reader)
+    {
+        return load( reader, null );
+    }
+
+    @Override
+    @SuppressWarnings("unchecked")
+    public Configuration load(Reader reader, Configuration defaults)
+    {
+        Map<String, Object> map = yaml.get().loadAs( reader, LinkedHashMap.class );
+        if ( map == null )
+        {
+            map = new LinkedHashMap<>();
+        }
+        return new Configuration( map, defaults );
+    }
+
+    @Override
+    public Configuration load(InputStream is)
+    {
+        return load( is, null );
+    }
+
+    @Override
+    @SuppressWarnings("unchecked")
+    public Configuration load(InputStream is, Configuration defaults)
+    {
+        Map<String, Object> map = yaml.get().loadAs( is, LinkedHashMap.class );
+        if ( map == null )
+        {
+            map = new LinkedHashMap<>();
+        }
+        return new Configuration( map, defaults );
+    }
+
+    @Override
+    public Configuration load(String string)
+    {
+        return load( string, null );
+    }
+
+    @Override
+    @SuppressWarnings("unchecked")
+    public Configuration load(String string, Configuration defaults)
+    {
+        Map<String, Object> map = yaml.get().loadAs( string, LinkedHashMap.class );
+        if ( map == null )
+        {
+            map = new LinkedHashMap<>();
+        }
+        return new Configuration( map, defaults );
+    }
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/util/Config.java

@@ -0,0 +1,115 @@
+package dev.brighten.antivpn.velocity.util;
+
+import com.google.common.io.ByteStreams;
+import dev.brighten.antivpn.velocity.VelocityPlugin;
+import dev.brighten.antivpn.velocity.config.Configuration;
+import dev.brighten.antivpn.velocity.config.ConfigurationProvider;
+import dev.brighten.antivpn.velocity.config.YamlConfiguration;
+
+import java.io.*;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+/**
+ * Author: nitramleo (Martin)
+ * Date created: 10-Aug-18
+ */
+public class Config {
+
+    private File file;
+    private Configuration configuration;
+
+    public Config() {
+        File dataFolder = VelocityPlugin.INSTANCE.getConfigDir().toFile();
+        this.file = new File(dataFolder, "config.yml");
+        try {
+            if (!this.file.exists()) {
+                if (!dataFolder.exists()) {
+                    dataFolder.mkdir();
+                }
+                this.file.createNewFile();
+                try (final InputStream is =VelocityPlugin.INSTANCE.getClass().getResourceAsStream("config.yml");
+                     final OutputStream os = new FileOutputStream(this.file)) {
+                    ByteStreams.copy(is, os);
+                }
+            }
+            this.configuration = ConfigurationProvider.getProvider(YamlConfiguration.class).load(this.file);
+        }
+        catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public void load() {
+        File dataFolder = VelocityPlugin.INSTANCE.getConfigDir().toFile();
+        this.file = new File(dataFolder, "config.yml");
+        try {
+            this.configuration = ConfigurationProvider.getProvider(YamlConfiguration.class).load(this.file);
+        }
+        catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public void save() {
+        try {
+            ConfigurationProvider.getProvider( YamlConfiguration.class).save(this.configuration, this.file);
+        }
+        catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public Configuration getConfiguration() {
+        return this.configuration;
+    }
+
+    public File getFile() {
+        return this.file;
+    }
+
+    public double getDouble(final String path) {
+        if (this.configuration.get(path) != null) {
+            return this.configuration.getDouble(path);
+        }
+        return 0.0;
+    }
+
+    public int getInt(final String path) {
+        if (this.configuration.get(path) != null) {
+            return this.configuration.getInt(path);
+        }
+        return 0;
+    }
+
+    public Object get(final String path) {
+        return this.configuration.get(path);
+    }
+
+    public void set(final String path, final Object object) {
+        configuration.set(path, object);
+    }
+
+    public boolean getBoolean(final String path) {
+        return this.configuration.get(path) != null && this.configuration.getBoolean(path);
+    }
+
+    public String getString(final String path) {
+        if (this.configuration.get(path) != null) {
+            return StringUtils.translateAlternateColorCodes('&', this.configuration.getString(path));
+        }
+        return "String at path: " + path + " not found!";
+    }
+
+    public List<String> getStringList(final String path) {
+        if (this.configuration.get(path) != null) {
+            final ArrayList<String> strings = new ArrayList<String>();
+            for (final String string : this.configuration.getStringList(path)) {
+                strings.add(StringUtils.translateAlternateColorCodes('&', string));
+            }
+            return strings;
+        }
+        return Arrays.asList("String List at path: " + path + " not found!");
+    }
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/util/ConfigDefault.java

@@ -0,0 +1,28 @@
+package dev.brighten.antivpn.velocity.util;
+
+import dev.brighten.antivpn.velocity.VelocityPlugin;
+import lombok.AllArgsConstructor;
+
+@AllArgsConstructor
+public class ConfigDefault<A> {
+
+    private final A defaultValue;
+    private final String path;
+    private final VelocityPlugin plugin;
+
+    public A get() {
+        if(plugin.getConfig().get(path) != null)
+            return (A) plugin.getConfig().get(path);
+        else {
+            plugin.getConfig().set(path, defaultValue);
+            plugin.getConfig().save();
+            return defaultValue;
+        }
+    }
+
+    public A set(A value) {
+        plugin.getConfig().set(path, value);
+
+        return value;
+    }
+}

Velocity/src/main/java/dev/brighten/antivpn/velocity/util/StringUtils.java

@@ -0,0 +1,17 @@
+package dev.brighten.antivpn.velocity.util;
+
+public class StringUtils {
+
+    public static String translateAlternateColorCodes(char altColorChar, String textToTranslate) {
+        char[] b = textToTranslate.toCharArray();
+
+        for(int i = 0; i < b.length - 1; ++i) {
+            if (b[i] == altColorChar && "0123456789AaBbCcDdEeFfKkLlMmNnOoRr".indexOf(b[i + 1]) > -1) {
+                b[i] = 167;
+                b[i + 1] = Character.toLowerCase(b[i + 1]);
+            }
+        }
+
+        return new String(b);
+    }
+}

pom.xml

@@ -7,13 +7,14 @@
     <groupId>dev.brighten.antivpn</groupId>
     <artifactId>AntiVPN</artifactId>
     <packaging>pom</packaging>
-    <version>1.1.1</version>
+    <version>1.5.0</version>
 
     <modules>
         <module>Common</module>
         <module>Bungee</module>
         <module>Bukkit</module>
         <module>Assembly</module>
+        <module>Velocity</module>
     </modules>
 
     <properties>