Add profile cache

plugin/build.gradle.kts

@@ -22,6 +22,8 @@ dependencies {
   implementation(project(":openinvadapterspigot", configuration = SpigotReobf.ARTIFACT_CONFIG))
   implementation(libs.planarwrappers)
   implementation(libs.folia.scheduler.wrapper)
+  // TODO move to libs, check versions on Spigot/Paper
+  compileOnly("org.xerial:sqlite-jdbc:3.51.1.0")
 }
 
 tasks.processResources {

plugin/src/main/java/com/lishid/openinv/OpenInv.java

@@ -56,6 +56,7 @@
 import java.util.Locale;
 import java.util.UUID;
 import java.util.function.Consumer;
+import java.util.logging.Level;
 
 /**
  * The main class for OpenInv.
@@ -69,6 +70,10 @@ public class OpenInv extends FoliaWrappedJavaPlugin implements IOpenInv {
   private PlayerLoader playerLoader;
   private boolean isSpigot = false;
 
+  public PlayerLoader getPlayerLoader() {
+    return playerLoader;
+  }
+
   @Override
   public void reloadConfig() {
     super.reloadConfig();
@@ -96,6 +101,11 @@ public boolean onCommand(
   @Override
   public void onDisable() {
     inventoryManager.evictAll();
+    try {
+      playerLoader.getProfileStore().shutdown();
+    } catch (Exception e) {
+      getLogger().log(Level.WARNING, "Failed to shut down profile store correctly", e);
+    }
   }
 
   @Override

plugin/src/main/java/com/lishid/openinv/util/PlayerLoader.java

@@ -5,13 +5,16 @@
 import com.google.errorprone.annotations.Keep;
 import com.lishid.openinv.OpenInv;
 import com.lishid.openinv.util.config.Config;
+import com.lishid.openinv.util.profile.OfflinePlayerProfileStore;
+import com.lishid.openinv.util.profile.Profile;
+import com.lishid.openinv.util.profile.ProfileStore;
+import com.lishid.openinv.util.profile.sqlite.SqliteProfileStore;
 import org.bukkit.Bukkit;
 import org.bukkit.OfflinePlayer;
 import org.bukkit.entity.Player;
 import org.bukkit.event.EventHandler;
 import org.bukkit.event.Listener;
 import org.bukkit.event.player.PlayerJoinEvent;
-import org.bukkit.profile.PlayerProfile;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
@@ -33,7 +36,8 @@ public class PlayerLoader implements Listener {
   private final @NotNull InventoryManager inventoryManager;
   private final @NotNull InternalAccessor internalAccessor;
   private final @NotNull Logger logger;
-  private final @NotNull Cache<String, PlayerProfile> lookupCache;
+  private final @NotNull Cache<String, Profile> lookupCache;
+  private @NotNull ProfileStore profileStore;
 
   public PlayerLoader(
       @NotNull OpenInv plugin,
@@ -46,10 +50,30 @@ public PlayerLoader(
     this.config = config;
     this.inventoryManager = inventoryManager;
     this.internalAccessor = internalAccessor;
+    try {
+      SqliteProfileStore sqliteStore = new SqliteProfileStore(plugin);
+      sqliteStore.setup();
+      sqliteStore.tryImport();
+      this.profileStore = sqliteStore;
+    } catch (Exception e) {
+      this.profileStore = new OfflinePlayerProfileStore(logger);
+    }
     this.logger = logger;
     this.lookupCache = CacheBuilder.newBuilder().maximumSize(20).build();
   }
 
+  public @NotNull ProfileStore getProfileStore() {
+    return profileStore;
+  }
+
+  public void setProfileStore(@NotNull ProfileStore profileStore) {
+    plugin.getLogger().log(
+        Level.INFO,
+        () -> "Setting profile store implementation to " + profileStore.getClass().getName()
+    );
+    this.profileStore = profileStore;
+  }
+
   /**
    * Load a {@link Player} from an {@link OfflinePlayer}. If the user has not played before or the default world for
    * the server is not loaded, this will return {@code null}.
@@ -59,22 +83,20 @@ public PlayerLoader(
    * @throws IllegalStateException if the server version is unsupported
    */
   public @Nullable Player load(@NotNull OfflinePlayer offline) {
-    UUID key = offline.getUniqueId();
-
     Player player = offline.getPlayer();
     if (player != null) {
       return player;
     }
 
-    player = inventoryManager.getLoadedPlayer(key);
-    if (player != null) {
-      return player;
-    }
-
     if (config.isOfflineDisabled() || !internalAccessor.isSupported()) {
       return null;
     }
 
+    player = inventoryManager.getLoadedPlayer(offline.getUniqueId());
+    if (player != null) {
+      return player;
+    }
+
     if (Bukkit.isPrimaryThread()) {
       return internalAccessor.getPlayerDataManager().loadPlayer(offline);
     }
@@ -93,13 +115,6 @@ public PlayerLoader(
   }
 
   public @Nullable OfflinePlayer matchExact(@NotNull String name) {
-    // Warn if called on the main thread - if we resort to searching offline players, this may take several seconds.
-    if (Bukkit.getServer().isPrimaryThread()) {
-      logger.warning("Call to PlayerSearchCache#matchPlayer made on the main thread!");
-      logger.warning("This can cause the server to hang, potentially severely.");
-      logger.log(Level.WARNING, "Current stack trace", new Throwable("Current stack trace"));
-    }
-
     OfflinePlayer player;
 
     try {
@@ -123,9 +138,9 @@ public PlayerLoader(
     }
 
     // Cached offline match.
-    PlayerProfile cachedResult = lookupCache.getIfPresent(name);
-    if (cachedResult != null && cachedResult.getUniqueId() != null) {
-      player = Bukkit.getOfflinePlayer(cachedResult.getUniqueId());
+    Profile cachedResult = lookupCache.getIfPresent(name);
+    if (cachedResult != null) {
+      player = Bukkit.getOfflinePlayer(cachedResult.id());
       // Ensure player is an existing player.
       if (player.hasPlayedBefore() || player.isOnline()) {
         return player;
@@ -135,10 +150,15 @@ public PlayerLoader(
     }
 
     // Exact offline match second - ensure offline access works when matchable users are online.
-    player = Bukkit.getServer().getOfflinePlayer(name);
+    Profile profile = profileStore.getProfileExact(name);
+    if (profile == null) {
+      return null;
+    }
+
+    player = Bukkit.getOfflinePlayer(profile.id());
 
     if (player.hasPlayedBefore()) {
-      lookupCache.put(name, player.getPlayerProfile());
+      lookupCache.put(name, profile);
       return player;
     }
 
@@ -160,77 +180,51 @@ public PlayerLoader(
     }
 
     // Finally, inexact offline match.
-    float bestMatch = 0;
-    for (OfflinePlayer offline : Bukkit.getServer().getOfflinePlayers()) {
-      if (offline.getName() == null) {
-        // Loaded by UUID only, name has never been looked up.
-        continue;
-      }
-
-      float currentMatch = StringMetric.compareJaroWinkler(name, offline.getName());
-
-      if (currentMatch == 1.0F) {
-        return offline;
-      }
+    Profile profile = getProfileStore().getProfileInexact(name);
 
-      if (currentMatch > bestMatch) {
-        bestMatch = currentMatch;
-        player = offline;
-      }
-    }
-
-    if (player != null) {
-      // If a match was found, store it.
-      lookupCache.put(name, player.getPlayerProfile());
-      return player;
+    if (profile == null) {
+      // No match found.
+      return null;
     }
 
-    // No players have ever joined the server.
-    return null;
+    // Get associated player and store match.
+    player = Bukkit.getOfflinePlayer(profile.id());
+    lookupCache.put(name, profile);
+    return player;
   }
 
   @Keep
   @EventHandler
+  private void onPlayerJoin(@NotNull PlayerJoinEvent event) {
+    plugin.getScheduler().runTaskLaterAsynchronously(() -> updateMatches(event), 7L);
+  }
+
   private void updateMatches(@NotNull PlayerJoinEvent event) {
+    // Update profile store.
+    profileStore.addProfile(new Profile(event.getPlayer()));
+
     // If player is not new, any cached values are valid.
-    if (event.getPlayer().hasPlayedBefore()) {
+    if (event.getPlayer().hasPlayedBefore() || lookupCache.size() == 0) {
       return;
     }
 
     // New player may have a name that already points to someone else in lookup cache.
     String name = event.getPlayer().getName();
     lookupCache.invalidate(name);
 
-    // If the cache is empty, nothing to do. Don't hit scheduler.
-    if (lookupCache.size() == 0) {
-      return;
+    Iterator<Map.Entry<String, Profile>> iterator = lookupCache.asMap().entrySet().iterator();
+    while (iterator.hasNext()) {
+      Map.Entry<String, Profile> entry = iterator.next();
+      String oldMatch = entry.getValue().name();
+      String lookup = entry.getKey();
+      float oldMatchScore = StringMetric.compareJaroWinkler(lookup, oldMatch);
+      float newMatchScore = StringMetric.compareJaroWinkler(lookup, name);
+
+      // If new match exceeds old match, delete old match.
+      if (newMatchScore > oldMatchScore) {
+        iterator.remove();
+      }
     }
-
-    plugin.getScheduler().runTaskLaterAsynchronously(
-        () -> {
-          Iterator<Map.Entry<String, PlayerProfile>> iterator = lookupCache.asMap().entrySet().iterator();
-          while (iterator.hasNext()) {
-            Map.Entry<String, PlayerProfile> entry = iterator.next();
-            String oldMatch = entry.getValue().getName();
-
-            // Shouldn't be possible - all profiles should be complete.
-            if (oldMatch == null) {
-              iterator.remove();
-              continue;
-            }
-
-            String lookup = entry.getKey();
-            float oldMatchScore = StringMetric.compareJaroWinkler(lookup, oldMatch);
-            float newMatchScore = StringMetric.compareJaroWinkler(lookup, name);
-
-            // If new match exceeds old match, delete old match.
-            if (newMatchScore > oldMatchScore) {
-              iterator.remove();
-            }
-          }
-        },
-        7L
-    );
   }
 
 }

plugin/src/main/java/com/lishid/openinv/util/profile/BatchProfileStore.java

@@ -0,0 +1,68 @@
+package com.lishid.openinv.util.profile;
+
+import com.github.jikoo.planarwrappers.scheduler.TickTimeUnit;
+import me.nahu.scheduler.wrapper.WrappedJavaPlugin;
+import me.nahu.scheduler.wrapper.runnable.WrappedRunnable;
+import org.jetbrains.annotations.NotNull;
+
+import java.util.Collections;
+import java.util.HashSet;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicReference;
+
+public abstract class BatchProfileStore implements ProfileStore {
+
+  private final Set<Profile> pending = Collections.synchronizedSet(new HashSet<>());
+  private final AtomicReference<WrappedRunnable> insertTask = new AtomicReference<>();
+  protected final @NotNull WrappedJavaPlugin plugin;
+
+  protected BatchProfileStore(@NotNull WrappedJavaPlugin plugin) {
+    this.plugin = plugin;
+  }
+
+  @Override
+  public void addProfile(@NotNull Profile profile) {
+    pending.add(profile);
+    buildBatch();
+  }
+
+  private void buildBatch() {
+    if (insertTask.compareAndSet(null, new WrappedRunnable() {
+      @Override
+      public void run() {
+        pushBatch();
+      }
+    })) {
+      // Wait 5 seconds to accumulate other player data to reduce scheduler load on larger servers.
+      insertTask.get().runTaskLaterAsynchronously(plugin, TickTimeUnit.toTicks(5, TimeUnit.SECONDS));
+    }
+  }
+
+  private void pushBatch() {
+    Set<Profile> batch = new HashSet<>(pending);
+    // This is a bit roundabout but removes the risk of data loss.
+    pending.removeAll(batch);
+
+    // Push current batch.
+    pushBatch(batch);
+
+    WrappedRunnable running = insertTask.getAndSet(null);
+    if (running != null) {
+      running.cancel();
+    }
+  }
+
+  @Override
+  public void shutdown() {
+    WrappedRunnable wrappedRunnable = insertTask.get();
+    if (wrappedRunnable != null) {
+      wrappedRunnable.cancel();
+    }
+    pushBatch();
+    insertTask.set(null);
+  }
+
+  protected abstract void pushBatch(@NotNull Set<Profile> batch);
+
+}

plugin/src/main/java/com/lishid/openinv/util/profile/OfflinePlayerImporter.java

@@ -0,0 +1,29 @@
+package com.lishid.openinv.util.profile;
+
+import me.nahu.scheduler.wrapper.runnable.WrappedRunnable;
+import org.bukkit.Bukkit;
+import org.bukkit.OfflinePlayer;
+import org.jetbrains.annotations.NotNull;
+
+public abstract class OfflinePlayerImporter extends WrappedRunnable {
+
+  private final @NotNull BatchProfileStore profileStore;
+
+  public OfflinePlayerImporter(@NotNull BatchProfileStore profileStore) {
+    this.profileStore = profileStore;
+  }
+
+  @Override
+  public void run() {
+    for (OfflinePlayer offline : Bukkit.getOfflinePlayers()) {
+      String name = offline.getName();
+      if (name != null) {
+        profileStore.addProfile(new Profile(name, offline.getUniqueId()));
+      }
+    }
+    onComplete();
+  }
+
+  public abstract void onComplete();
+
+}