feat: add live refresh for fake chunks

Author: Mapacheee

src/main/java/me/mapacheee/extendedhorizons/chunk/FakeChunkService.java

@@ -69,6 +69,8 @@ public class FakeChunkService {
     private final Map<UUID, Integer> lastSentRadius = new ConcurrentHashMap<>();
     private final Map<UUID, Integer> lastSentSimulationDistance = new ConcurrentHashMap<>();
     private final Map<UUID, Long> lastForcedPlanMs = new ConcurrentHashMap<>();
+    private final Map<UUID, Long> lastAutoRefreshMs = new ConcurrentHashMap<>();
+    private final Map<UUID, AtomicInteger> autoRefreshCursor = new ConcurrentHashMap<>();
     private final Map<UUID, UUID> lastKnownWorldId = new ConcurrentHashMap<>();
     private final Map<UUID, Long> sessionEpoch = new ConcurrentHashMap<>();
     private final AtomicLong chunkLoadSamples = new AtomicLong();
@@ -141,6 +143,9 @@ public void onEnable() {
                                         }
                                     }
                                 }
+                                if (tracker != null) {
+                                    maybeAutoRefreshSentChunks(world, playerId, tracker);
+                                }
                             });
                         }
                     },
@@ -168,6 +173,8 @@ public void onDisable() {
         lastSentRadius.clear();
         lastSentSimulationDistance.clear();
         lastForcedPlanMs.clear();
+        lastAutoRefreshMs.clear();
+        autoRefreshCursor.clear();
         lastKnownWorldId.clear();
         sessionEpoch.clear();
     }
@@ -431,6 +438,34 @@ private void resetPlayerState(UUID playerId, boolean resetTracker) {
         lastSentRadius.remove(playerId);
         lastSentSimulationDistance.remove(playerId);
         lastForcedPlanMs.remove(playerId);
+        lastAutoRefreshMs.remove(playerId);
+        autoRefreshCursor.remove(playerId);
+    }
+
+    private void maybeAutoRefreshSentChunks(World world, UUID playerId, PlayerChunkTracker tracker) {
+        if (!config().autoRefreshEnabled()) return;
+        if (world == null || playerId == null || tracker == null) return;
+        Set<Long> sent = tracker.getSentChunks();
+        if (sent.isEmpty()) return;
+        long now = System.currentTimeMillis();
+        long periodMs = config().autoRefreshPeriodMs();
+        Long last = lastAutoRefreshMs.get(playerId);
+        if (last != null && now - last < periodMs) return;
+
+        List<Long> sentList = new ArrayList<>(sent);
+        int size = sentList.size();
+        if (size == 0) return;
+
+        int perCycle = Math.min(config().autoRefreshChunksPerCycle(), size);
+        AtomicInteger cursor = autoRefreshCursor.computeIfAbsent(playerId, k -> new AtomicInteger(0));
+        for (int i = 0; i < perCycle; i++) {
+            int idx = Math.floorMod(cursor.getAndIncrement(), size);
+            long chunkKey = sentList.get(idx);
+            int cx = ChunkPos.getX(chunkKey);
+            int cz = ChunkPos.getZ(chunkKey);
+            handleRealChunkInteraction(world, cx, cz);
+        }
+        lastAutoRefreshMs.put(playerId, now);
     }
 
     private void refreshChunkForPlayer(Player player, World world, PlayerChunkTracker tracker, int chunkX, int chunkZ, long chunkKey) {

src/main/java/me/mapacheee/extendedhorizons/config/Config.java

@@ -65,6 +65,21 @@ public long cacheBypassAfterRealInteractionMs() {
         return fakeChunks.cache().bypassAfterRealInteractionMs();
     }
 
+    public boolean autoRefreshEnabled() {
+        if (fakeChunks == null || fakeChunks.liveRefresh() == null) return true;
+        return fakeChunks.liveRefresh().enabled();
+    }
+
+    public long autoRefreshPeriodMs() {
+        if (fakeChunks == null || fakeChunks.liveRefresh() == null) return 2000L;
+        return Math.max(250L, fakeChunks.liveRefresh().periodMs());
+    }
+
+    public int autoRefreshChunksPerCycle() {
+        if (fakeChunks == null || fakeChunks.liveRefresh() == null) return 1;
+        return Math.max(1, fakeChunks.liveRefresh().chunksPerCycle());
+    }
+
     public int interceptorMaxTargetDistance() {
         return packetInterceptor == null ? 32 : packetInterceptor.maxTargetDistance();
     }
@@ -90,6 +105,7 @@ public record FakeChunksConfig(
             KeepAliveConfig keepalive,
             WarmupConfig warmup,
             CacheConfig cache,
+            @Setting("live-refresh") LiveRefreshConfig liveRefresh,
             @Setting("safe-square-factor") double safeSquareFactor
     ) {
         @ConfigSerializable
@@ -113,6 +129,14 @@ public record CacheConfig(
         ) {
         }
 
+        @ConfigSerializable
+        public record LiveRefreshConfig(
+                boolean enabled,
+                @Setting("period-ms") long periodMs,
+                @Setting("chunks-per-cycle") int chunksPerCycle
+        ) {
+        }
+
     }
 
     @ConfigSerializable

src/main/resources/config.yml

@@ -38,6 +38,13 @@ fake-chunks:
     max-entries: 1500
     # Temporary cache bypass after real-player interaction in a chunk.
     bypass-after-real-interaction-ms: 3000
+  live-refresh:
+    # Periodically refreshes already-sent fake chunks to sync edits (e.g. WorldEdit) and activity.
+    enabled: true
+    # Minimum delay between refresh cycles per player.
+    period-ms: 2000
+    # Number of sent fake chunks refreshed per cycle.
+    chunks-per-cycle: 1
   # Internal safe-square factor (0.65 = 65% of server view distance).
   # Fake chunks are not forced inside this area.
   safe-square-factor: 0.65