nodespace foundry channels! (also fix arc furnace only accepting one stack from IO port if it triggers it to close)

src/main/java/com/hbm/blocks/machine/FoundryChannel.java

@@ -4,11 +4,17 @@ import java.util.ArrayList;
 import java.util.List;
 
 import com.hbm.blocks.ModBlocks;
+import com.hbm.inventory.material.NTMMaterial;
 import com.hbm.inventory.material.Mats.MaterialStack;
 import com.hbm.items.machine.ItemScraps;
 import com.hbm.lib.Library;
 import com.hbm.lib.RefStrings;
 import com.hbm.tileentity.machine.TileEntityFoundryChannel;
+import com.hbm.uninos.GenNode;
+import com.hbm.uninos.INetworkProvider;
+import com.hbm.uninos.networkproviders.FoundryNetwork;
+import com.hbm.util.fauxpointtwelve.BlockPos;
+import com.hbm.util.fauxpointtwelve.DirPos;
 
 import api.hbm.block.ICrucibleAcceptor;
 import cpw.mods.fml.client.registry.RenderingRegistry;
@@ -176,7 +182,6 @@ public class FoundryChannel extends BlockContainer implements ICrucibleAcceptor
 				}
 				cast.amount = 0;
 				cast.type = null;
-				cast.propagateMaterial(null);
 				cast.markDirty();
 				world.markBlockForUpdate(x, y, z);
 			}
@@ -199,4 +204,21 @@ public class FoundryChannel extends BlockContainer implements ICrucibleAcceptor
 
 		super.breakBlock(world, x, y, z, b, i);
 	}
+
+	public static class FoundryNode extends GenNode<FoundryNetwork> {
+
+		public NTMMaterial type;
+
+		public FoundryNode(INetworkProvider<FoundryNetwork> provider, BlockPos... positions) {
+			super(provider, positions);
+		}
+
+		@Override
+		public FoundryNode setConnections(DirPos... connections) {
+			super.setConnections(connections);
+			return this;
+		}
+
+	}
+
 }

src/main/java/com/hbm/tileentity/machine/TileEntityFoundryChannel.java

@@ -5,10 +5,14 @@ import java.util.Collections;
 import java.util.List;
 
 import com.hbm.blocks.ModBlocks;
+import com.hbm.blocks.machine.FoundryChannel.FoundryNode;
 import com.hbm.inventory.material.MaterialShapes;
-import com.hbm.inventory.material.Mats;
 import com.hbm.inventory.material.Mats.MaterialStack;
-import com.hbm.inventory.material.NTMMaterial;
+import com.hbm.lib.Library;
+import com.hbm.uninos.UniNodespace;
+import com.hbm.uninos.networkproviders.FoundryNetworkProvider;
+import com.hbm.util.fauxpointtwelve.BlockPos;
+import com.hbm.util.fauxpointtwelve.DirPos;
 
 import api.hbm.block.ICrucibleAcceptor;
 import net.minecraft.block.Block;
@@ -22,22 +26,16 @@ public class TileEntityFoundryChannel extends TileEntityFoundryBase {
 	public int nextUpdate;
 	public int lastFlow = 0;
 
-	protected NTMMaterial neighborType;
+	protected FoundryNode node;
-	protected boolean hasCheckedNeighbors;
-	protected int unpropagateTime;
 
 	@Override
 	public void updateEntity() {
 
 		if(!worldObj.isRemote) {
+			initNode();
 
-			// Initialise before allowing pours, so newly added channels will avoid causing clog feeds
+			if(this.node.type != null && this.amount == 0) {
-			if(!hasCheckedNeighbors) {
+				this.node.type = null;
-				List<TileEntityFoundryChannel> visited = new ArrayList<TileEntityFoundryChannel>();
-				visited.add(this);
-
-				neighborType = checkNeighbors(visited);
-				hasCheckedNeighbors = true;
 			}
 
 			if(this.type == null && this.amount != 0) {
@@ -71,7 +69,7 @@ public class TileEntityFoundryChannel extends TileEntityFoundryBase {
 								this.type = null;
 								this.amount = 0;
 
-								propagateMaterial(null);
+								this.node.type = null;
 							} else {
 								this.amount = left.amount;
 							}
@@ -91,6 +89,8 @@ public class TileEntityFoundryChannel extends TileEntityFoundryBase {
 
 							if(acc.type == null || acc.type == this.type || acc.amount == 0) {
 								acc.type = this.type;
+								acc.initNode();
+								acc.node.type = this.type;
 
 								acc.lastFlow = dir.getOpposite().ordinal();
 
@@ -117,24 +117,28 @@ public class TileEntityFoundryChannel extends TileEntityFoundryBase {
 				}
 			}
 
-			if(neighborType != null && amount == 0) unpropagateTime++;
-
-			// every 5 seconds do a unprop test, will only occur once per contiguous channel per 5 seconds due to the timer getting updated in all channels from the prop
-			if(unpropagateTime > 100) {
-				propagateMaterial(null);
-			}
-			
 			if(this.amount == 0) {
 				this.lastFlow = 0;
 				this.nextUpdate = 5;
-			} else {
-				unpropagateTime = 0;
 			}
 		}
 
 		super.updateEntity();
 	}
 
+	protected void initNode() {
+		if(this.node == null || this.node.expired) {
+
+			this.node = (FoundryNode) UniNodespace.getNode(worldObj, xCoord, yCoord, zCoord, FoundryNetworkProvider.THE_PROVIDER);
+
+			if(this.node == null || this.node.expired) {
+				this.node = this.createNode();
+				this.node.type = this.type;
+				UniNodespace.createNode(worldObj, this.node);
+			}
+		}
+	}
+
 	@Override
 	public int getCapacity() {
 		return MaterialShapes.INGOT.q(2);
@@ -144,95 +148,58 @@ public class TileEntityFoundryChannel extends TileEntityFoundryBase {
 	public void readFromNBT(NBTTagCompound nbt) {
 		super.readFromNBT(nbt);
 		this.lastFlow = nbt.getByte("flow");
-		this.neighborType = Mats.matById.get(nbt.getInteger("nType"));
-		this.hasCheckedNeighbors = nbt.getBoolean("init");
 	}
 
 	@Override
 	public void writeToNBT(NBTTagCompound nbt) {
 		super.writeToNBT(nbt);
 		nbt.setByte("flow", (byte) this.lastFlow);
-		nbt.setInteger("nType", this.neighborType != null ? this.neighborType.id : -1);
-		nbt.setBoolean("init", hasCheckedNeighbors);
 	}
 
-	/**
+	@Override
-	 * Channels accept pouring as normal, except when neighbor channels already have material.
+	public void invalidate() {
-	 * This prevents a contiguous channel from having multiple different types of material in it, causing clogs.
+		super.invalidate();
-	 * If you connect two channels that have different materials already in them, god help you (nah jokes it'll just be clogged until you fix manually)
+
-	 */
+		if(!worldObj.isRemote) {
+			if(this.node != null) {
+				UniNodespace.destroyNode(worldObj, xCoord, yCoord, zCoord, FoundryNetworkProvider.THE_PROVIDER);
+			}
+		}
+	}
+
+	public FoundryNode createNode() {
+		TileEntity tile = (TileEntity) this;
+		return new FoundryNode(FoundryNetworkProvider.THE_PROVIDER, new BlockPos(tile.xCoord, tile.yCoord, tile.zCoord)).setConnections(
+			new DirPos(tile.xCoord + 1, tile.yCoord, tile.zCoord, Library.POS_X),
+			new DirPos(tile.xCoord - 1, tile.yCoord, tile.zCoord, Library.NEG_X),
+			new DirPos(tile.xCoord, tile.yCoord, tile.zCoord + 1, Library.POS_Z),
+			new DirPos(tile.xCoord, tile.yCoord, tile.zCoord - 1, Library.NEG_Z)
+		);
+	}
+
 	@Override
 	public boolean canAcceptPartialPour(World world, int x, int y, int z, double dX, double dY, double dZ, ForgeDirection side, MaterialStack stack) {
-		if(!hasCheckedNeighbors || (neighborType != null && neighborType != stack.material)) return false;
+		if(this.node == null) return false;
+		for(Object o : this.node.net.links) {
+			FoundryNode node = (FoundryNode) o;
+			if(node.type != null && node.type != stack.material) {
+				return false;
+			}
+		}
+
 		return super.canAcceptPartialPour(world, x, y, z, dX, dY, dZ, side, stack);
 	}
 
-	/** Upon pouring, propagate the current material type along contiguous channels */
+	@Override
+	public MaterialStack flow(World world, int x, int y, int z, ForgeDirection side, MaterialStack stack) {
+		if(this.node != null) this.node.type = stack.material;
+		return super.flow(world, x, y, z, side, stack);
+	}
+
 	@Override
 	public MaterialStack pour(World world, int x, int y, int z, double dX, double dY, double dZ, ForgeDirection side, MaterialStack stack) {
-		propagateMaterial(stack.material);
+		if(this.node != null) this.node.type = stack.material;
 		return super.pour(world, x, y, z, dX, dY, dZ, side, stack);
 	}
 
-	public void propagateMaterial(NTMMaterial propType) {
-		if(propType != null && neighborType != null) return; // optimise away any pours that change nothing
-
-		List<TileEntityFoundryChannel> visited = new ArrayList<TileEntityFoundryChannel>();
-		visited.add(this);
-
-		boolean hasMaterial = propagateMaterial(propType, visited, false);
-
-		// since we are now fully clear, it's safe to unassign the contiguous channel type
-		if(propType == null && !hasMaterial) {
-			for(TileEntityFoundryChannel acc : visited) {
-				acc.neighborType = null;
-			}
-		}
-	}
-
-	protected boolean propagateMaterial(NTMMaterial propType, List<TileEntityFoundryChannel> visited, boolean hasMaterial) {
-		// if emptying, don't mark the channel as ready for a new material until it is entirely clear
-		if(propType != null) {
-			neighborType = propType;
-		} else {
-			// and when empty testing, update the last unpropagate time
-			unpropagateTime = 0;
-		}
-
-		for(ForgeDirection dir : new ForgeDirection[] { ForgeDirection.NORTH, ForgeDirection.SOUTH, ForgeDirection.WEST, ForgeDirection.EAST }) {
-			TileEntity b = worldObj.getTileEntity(xCoord + dir.offsetX, yCoord, zCoord + dir.offsetZ);
-					
-			if(b instanceof TileEntityFoundryChannel && !visited.contains(b)) {
-				TileEntityFoundryChannel acc = (TileEntityFoundryChannel) b;
-				visited.add(acc);
-
-				if(acc.amount > 0) hasMaterial = true;
-
-				hasMaterial = acc.propagateMaterial(propType, visited, hasMaterial);
-			}
-		}
-
-		return hasMaterial;
-	}
-
-	protected NTMMaterial checkNeighbors(List<TileEntityFoundryChannel> visited) {
-		if(neighborType != null) return neighborType;
-
-		for(ForgeDirection dir : new ForgeDirection[] { ForgeDirection.NORTH, ForgeDirection.SOUTH, ForgeDirection.WEST, ForgeDirection.EAST }) {
-			TileEntity b = worldObj.getTileEntity(xCoord + dir.offsetX, yCoord, zCoord + dir.offsetZ);
-			
-			if(b instanceof TileEntityFoundryChannel && !visited.contains(b)) {
-				TileEntityFoundryChannel acc = (TileEntityFoundryChannel) b;
-				visited.add(acc);
-
-				NTMMaterial neighborMaterial = acc.checkNeighbors(visited);
-
-				// immediately propagate backwards if a material is found
-				if(neighborMaterial != null) return neighborMaterial;
-			}
-		}
-
-		return null;
-	}
-
 }

src/main/java/com/hbm/tileentity/machine/TileEntityMachineArcFurnaceLarge.java

@@ -114,7 +114,7 @@ public class TileEntityMachineArcFurnaceLarge extends TileEntityMachineBase impl
 
 			for(DirPos pos : getConPos()) this.trySubscribe(worldObj, pos.getX(), pos.getY(), pos.getZ(), pos.getDir());
 
-			if(lid == 1) loadIngredients();
+			if(lid > 0) loadIngredients();
 
 			if(power > 0) {
 

src/main/java/com/hbm/uninos/networkproviders/FoundryNetwork.java

@@ -0,0 +1,10 @@
+package com.hbm.uninos.networkproviders;
+
+import com.hbm.uninos.NodeNet;
+
+public class FoundryNetwork extends NodeNet {
+
+	@Override
+	public void update() { }
+
+}

src/main/java/com/hbm/uninos/networkproviders/FoundryNetworkProvider.java

@@ -0,0 +1,14 @@
+package com.hbm.uninos.networkproviders;
+
+import com.hbm.uninos.INetworkProvider;
+
+public class FoundryNetworkProvider implements INetworkProvider<FoundryNetwork> {
+
+	public static FoundryNetworkProvider THE_PROVIDER = new FoundryNetworkProvider();
+
+	@Override
+	public FoundryNetwork provideNetwork() {
+		return new FoundryNetwork();
+	}
+
+}