Revert "fix: ghost mushroom attempt 1"

This reverts commit 5054bef.

Author: ishland

c2me-notickvd/src/main/java/com/ishland/c2me/notickvd/common/Config.java

@@ -13,6 +13,12 @@ public class Config {
                     " Lower this for a better latency and higher this for a faster loading")
             .getLong(GlobalExecutors.GLOBAL_EXECUTOR_PARALLELISM * 2L, GlobalExecutors.GLOBAL_EXECUTOR_PARALLELISM * 2L, ConfigSystem.LongChecks.POSITIVE_VALUES_ONLY);
 
+    public static final boolean compatibilityMode = new ConfigSystem.ConfigAccessor()
+            .key("noTickViewDistance.compatibilityMode")
+            .comment("Whether to use compatibility mode to send chunks \n" +
+                    " This may fix some mod compatibility issues")
+            .getBoolean(true, true);
+
     public static final boolean enableExtRenderDistanceProtocol = new ConfigSystem.ConfigAccessor()
             .key("noTickViewDistance.enableExtRenderDistanceProtocol")
             .comment("""

c2me-notickvd/src/main/java/com/ishland/c2me/notickvd/mixin/MixinServerAccessible.java

@@ -27,4 +27,14 @@ private static boolean needSendChunks() {
         return true;
     }
 
+    @Dynamic
+    @WrapOperation(method = "lambda$upgradeToThis$0", at = @At(value = "INVOKE", target = "Lcom/ishland/c2me/rewrites/chunksystem/common/statuses/ServerAccessible;sendChunkToPlayer(Lnet/minecraft/server/world/ServerChunkLoadingManager;Lcom/ishland/flowsched/scheduler/ItemHolder;)V", remap = true), remap = false)
+    private static void wrapSendChunks(ServerChunkLoadingManager tacs, ItemHolder<?, ?, ?, ?> holder, Operation<Void> original) {
+        if (Config.compatibilityMode) {
+            ((IThreadedAnvilChunkStorage) tacs).getMainThreadExecutor().submit(() -> original.call(tacs, holder));
+        } else {
+            original.call(tacs, holder);
+        }
+    }
+
 }

c2me-notickvd/src/main/java/com/ishland/c2me/notickvd/mixin/MixinThreadedAnvilChunkStorage.java

@@ -53,7 +53,11 @@ private WorldChunk redirectSendWatchPacketsGetWorldChunk(ChunkHolder chunkHolder
     @Inject(method = "makeChunkAccessible", at = @At("RETURN"))
     private void onMakeChunkAccessible(ChunkHolder chunkHolder, CallbackInfoReturnable<CompletableFuture<OptionalChunk<WorldChunk>>> cir) {
         cir.getReturnValue().thenAccept(either -> either.ifPresent(worldChunk -> {
-            this.mainThreadExecutor.send(() -> this.sendToPlayers(worldChunk));
+            if (Config.compatibilityMode) {
+                this.mainThreadExecutor.send(() -> this.sendToPlayers(worldChunk));
+            } else {
+                this.sendToPlayers(worldChunk);
+            }
         }));
     }
 

c2me-rewrites-chunk-system/src/main/java/com/ishland/c2me/rewrites/chunksystem/common/ducks/IPartialPostProcessing.java

@@ -9,7 +9,6 @@
 import com.ishland.c2me.rewrites.chunksystem.common.Config;
 import com.ishland.c2me.rewrites.chunksystem.common.NewChunkHolderVanillaInterface;
 import com.ishland.c2me.rewrites.chunksystem.common.NewChunkStatus;
-import com.ishland.c2me.rewrites.chunksystem.common.ducks.IPartialPostProcessing;
 import com.ishland.c2me.rewrites.chunksystem.common.fapi.LifecycleEventInvoker;
 import com.ishland.flowsched.scheduler.ItemHolder;
 import com.ishland.flowsched.scheduler.KeyStatusPair;
@@ -86,13 +85,15 @@ private static boolean needSendChunks() {
     }
 
     private static void sendChunkToPlayer(ServerChunkLoadingManager tacs, ItemHolder<ChunkPos, ChunkState, ChunkLoadingContext, NewChunkHolderVanillaInterface> holder) {
-        holder.submitOp(CompletableFuture.runAsync(() -> {
-            final Chunk chunk = holder.getItem().get().chunk();
-            if (chunk instanceof WorldChunk worldChunk) {
-                ((IPartialPostProcessing) worldChunk).c2me$runBorderPostProcessing();
+        final Chunk chunk = holder.getItem().get().chunk();
+        if (chunk instanceof WorldChunk worldChunk) {
+            CompletableFuture<?> completableFuturexx = holder.getUserData().get().getPostProcessingFuture();
+            if (completableFuturexx.isDone()) {
                 ((IThreadedAnvilChunkStorage) tacs).invokeSendToPlayers(worldChunk);
+            } else {
+                completableFuturexx.thenAcceptAsync(v -> ((IThreadedAnvilChunkStorage) tacs).invokeSendToPlayers(worldChunk), ((IThreadedAnvilChunkStorage) tacs).getMainThreadExecutor());
             }
-        }, ((IThreadedAnvilChunkStorage) tacs).getMainThreadExecutor()::submit));
+        }
     }
 
     private static WorldChunk toFullChunk(ProtoChunk protoChunk, ServerWorld serverWorld) {

c2me-rewrites-chunk-system/src/main/java/com/ishland/c2me/rewrites/chunksystem/common/statuses/ServerAccessible.java

@@ -12,7 +12,6 @@
     "MixinNoiseChunkGenerator",
     "MixinServerChunkManager",
     "MixinThreadedAnvilChunkStorage",
-    "MixinWorldChunk",
     "async_serialization.MixinBlender",
     "async_serialization.MixinChunkRegion",
     "async_serialization.MixinChunkSerializer",