fix: limits doesn't persist across reboots

Replaces: InsightsPlugin#249

Author: Euphillya

Insights-API/src/main/java/dev/frankheijden/insights/api/concurrent/ChunkContainerExecutor.java

@@ -62,6 +62,13 @@ public CompletableFuture<Storage> submit(Chunk chunk, ChunkCuboid cuboid, ScanOp
         return submit(new LoadedChunkContainer(nms, chunk, cuboid, options), options);
     }
 
+    public CompletableFuture<Storage> submitLoadChunkContainer(World world, int chunkX, int chunkZ, ChunkCuboid cuboid, ScanOptions options) {
+        return world.getChunkAtAsync(chunkX, chunkZ, false, true)
+                .thenCompose(chunk ->
+                        submit(new LoadedChunkContainer(nms, chunk, cuboid, options), options)
+                );
+    }
+
     public CompletableFuture<Storage> submit(World world, int x, int z, ChunkCuboid cuboid, ScanOptions options) {
         return submit(new UnloadedChunkContainer(nms, world, x, z, cuboid, options), options);
     }

Insights-API/src/main/java/dev/frankheijden/insights/api/concurrent/containers/LoadedChunkContainer.java

@@ -26,19 +26,11 @@ public LoadedChunkContainer(InsightsNMS nms, Chunk chunk, ChunkCuboid cuboid, Sc
 
     @Override
     public void getChunkSections(Consumer<@Nullable ChunkSection> sectionConsumer) {
-        if (Bukkit.isOwnedByCurrentRegion(chunk.getWorld(), chunkX, chunkZ)) {
-            nms.getLoadedChunkSections(chunk, sectionConsumer);
-        } else {
-            Bukkit.getRegionScheduler().execute(InsightsPlugin.getInstance(), chunk.getWorld(), chunkX, chunkZ, () -> nms.getLoadedChunkSections(chunk, sectionConsumer));
-        }
+        nms.getLoadedChunkSections(chunk, sectionConsumer);
     }
 
     @Override
     public void getChunkEntities(Consumer<@NotNull ChunkEntity> entityConsumer) {
-        if (Bukkit.isOwnedByCurrentRegion(chunk.getWorld(), chunkX, chunkZ)) {
-            nms.getLoadedChunkEntities(chunk, entityConsumer);
-        } else {
-            Bukkit.getRegionScheduler().execute(InsightsPlugin.getInstance(), chunk.getWorld(), chunkX, chunkZ, () -> nms.getLoadedChunkEntities(chunk, entityConsumer));
-        }
+        nms.getLoadedChunkEntities(chunk, entityConsumer);
     }
 }

Insights-API/src/main/java/dev/frankheijden/insights/api/tasks/ScanTask.java

@@ -418,36 +418,22 @@ public void run() {
             var loc = chunkPart.getChunkLocation();
             var world = loc.getWorld();
 
-            Bukkit.getRegionScheduler().run(plugin, world, loc.getX(), loc.getZ(), scheduledTask -> {
-                CompletableFuture<Storage> storageFuture;
-                if (world.isChunkLoaded(loc.getX(), loc.getZ())) {
-                    storageFuture = executor.submit(
-                            world.getChunkAt(loc.getX(), loc.getZ()),
-                            chunkPart.getChunkCuboid(),
-                            options
-                    );
-                } else {
-                    storageFuture = executor.submit(
-                            loc.getWorld(),
-                            loc.getX(),
-                            loc.getZ(),
-                            chunkPart.getChunkCuboid(),
-                            options
-                    );
-                }
-                storageFuture
-                        .thenAccept(storage -> resultMerger.accept(storage, loc, result))
-                        .thenRun(() -> {
-                            iterationChunks.incrementAndGet();
-                            chunks.incrementAndGet();
-                        })
-                        .exceptionally(th -> {
-                            if (!completedExceptionally.getAndSet(true)) {
-                                plugin.getLogger().log(Level.SEVERE, th, th::getMessage);
-                            }
-                            return null;
-                        });
-            });
+            executor.submitLoadChunkContainer(world,
+                    loc.getX(),
+                    loc.getZ(),
+                    chunkPart.getChunkCuboid(),
+                    options)
+                    .thenAccept(storage -> resultMerger.accept(storage, loc, result))
+                    .thenRun(() -> {
+                        iterationChunks.incrementAndGet();
+                        chunks.incrementAndGet();
+                    })
+                    .exceptionally(th -> {
+                        if (!completedExceptionally.getAndSet(true)) {
+                            plugin.getLogger().log(Level.SEVERE, th, th::getMessage);
+                        }
+                        return null;
+                    });
         }
     }