Chain conveyors now detach on assembly

Closes #183

Author: Ocelot5836

neoforge/src/main/java/dev/ryanhcode/sable/neoforge/mixin/compatibility/create/chain_conveyor/ChainConveyorBlockEntityMixin.java

@@ -0,0 +1,39 @@
+package dev.ryanhcode.sable.neoforge.mixin.compatibility.create.chain_conveyor;
+
+import com.llamalad7.mixinextras.sugar.Local;
+import com.simibubi.create.content.kinetics.chainConveyor.ChainConveyorBlockEntity;
+import com.simibubi.create.content.kinetics.chainConveyor.ChainConveyorPackage;
+import net.minecraft.core.BlockPos;
+import org.spongepowered.asm.mixin.Mixin;
+import org.spongepowered.asm.mixin.Shadow;
+import org.spongepowered.asm.mixin.injection.At;
+import org.spongepowered.asm.mixin.injection.Inject;
+import org.spongepowered.asm.mixin.injection.callback.CallbackInfo;
+
+import java.util.List;
+import java.util.Map;
+
+@Mixin(ChainConveyorBlockEntity.class)
+public abstract class ChainConveyorBlockEntityMixin {
+
+    @Shadow
+    public Map<BlockPos, ChainConveyorBlockEntity.ConnectionStats> connectionStats;
+
+    @Shadow
+    Map<BlockPos, List<ChainConveyorPackage>> travellingPackages;
+
+    @Shadow
+    protected abstract void drop(ChainConveyorPackage box);
+
+    @Inject(method = "removeInvalidConnections", at = @At(value = "INVOKE", target = "Ljava/util/Iterator;remove()V"))
+    public void dropInvalidPackages(final CallbackInfo ci, @Local(name = "next") final BlockPos next) {
+        this.connectionStats.remove(next);
+
+        final List<ChainConveyorPackage> packages = this.travellingPackages.remove(next);
+        if (packages != null && !packages.isEmpty()) {
+            for (final ChainConveyorPackage box : packages) {
+                this.drop(box);
+            }
+        }
+    }
+}

neoforge/src/main/java/dev/ryanhcode/sable/neoforge/mixin/compatibility/create/chain_conveyor/ChainConveyorBlockMixin.java

@@ -0,0 +1,28 @@
+package dev.ryanhcode.sable.neoforge.mixin.compatibility.create.chain_conveyor;
+
+import com.simibubi.create.content.kinetics.chainConveyor.ChainConveyorBlock;
+import com.simibubi.create.content.kinetics.chainConveyor.ChainConveyorBlockEntity;
+import dev.ryanhcode.sable.api.block.BlockSubLevelAssemblyListener;
+import net.minecraft.core.BlockPos;
+import net.minecraft.server.level.ServerLevel;
+import net.minecraft.world.level.block.state.BlockState;
+import org.spongepowered.asm.mixin.Mixin;
+
+@Mixin(ChainConveyorBlock.class)
+public class ChainConveyorBlockMixin implements BlockSubLevelAssemblyListener {
+
+    @Override
+    public void beforeMove(final ServerLevel originLevel, final ServerLevel resultingLevel, final BlockState newState, final BlockPos oldPos, final BlockPos newPos) {
+        if (originLevel.getBlockEntity(oldPos) instanceof final ChainConveyorBlockEntity be) {
+            // This tells all connected conveyors to re-check and detach if necessary next tick
+            be.notifyConnectedToValidate();
+        }
+    }
+
+    @Override
+    public void afterMove(final ServerLevel originLevel, final ServerLevel resultingLevel, final BlockState newState, final BlockPos oldPos, final BlockPos newPos) {
+        if (resultingLevel.getBlockEntity(newPos) instanceof final ChainConveyorBlockEntity be) {
+            be.checkInvalid = true;
+        }
+    }
+}

neoforge/src/main/resources/sable-neoforge.mixins.json

@@ -82,6 +82,8 @@
     "compatibility.create.block_breakers.BlockBreakingKineticBlockEntityDamageMixin",
     "compatibility.create.block_breakers.BlockBreakingKineticBlockEntityMixin",
     "compatibility.create.block_entity_config.BlockEntityConfigurationPacketMixin",
+    "compatibility.create.chain_conveyor.ChainConveyorBlockEntityMixin",
+    "compatibility.create.chain_conveyor.ChainConveyorBlockMixin",
     "compatibility.create.contraptions.AbstractContraptionEntityMixin",
     "compatibility.create.contraptions.ContraptionColliderMixin",
     "compatibility.create.contraptions.Matrix3dAccessor",