From 37ef9a780d99e31c2e808cd11eadd12a375a7503 Mon Sep 17 00:00:00 2001
From: Fisch <interfisch@gmx.net>
Date: Mon, 14 Jul 2025 18:50:26 +0200
Subject: [PATCH] fix flow check and add reset when pump is off

---
 include/flow.h | 9 +++++++--
 src/main.cpp   | 4 +++-
 2 files changed, 10 insertions(+), 3 deletions(-)

diff --git a/include/flow.h b/include/flow.h
index d5df752..cb5de9d 100644
--- a/include/flow.h
+++ b/include/flow.h
@@ -9,7 +9,7 @@ uint16_t flow_counter=0; //maximum counts/s measured with Eden 128 Pump was 171
 
 void flow_setup();
 void flow_loop(unsigned long loopmillis);
-bool checkFlow(float minflow,unsigned long maxtime);
+bool checkFlow(float minflow,unsigned long maxtime,bool reset=false);
 void IRAM_ATTR isr_flow();
 
 unsigned long last_read_flow=0;
@@ -58,8 +58,12 @@ void flow_loop(unsigned long loopmillis) {
 
 }
 
-bool checkFlow(float minflow,unsigned long maxtime) { //L/min, milliseconds
+bool checkFlow(float minflow,unsigned long maxtime,bool reset) { //L/min, milliseconds
   static unsigned long last_flow_low=0; //0=flow ok
+  if (reset) {
+    last_flow_low=0;
+    return true;
+  }
   if (flow<minflow) { //flow too low
     if (last_flow_low==0) { //not set yet
       last_flow_low=millis();
@@ -74,6 +78,7 @@ bool checkFlow(float minflow,unsigned long maxtime) { //L/min, milliseconds
   }
 }
 
+
 void IRAM_ATTR isr_flow() {
 	flow_counter++;
   flow_counter_sum++;
diff --git a/src/main.cpp b/src/main.cpp
index 12bd357..cd7ebfa 100644
--- a/src/main.cpp
+++ b/src/main.cpp
@@ -249,12 +249,14 @@ void loop() {
   pump_loop(loopmillis);
   #ifdef FLOW_PIN
   if (isPumpRunning(1)) { //Check pump 1 flow
-    if (checkFlow(0.2, 20*1000)) {
+    if (!checkFlow(0.2, 20*1000)) {
       Serial.println("pumpError flow too low");
       if (mqtt){
         publishInfo("error/pump","pumpError flow too low. flow="+String(flow));
       }
     }
+  }else{
+    checkFlow(0,0,true); //reset reset timer
   }
   #endif
   #endif