Add cache command

Author: benwoo1110

src/main/java/org/mvplugins/multiverse/inventories/commands/CacheCommand.java

@@ -0,0 +1,64 @@
+package org.mvplugins.multiverse.inventories.commands;
+
+import com.google.common.cache.CacheStats;
+import org.bukkit.entity.Player;
+import org.jvnet.hk2.annotations.Service;
+import org.mvplugins.multiverse.core.commandtools.MVCommandIssuer;
+import org.mvplugins.multiverse.core.commandtools.MVCommandManager;
+import org.mvplugins.multiverse.external.acf.commands.annotation.CommandAlias;
+import org.mvplugins.multiverse.external.acf.commands.annotation.CommandCompletion;
+import org.mvplugins.multiverse.external.acf.commands.annotation.CommandPermission;
+import org.mvplugins.multiverse.external.acf.commands.annotation.Flags;
+import org.mvplugins.multiverse.external.acf.commands.annotation.Subcommand;
+import org.mvplugins.multiverse.external.acf.commands.annotation.Syntax;
+import org.mvplugins.multiverse.external.jakarta.inject.Inject;
+import org.mvplugins.multiverse.external.jetbrains.annotations.NotNull;
+import org.mvplugins.multiverse.inventories.profile.ProfileDataSource;
+
+import java.util.Map;
+
+@Service
+@CommandAlias("mvinv")
+final class CacheCommand extends InventoriesCommand {
+
+    private final ProfileDataSource profileDataSource;
+
+    @Inject
+    CacheCommand(@NotNull MVCommandManager commandManager, @NotNull ProfileDataSource profileDataSource) {
+        super(commandManager);
+        this.profileDataSource = profileDataSource;
+    }
+
+    @Subcommand("cache stats")
+    @CommandPermission("multiverse.inventories.cache.stats")
+    void onCacheStatsCommand(MVCommandIssuer issuer) {
+        Map<String, CacheStats> stats = this.profileDataSource.getCacheStats();
+        for (Map.Entry<String, CacheStats> entry : stats.entrySet()) {
+            issuer.sendInfo("Cache: " + entry.getKey());
+            issuer.sendInfo("  hits count: " + entry.getValue().hitCount());
+            issuer.sendInfo("  misses count: " + entry.getValue().missCount());
+            issuer.sendInfo("  loads count: " + entry.getValue().loadCount());
+            issuer.sendInfo("  avg load time: " + entry.getValue().averageLoadPenalty());
+            issuer.sendInfo("  exceptions: " + entry.getValue().loadExceptionCount());
+            issuer.sendInfo("  evictions: " + entry.getValue().evictionCount());
+        }
+    }
+
+    @Subcommand("cache invalidate all")
+    @CommandPermission("multiverse.inventories.cache.invalidate")
+    void onCacheClearAllCommand(MVCommandIssuer issuer) {
+        this.profileDataSource.clearAllCache();
+    }
+
+    @Subcommand("cache invalidate player")
+    @CommandPermission("multiverse.inventories.cache.invalidate")
+    @CommandCompletion("@players")
+    @Syntax("<player>")
+    void onCacheClearProfileCommand(
+            MVCommandIssuer issuer,
+
+            @Flags("resolve=issuerAware")
+            Player player) {
+        this.profileDataSource.clearProfileCache(key -> key.getPlayerUUID().equals(player.getUniqueId()));
+    }
+}

src/test/java/org/mvplugins/multiverse/inventories/InjectionTest.kt

@@ -15,7 +15,7 @@ class InjectionTest : TestWithMockBukkit() {
 
     @Test
     fun `InventoriesCommand are available as a service`() {
-        assertEquals(12, serviceLocator.getAllActiveServices(InventoriesCommand::class.java).size)
+        assertEquals(14, serviceLocator.getAllActiveServices(InventoriesCommand::class.java).size)
     }
 
     @Test