commit e0f5d3c7a56d4bb8e911f0b589d24f7d7007e086
Author: NilsGrunwald <nilsgrunwald@msn.com>
Date:   Sat Mar 6 14:46:58 2021 +0100

    initial check-in

diff --git a/Esp32/GartenSteuerung.ino b/Esp32/GartenSteuerung.ino
new file mode 100644
index 0000000..8bcc86d
--- /dev/null
+++ b/Esp32/GartenSteuerung.ino
@@ -0,0 +1,179 @@
+/*
+  SimpleMQTTClient.ino
+  The purpose of this exemple is to illustrate a simple handling of MQTT and Wifi connection.
+  Once it connects successfully to a Wifi network and a MQTT broker, it subscribe to a topic and send a message to it.
+  It will also send a message delayed 5 seconds later.
+*/
+
+//Define DEBUG to get the Output from DEBUG_PRINTLN
+#define DEBUG 1
+#ifdef DEBUG
+ #define DEBUG_PRINTLN(x)  Serial.println (x)
+#else
+ #define DEBUG_PRINTLN(x)
+#endif
+
+#include "EspMQTTClient.h"
+#include <esp_task_wdt.h>
+#define WDT_TIMEOUT 900 //Seconds timeout, 15min
+
+static const String HOSTNAME       = "gartensteuerung";
+static const String HEARTBEATTOPIC = "stat/hs2/hk2/temperature";
+
+static const int ResetPin = 35;
+static const int GartenSteuerungPumpenPin[5] = {32,33,25,26,27};
+int GartenSteuerungPumpenTarget[5] = {0,0,0,0,0};
+int GartenSteuerungPumpenStatus[5] = {1,1,1,1,1};
+
+String GartenSteuerungDebugMessage;
+String GartenSteuerungPumpenStatusTopic[5];      // PumpIterator1 1/0 status information
+String GartenSteuerungPumpenTargetTopic[5];      // target from APP/Web
+
+String Output;
+
+int PumpIterator;
+int CountHeartBeats;
+bool resetWDT;
+
+EspMQTTClient client(
+  "EasyBox-368239",
+  "inginf95",
+  "192.168.178.36",  // MQTT Broker server ip
+  "",                // Can be omitted if not needed
+  "",                // Can be omitted if not needed
+  "Gartensteuerung", // Client name that uniquely identify your device
+  1883               // The MQTT port, default to 1883. this line can be omitted
+);
+
+void setup()
+{
+  Serial.begin(115200);  
+  DEBUG_PRINTLN("**** STARTING SETUP ****");
+
+  //Set up Relais Pins
+  for (int i=0;i<=4;i++){
+    pinMode(GartenSteuerungPumpenPin[i],OUTPUT);
+    digitalWrite(GartenSteuerungPumpenPin[i], HIGH);
+  }
+
+  for (int i=0;i<=4;i++){
+    PumpIterator=i+1;
+    
+    GartenSteuerungPumpenStatusTopic[i] = "stat/"+HOSTNAME+"/pump"+PumpIterator+"/status";
+    GartenSteuerungPumpenTargetTopic[i] = "stat/"+HOSTNAME+"/pump"+PumpIterator+"/target";
+  }
+  GartenSteuerungDebugMessage = "stat/"+HOSTNAME+"/debug";
+  
+  // Optionnal functionnalities of EspMQTTClient : 
+  client.enableDebuggingMessages(); // Enable debugging messages sent to serial output
+  client.enableHTTPWebUpdater("nils","inginf"); // Enable the web updater. User and password default to values of MQTTUsername and MQTTPassword. These can be overrited with enableHTTPWebUpdater("user", "password").
+  //client.enableLastWillMessage("TestClient/lastwill", "I am going offline");  // You can activate the retain flag by setting the third parameter to true
+
+  GartenSteuerungDebugMessage = "stat/"+HOSTNAME+"/debug";  
+
+  esp_task_wdt_init(WDT_TIMEOUT, true); //enable panic so ESP32 restarts
+  esp_task_wdt_add(NULL); //add current thread to WDT watch
+}
+
+//This function transfers the state of the sensor. That includes the door status, battery status and level
+void transmitStatus() {
+  DEBUG_PRINTLN(__func__);
+  String Output = "";
+  bool publish = false;
+  
+  for (int i=0;i<=4;i++){
+    PumpIterator=i+1;
+    if (GartenSteuerungPumpenStatus[i] != GartenSteuerungPumpenTarget[i]) {
+            
+      GartenSteuerungPumpenStatus[i] = GartenSteuerungPumpenTarget[i];
+      if (GartenSteuerungPumpenStatus[i]==1) {
+        digitalWrite(GartenSteuerungPumpenPin[i], LOW);
+        client.publish(GartenSteuerungPumpenStatusTopic[i].c_str(), "ON" );
+        Output += "Pump"+String(PumpIterator);
+        Output += " turned on.";
+      } else {
+        digitalWrite(GartenSteuerungPumpenPin[i], HIGH);
+        client.publish(GartenSteuerungPumpenStatusTopic[i].c_str(), "OFF" );        
+        Output += "Pump"+String(PumpIterator);
+        Output += " turned off.";
+      }
+      publish = true;
+      Output += "\n"; //publish always
+    }    
+  }
+
+  if (publish==true) {
+    client.publish(GartenSteuerungDebugMessage.c_str(), Output.c_str() );
+    DEBUG_PRINTLN(Output.c_str());    
+  }
+}
+
+// This function is called once everything is connected (Wifi and MQTT)
+// WARNING : YOU MUST IMPLEMENT IT IF YOU USE EspMQTTClient
+void onConnectionEstablished()
+{
+  client.subscribe(HEARTBEATTOPIC, [](const String & payload) {
+    resetWDT = true;
+    CountHeartBeats++;
+
+    Output = "Heart-Beat count: "+String(CountHeartBeats);
+    client.publish(GartenSteuerungDebugMessage.c_str(), Output.c_str() );
+    DEBUG_PRINTLN(Output.c_str()); 
+    
+    //automatically turn off all pumps after 15-20min
+    if (CountHeartBeats >= 3){
+      for (int i=0;i<=4;i++){  
+        GartenSteuerungPumpenTarget[i] = 0;
+      }
+      CountHeartBeats = 0;
+      Output = "Deactivated all pumps due to longer inactivity";
+      client.publish(GartenSteuerungDebugMessage.c_str(), Output.c_str() );
+      DEBUG_PRINTLN(Output.c_str()); 
+    }
+    transmitStatus();      
+    DEBUG_PRINTLN("received heartbeat topic");
+  });
+
+  client.subscribe("stat/"+HOSTNAME+"/#", [](const String & topic, const String & payload) {
+    bool publish = false;    
+    //Check all other messages
+    for (int i=0;i<=4;i++){  
+      PumpIterator=i+1;
+      if (topic.equals(GartenSteuerungPumpenTargetTopic[i]))  {
+        resetWDT = true;
+        publish = true;
+        Output = "Neue Target Message (Pumpe"+String(PumpIterator);
+        Output += "): ";
+        //Update PumpIteratoriTarget...
+        if (payload.equals("ON"))  {
+          GartenSteuerungPumpenTarget[i] = 1;
+        } else {
+          GartenSteuerungPumpenTarget[i] = 0;
+        }
+        Output += String(GartenSteuerungPumpenTarget[i]);
+        Output += " payload: ";
+        Output += payload;
+        client.publish(GartenSteuerungDebugMessage.c_str(), Output.c_str() );
+        DEBUG_PRINTLN(Output.c_str());     
+      } 
+    }
+    if (publish){ 
+      transmitStatus(); 
+      CountHeartBeats = 0; //reset heartbeatcounter
+      Output = "Heart-Beat count: "+String(CountHeartBeats);
+      DEBUG_PRINTLN(Output.c_str());
+    }
+  });
+
+  DEBUG_PRINTLN("**** ENDING SETUP ****");
+}
+
+void loop()
+{
+  if (resetWDT){
+    esp_task_wdt_reset();  
+    resetWDT = false;
+  }
+  
+  client.loop();
+}
diff --git a/readme.md b/readme.md
new file mode 100644
index 0000000..aebef30
--- /dev/null
+++ b/readme.md
@@ -0,0 +1,3 @@
+# Garten Steuerung
+
+Small ESP32 SensorActor Unit to sense the water level and active pumps...
\ No newline at end of file