add backups to filebase storage

Author: rossnoah

src/main/java/dev/noah/perplayerkit/PerPlayerKit.java

@@ -31,6 +31,7 @@
 import dev.noah.perplayerkit.storage.StorageSelector;
 import dev.noah.perplayerkit.storage.exceptions.StorageConnectionException;
 import dev.noah.perplayerkit.storage.exceptions.StorageOperationException;
+import dev.noah.perplayerkit.util.BackupManager;
 import dev.noah.perplayerkit.util.BroadcastManager;
 import org.bstats.bukkit.Metrics;
 import org.bukkit.Bukkit;
@@ -40,11 +41,11 @@
 import org.bukkit.plugin.java.JavaPlugin;
 import org.ipvp.canvas.MenuFunctionListener;
 
-
 public final class PerPlayerKit extends JavaPlugin {
 
     public static Plugin plugin;
     public static StorageManager storageManager;
+    private BackupManager backupManager;
 
     public static Plugin getPlugin() {
         return plugin;
@@ -98,6 +99,18 @@ public void onEnable() {
             return;
         }
 
+        // Initialize backup system for file-based storage methods
+        if (isFileBasedStorage(dbType)) {
+            backupManager = new BackupManager(this);
+            if (backupManager.isEnabled()) {
+                getLogger().info("Backup system initialized for file-based storage");
+            } else {
+                getLogger().info("Backup system disabled in configuration");
+            }
+        } else {
+            getLogger().info("Backup system not needed for non-file-based storage: " + dbType);
+        }
+
         Bukkit.getScheduler().runTaskTimerAsynchronously(this, () -> {
 
             if (storageManager.isConnected()) {
@@ -111,14 +124,13 @@ public void onEnable() {
                 attemptDatabaseConnection(false);
             }
 
-        }, 30 * 20, 30 * 20); //runs every 30 seconds
+        }, 30 * 20, 30 * 20); // runs every 30 seconds
 
         loadDatabaseData();
         getLogger().info("Database data loaded");
 
         UpdateChecker updateChecker = new UpdateChecker(this);
 
-
         // REGISTER THINGS START
         KitSlotTabCompleter kitSlotTabCompleter = new KitSlotTabCompleter();
         ECSlotTabCompleter ecSlotTabCompleter = new ECSlotTabCompleter();
@@ -144,50 +156,43 @@ public void onEnable() {
         this.getCommand("deletekit").setTabCompleter(kitSlotTabCompleter);
 
         this.getCommand("inspectkit").setExecutor(new InspectKitCommand(plugin));
-        this.getCommand("inspectkit").setTabCompleter(new InspectKitCommand(plugin));
+        this.getCommand("inspectkit").setTabCompleter(kitSlotTabCompleter);
 
         this.getCommand("inspectec").setExecutor(new InspectEcCommand(plugin));
-        this.getCommand("inspectec").setTabCompleter(new InspectEcCommand(plugin));
+        this.getCommand("inspectec").setTabCompleter(ecSlotTabCompleter);
 
         this.getCommand("enderchest").setExecutor(new EnderchestCommand());
+        this.getCommand("enderchest").setTabCompleter(ecSlotTabCompleter);
 
+        this.getCommand("regear").setExecutor(new RegearCommand(this));
 
-        SavePublicKitCommand savePublicKitCommand = new SavePublicKitCommand();
-        this.getCommand("savepublickit").setExecutor(savePublicKitCommand);
-        this.getCommand("savepublickit").setTabCompleter(savePublicKitCommand);
-
-        PublicKitCommand publicKitCommand = new PublicKitCommand(plugin);
-        this.getCommand("publickit").setExecutor(publicKitCommand);
-        this.getCommand("publickit").setTabCompleter(publicKitCommand);
+        this.getCommand("publickit").setExecutor(new PublicKitCommand(plugin));
 
+        this.getCommand("savepublickit").setExecutor(new SavePublicKitCommand());
+        this.getCommand("savepublickit").setTabCompleter(kitSlotTabCompleter);
 
-        for (int i = 1; i <= 9; i++) {
-            this.getCommand("k" + i).setExecutor(new ShortKitCommand());
-        }
-
-        for (int i = 1; i <= 9; i++) {
-            this.getCommand("ec" + i).setExecutor(new ShortECCommand());
-        }
-
-        RegearCommand regearCommand = new RegearCommand(this);
-        this.getCommand("regear").setExecutor(regearCommand);
+        this.getCommand("perplayerkit").setExecutor(new PerPlayerKitCommand(plugin));
 
-        this.getCommand("heal").setExecutor(new HealCommand());
         this.getCommand("repair").setExecutor(new RepairCommand());
-        this.getCommand("perplayerkit").setExecutor(new PerPlayerKitCommand(this));
+        this.getCommand("heal").setExecutor(new HealCommand());
 
+        this.getCommand("shortkit").setExecutor(new ShortKitCommand());
+        this.getCommand("shortkit").setTabCompleter(kitSlotTabCompleter);
+
+        this.getCommand("shortec").setExecutor(new ShortECCommand());
+        this.getCommand("shortec").setTabCompleter(ecSlotTabCompleter);
 
-        Bukkit.getPluginManager().registerEvents(regearCommand, this);
-        Bukkit.getPluginManager().registerEvents(new JoinListener(this, updateChecker), this);
-        Bukkit.getPluginManager().registerEvents(new QuitListener(this), this);
         Bukkit.getPluginManager().registerEvents(new MenuFunctionListener(), this);
+        Bukkit.getPluginManager().registerEvents(new AutoRekitListener(this), this);
+        Bukkit.getPluginManager().registerEvents(new JoinListener(plugin, updateChecker), this);
+        Bukkit.getPluginManager().registerEvents(new QuitListener(this), this);
         Bukkit.getPluginManager().registerEvents(new KitMenuCloseListener(), this);
         Bukkit.getPluginManager().registerEvents(new KitRoomSaveListener(), this);
-        Bukkit.getPluginManager().registerEvents(new AutoRekitListener(this), this);
+
         Bukkit.getPluginManager().registerEvents(new AboutCommandListener(), this);
 
-//        features
-        if(getConfig().getBoolean("feature.old-death-drops", false)) {
+        // features
+        if (getConfig().getBoolean("feature.old-death-drops", false)) {
             Bukkit.getPluginManager().registerEvents(new OldDeathDropListener(), this);
         }
 
@@ -199,10 +204,8 @@ public void onEnable() {
             Bukkit.getPluginManager().registerEvents(new ShulkerDropItemsListener(), this);
         }
 
-
         // REGISTER THINGS END
 
-
         BroadcastManager.get().startScheduledBroadcast();
         updateChecker.printStartupStatus();
 
@@ -211,8 +214,24 @@ public void onEnable() {
     @Override
     public void onDisable() {
         closeDatabaseConnection();
+
+        // Shutdown backup manager if it exists
+        if (backupManager != null) {
+            backupManager.shutdown();
+        }
     }
 
+    /**
+     * Check if the storage type is file-based (requires backups)
+     * 
+     * @param storageType The storage type from configuration
+     * @return true if file-based storage, false otherwise
+     */
+    private boolean isFileBasedStorage(String storageType) {
+        return storageType.equalsIgnoreCase("sqlite") ||
+                storageType.equalsIgnoreCase("yml") ||
+                storageType.equalsIgnoreCase("yaml");
+    }
 
     private void loadPublicKitsIdsFromConfig() {
         // generate list of public kits from the config
@@ -238,7 +257,6 @@ private void loadDatabaseData() {
 
     }
 
-
     private void attemptDatabaseConnection(boolean disableOnFail) {
         try {
             storageManager.connect();
@@ -260,7 +278,7 @@ private void closeDatabaseConnection() {
         try {
             storageManager.close();
         } catch (StorageConnectionException e) {
-//            retry once
+            // retry once
             try {
                 storageManager.close();
             } catch (StorageConnectionException ex) {
@@ -269,8 +287,7 @@ private void closeDatabaseConnection() {
         }
     }
 
-
-    private void notice(){
+    private void notice() {
         String notice = """
                 * PerPlayerKit is free software: you can redistribute it and/or modify it under
                 * the terms of the GNU Affero General Public License as published by the
@@ -285,19 +302,14 @@ private void notice(){
                 * You should have received a copy of the GNU Affero General Public License
                 * along with PerPlayerKit. If not, see <https://www.gnu.org/licenses/>.""";
 
-
         String otherInfo = """
                 * All users must be provided with the source code of the software, as per the AGPL-3.0 license.
                 * If you are using a modified version of PerPlayerKit, you must make the source code of your
                 * modified version available to all users, as per the AGPL-3.0 license.
                 * Consider modifying the /aboutperplayerkit command to include a link to your modified source code.
                 """;
 
-
-
         getLogger().info(notice);
         getLogger().info(otherInfo);
     }
-
-
 }