Merge pull request 'Fix replay in 1.21 -> RPlayer needs fixing before' (#199) from FightSystem/ReplayFix21 into main

Reviewed-on: SteamWar/SteamWar#199

SpigotCore/SpigotCore_21/src/de/steamwar/core/FlatteningWrapper21.java

@@ -43,4 +43,11 @@ public class FlatteningWrapper21 extends FlatteningWrapper14 implements Flatteni
         });
         return head;
     }
+
+    protected static final Object shooting = entityPose.getEnumConstants()[16];
+    @Override
+    public Object getPose(FlatteningWrapper.EntityPose pose) {
+        if (pose == FlatteningWrapper.EntityPose.SHOOTING) return shooting;
+        return super.getPose(pose);
+    }
 }

SpigotCore/SpigotCore_21/src/de/steamwar/core/ProtocolWrapper21.java

@@ -21,8 +21,6 @@ package de.steamwar.core;
 
 import com.mojang.authlib.GameProfile;
 import com.mojang.datafixers.util.Pair;
-import de.steamwar.Reflection;
-import net.minecraft.Util;
 import net.minecraft.network.protocol.game.ClientboundPlayerInfoRemovePacket;
 import net.minecraft.network.protocol.game.ClientboundPlayerInfoUpdatePacket;
 import net.minecraft.network.protocol.game.ClientboundSetEquipmentPacket;
@@ -33,8 +31,6 @@ import org.bukkit.GameMode;
 
 import java.util.Collections;
 import java.util.EnumSet;
-import java.util.List;
-import java.util.function.LongSupplier;
 
 public class ProtocolWrapper21 implements ProtocolWrapper {
     @Override

SpigotCore/SpigotCore_21/src/de/steamwar/core/WorldEditWrapper21.java

@@ -19,7 +19,6 @@
 
 package de.steamwar.core;
 
-import com.fastasyncworldedit.core.extent.clipboard.io.FastSchematicReaderV2;
 import com.sk89q.jnbt.NBTInputStream;
 import com.sk89q.worldedit.extension.platform.Actor;
 import com.sk89q.worldedit.extent.clipboard.Clipboard;
@@ -37,7 +36,11 @@ import org.bukkit.entity.Player;
 import org.bukkit.util.Vector;
 import org.enginehub.linbus.stream.LinBinaryIO;
 
-import java.io.*;
+import java.io.DataInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.List;
 
 public class WorldEditWrapper21 implements WorldEditWrapper {
 
@@ -68,12 +71,58 @@ public class WorldEditWrapper21 implements WorldEditWrapper {
 
     @Override
     @SuppressWarnings("removal")
-    public Clipboard getClipboard(InputStream is, NodeData.SchematicFormat schemFormat) throws IOException {
-        return switch (schemFormat) {
-            case MCEDIT -> new MCEditSchematicReader(new NBTInputStream(is)).read();
-            case SPONGE_V2 -> new SpongeSchematicV2Reader(LinBinaryIO.read(new DataInputStream(is))).read();
-            case SPONGE_V3 -> new SpongeSchematicV3Reader(LinBinaryIO.read(new DataInputStream(is))).read();
-        };
+    public Clipboard getClipboard(InputStream is, NodeData.SchematicFormat ignored) throws IOException {
+        ResetableInputStream ris = new ResetableInputStream(is);
+        for (NodeData.SchematicFormat schemFormat : NodeData.SchematicFormat.values()) {
+            try {
+                Clipboard clipboard = switch (schemFormat) {
+                    case MCEDIT -> new MCEditSchematicReader(new NBTInputStream(ris)).read();
+                    case SPONGE_V2 -> new SpongeSchematicV2Reader(LinBinaryIO.read(new DataInputStream(ris))).read();
+                    case SPONGE_V3 -> new SpongeSchematicV3Reader(LinBinaryIO.read(new DataInputStream(ris))).read();
+                };
+                ris.close();
+                return clipboard;
+            } catch (Exception e) {
+                // Ignore
+            }
+            ris.reset();
+        }
+        throw new IOException("No clipboard found");
+    }
+
+    private class ResetableInputStream extends InputStream {
+
+        private InputStream inputStream;
+        private int pointer = 0;
+        private List<Integer> list = new ArrayList<>();
+
+        public ResetableInputStream(InputStream in) {
+            this.inputStream = in;
+        }
+
+        @Override
+        public int read() throws IOException {
+            if (pointer >= list.size()) {
+                int data = inputStream.read();
+                list.add(data);
+                pointer++;
+                return data;
+            }
+            int data = list.get(pointer);
+            pointer++;
+            return data;
+        }
+
+        @Override
+        public void reset() throws IOException {
+            pointer = 0;
+        }
+
+        @Override
+        public void close() throws IOException {
+            list.clear();
+            pointer = -1;
+        }
     }
 
     @Override