flood fill

src/main/java/net/brokenmoon/redcontrol/RedControl.java

@@ -189,9 +189,10 @@ public class RedControl implements ModInitializer {
 				((ServerWorld)world).spawnParticles(ParticleTypes.CRIT,center.x,center.y,center.z,30,0.1,0.1,0.1,0.1);
 				if (newState.isIn(TAG_BUSABLE)) {
 					//a bus-block was placed
-					FloodFill.INSTANCE.blockFloodFiller((ServerWorld) world,blockPos);
+					FloodFill.INSTANCE.blockFloodFiller((ServerWorld) world, blockPos);
 				} else {
 					//a bus block was removed
+					FloodFill.INSTANCE.blockBreakFloodFiller((ServerWorld) world, blockPos);
 				}
 			}
 		});

src/main/java/net/brokenmoon/redcontrol/api/RCWorldBus.java

@@ -2,6 +2,7 @@ package net.brokenmoon.redcontrol.api;
 
 import com.simon816.j65el02.device.RedBus;
 import net.brokenmoon.redcontrol.blocks.NetworkCarrier;
+import net.minecraft.server.world.ServerWorld;
 import net.minecraft.util.math.BlockPos;
 import net.minecraft.world.World;
 
@@ -21,7 +22,7 @@ public class RCWorldBus {
     }
 
 
-    public void generateBus(World world, BlockPos pos){
+    public void generateBus(ServerWorld world, BlockPos pos){
         ((NetworkCarrier)(world.getBlockState(pos).getBlock())).generateBus(world, pos);
     }
 

src/main/java/net/brokenmoon/redcontrol/blockentities/CpuEntity.java

@@ -11,6 +11,7 @@ import net.minecraft.nbt.NbtCompound;
 import net.minecraft.network.listener.ClientPlayPacketListener;
 import net.minecraft.network.packet.Packet;
 import net.minecraft.network.packet.s2c.play.BlockEntityUpdateS2CPacket;
+import net.minecraft.server.world.ServerWorld;
 import net.minecraft.util.math.BlockPos;
 import net.minecraft.world.World;
 import org.jetbrains.annotations.Nullable;
@@ -33,11 +34,11 @@ public class CpuEntity extends Peripheral{
         super(RedControl.CPU_BLOCK_ENTITY, pos, state, 0);
     }
 
-    public static void tick(World world, BlockPos pos, BlockState state, CpuEntity be) {
+    public static void tick(World world, BlockPos pos, BlockState state, CpuEntity beo) {
+        if(!world.isClient) {
             if(be.worldBus == null || !be.worldBus.getValid()){
-            ((NetworkCarrier)state.getBlock()).generateBus(world, pos);
+                ((NetworkCarrier)state.getBlock()).generateBus((ServerWorld) world, pos);
             }
-        if(!world.isClient) {
             if (be.notTicked) {
                 be.notTicked = false;
             }

src/main/java/net/brokenmoon/redcontrol/blocks/CpuBlock.java

@@ -49,8 +49,6 @@ public class CpuBlock extends NetworkCarrier {
                 super.onUse(state,world,pos,player,hand,hit);
                 CpuEntity peripheral = (CpuEntity) world.getBlockEntity(pos);
                 player.sendMessage(Text.literal("Cpu Debug: "), false);
-                player.sendMessage(Text.literal("  " + Integer.toHexString(peripheral.getBus().hashCode())), false);
-                player.sendMessage(Text.literal("  " + Integer.toHexString(peripheral.core.cpu.getBus().getRedBus().hashCode())), false);
                 player.sendMessage(Text.literal("  " + Integer.toHexString(peripheral.i)), false);
                 player.sendMessage(Text.literal("  " + peripheral.core.isWaitingOnInterrupt()), false);
                 player.sendMessage(Text.literal("  " + peripheral.core.cpu.getCpuState().toTraceEvent()));

src/main/java/net/brokenmoon/redcontrol/blocks/NetworkCarrier.java

@@ -3,13 +3,19 @@ package net.brokenmoon.redcontrol.blocks;
 import com.simon816.j65el02.device.RedBus;
 import net.brokenmoon.redcontrol.RedControl;
 import net.brokenmoon.redcontrol.api.RCWorldBus;
+import net.brokenmoon.redcontrol.blockentities.CpuEntity;
 import net.brokenmoon.redcontrol.blockentities.Peripheral;
 import net.brokenmoon.redcontrol.mixin.RedBusAccessor;
+import net.brokenmoon.redcontrol.util.FloodFill;
 import net.minecraft.block.*;
+import net.minecraft.block.entity.BlockEntity;
+import net.minecraft.block.entity.BlockEntityTicker;
+import net.minecraft.block.entity.BlockEntityType;
 import net.minecraft.entity.LivingEntity;
 import net.minecraft.entity.player.PlayerEntity;
 import net.minecraft.item.ItemPlacementContext;
 import net.minecraft.item.ItemStack;
+import net.minecraft.server.world.ServerWorld;
 import net.minecraft.state.StateManager;
 import net.minecraft.state.property.Properties;
 import net.minecraft.text.Text;
@@ -35,11 +41,12 @@ public abstract class NetworkCarrier extends BlockWithEntity implements BlockEnt
 
     @Override
     public void onPlaced(World world, BlockPos pos, BlockState state, @Nullable LivingEntity placer, ItemStack itemStack) {
-        generateBus(world, pos);
+        if (!world.isClient) {
+            generateBus((ServerWorld)  world, pos);
+        }
     }
 
     @Override
-    @SuppressWarnings("uses or overrides a deprecated API.")
     public void onStateReplaced(BlockState state, World world, BlockPos pos, BlockState newState, boolean moved) {
         if(state.hasBlockEntity() && world.getBlockEntity(pos) instanceof Peripheral){
             if(((Peripheral) world.getBlockEntity(pos)).getBus() != null)
@@ -57,7 +64,7 @@ public abstract class NetworkCarrier extends BlockWithEntity implements BlockEnt
     }
 
 
-    public void generateBus(World world, BlockPos pos){
+    public void generateBus(ServerWorld world, BlockPos pos){
         Block worldBlock = world.getBlockState(pos).getBlock();
         if(world.getBlockEntity(pos) instanceof Peripheral){
             Peripheral entityBlock = (Peripheral) world.getBlockEntity(pos);
@@ -69,20 +76,9 @@ public abstract class NetworkCarrier extends BlockWithEntity implements BlockEnt
 
     }
 
-    private void floodBus(RCWorldBus bus, World world, BlockPos pos) {
+    private void floodBus(RCWorldBus bus, ServerWorld world, BlockPos pos) {
-        replaceBus(bus, world, pos.north());
+        this.setBus(world,pos,bus);
-        replaceBus(bus, world, pos.south());
+        FloodFill.INSTANCE.blockFloodFiller(world,pos);
-        replaceBus(bus, world, pos.east());
-        replaceBus(bus, world, pos.west());
-        replaceBus(bus, world, pos.up());
-        replaceBus(bus, world, pos.down());
-    }
-
-    private void replaceBus(RCWorldBus bus, World world, BlockPos pos) {
-        if(world.getBlockEntity(pos) instanceof Peripheral && ((Peripheral) world.getBlockEntity(pos)).getBus() != bus){
-            ((Peripheral) world.getBlockEntity(pos)).setBus(bus);
-            floodBus(bus, world, pos);
-        }
     }
 
     @Override

src/main/java/net/brokenmoon/redcontrol/blocks/Terminal.kt

@@ -36,11 +36,10 @@ class TerminalBlock(settings: Settings) : NetworkCarrier(settings) {
         if (!world.isClient) {
             if (player.getStackInHand(hand).item === RedControl.SQUEAKY_HAMMER) {
                 super.onUse(state, world, pos, player, hand, hit)
-                player.sendMessage(Text.literal(java.lang.String.valueOf(monitor.bus.hashCode())), false)
+                //val text: Array<String> = monitor.getText()
-                val text: Array<String> = monitor.getText()
+                //for (s in text) {
-                for (s in text) {
+                //    player.sendMessage(Text.literal(s), false)
-                    player.sendMessage(Text.literal(s), false)
+                //}
-                }
             }
             val bbuf = PacketByteBufs.create()
             bbuf.writeBlockPos(pos)

src/main/java/net/brokenmoon/redcontrol/util/FloodFill.kt

@@ -1,6 +1,8 @@
 package net.brokenmoon.redcontrol.util
 
 import net.brokenmoon.redcontrol.RedControl
+import net.brokenmoon.redcontrol.api.RCWorldBus
+import net.brokenmoon.redcontrol.blocks.NetworkCarrier
 import net.minecraft.particle.ParticleTypes
 import net.minecraft.server.world.ServerWorld
 import net.minecraft.util.math.BlockPos
@@ -10,16 +12,57 @@ object FloodFill {
     fun blockFloodFiller(world: ServerWorld, seed: BlockPos) {
         val checkable = mutableListOf(seed)
         val seen = mutableListOf<BlockPos>()
+        var bus: RCWorldBus? = null
         while (checkable.isNotEmpty()) {
             val pos = checkable.removeFirst()
             if (pos in seen) {continue}
-            if (!world.getBlockState(pos).isIn(RedControl.TAG_BUSABLE)){continue}
+            val state = world.getBlockState(pos)
+            if (!state.isIn(RedControl.TAG_BUSABLE)){continue}
+            val net = state.block as? NetworkCarrier
+            if (net != null) {
                 val cpos = pos.toCenterPos()
-            world.spawnParticles(ParticleTypes.CHERRY_LEAVES,cpos.x,cpos.y,cpos.z,20,0.2,0.2,0.2,0.2)
+                world.spawnParticles(ParticleTypes.WAX_ON,cpos.x,cpos.y,cpos.z,20,0.6,0.6,0.6,0.2)
+                if (bus == null) {
+                    bus = net.getBus(world,pos)
+                } else {
+                    net.setBus(world,pos,bus)
+                }
+            }
+            //val cpos = pos.toCenterPos()
+            //world.spawnParticles(ParticleTypes.WAX_ON,cpos.x,cpos.y,cpos.z,20,0.2,0.2,0.2,0.2)
             Direction.entries.forEach {
                 checkable.add(pos.add(it.offsetX,it.offsetY,it.offsetZ))
             }
             seen.add(pos)
         }
     }
+    fun blockBreakFloodFiller(world: ServerWorld, seed: BlockPos) {
+        val checkable = mutableListOf<BlockPos>()
+        Direction.entries.forEach {
+            checkable.add(seed.add(it.offsetX,it.offsetY,it.offsetZ))
+        }
+        val seen = mutableListOf<BlockPos>()
+        while (checkable.isNotEmpty()) {
+            val pos = checkable.removeFirst()
+            if (pos in seen) {
+                continue
+            }
+            val state = world.getBlockState(pos)
+            if (!state.isIn(RedControl.TAG_BUSABLE)) {
+                continue
+            }
+            Direction.entries.forEach {
+                checkable.add(pos.add(it.offsetX, it.offsetY, it.offsetZ))
+            }
+            seen.add(pos)
+            val nc = (state.block as? NetworkCarrier)
+            if (nc != null) {
+                nc.getBus(world,pos).valid = false
+                val cpos = pos.toCenterPos()
+                world.spawnParticles(ParticleTypes.WAX_OFF,cpos.x,cpos.y,cpos.z,20,0.6,0.6,0.6,0.2)
+            }
+            //val cpos = pos.toCenterPos()
+            //world.spawnParticles(ParticleTypes.WAX_OFF, cpos.x, cpos.y, cpos.z, 20, 0.2, 0.2, 0.2, 0.2)
+        }
+    }
 }

src/main/resources/data/redcontrol/tags/blocks/bus_conductive.json

@@ -1,4 +1,9 @@
 {
   "replace": false,
-  "values": ["minecraft:glass"]
+  "values": [
+    "minecraft:glass",
+    "redcontrol:cpu",
+    "redcontrol:disk_drive",
+    "redcontrol:monitor"
+  ]
 }