убрали лишние ошибки json

include/Global.h

@@ -106,6 +106,8 @@ extern String mqttPass;
 extern unsigned long mqttUptime;
 extern unsigned long flashWriteNumber;
 
+extern unsigned long wifiUptime;
+
 extern String mqttRootDevice;
 extern String chipId;
 extern String prex;

include/MqttClient.h

@@ -31,3 +31,6 @@ void mqttCallback(char* topic, uint8_t* payload, size_t length);
 void handleMqttStatus(bool send);
 void handleMqttStatus(bool send, int state);
 const String getStateStr(int e);
+
+void mqttUptimeCalc();
+void wifiUptimeCalc();

include/utils/JsonUtils.h

@@ -5,26 +5,26 @@
 extern String jsonReadStrDoc(DynamicJsonDocument& doc, String name);
 extern void jsonWriteStrDoc(DynamicJsonDocument& doc, String name, String value);
 
-extern String jsonWriteStr(String& json, String name, String value);
+extern String jsonWriteStr(String& json, String name, String value, bool e = true);
-extern String jsonWriteInt(String& json, String name, int value);
+extern String jsonWriteInt(String& json, String name, int value, bool e = true);
-extern String jsonWriteFloat(String& json, String name, float value);
+extern String jsonWriteFloat(String& json, String name, float value, bool e = true);
-extern String jsonWriteBool(String& json, String name, boolean value);
+extern String jsonWriteBool(String& json, String name, boolean value, bool e = true);
 
-extern bool jsonRead(String& json, String key, unsigned long& value);
+extern bool jsonRead(String& json, String key, unsigned long& value, bool e = true);
-extern bool jsonRead(String& json, String key, float& value);
+extern bool jsonRead(String& json, String key, float& value, bool e = true);
-extern bool jsonRead(String& json, String key, String& value);
+extern bool jsonRead(String& json, String key, String& value, bool e = true);
-extern bool jsonRead(String& json, String key, bool& value);
+extern bool jsonRead(String& json, String key, bool& value, bool e = true);
-extern bool jsonRead(String& json, String key, int& value);
+extern bool jsonRead(String& json, String key, int& value, bool e = true);
 
-extern String jsonReadStr(String& json, String name);
+extern String jsonReadStr(String& json, String name, bool e = true);
-extern int jsonReadInt(String& json, String name);
+extern int jsonReadInt(String& json, String name, bool e = true);
-extern boolean jsonReadBool(String& json, String name);
+extern boolean jsonReadBool(String& json, String name, bool e = true);
 
-extern bool jsonWriteStr_(String& json, String name, String value);
+extern bool jsonWriteStr_(String& json, String name, String value, bool e = true);
-extern bool jsonWriteBool_(String& json, String name, bool value);
+extern bool jsonWriteBool_(String& json, String name, bool value, bool e = true);
-extern bool jsonWriteInt_(String& json, String name, int value);
+extern bool jsonWriteInt_(String& json, String name, int value, bool e = true);
-extern bool jsonWriteFloat_(String& json, String name, float value);
+extern bool jsonWriteFloat_(String& json, String name, float value, bool e = true);
 void writeUint8tValueToJsonString(uint8_t* payload, size_t length, size_t headerLenth, String& json);
-extern bool jsonMergeObjects(String& json1, String& json2);
+extern bool jsonMergeObjects(String& json1, String& json2, bool e = true);
 extern void jsonMergeDocs(JsonObject dest, JsonObjectConst src);
 extern void jsonErrorDetected();

src/DeviceList.cpp

@@ -52,13 +52,15 @@ void asyncUdpInit() {
         });
     }
 
-    //будем отправлять каждые 60 секунд презентацию данного устройства
+    //будем отправлять каждые 30 секунд презентацию данного устройства
     ts.add(
         UDP, 30000, [&](void*) {
+            if (isNetworkActive()) {
                 SerialPrint("i", F("UDP"), F("Broadcast device presentation"));
                 asyncUdp.broadcastTo(getThisDevice().c_str(), 4210);
                 // asyncUdp.broadcast("test");
                 // asyncUdp.print("Hello Server!");
+            }
         },
         nullptr, true);
 

src/Global.cpp

@@ -57,6 +57,8 @@ String mqttPass = "";
 unsigned long mqttUptime = 0;
 unsigned long flashWriteNumber = 0;
 
+unsigned long wifiUptime = 0;
+
 String chipId = "";
 String prex = "";
 String all_widgets = "";

src/MqttClient.cpp

@@ -7,14 +7,12 @@ void mqttInit() {
         [&](void*) {
             if (WiFi.status() == WL_CONNECTED) {
                 SerialPrint("i", F("WIFI"), F("OK"));
+                wifiUptimeCalc();
                 if (mqtt.connected()) {
                     SerialPrint("i", F("MQTT"), "OK");
+                    mqttUptimeCalc();
                     handleMqttStatus(false);
 
-                    static unsigned int prevMillis;
-                    mqttUptime = mqttUptime + (millis() - prevMillis);
-                    prevMillis = millis();
-
                     // setLedStatus(LED_OFF);
                 } else {
                     SerialPrint("E", F("MQTT"), F("✖ Connection lost"));
@@ -25,6 +23,7 @@ void mqttInit() {
             } else {
                 SerialPrint("E", F("WIFI"), F("✖ Lost WiFi connection"));
                 ts.remove(WIFI_MQTT_CONNECTION_CHECK);
+                wifiUptime = 0;
                 startAPMode();
             }
         },
@@ -347,3 +346,15 @@ const String getStateStr(int e) {
             break;
     }
 }
+
+void mqttUptimeCalc() {
+    static unsigned int prevMillis;
+    mqttUptime = mqttUptime + (millis() - prevMillis);
+    prevMillis = millis();
+}
+
+void wifiUptimeCalc() {
+    static unsigned int prevMillis;
+    wifiUptime = wifiUptime + (millis() - prevMillis);
+    prevMillis = millis();
+}

src/PeriodicTasks.cpp

@@ -14,11 +14,14 @@ void periodicTasksInit() {
             // uptime
             jsonWriteStr_(errorsHeapJson, F("upt"), prettyMillis(millis()));
             jsonWriteStr_(errorsHeapJson, F("uptm"), prettyMillis(mqttUptime));
+            jsonWriteStr_(errorsHeapJson, F("uptw"), prettyMillis(wifiUptime));
             // flash
             jsonWriteInt_(errorsHeapJson, F("fl"), flashWriteNumber);
             // build ver
             jsonWriteStr_(errorsHeapJson, F("bver"), String(FIRMWARE_VERSION));
             jsonWriteStr_(errorsHeapJson, F("bn"), String(FIRMWARE_NAME));
+            // reset reason
+            jsonWriteStr_(errorsHeapJson, F("rst"), ESP_getResetReason());
             periodicWsSend();
         },
         nullptr, true);
@@ -35,15 +38,15 @@ void handleError(String errorId, int errorValue) {
 
 void printGlobalVarSize() {
     size_t settingsFlashJsonSize = settingsFlashJson.length();
-    SerialPrint(F("i"), F("settingsFlashJson"), String(settingsFlashJsonSize));
+    // SerialPrint(F("i"), F("settingsFlashJson"), String(settingsFlashJsonSize));
     size_t errorsHeapJsonSize = errorsHeapJson.length();
-    SerialPrint(F("i"), F("errorsHeapJson"), String(errorsHeapJsonSize));
+    // SerialPrint(F("i"), F("errorsHeapJson"), String(errorsHeapJsonSize));
     size_t paramsFlashJsonSize = paramsFlashJson.length();
-    SerialPrint(F("i"), F("paramsFlashJson"), String(paramsFlashJsonSize));
+    // SerialPrint(F("i"), F("paramsFlashJson"), String(paramsFlashJsonSize));
     size_t paramsHeapJsonSize = paramsHeapJson.length();
-    SerialPrint(F("i"), F("paramsHeapJson"), String(paramsHeapJsonSize));
+    // SerialPrint(F("i"), F("paramsHeapJson"), String(paramsHeapJsonSize));
     size_t devListHeapJsonSize = devListHeapJson.length();
-    SerialPrint(F("i"), F("devListHeapJson"), String(devListHeapJsonSize));
+    // SerialPrint(F("i"), F("devListHeapJson"), String(devListHeapJsonSize));
 
     size_t halfBuffer = JSON_BUFFER_SIZE / 2;
 

src/classes/IoTItem.cpp

@@ -6,16 +6,16 @@
 #include "ESPConfiguration.h"
 
 IoTItem::IoTItem(String parameters) {
-    jsonRead(parameters, "int", _interval);
+    jsonRead(parameters, F("int"), _interval);
     _interval = _interval * 1000;
-    jsonRead(parameters, "subtype", _subtype);
+    jsonRead(parameters, F("subtype"), _subtype);
-    jsonRead(parameters, "id", _id);
+    jsonRead(parameters, F("id"), _id);
-    jsonRead(parameters, "multiply", _multiply);
+    jsonRead(parameters, F("multiply"), _multiply, false);
-    jsonRead(parameters, "plus", _plus);
+    jsonRead(parameters, F("plus"), _plus, false);
-    jsonRead(parameters, "round", _round);
+    jsonRead(parameters, F("round"), _round, false);
 
     String map;
-    jsonRead(parameters, "map", map);
+    jsonRead(parameters, F("map"), map, false);
     if (map != "") {
         _map1 = selectFromMarkerToMarker(map, ",", 0).toInt();
         _map2 = selectFromMarkerToMarker(map, ",", 1).toInt();

src/modules/Bme280.cpp

@@ -4,14 +4,12 @@
   https://github.com/adafruit/Adafruit_BME280_Library
  ******************************************************************/
 
-
 #include "Global.h"
 #include "classes/IoTItem.h"
 
 #include <Adafruit_BME280.h>
 #include <map>
 
-
 std::map<String, Adafruit_BME280*> bmes;
 
 class Bme280t : public IoTItem {
@@ -25,14 +23,15 @@ class Bme280t : public IoTItem {
 
     void doByInterval() {
         value.valD = _bme->readTemperature();
-        if (value.valD < 145) regEvent(value.valD, "Bme280t");
+        if (value.valD < 145)
-            else SerialPrint("E", "Sensor Bme280t", "Error");  
+            regEvent(value.valD, "Bme280t");
+        else
+            SerialPrint("E", "Sensor Bme280t", "Error");
     }
 
     ~Bme280t();
 };
 
-  
 class Bme280h : public IoTItem {
    private:
     Adafruit_BME280* _bme;
@@ -44,14 +43,15 @@ class Bme280h : public IoTItem {
 
     void doByInterval() {
         value.valD = _bme->readHumidity();
-        if (value.valD < 100) regEvent(value.valD, "Bme280h");
+        if (value.valD < 100)
-            else SerialPrint("E", "Sensor Bme280h", "Error");  
+            regEvent(value.valD, "Bme280h");
+        else
+            SerialPrint("E", "Sensor Bme280h", "Error");
     }
 
     ~Bme280h();
 };
 
-
 class Bme280p : public IoTItem {
    private:
     Adafruit_BME280* _bme;
@@ -66,13 +66,13 @@ class Bme280p : public IoTItem {
         if (value.valD > 0) {
             value.valD = value.valD / 1.333224 / 100;
             regEvent(value.valD, "Bme280p");
-        } else SerialPrint("E", "Sensor Bme280p", "Error");  
+        } else
+            SerialPrint("E", "Sensor Bme280p", "Error");
     }
 
     ~Bme280p();
 };
 
-
 void* getAPI_Bme280(String subtype, String param) {
     String addr;
     jsonRead(param, "addr", addr);

src/modules/Ds18b20.cpp

@@ -29,8 +29,8 @@ class Ds18b20 : public IoTItem {
     // jsonReadStr, jsonReadBool, jsonReadInt
     Ds18b20(String parameters) : IoTItem(parameters) {
         jsonRead(parameters, "pin", _pin);
-        jsonRead(parameters, "index", _index);
+        jsonRead(parameters, "index", _index, false);
-        jsonRead(parameters, "addr", _addr);            
+        jsonRead(parameters, "addr", _addr, false);
 
         //учитываем, что библиотека может работать с несколькими линиями на разных пинах, поэтому инициируем библиотеку, если линия ранее не использовалась
         if (oneWireTemperatureArray.find(_pin) == oneWireTemperatureArray.end()) {
@@ -74,8 +74,10 @@ class Ds18b20 : public IoTItem {
         char addrStr[20] = "";
         hex2string(deviceAddress, 8, addrStr);
 
-        if (value.valD != -127) regEvent(value.valD, "addr: " + String(addrStr));  //обязательный вызов для отправки результата работы
+        if (value.valD != -127)
-            else SerialPrint("E", "Sensor Ds18b20", "Error");
+            regEvent(value.valD, "addr: " + String(addrStr));  //обязательный вызов для отправки результата работы
+        else
+            SerialPrint("E", "Sensor Ds18b20", "Error");
     }
     //=======================================================================================================
 

src/utils/JsonUtils.cpp

@@ -11,85 +11,105 @@ void jsonWriteStrDoc(DynamicJsonDocument& doc, String name, String value) {
 }
 
 // new==============================================================================
-bool jsonRead(String& json, String key, unsigned long& value) {
+bool jsonRead(String& json, String key, unsigned long& value, bool e) {
     bool ret = true;
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), error.f_str());
             jsonErrorDetected();
+        }
         ret = false;
     } else if (!doc.containsKey(key)) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), key + " missing");
             jsonErrorDetected();
+        }
         ret = false;
     }
     value = doc[key].as<unsigned long>();
     return ret;
 }
 
-bool jsonRead(String& json, String key, float& value) {
+bool jsonRead(String& json, String key, float& value, bool e) {
     bool ret = true;
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), error.f_str());
             jsonErrorDetected();
+        }
         ret = false;
     } else if (!doc.containsKey(key)) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), key + " missing");
             jsonErrorDetected();
+        }
         ret = false;
     }
     value = doc[key].as<float>();
     return ret;
 }
 
-bool jsonRead(String& json, String key, String& value) {
+bool jsonRead(String& json, String key, String& value, bool e) {
     bool ret = true;
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), error.f_str());
             jsonErrorDetected();
+        }
         ret = false;
     } else if (!doc.containsKey(key)) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), key + " missing");
             jsonErrorDetected();
+        }
         ret = false;
     }
     value = doc[key].as<String>();
     return ret;
 }
 
-bool jsonRead(String& json, String key, bool& value) {
+bool jsonRead(String& json, String key, bool& value, bool e) {
     bool ret = true;
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), error.f_str());
             jsonErrorDetected();
+        }
         ret = false;
     } else if (!doc.containsKey(key)) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), key + " missing");
             jsonErrorDetected();
+        }
         ret = false;
     }
     value = doc[key].as<bool>();
     return ret;
 }
 
-bool jsonRead(String& json, String key, int& value) {
+bool jsonRead(String& json, String key, int& value, bool e) {
     bool ret = true;
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), error.f_str());
             jsonErrorDetected();
+        }
         ret = false;
     } else if (!doc.containsKey(key)) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), key + " missing");
             jsonErrorDetected();
+        }
         ret = false;
     }
     value = doc[key].as<int>();
@@ -97,13 +117,15 @@ bool jsonRead(String& json, String key, int& value) {
 }
 
 // new==============================================================================
-bool jsonWriteStr_(String& json, String key, String value) {
+bool jsonWriteStr_(String& json, String key, String value, bool e) {
     bool ret = true;
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonWrite"), error.f_str());
             jsonErrorDetected();
+        }
         ret = false;
     }
     doc[key] = value;
@@ -112,13 +134,15 @@ bool jsonWriteStr_(String& json, String key, String value) {
     return ret;
 }
 
-bool jsonWriteBool_(String& json, String key, bool value) {
+bool jsonWriteBool_(String& json, String key, bool value, bool e) {
     bool ret = true;
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonWrite"), error.f_str());
             jsonErrorDetected();
+        }
         ret = false;
     }
     doc[key] = value;
@@ -127,13 +151,15 @@ bool jsonWriteBool_(String& json, String key, bool value) {
     return ret;
 }
 
-bool jsonWriteInt_(String& json, String key, int value) {
+bool jsonWriteInt_(String& json, String key, int value, bool e) {
     bool ret = true;
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonWrite"), error.f_str());
             jsonErrorDetected();
+        }
         ret = false;
     }
     doc[key] = value;
@@ -142,13 +168,15 @@ bool jsonWriteInt_(String& json, String key, int value) {
     return ret;
 }
 
-bool jsonWriteFloat_(String& json, String key, float value) {
+bool jsonWriteFloat_(String& json, String key, float value, bool e) {
     bool ret = true;
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonWrite"), error.f_str());
             jsonErrorDetected();
+        }
         ret = false;
     }
     doc[key] = value;
@@ -166,7 +194,7 @@ void writeUint8tValueToJsonString(uint8_t* payload, size_t length, size_t header
     jsonMergeObjects(json, payloadStr);
 }
 
-bool jsonMergeObjects(String& json1, String& json2) {
+bool jsonMergeObjects(String& json1, String& json2, bool e) {
     bool ret = true;
     DynamicJsonDocument doc1(JSON_BUFFER_SIZE);
     DeserializationError error1 = deserializeJson(doc1, json1);
@@ -174,8 +202,10 @@ bool jsonMergeObjects(String& json1, String& json2) {
     DeserializationError error2 = deserializeJson(doc2, json2);
     jsonMergeDocs(doc1.as<JsonObject>(), doc2.as<JsonObject>());
     if (error1 || error2) {
+        if (e) {
             SerialPrint("EE", F("json"), "jsonMergeObjects error");
             jsonErrorDetected();
+        }
         ret = false;
     }
     json1 = "";
@@ -190,83 +220,97 @@ void jsonMergeDocs(JsonObject dest, JsonObjectConst src) {
 }
 
 // depricated======================================================================
-String jsonReadStr(String& json, String name) {
+String jsonReadStr(String& json, String name, bool e) {
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), error.f_str());
             jsonErrorDetected();
         }
+    }
     return doc[name].as<String>();
 }
 
-boolean jsonReadBool(String& json, String name) {
+boolean jsonReadBool(String& json, String name, bool e) {
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), error.f_str());
             jsonErrorDetected();
         }
+    }
     return doc[name].as<bool>();
 }
 
-int jsonReadInt(String& json, String name) {
+int jsonReadInt(String& json, String name, bool e) {
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonRead"), error.f_str());
             jsonErrorDetected();
         }
+    }
     return doc[name].as<int>();
 }
 
 // depricated========================================================================
-String jsonWriteStr(String& json, String name, String value) {
+String jsonWriteStr(String& json, String name, String value, bool e) {
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonWrite"), error.f_str());
             jsonErrorDetected();
         }
+    }
     doc[name] = value;
     json = "";
     serializeJson(doc, json);
     return json;
 }
 
-String jsonWriteBool(String& json, String name, boolean value) {
+String jsonWriteBool(String& json, String name, boolean value, bool e) {
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonWrite"), error.f_str());
             jsonErrorDetected();
         }
+    }
     doc[name] = value;
     json = "";
     serializeJson(doc, json);
     return json;
 }
 
-String jsonWriteInt(String& json, String name, int value) {
+String jsonWriteInt(String& json, String name, int value, bool e) {
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonWrite"), error.f_str());
             jsonErrorDetected();
         }
+    }
     doc[name] = value;
     json = "";
     serializeJson(doc, json);
     return json;
 }
 
-String jsonWriteFloat(String& json, String name, float value) {
+String jsonWriteFloat(String& json, String name, float value, bool e) {
     DynamicJsonDocument doc(JSON_BUFFER_SIZE);
     DeserializationError error = deserializeJson(doc, json);
     if (error) {
+        if (e) {
             SerialPrint("EE", F("jsonWrite"), error.f_str());
             jsonErrorDetected();
         }
+    }
     doc[name] = value;
     json = "";
     serializeJson(doc, json);

src/utils/SerialPrint.cpp

@@ -5,7 +5,9 @@ void SerialPrint(String errorLevel, String module, String msg) {
     String tosend = prettyMillis(millis()) + " [" + errorLevel + "] [" + module + "] " + msg;
     Serial.println(tosend);
 
+    if (isNetworkActive()) {
         if (jsonReadInt(settingsFlashJson, F("log")) != 0) {
             standWebSocket.broadcastTXT("/log|" + tosend);
         }
     }
+}