From eb15011d31c9afcf3a82200b23bacf538208aeb1 Mon Sep 17 00:00:00 2001
From: Ellpeck <me@ellpeck.de>
Date: Sat, 30 Nov 2024 19:33:34 +0100
Subject: [PATCH] clean up some dead code

---
 .../prettypipes/network/PipeNetwork.java      | 10 +++----
 .../modules/craft/CraftingModuleItem.java     | 29 +++++--------------
 2 files changed, 12 insertions(+), 27 deletions(-)

diff --git a/src/main/java/de/ellpeck/prettypipes/network/PipeNetwork.java b/src/main/java/de/ellpeck/prettypipes/network/PipeNetwork.java
index b6f3371..a5f02a2 100644
--- a/src/main/java/de/ellpeck/prettypipes/network/PipeNetwork.java
+++ b/src/main/java/de/ellpeck/prettypipes/network/PipeNetwork.java
@@ -217,6 +217,7 @@ public class PipeNetwork extends SavedData implements GraphListener<BlockPos, Ne
             if (remain.isEmpty())
                 return remain;
         }
+        System.out.println(remain);
         // check craftable items
         return this.requestCraftedItem(destPipe, null, remain, new Stack<>(), equalityTypes).getLeft();
     }
@@ -286,11 +287,9 @@ public class PipeNetwork extends SavedData implements GraphListener<BlockPos, Ne
         amount -= this.getLockedAmount(location.getPos(), stack, ignoredLock, equalityTypes);
         if (amount <= 0)
             return stack;
-        var remain = stack.copy();
         // make sure we only extract less than or equal to the requested amount
-        if (remain.getCount() < amount)
-            amount = remain.getCount();
-        remain.shrink(amount);
+        if (stack.getCount() < amount)
+            amount = stack.getCount();
         for (int slot : location.getStackSlots(this.level, stack, equalityTypes)) {
             // try to extract from that location's inventory and send the item
             var handler = location.getItemHandler(this.level);
@@ -302,7 +301,8 @@ public class PipeNetwork extends SavedData implements GraphListener<BlockPos, Ne
                     break;
             }
         }
-        return remain;
+        // we reduce the amount by what we managed to extract & insert in the for loop, so the amount down here will be what we couldn't
+        return stack.copyWithCount(amount);
     }
 
     public PipeBlockEntity getPipe(BlockPos pos) {
diff --git a/src/main/java/de/ellpeck/prettypipes/pipe/modules/craft/CraftingModuleItem.java b/src/main/java/de/ellpeck/prettypipes/pipe/modules/craft/CraftingModuleItem.java
index badf575..017e0c0 100644
--- a/src/main/java/de/ellpeck/prettypipes/pipe/modules/craft/CraftingModuleItem.java
+++ b/src/main/java/de/ellpeck/prettypipes/pipe/modules/craft/CraftingModuleItem.java
@@ -84,25 +84,11 @@ public class CraftingModuleItem extends ModuleItem {
                         var ensureItemOrder = module.get(Contents.TYPE).ensureItemOrder;
                         // if we're ensuring the correct item order and the item is already on the way, don't do anything yet
                         if (!ensureItemOrder || network.getPipeItemsOnTheWay(dest.getLeft()).findAny().isEmpty()) {
-                            var requestRemain = network.requestExistingItem(lock.location, tile.getBlockPos(), dest.getLeft(), lock, dest.getRight(), equalityTypes);
+                            network.requestExistingItem(lock.location, tile.getBlockPos(), dest.getLeft(), lock, dest.getRight(), equalityTypes);
                             network.resolveNetworkLock(lock);
                             craft.ingredientsToRequest.remove(lock);
+                            craft.travelingIngredients.add(lock.stack.copy());
                             craft.inProgress = true;
-
-                            var traveling = lock.stack.copy();
-                            traveling.shrink(requestRemain.getCount());
-                            craft.travelingIngredients.add(traveling);
-
-                            // if we couldn't fit all items into the destination, create another request for the rest
-                            var remain = lock.stack.copy();
-                            remain.shrink(dest.getRight().getCount() - requestRemain.getCount());
-                            if (!remain.isEmpty()) {
-                                var remainRequest = new NetworkLock(lock.location, remain);
-                                // if we're ensuring item order, we need to insert the remaining request at the start so that it gets processed first
-                                var index = ensureItemOrder ? 0 : craft.ingredientsToRequest.size();
-                                craft.ingredientsToRequest.add(index, remainRequest);
-                                network.createNetworkLock(remainRequest);
-                            }
                         }
                     }
                     network.endProfile();
@@ -218,11 +204,10 @@ public class CraftingModuleItem extends ModuleItem {
         var slot = tile.getModuleSlot(module);
         var contents = module.get(Contents.TYPE);
         var equalityTypes = ItemFilter.getEqualityTypes(tile);
-        var crafts = tile.getActiveCrafts();
-        var craft = crafts.stream()
-            .filter(c -> c.moduleSlot == slot && !c.getTravelingIngredient(stack, equalityTypes).isEmpty())
-            .findAny().orElse(null);
-        if (craft != null) {
+        var allCrafts = tile.getActiveCrafts();
+        var ourCrafts = allCrafts.stream().filter(c -> c.moduleSlot == slot && !c.getTravelingIngredient(stack, equalityTypes).isEmpty()).iterator();
+        while (ourCrafts.hasNext()) {
+            var craft = ourCrafts.next();
             craft.travelingIngredients.remove(craft.getTravelingIngredient(stack, equalityTypes));
 
             if (contents.insertSingles) {
@@ -245,7 +230,7 @@ public class CraftingModuleItem extends ModuleItem {
 
                 // if we canceled the request and all input items are delivered (ie the machine actually got what it expected), remove it from the queue
                 if (craft.canceled)
-                    crafts.remove(craft);
+                    allCrafts.remove(craft);
             }
         }
         return stack;