Preparing ESPCommander Intergration

WaterishOS-core3.0/WaterishOS-core3.0.ino

@@ -69,6 +69,7 @@ void updatemqtt() {
   mqtt.publish("/waterishos/node" + nodename + "/flowrate2", String(sensor2.getCurrentFlowrate()));
   mqtt.publish("/waterishos/node" + nodename + "/volume2", String(sensor2.getTotalVolume()));
 }
+#include "espcommander.cpp"
 void setup() {
   lcd.begin();
   writelcd(" Siwat INC (tm) ","  Waterish OS");
@@ -117,6 +118,7 @@ void setup() {
   writelcd(" Telemetry Node","siwatsystem.com");
   if (client.connect("waterishos",telemetryuser,telemetrykey)) {
     writelcd(" Telemetry Node","Connected");
+    mqtt.subscribe("/waterishos/node" + nodename + "command", espcommander);
     delay(1000);
   } else {
     writelcd(" Telemetry Node"," Failed Offline");

WaterishOS-core3.0/espcommander.cpp

@@ -0,0 +1,14 @@
+// Copyright Siwat INC(tm) 2019
+// Created by Siwat Sirichai
+// ESPCommander EXTENDED v1.2
+void espcommander(String topic, String command)  { //the command is in json format!
+    StaticJsonDocument<200> doc;
+    DeserializationError error = deserializeJson(doc, json);
+    if (error) {
+      Serial.print(F("deserializeJson() failed: "));
+      Serial.println(error.c_str());
+    return;
+  }
+  String command = doc["command"];
+  String value = doc["value"];
+}