Fixing version and sql on load

- Added ip exemptions in addition to the existing player exemptions./
- Fixing System.out usage warnings that some users were experiencing.
- Fixing MySQL drivers not loading on some servers.
- Fixing bug that would make whitelisted players not load for awhile after server starts

Assembly/dependency-reduced-pom.xml

@@ -3,7 +3,7 @@
   <parent>
     <artifactId>AntiVPN</artifactId>
     <groupId>dev.brighten.antivpn</groupId>
-    <version>1.5.0</version>
+    <version>1.5.2.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
   <artifactId>Assembly</artifactId>
@@ -35,8 +35,8 @@
     </dependency>
   </dependencies>
   <properties>
-    <maven.compiler.source>8</maven.compiler.source>
     <maven.compiler.target>8</maven.compiler.target>
+    <maven.compiler.source>8</maven.compiler.source>
   </properties>
 </project>
 

Assembly/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>AntiVPN</artifactId>
         <groupId>dev.brighten.antivpn</groupId>
-        <version>1.5.0</version>
+        <version>1.5.2.1</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -46,13 +46,13 @@
         </dependency>
         <dependency>
             <groupId>dev.brighten.antivpn</groupId>
-            <artifactId>Common</artifactId>
+            <artifactId>Velocity</artifactId>
             <version>${version}</version>
             <scope>compile</scope>
         </dependency>
         <dependency>
             <groupId>dev.brighten.antivpn</groupId>
-            <artifactId>Velocity</artifactId>
+            <artifactId>Common</artifactId>
             <version>${version}</version>
             <scope>compile</scope>
         </dependency>

Bukkit/dependency-reduced-pom.xml

@@ -3,7 +3,7 @@
   <parent>
     <artifactId>AntiVPN</artifactId>
     <groupId>dev.brighten.antivpn</groupId>
-    <version>1.5.0</version>
+    <version>1.5.2.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
   <artifactId>Bukkit</artifactId>
@@ -56,8 +56,18 @@
     <dependency>
       <groupId>dev.brighten.antivpn</groupId>
       <artifactId>Common</artifactId>
-      <version>1.5.0</version>
+      <version>1.5.2.1</version>
       <scope>provided</scope>
+      <exclusions>
+        <exclusion>
+          <artifactId>toml4j</artifactId>
+          <groupId>com.moandjiezana.toml</groupId>
+        </exclusion>
+        <exclusion>
+          <artifactId>mysql-connector-java</artifactId>
+          <groupId>mysql</groupId>
+        </exclusion>
+      </exclusions>
     </dependency>
     <dependency>
       <groupId>cc.funkemunky.utils</groupId>
@@ -67,8 +77,8 @@
     </dependency>
   </dependencies>
   <properties>
-    <maven.compiler.source>8</maven.compiler.source>
     <maven.compiler.target>8</maven.compiler.target>
+    <maven.compiler.source>8</maven.compiler.source>
   </properties>
 </project>
 

Bukkit/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>AntiVPN</artifactId>
         <groupId>dev.brighten.antivpn</groupId>
-        <version>1.5.0</version>
+        <version>1.5.2.1</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -69,7 +69,7 @@
         <dependency>
             <groupId>dev.brighten.antivpn</groupId>
             <artifactId>Common</artifactId>
-            <version>1.5.0</version>
+            <version>1.5.2.1</version>
             <scope>provided</scope>
         </dependency>
         <dependency>

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

@@ -47,18 +47,23 @@ public class BukkitListener extends VPNExecutor implements Listener {
         if(cacheResetTask != null && !cacheResetTask.isCancelled()) cacheResetTask.cancel();
     }
 
+    @Override
+    public void log(String log, Object... objects) {
+        Bukkit.getLogger().log(Level.INFO, String.format(log, objects));
+    }
+
     @EventHandler
     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");
+                            AntiVPN.getInstance().getExecutor().log("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");
+                        } else AntiVPN.getInstance().getExecutor().log("Not enabled");
                     });
                 });
     }
@@ -66,7 +71,8 @@ public class BukkitListener extends VPNExecutor implements Listener {
     @EventHandler
     public void onListener(final PlayerLoginEvent event) {
         //If they're exempt, don't check.
-        if(AntiVPN.getInstance().getExecutor().isWhitelisted(event.getPlayer().getUniqueId())) return;
+        if(AntiVPN.getInstance().getExecutor().isWhitelisted(event.getPlayer().getUniqueId())
+                || AntiVPN.getInstance().getExecutor().isWhitelisted(event.getAddress().getHostAddress())) return;
         checkIp(event.getAddress().getHostAddress(), AntiVPN.getInstance().getConfig().cachedResults(), result -> {
             if(result.isSuccess() && result.isProxy()) {
                 new BukkitRunnable() {

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

@@ -38,7 +38,7 @@ public class BukkitPlugin extends JavaPlugin {
         saveDefaultConfig();
 
         Bukkit.getLogger().info("Starting AntiVPN services...");
-        AntiVPN.start(new BukkitConfig(), new BukkitListener(), new BukkitPlayerExecutor());
+        AntiVPN.start(new BukkitConfig(), new BukkitListener(), new BukkitPlayerExecutor(), getDataFolder());
 
         if(AntiVPN.getInstance().getConfig().metrics()) {
             Bukkit.getLogger().info("Starting bStats metrics...");

Bukkit/src/main/resources/plugin.yml

@@ -1,4 +1,4 @@
-name: AntiVPN
+name: KauriVPN
 main: dev.brighten.antivpn.bukkit.BukkitPlugin
 version: ${project.version}
 author: funkemunky

Bungee/dependency-reduced-pom.xml

@@ -3,7 +3,7 @@
   <parent>
     <artifactId>AntiVPN</artifactId>
     <groupId>dev.brighten.antivpn</groupId>
-    <version>1.5.0</version>
+    <version>1.5.2.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
   <artifactId>Bungee</artifactId>
@@ -50,8 +50,18 @@
     <dependency>
       <groupId>dev.brighten.antivpn</groupId>
       <artifactId>Common</artifactId>
-      <version>1.5.0</version>
+      <version>1.5.2.1</version>
       <scope>provided</scope>
+      <exclusions>
+        <exclusion>
+          <artifactId>toml4j</artifactId>
+          <groupId>com.moandjiezana.toml</groupId>
+        </exclusion>
+        <exclusion>
+          <artifactId>mysql-connector-java</artifactId>
+          <groupId>mysql</groupId>
+        </exclusion>
+      </exclusions>
     </dependency>
     <dependency>
       <groupId>org.github.bungee</groupId>
@@ -67,8 +77,8 @@
     </dependency>
   </dependencies>
   <properties>
-    <maven.compiler.source>8</maven.compiler.source>
     <maven.compiler.target>8</maven.compiler.target>
+    <maven.compiler.source>8</maven.compiler.source>
   </properties>
 </project>
 

Bungee/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>AntiVPN</artifactId>
         <groupId>dev.brighten.antivpn</groupId>
-        <version>1.5.0</version>
+        <version>1.5.2.1</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -63,7 +63,7 @@
         <dependency>
             <groupId>dev.brighten.antivpn</groupId>
             <artifactId>Common</artifactId>
-            <version>1.5.0</version>
+            <version>1.5.2.1</version>
             <scope>provided</scope>
         </dependency>
         <dependency>

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

@@ -40,11 +40,18 @@ public class BungeeListener extends VPNExecutor implements Listener {
         BungeePlugin.pluginInstance.getProxy().getPluginManager().unregisterListener(this);
     }
 
+    @Override
+    public void log(String log, Object... objects) {
+        BungeeCord.getInstance().getLogger().log(Level.INFO, String.format(log, objects));
+    }
+
     @EventHandler
     public void onListener(final PostLoginEvent event) {
         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().getExecutor().isWhitelisted(event.getPlayer().getAddress().getAddress()
+                     .getHostAddress())
                 || AntiVPN.getInstance().getConfig().getPrefixWhitelists().stream()
                 .anyMatch(prefix -> event.getPlayer().getName().startsWith(prefix))) return;
 

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

@@ -42,7 +42,7 @@ public class BungeePlugin extends Plugin {
 
         //Loading plugin
         BungeeCord.getInstance().getLogger().info("Starting AntiVPN services...");
-        AntiVPN.start(new BungeeConfig(), new BungeeListener(), new BungeePlayerExecutor());
+        AntiVPN.start(new BungeeConfig(), new BungeeListener(), new BungeePlayerExecutor(), getDataFolder());
 
         if(AntiVPN.getInstance().getConfig().metrics()) {
             BungeeCord.getInstance().getLogger().info("Starting bStats metrics...");

Bungee/src/main/resources/bungee.yml

@@ -1,4 +1,4 @@
-name: AntiVPN
+name: KauriVPN
 main: dev.brighten.antivpn.bungee.BungeePlugin
 description: A simple and fast antivpn plugin.
 version: ${project.version}

Common/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>AntiVPN</artifactId>
         <groupId>dev.brighten.antivpn</groupId>
-        <version>1.5.0</version>
+        <version>1.5.2.1</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -21,7 +21,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-compiler-plugin</artifactId>
-                <version>3.7.0</version>
+                <version>3.8.1</version>
                 <configuration>
                     <source>8</source>
                     <target>8</target>
@@ -37,4 +37,27 @@
         </resources>
     </build>
 
+    <repositories>
+        <repository>
+            <id>funkemunky-releases</id>
+            <url>https://nexus.funkemunky.cc/content/repositories/releases/</url>
+        </repository>
+    </repositories>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.moandjiezana.toml</groupId>
+            <artifactId>toml4j</artifactId>
+            <version>0.7.2</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>8.0.27</version>
+            <type>jar</type>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+
 </project>

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

@@ -16,6 +16,7 @@ import lombok.AccessLevel;
 import lombok.Getter;
 import lombok.Setter;
 
+import java.io.File;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.List;
@@ -32,12 +33,14 @@ public class AntiVPN {
     private MessageHandler messageHandler;
     private List<Command> commands = new ArrayList<>();
     public int detections, checked;
+    private File pluginFolder;
 
-    public static void start(VPNConfig config, VPNExecutor executor, PlayerExecutor playerExecutor) {
+    public static void start(VPNConfig config, VPNExecutor executor, PlayerExecutor playerExecutor, File pluginFolder) {
         //Initializing
 
         INSTANCE = new AntiVPN();
 
+        INSTANCE.pluginFolder = pluginFolder;
         INSTANCE.config = config;
         INSTANCE.executor = executor;
         INSTANCE.playerExecutor = playerExecutor;
@@ -50,7 +53,7 @@ public class AntiVPN {
         switch(INSTANCE.config.getDatabaseType().toLowerCase()) {
             case "mysql":
             case "sql":{
-                System.out.println("Using databaseType MySQL...");
+                AntiVPN.getInstance().getExecutor().log("Using databaseType MySQL...");
                 INSTANCE.database = new MySqlVPN();
                 INSTANCE.database.init();
                 break;
@@ -58,11 +61,11 @@ public class AntiVPN {
             case "mongo":
             case "mongodb":
             case "mongod": {
-                System.out.println("We currently do not support Mongo, but this is coming in future updates.");
+                AntiVPN.getInstance().getExecutor().log("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() + "\". " +
+                AntiVPN.getInstance().getExecutor().log("Could not find database type \"" + INSTANCE.config.getDatabaseType() + "\". " +
                         "Options: [MySQL]");
                 break;
             }

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

@@ -18,6 +18,8 @@ public abstract class VPNExecutor {
     private static final Map<String, VPNResponse> responseCache = new HashMap<>();
     @Getter
     private final Set<UUID> whitelisted = Collections.synchronizedSet(new HashSet<>());
+    @Getter
+    private final Set<String> whitelistedIps = Collections.synchronizedSet(new HashSet<>());
 
     public abstract void registerListeners();
 
@@ -29,10 +31,16 @@ public abstract class VPNExecutor {
 
     public abstract void shutdown();
 
+    public abstract void log(String log, Object... objects);
+
     public boolean isWhitelisted(UUID uuid) {
         return whitelisted.contains(uuid);
     }
 
+    public boolean isWhitelisted(String ip) {
+        return whitelistedIps.contains(ip);
+    }
+
     public void checkIp(String ip, boolean cachedResults, Consumer<VPNResponse> result) {
         threadExecutor.execute(() -> result.accept(responseCache.compute(ip, (key, val) -> {
             if(val == null) {
@@ -47,12 +55,12 @@ public abstract class VPNExecutor {
                         if(response.isSuccess()) {
                             AntiVPN.getInstance().getDatabase().cacheResponse(response);
                         } else {
-                            System.out.println("Query to VPN API failed! Reason: " + response.getFailureReason());
+                            log("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");
+                        log("Query to VPN API failed! Reason: Java Exception");
                         e.printStackTrace();
                     }
                 }
@@ -76,12 +84,12 @@ public abstract class VPNExecutor {
                         if(response.isSuccess()) {
                             threadExecutor.execute(() -> AntiVPN.getInstance().getDatabase().cacheResponse(response));
                         } else {
-                            System.out.println("Query to VPN API failed! Reason: " + response.getFailureReason());
+                            log("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");
+                        log("Query to VPN API failed! Reason: Java Exception");
                         e.printStackTrace();
                     }
                 }

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

@@ -4,6 +4,7 @@ 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.utils.MiscUtils;
 
 import java.util.*;
 import java.util.stream.Collectors;
@@ -34,7 +35,7 @@ public class AllowlistCommand extends Command {
 
     @Override
     public String usage() {
-        return "<add/remove> <player/uuid>";
+        return "<add/remove> <player/uuid/ip>";
     }
 
     @Override
@@ -50,7 +51,7 @@ public class AllowlistCommand extends Command {
     @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>";
+            return "&cUsage: /antivpn allowlist " + usage();
         }
 
         if(args.length == 1)
@@ -61,34 +62,82 @@ public class AllowlistCommand extends Command {
         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());
+        if(MiscUtils.isIpv4(args[1])) {
+            if(!databaseEnabled) {
+                switch(args[0].toLowerCase()) {
+                    case "add": {
+                        AntiVPN.getInstance().getExecutor().getWhitelistedIps().add(args[1]);
+                        return String.format("&aAdded &6%s &ato the exemption allowlist.", args[1]);
+                    }
+                    case "remove":
+                    case "delete": {
+                        AntiVPN.getInstance().getExecutor().getWhitelistedIps().remove(args[1]);
+                        return String.format("&cRemoved &6%s &cfrom the exemption allowlist.", args[1]);
+                    }
+                    default: {
+                        return "&c\"" + args[0] + "\" is not a valid argument";
+                    }
+                }
             } else {
-                AntiVPN.getInstance().getExecutor().getWhitelisted().remove(uuid);
-                return String.format("&cRemoved &6%s &cuuid from the exemption allowlist.", uuid.toString());
+                switch(args[0].toLowerCase()) {
+                    case "add": {
+                        AntiVPN.getInstance().getDatabase().setWhitelisted(args[1], true);
+                        return String.format("&aAdded &6%s &a to the exemption allowlist.", args[1]);
+                    }
+                    case "remove":
+                    case "delete": {
+                        AntiVPN.getInstance().getDatabase().setWhitelisted(args[1], false);
+                        return String.format("&cRemoved &6%s &c from the exemption allowlist.", args[1]);
+                    }
+                    default: {
+                        return "&c\"" + args[0] + "\" is not a valid argument";
+                    }
+                }
             }
         } 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());
+            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) {
+                switch(args[0].toLowerCase()) {
+                    case "add": {
+                        AntiVPN.getInstance().getExecutor().getWhitelisted().add(uuid);
+                        return String.format("&aAdded &6%s &auuid to the exemption allowlist.", uuid.toString());
+                    }
+                    case "remove":
+                    case "delete": {
+                        AntiVPN.getInstance().getExecutor().getWhitelisted().remove(uuid);
+                        return String.format("&cRemoved &6%s &cuuid from the exemption allowlist.", uuid.toString());
+                    }
+                    default: {
+                        return "&c\"" + args[0] + "\" is not a valid argument";
+                    }
+                }
             } else {
-                AntiVPN.getInstance().getDatabase().setWhitelisted(uuid, false);
-                return String.format("&cRemoved &6%s &cuuid from the exemption allowlist.", uuid.toString());
+                switch(args[0].toLowerCase()) {
+                    case "add": {
+                        AntiVPN.getInstance().getDatabase().setWhitelisted(uuid, true);
+                        return String.format("&aAdded &6%s &auuid to the exemption allowlist.", uuid.toString());
+                    }
+                    case "remove":
+                    case "delete": {
+                        AntiVPN.getInstance().getDatabase().setWhitelisted(uuid, false);
+                        return String.format("&cRemoved &6%s &cuuid from the exemption allowlist.", uuid.toString());
+                    }
+                    default: {
+                        return "&c\"" + args[0] + "\" is not a valid argument";
+                    }
+                }
             }
         }
     }

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

@@ -14,14 +14,22 @@ public interface VPNDatabase {
 
     boolean isWhitelisted(UUID uuid);
 
+    boolean isWhitelisted(String ip);
+
     void setWhitelisted(UUID uuid, boolean whitelisted);
 
+    void setWhitelisted(String ip, boolean whitelisted);
+
     List<UUID> getAllWhitelisted();
 
+    List<String> getAllWhitelistedIps();
+
     void getStoredResponseAsync(String ip, Consumer<Optional<VPNResponse>> result);
 
     void isWhitelistedAsync(UUID uuid, Consumer<Boolean> result);
 
+    void isWhitelistedAsync(String ip, Consumer<Boolean> result);
+
     void alertsState(UUID uuid, Consumer<Boolean> result);
 
     void updateAlertsState(UUID uuid, boolean state);

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

@@ -20,7 +20,7 @@ public class MySqlVPN implements VPNDatabase {
     public MySqlVPN() {
         whitelistedThread = new Thread(() -> {
             try {
-                Thread.sleep(TimeUnit.SECONDS.toMillis(8));
+                Thread.sleep(TimeUnit.SECONDS.toMillis(2));
             } catch (InterruptedException e) {
                 e.printStackTrace();
             }
@@ -30,6 +30,9 @@ public class MySqlVPN implements VPNDatabase {
                     AntiVPN.getInstance().getExecutor().getWhitelisted().clear();
                     AntiVPN.getInstance().getExecutor().getWhitelisted()
                             .addAll(AntiVPN.getInstance().getDatabase().getAllWhitelisted());
+                    AntiVPN.getInstance().getExecutor().getWhitelistedIps().clear();
+                    AntiVPN.getInstance().getExecutor().getWhitelistedIps()
+                            .addAll(AntiVPN.getInstance().getDatabase().getAllWhitelistedIps());
                 }
                 try {
                     Thread.sleep(TimeUnit.SECONDS.toMillis(4));
@@ -95,15 +98,28 @@ public class MySqlVPN implements VPNDatabase {
     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();
+        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;
     }
 
+    @SneakyThrows
+    @Override
+    public boolean isWhitelisted(String ip) {
+        if (!AntiVPN.getInstance().getConfig().isDatabaseEnabled() || MySQL.isClosed())
+            return false;
+        ResultSet set = Query.prepare("select `ip` from `whitelisted-ips` where `ip` = ? limit 1")
+                .append(ip).executeQuery();
+
+
+        return set != null && set.next() && set.getString("ip") != null;
+    }
+
     @Override
     public void setWhitelisted(UUID uuid, boolean whitelisted) {
-        if(MySQL.isClosed()) return;
+        if (!AntiVPN.getInstance().getConfig().isDatabaseEnabled() || MySQL.isClosed())
+            return;
 
         if (whitelisted) {
             if (!isWhitelisted(uuid)) {
@@ -116,24 +132,42 @@ public class MySqlVPN implements VPNDatabase {
         }
     }
 
+    @Override
+    public void setWhitelisted(String ip, boolean whitelisted) {
+        if (!AntiVPN.getInstance().getConfig().isDatabaseEnabled() || MySQL.isClosed())
+            return;
+
+        if(whitelisted) {
+            if(!isWhitelisted(ip)) {
+                Query.prepare("insert into `whitelisted-ips` (`ip`) values (?)").append(ip).execute();
+            }
+            AntiVPN.getInstance().getExecutor().getWhitelistedIps().add(ip);
+        } else {
+            Query.prepare("delete from `whitelisted-ips` where `ip` = ?").append(ip).execute();
+            AntiVPN.getInstance().getExecutor().getWhitelistedIps().remove(ip);
+        }
+    }
+
     @Override
     public List<UUID> getAllWhitelisted() {
         List<UUID> uuids = new ArrayList<>();
 
-        if(MySQL.isClosed()) return uuids;
+        if(!MySQL.isClosed()) Query.prepare("select uuid from `whitelisted`")
+                .execute(set -> uuids.add(UUID.fromString(set.getString("uuid"))));
 
-        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 List<String> getAllWhitelistedIps() {
+        List<String> ips = new ArrayList<>();
+
+        if(!MySQL.isClosed()) Query.prepare("select `ip` from `whitelisted-ips`")
+                    .execute(set -> ips.add(set.getString("ip")));
+
+        return ips;
+    }
+
     @Override
     public void getStoredResponseAsync(String ip, Consumer<Optional<VPNResponse>> result) {
         if(MySQL.isClosed()) return;
@@ -148,6 +182,13 @@ public class MySqlVPN implements VPNDatabase {
         VPNExecutor.threadExecutor.execute(() -> result.accept(isWhitelisted(uuid)));
     }
 
+    @Override
+    public void isWhitelistedAsync(String ip, Consumer<Boolean> result) {
+        if(MySQL.isClosed()) return;
+
+        VPNExecutor.threadExecutor.execute(() -> result.accept(isWhitelisted(ip)));
+    }
+
     @Override
     public void alertsState(UUID uuid, Consumer<Boolean> result) {
         if(MySQL.isClosed()) return;
@@ -188,71 +229,93 @@ public class MySqlVPN implements VPNDatabase {
     public void init() {
         if (!AntiVPN.getInstance().getConfig().isDatabaseEnabled())
             return;
-        System.out.println("Initializing MySQL...");
+        AntiVPN.getInstance().getExecutor().log("Initializing MySQL...");
         MySQL.init();
 
-        System.out.println("Creating tables...");
+        AntiVPN.getInstance().getExecutor().log("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! " +
+                            AntiVPN.getInstance().getExecutor().log("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!");
+                                AntiVPN.getInstance().getExecutor().log("Successfully dropped table!");
                             }
                         }
             });
         }
 
         Query.prepare("create table if not exists `whitelisted` (`uuid` varchar(36) not null)").execute();
+        Query.prepare("create table if not exists `whitelisted-ips` (`ip` varchar(45) 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...");
+        AntiVPN.getInstance().getExecutor().log("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';";
+
+            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");
+            whitelistedIndex: {
+                while (rs.next()) {
+                    id = rs.getInt("IndexExists");
+                }
+                if (id == 0) {
+                    Query.prepare("create index `uuid_1` on `whitelisted` (`uuid`)").execute();
+                }
+                id = 0;
             }
-            if (id == 0) {
-                Query.prepare("create index `uuid_1` on `whitelisted` (`uuid`)").execute();
+            responsesIndex: {
+                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();
+                }
+                id = 0;
             }
-            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();
+            whitelistedIpsIndex: {
+                query = "SELECT COUNT(1) IndexExists FROM INFORMATION_SCHEMA.STATISTICS WHERE table_schema=DATABASE()" +
+                        " AND table_name='whitelisted-ips' 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 `whitelisted-ips` (`ip`)").execute();
+                }
             }
         } catch (Exception e) {
             System.err.println("MySQL Excepton created" + e.getMessage());

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

@@ -12,6 +12,7 @@ public class MySQL {
     public static void init() {
         try {
             if (conn == null || conn.isClosed()) {
+                Class.forName("com.mysql.jdbc.Driver");
                 conn = DriverManager.getConnection("jdbc:mysql://" + AntiVPN.getInstance().getConfig().getIp()
                                 + ":" + AntiVPN.getInstance().getConfig().getPort()
                                 + "/?useSSL=true&autoReconnect=true",
@@ -22,14 +23,31 @@ public class MySQL {
                 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.");
+                AntiVPN.getInstance().getExecutor().log("Connection to MySQL has been established.");
             }
         } catch (Exception e) {
-            System.out.println("Failed to load mysql: " + e.getMessage());
+            AntiVPN.getInstance().getExecutor().log("Failed to load mysql: " + e.getMessage());
             e.printStackTrace();
         }
     }
 
+    /*public static void initH2() {
+        File dataFolder = new File(AntiVPN.getInstance().getPluginFolder(), "databases" + File.separator + "database");
+        try {
+            Class.forName("org.h2.Driver");
+            conn = new NonClosableConnection(new JdbcConnection("jdbc:h2:file:" +
+                    dataFolder.getAbsolutePath(), new Properties()));
+            conn.setAutoCommit(true);
+            Query.use(conn);
+            AntiVPN.getInstance().getExecutor().log("Connection to SQlLite has been established.");
+        } catch (SQLException ex) {
+            AntiVPN.getInstance().getExecutor().log("SQLite exception on initialize");
+            ex.printStackTrace();
+        } catch (ClassNotFoundException ex) {
+            AntiVPN.getInstance().getExecutor().log("No H2 library found!");
+        }
+    }*/
+
     public static void use() {
         try {
             init();
@@ -41,7 +59,9 @@ public class MySQL {
     public static void shutdown() {
         try {
             if(conn != null && !conn.isClosed()) {
-                conn.close();
+                if(conn instanceof NonClosableConnection) {
+                    ((NonClosableConnection)conn).shutdown();
+                } else conn.close();
                 conn = null;
             }
         } catch (Exception e) {

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

@@ -0,0 +1,122 @@
+/*
+ * This file is part of LuckPerms, licensed under the MIT License.
+ *
+ *  Copyright (c) lucko (Luck) <luck@lucko.me>
+ *  Copyright (c) contributors
+ *
+ *  Permission is hereby granted, free of charge, to any person obtaining a copy
+ *  of this software and associated documentation files (the "Software"), to deal
+ *  in the Software without restriction, including without limitation the rights
+ *  to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ *  copies of the Software, and to permit persons to whom the Software is
+ *  furnished to do so, subject to the following conditions:
+ *
+ *  The above copyright notice and this permission notice shall be included in all
+ *  copies or substantial portions of the Software.
+ *
+ *  THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ *  IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ *  FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ *  AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ *  LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ *  OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ *  SOFTWARE.
+ */
+
+package dev.brighten.antivpn.database.sql.utils;
+
+import java.sql.*;
+import java.util.Map;
+import java.util.Properties;
+import java.util.concurrent.Executor;
+
+/**
+ * A wrapper around a {@link Connection} which blocks usage of the default {@link #close()} method.
+ */
+public class NonClosableConnection implements Connection {
+    private final Connection delegate;
+
+    public NonClosableConnection(Connection delegate) {
+        this.delegate = delegate;
+    }
+
+    /**
+     * Actually {@link #close() closes} the underlying connection.
+     */
+    public final void shutdown() throws SQLException {
+        this.delegate.close();
+    }
+
+    @Override
+    public final void close() throws SQLException {
+        // do nothing
+    }
+
+    @Override
+    public final boolean isWrapperFor(Class<?> iface) throws SQLException {
+        return iface.isInstance(this.delegate) || this.delegate.isWrapperFor(iface);
+    }
+
+    @SuppressWarnings("unchecked")
+    @Override
+    public final <T> T unwrap(Class<T> iface) throws SQLException {
+        if (iface.isInstance(this.delegate)) {
+            return (T) this.delegate;
+        }
+        return this.delegate.unwrap(iface);
+    }
+
+    // Forward to the delegate connection
+    @Override public Statement createStatement() throws SQLException { return this.delegate.createStatement(); }
+    @Override public PreparedStatement prepareStatement(String sql) throws SQLException { return this.delegate.prepareStatement(sql); }
+    @Override public CallableStatement prepareCall(String sql) throws SQLException { return this.delegate.prepareCall(sql); }
+    @Override public String nativeSQL(String sql) throws SQLException { return this.delegate.nativeSQL(sql); }
+    @Override public void setAutoCommit(boolean autoCommit) throws SQLException { this.delegate.setAutoCommit(autoCommit); }
+    @Override public boolean getAutoCommit() throws SQLException { return this.delegate.getAutoCommit(); }
+    @Override public void commit() throws SQLException { this.delegate.commit(); }
+    @Override public void rollback() throws SQLException { this.delegate.rollback(); }
+    @Override public boolean isClosed() throws SQLException { return this.delegate.isClosed(); }
+    @Override public DatabaseMetaData getMetaData() throws SQLException { return this.delegate.getMetaData(); }
+    @Override public void setReadOnly(boolean readOnly) throws SQLException { this.delegate.setReadOnly(readOnly); }
+    @Override public boolean isReadOnly() throws SQLException { return this.delegate.isReadOnly(); }
+    @Override public void setCatalog(String catalog) throws SQLException { this.delegate.setCatalog(catalog); }
+    @Override public String getCatalog() throws SQLException { return this.delegate.getCatalog(); }
+    @Override public void setTransactionIsolation(int level) throws SQLException { this.delegate.setTransactionIsolation(level); }
+    @Override public int getTransactionIsolation() throws SQLException { return this.delegate.getTransactionIsolation(); }
+    @Override public SQLWarning getWarnings() throws SQLException { return this.delegate.getWarnings(); }
+    @Override public void clearWarnings() throws SQLException { this.delegate.clearWarnings(); }
+    @Override public Statement createStatement(int resultSetType, int resultSetConcurrency) throws SQLException { return this.delegate.createStatement(resultSetType, resultSetConcurrency); }
+    @Override public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException { return this.delegate.prepareStatement(sql, resultSetType, resultSetConcurrency); }
+    @Override public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency) throws SQLException { return this.delegate.prepareCall(sql, resultSetType, resultSetConcurrency); }
+    @Override public Map<String, Class<?>> getTypeMap() throws SQLException { return this.delegate.getTypeMap(); }
+    @Override public void setTypeMap(Map<String, Class<?>> map) throws SQLException { this.delegate.setTypeMap(map); }
+    @Override public void setHoldability(int holdability) throws SQLException { this.delegate.setHoldability(holdability); }
+    @Override public int getHoldability() throws SQLException { return this.delegate.getHoldability(); }
+    @Override public Savepoint setSavepoint() throws SQLException { return this.delegate.setSavepoint(); }
+    @Override public Savepoint setSavepoint(String name) throws SQLException { return this.delegate.setSavepoint(name); }
+    @Override public void rollback(Savepoint savepoint) throws SQLException { this.delegate.rollback(savepoint); }
+    @Override public void releaseSavepoint(Savepoint savepoint) throws SQLException { this.delegate.releaseSavepoint(savepoint); }
+    @Override public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException { return this.delegate.createStatement(resultSetType, resultSetConcurrency, resultSetHoldability); }
+    @Override public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException { return this.delegate.prepareStatement(sql, resultSetType, resultSetConcurrency, resultSetHoldability); }
+    @Override public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException { return this.delegate.prepareCall(sql, resultSetType, resultSetConcurrency, resultSetHoldability); }
+    @Override public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys) throws SQLException { return this.delegate.prepareStatement(sql, autoGeneratedKeys); }
+    @Override public PreparedStatement prepareStatement(String sql, int[] columnIndexes) throws SQLException { return this.delegate.prepareStatement(sql, columnIndexes); }
+    @Override public PreparedStatement prepareStatement(String sql, String[] columnNames) throws SQLException { return this.delegate.prepareStatement(sql, columnNames); }
+    @Override public Clob createClob() throws SQLException { return this.delegate.createClob(); }
+    @Override public Blob createBlob() throws SQLException { return this.delegate.createBlob(); }
+    @Override public NClob createNClob() throws SQLException { return this.delegate.createNClob(); }
+    @Override public SQLXML createSQLXML() throws SQLException { return this.delegate.createSQLXML(); }
+    @Override public boolean isValid(int timeout) throws SQLException { return this.delegate.isValid(timeout); }
+    @Override public void setClientInfo(String name, String value) throws SQLClientInfoException { this.delegate.setClientInfo(name, value); }
+    @Override public void setClientInfo(Properties properties) throws SQLClientInfoException { this.delegate.setClientInfo(properties); }
+    @Override public String getClientInfo(String name) throws SQLException { return this.delegate.getClientInfo(name); }
+    @Override public Properties getClientInfo() throws SQLException { return this.delegate.getClientInfo(); }
+    @Override public Array createArrayOf(String typeName, Object[] elements) throws SQLException { return this.delegate.createArrayOf(typeName, elements); }
+    @Override public Struct createStruct(String typeName, Object[] attributes) throws SQLException { return this.delegate.createStruct(typeName, attributes); }
+    @Override public void setSchema(String schema) throws SQLException { this.delegate.setSchema(schema); }
+    @Override public String getSchema() throws SQLException { return this.delegate.getSchema(); }
+    @Override public void abort(Executor executor) throws SQLException { this.delegate.abort(executor); }
+    @Override public void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException { this.delegate.setNetworkTimeout(executor, milliseconds); }
+    @Override public int getNetworkTimeout() throws SQLException { return this.delegate.getNetworkTimeout(); }
+
+}

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

@@ -1,6 +1,16 @@
 package dev.brighten.antivpn.utils;
 
 import java.io.Closeable;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.InputStream;
+import java.lang.reflect.Method;
+import java.net.Inet4Address;
+import java.net.InetAddress;
+import java.net.URL;
+import java.net.URLClassLoader;
+import java.nio.channels.Channels;
+import java.nio.channels.ReadableByteChannel;
 
 public class MiscUtils {
 
@@ -20,4 +30,44 @@ public class MiscUtils {
         }
     }
 
+    public static boolean isIpv4(String ip)
+    {
+
+        try {
+            InetAddress address = InetAddress.getByName(ip);
+
+            return address instanceof Inet4Address;
+        } catch(Exception e) {
+            return false;
+        }
+    }
+
+    /* Borrowed from FireFlyx ngxdev */
+    public static void download(File file, String from) throws Exception {
+        URL url = new URL(from);
+        InputStream stream = url.openStream();
+        ReadableByteChannel channel = Channels.newChannel(stream);
+        FileOutputStream out = new FileOutputStream(file);
+        out.getChannel().transferFrom(channel, 0L, Long.MAX_VALUE);
+    }
+
+    /* Borrowed from FireFlyx ngxdev */
+    public static ClassLoader injectorClassLoader = MiscUtils.class.getClassLoader();
+
+    /* Borrowed from FireFlyx ngxdev */
+    public static void injectURL(URL url) {
+        try {
+            URLClassLoader systemClassLoader = (URLClassLoader) injectorClassLoader;
+            Class<URLClassLoader> classLoaderClass = URLClassLoader.class;
+
+            try {
+                Method method = classLoaderClass.getDeclaredMethod("addURL", URL.class);
+                method.setAccessible(true);
+                method.invoke(systemClassLoader, url);
+            } catch (Throwable t) {
+                t.printStackTrace();
+            }
+        } catch (Exception e) {
+        }
+    }
 }

Velocity/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>AntiVPN</artifactId>
         <groupId>dev.brighten.antivpn</groupId>
-        <version>1.5.0</version>
+        <version>1.5.2.1</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -33,7 +33,7 @@
         <dependency>
             <groupId>dev.brighten.antivpn</groupId>
             <artifactId>Common</artifactId>
-            <version>1.5.0</version>
+            <version>1.5.2.1</version>
             <scope>provided</scope>
         </dependency>
         <dependency>

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

@@ -26,6 +26,8 @@ public class VelocityListener extends VPNExecutor {
                 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().getExecutor().isWhitelisted(event.getPlayer().getRemoteAddress()
+                                .getAddress().getHostAddress())
                         || AntiVPN.getInstance().getConfig().getPrefixWhitelists().stream()
                         .anyMatch(prefix -> event.getPlayer().getUsername().startsWith(prefix))) return;
 
@@ -88,4 +90,9 @@ public class VelocityListener extends VPNExecutor {
         threadExecutor.shutdown();
         VelocityPlugin.INSTANCE.getServer().getEventManager().unregisterListener(VelocityPlugin.INSTANCE, this);
     }
+
+    @Override
+    public void log(String log, Object... objects) {
+        VelocityPlugin.INSTANCE.getLogger().log(Level.INFO, String.format(log, objects));
+    }
 }

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

@@ -54,7 +54,7 @@ public class VelocityPlugin {
 
         //Loading plugin
         logger.info("Starting AntiVPN services...");
-        AntiVPN.start(new VelocityConfig(), new VelocityListener(), new VelocityPlayerExecutor());
+        AntiVPN.start(new VelocityConfig(), new VelocityListener(), new VelocityPlayerExecutor(), configDir.toFile());
 
         if(AntiVPN.getInstance().getConfig().metrics()) {
             logger.info("Starting metrics...");

Velocity/src/main/resources/velocity-plugin.json

@@ -0,0 +1 @@
+{"id":"kaurivpn","name":"KauriVPN","version":"${project.version}","authors":["funkemunky"],"dependencies":[],"main":"dev.brighten.antivpn.velocity.VelocityPlugin"}

pom.xml

@@ -7,7 +7,7 @@
     <groupId>dev.brighten.antivpn</groupId>
     <artifactId>AntiVPN</artifactId>
     <packaging>pom</packaging>
-    <version>1.5.0</version>
+    <version>1.5.2.1</version>
 
     <modules>
         <module>Common</module>
@@ -32,6 +32,14 @@
                     <source>8</source>
                     <target>8</target>
                     <compilerArgument>-XDignore.symbol.file</compilerArgument>
+                    <useIncrementalCompilation>false</useIncrementalCompilation>
+                    <annotationProcessorPaths>
+                        <path>
+                            <groupId>org.projectlombok</groupId>
+                            <artifactId>lombok</artifactId>
+                            <version>1.18.20</version>
+                        </path>
+                    </annotationProcessorPaths>
                 </configuration>
             </plugin>
         </plugins>