From f82570f58027ec7659c4050124fdc15d1203dbd8 Mon Sep 17 00:00:00 2001
From: thetaepsilon-gamedev <thetaepsilon-gamedev@noreply.users.github.com>
Date: Wed, 27 Sep 2017 14:14:33 +0100
Subject: [PATCH] initial stub patches to re-implement new_flow_logic

---
 flowing_logic.lua |  8 ++++++++
 pipes.lua         | 14 ++++++++++++++
 2 files changed, 22 insertions(+)

diff --git a/flowing_logic.lua b/flowing_logic.lua
index 632baa6..0e62b46 100644
--- a/flowing_logic.lua
+++ b/flowing_logic.lua
@@ -132,3 +132,11 @@ pipeworks.fountainhead_check = function(pos, node)
 		end
 	end
 end
+
+local debuglog = function(msg)
+	print("## pipeworks: "..msg)
+end
+
+pipeworks.balance_pressure = function(pos, node)
+	debuglog("balance_pressure() stub! "..node.name.." at "..pos.x.." "..pos.y.." "..pos.z)
+end
diff --git a/pipes.lua b/pipes.lua
index 9771e3b..5a48801 100644
--- a/pipes.lua
+++ b/pipes.lua
@@ -227,3 +227,17 @@ minetest.register_abm({
 	end
 })
 
+
+-- run pressure balancing ABM over all water-moving nodes
+local pipes_all_nodenames = pipes_full_nodenames
+for _, pipe in ipairs(pipes_empty_nodenames) do
+	table.insert(pipes_all_nodenames, pipe)
+end
+minetest.register_abm({
+	nodenames = pipes_all_nodenames,
+	interval = 1,
+	chance = 1,
+	action = function(pos, node, active_object_count, active_object_count_wider)
+		pipeworks.balance_pressure(pos, node)
+	end
+})