iotmanager/IoTManager
1
0
Fork 0
mirror of https://github.com/IoTManagerProject/IoTManager.git synced 2026-03-28 15:12:19 +03:00
Code Issues Packages Projects Releases Wiki Activity

ButtonOut changed (not working version)

Browse Source
This commit is contained in:
Dmitry Borisenko
2020-11-13 17:13:50 +03:00
parent 96f160fc88
commit 50ad50efb2
19 changed files with 216 additions and 168 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/MqttClient.cpp
View File

@@ -1,7 +1,7 @@
#include "MqttClient.h"
#include <LittleFS.h>
#include "items/LoggingClass.h"
#include "items/Logging.h"
#include "Class/NotAsync.h"
#include "Global.h"
#include "Init.h"
@@ -62,10 +62,9 @@ void mqttSubscribe() {
SerialPrint("I", "MQTT", "subscribe");
mqtt.subscribe(mqttPrefix.c_str());
mqtt.subscribe((mqttRootDevice + "/+/control").c_str());
mqtt.subscribe((mqttRootDevice + "/order").c_str());
mqtt.subscribe((mqttRootDevice + "/update").c_str());
mqtt.subscribe((mqttRootDevice + "/devc").c_str());
mqtt.subscribe((mqttRootDevice + "/devs").c_str());
//mqtt.subscribe((mqttRootDevice + "/order").c_str());
//mqtt.subscribe((mqttPrefix + "/event").c_str());
}
boolean mqttConnect() {
@@ -131,11 +130,16 @@ void mqttCallback(char* topic, uint8_t* payload, size_t length) {
}
else if (topicStr.indexOf("order")) {
payloadStr.replace("_", " ");
orderBuf += payloadStr;
orderBuf += ",";
//payloadStr.replace("_", " ");
//orderBuf += payloadStr;
//orderBuf += ",";
}
//else if (topicStr.indexOf("event")) {
// eventBuf += payloadStr;
//}
else if (topicStr.indexOf("update")) {
if (payloadStr == "1") {
myNotAsyncActions->make(do_UPGRADE);