Add database connection validation

Author: FireController1847

src/main/java/com/firecontroller1847/truediscordlink/DatabaseManager.java

@@ -115,6 +115,24 @@ public boolean isConnected() {
         }
     }
 
+    // Validates the database's connection and, if there isn't one, reconnects it
+    public void validateConnection() {
+        if (!this.isConnected()) {
+            this.reconnect();
+        }
+    }
+
+    // Reconnects the database
+    public void reconnect() {
+        this.disconnect();
+        new Thread(this::connect).start();
+        try {
+            Thread.sleep(1000);
+        } catch (InterruptedException e) {
+            // ...
+        }
+    }
+
     // Getters
     public Database getDatabase() {
         return database;

src/main/java/com/firecontroller1847/truediscordlink/commands/CommandLink.java

@@ -1,9 +1,6 @@
 package com.firecontroller1847.truediscordlink.commands;
 
-import com.firecontroller1847.truediscordlink.DiscordManager;
-import com.firecontroller1847.truediscordlink.FireCommand;
-import com.firecontroller1847.truediscordlink.FirePlugin;
-import com.firecontroller1847.truediscordlink.TrueDiscordLink;
+import com.firecontroller1847.truediscordlink.*;
 import com.firecontroller1847.truediscordlink.database.DbPlayer;
 import com.visualfiredev.javabase.Database;
 import com.visualfiredev.javabase.DatabaseValue;
@@ -39,7 +36,11 @@ public boolean onCommand(@NotNull CommandSender sender, @NotNull Command command
 
         // Fetch database & player
         Player player = (Player) sender;
-        Database database = ((TrueDiscordLink) plugin).getDatabaseManager().getDatabase();
+        DatabaseManager databaseManager = ((TrueDiscordLink) plugin).getDatabaseManager();
+        Database database = databaseManager.getDatabase();
+
+        // Validate database connection
+        databaseManager.validateConnection();
 
         // Check if user is in database
         try {

src/main/java/com/firecontroller1847/truediscordlink/commands/CommandReload.java

@@ -19,8 +19,7 @@ public boolean onCommand(CommandSender sender, Command command, String label, St
         discordlink.reload();
 
         // Reconnect database
-        discordlink.getDatabaseManager().disconnect();
-        new Thread(discordlink.getDatabaseManager()::connect).start();
+        discordlink.getDatabaseManager().reconnect();
 
         // Send notification message
         sender.sendMessage(discordlink.getTranslation("config.reloaded"));

src/main/java/com/firecontroller1847/truediscordlink/commands/CommandUnlink.java

@@ -1,5 +1,6 @@
 package com.firecontroller1847.truediscordlink.commands;
 
+import com.firecontroller1847.truediscordlink.DatabaseManager;
 import com.firecontroller1847.truediscordlink.FireCommand;
 import com.firecontroller1847.truediscordlink.FirePlugin;
 import com.firecontroller1847.truediscordlink.TrueDiscordLink;
@@ -36,7 +37,11 @@ public boolean onCommand(@NotNull CommandSender sender, @NotNull Command command
 
         // Fetch database & player
         Player player = (Player) sender;
-        Database database = ((TrueDiscordLink) plugin).getDatabaseManager().getDatabase();;
+        DatabaseManager databaseManager = ((TrueDiscordLink) plugin).getDatabaseManager();
+        Database database = databaseManager.getDatabase();
+
+        // Validate database connection
+        databaseManager.validateConnection();
 
         try {
             ArrayList<DbPlayer> results;