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

ver4

Browse Source
This commit is contained in:
Dmitry Borisenko
2021-12-21 21:58:56 +01:00
parent b0b8203fec
commit 01b0a7d53e
9 changed files with 477 additions and 450 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
data_svelte/build/bundle.css
View File

File diff suppressed because one or more lines are too long

2
data_svelte/build/bundle.js
View File

File diff suppressed because one or more lines are too long

7
data_svelte/lile.json Normal file
View File

@@ -0,0 +1,7 @@
{
"type": "binary",
"subtype": "button-out",
"id": "btn1",
"gpio": 1,
"inv": false
}

10
include/WebSocket.h
View File

@@ -2,8 +2,10 @@
#include "Class/TCircularBuffer.h"
#include "Global.h"
void wsInit();
void wsSendSetup();
void wsSendSetupBuffer();
void wsPublishData(String topic, String data);
void sendDataWs();
void loopWsExecute();
// void wsSendSetup();
// void wsSendSetupBuffer();
//
// void sendDataWs();
// void loopWsExecute();

4
src/Init.cpp
View File

@@ -75,8 +75,8 @@ void deviceInit() {
}
savedFromWeb = false;
//publishWidgets();
//publishState();
// publishWidgets();
// publishState();
}
void loadScenario() {

780
src/Web.cpp
View File

@@ -1,4 +1,5 @@
#include "Web.h"
#include "BufferExecute.h"
#include "Class/NotAsync.h"
#include "Global.h"
@@ -18,396 +19,395 @@ bool parseRequestForPreset(AsyncWebServerRequest* request, uint8_t& preset) {
}
void web_init() {
// server.on("/set", HTTP_GET, [](AsyncWebServerRequest* request) {
// //==============================set.device.json====================================================================================================
// if (request->hasArg(F("addItem"))) {
// addItem2(request->getParam("addItem")->value().toInt());
// request->redirect("/?set.device");
// }
//
// if (request->hasArg(F("addPreset"))) {
// addPreset2(request->getParam(F("addPreset"))->value().toInt());
//
// jsonWriteStr(configSetupJson, F("warning1"), F("<div style='margin-top:10px;margin-bottom:10px;'><font color='black'><p style='border: 1px solid #DCDCDC; border-radius: 3px; background-color: #ffc7c7; padding: 10px;'>Требуется перезагрузка</p></font></div>"));
//
// request->redirect(F("/?set.device"));
// }
//
// if (request->hasArg(F("delChoosingItems"))) {
// jsonWriteStr(configSetupJson, F("warning1"), F("<div style='margin-top:10px;margin-bottom:10px;'><font color='black'><p style='border: 1px solid #DCDCDC; border-radius: 3px; background-color: #ffc7c7; padding: 10px;'>Требуется перезагрузка</p></font></div>"));
// myNotAsyncActions->make(do_delChoosingItems);
// request->send(200);
// }
//
// if (request->hasArg(F("delAllItems"))) {
// delAllItems();
//#ifdef EnableLogging
// cleanLogAndData();
//#endif
// jsonWriteStr(configSetupJson, F("warning1"), F("<div style='margin-top:10px;margin-bottom:10px;'><font color='black'><p style='border: 1px solid #DCDCDC; border-radius: 3px; background-color: #ffc7c7; padding: 10px;'>Требуется перезагрузка</p></font></div>"));
// request->redirect(F("/?set.device"));
// }
//
// if (request->hasArg(F("saveItems"))) {
// myNotAsyncActions->make(do_deviceInit);
// savedFromWeb = true;
// request->send(200);
// }
//
// if (request->hasArg(F("scen"))) {
// bool value = request->getParam(F("scen"))->value().toInt();
// jsonWriteBool(configSetupJson, F("scen"), value);
// saveConfig();
// loadScenario();
// request->send(200);
// }
//
// if (request->hasArg(F("sceninit"))) {
// loadScenario();
// request->send(200);
// }
//
// if (request->hasArg(F("MqttIn"))) {
// bool value = request->getParam(F("MqttIn"))->value().toInt();
// jsonWriteBool(configSetupJson, "MqttIn", value);
// saveConfig();
// mqtt.subscribe((mqttPrefix + "/+/+/event").c_str());
// mqtt.subscribe((mqttPrefix + "/+/+/info").c_str());
// request->send(200);
// }
//
// if (request->hasArg(F("MqttOut"))) {
// bool value = request->getParam(F("MqttOut"))->value().toInt();
// jsonWriteBool(configSetupJson, F("MqttOut"), value);
// saveConfig();
// request->send(200);
// }
//
// if (request->hasArg(F("scenMqtt"))) {
// myNotAsyncActions->make(do_sendScenMQTT);
// request->send(200);
// }
//
// if (request->hasArg(F("cleanlog"))) {
//#ifdef EnableLogging
// cleanLogAndData();
//#endif
// request->send(200);
// }
//
// //==============================wifi settings=============================================
// if (request->hasArg(F("devname"))) {
// jsonWriteStr(configSetupJson, F("name"), request->getParam(F("devname"))->value());
// saveConfig();
// request->send(200);
// }
//
// if (request->hasArg(F("routerssid"))) {
// jsonWriteStr(configSetupJson, F("routerssid"), request->getParam(F("routerssid"))->value());
// saveConfig();
// request->send(200);
// }
//
// if (request->hasArg(F("routerpass"))) {
// jsonWriteStr(configSetupJson, F("routerpass"), request->getParam(F("routerpass"))->value());
// saveConfig();
// request->send(200);
// }
//
// if (request->hasArg(F("apssid"))) {
// jsonWriteStr(configSetupJson, F("apssid"), request->getParam(F("apssid"))->value());
// saveConfig();
// request->send(200, "text/text", "OK");
// }
//
// if (request->hasArg(F("appass"))) {
// jsonWriteStr(configSetupJson, F("appass"), request->getParam(F("appass"))->value());
// saveConfig();
// request->send(200);
// }
//
// if (request->hasArg(F("weblogin"))) {
// jsonWriteStr(configSetupJson, F("weblogin"), request->getParam(F("weblogin"))->value());
// saveConfig();
// request->send(200);
// }
//
// if (request->hasArg(F("webpass"))) {
// jsonWriteStr(configSetupJson, F("webpass"), request->getParam(F("webpass"))->value());
// saveConfig();
// request->send(200);
// }
//
// if (request->hasArg(F("timezone"))) {
// String timezoneStr = request->getParam(F("timezone"))->value();
// jsonWriteStr(configSetupJson, F("timezone"), timezoneStr);
// saveConfig();
// timeNow->setTimezone(timezoneStr.toInt());
// request->send(200);
// }
//
// if (request->hasArg(F("ntp"))) {
// String ntpStr = request->getParam(F("ntp"))->value();
// jsonWriteStr(configSetupJson, F("ntp"), ntpStr);
// saveConfig();
// timeNow->setNtpPool(ntpStr);
// request->send(200);
// }
//
// if (request->hasArg(F("blink"))) {
// bool value = request->getParam(F("blink"))->value().toInt();
// jsonWriteBool(configSetupJson, F("blink"), value);
// saveConfig();
// request->send(200);
// }
//
// if (request->hasArg(F("reqReset"))) {
// String tmp = "{}";
// jsonWriteStr(tmp, "title", F("<button class=\"close\" onclick=\"toggle('reset-block')\">×</button>Вы действительно хотите перезагрузить устройство?<a href=\"#\" class=\"btn btn-block btn-danger\" onclick=\"send_request(this, '/set?reset');setTimeout(function(){ location.href='/?set.device'; }, 15000);html('reset-block','<span class=loader></span>Идет перезагрузка устройства')\">Перезагрузить</a>"));
// jsonWriteStr(tmp, "class", "pop-up");
// request->send(200, "text/html", tmp);
// }
//
// if (request->hasArg(F("reset"))) {
// ESP.restart();
// request->send(200);
// }
//
// //==============================mqtt settings=============================================
// //primary
// if (request->hasArg(F("mqttServer"))) {
// jsonWriteStr(configSetupJson, F("mqttServer"), request->getParam(F("mqttServer"))->value());
// saveConfig();
// myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
// request->send(200);
// }
// if (request->hasArg(F("mqttPort"))) {
// int port = (request->getParam(F("mqttPort"))->value()).toInt();
// jsonWriteInt(configSetupJson, F("mqttPort"), port);
// saveConfig();
// myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
// request->send(200);
// }
// if (request->hasArg(F("mqttPrefix"))) {
// jsonWriteStr(configSetupJson, F("mqttPrefix"), request->getParam(F("mqttPrefix"))->value());
// saveConfig();
// myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
// request->send(200);
// }
// if (request->hasArg(F("mqttUser"))) {
// jsonWriteStr(configSetupJson, F("mqttUser"), request->getParam(F("mqttUser"))->value());
// saveConfig();
// myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
// request->send(200);
// }
// if (request->hasArg(F("mqttPass"))) {
// jsonWriteStr(configSetupJson, F("mqttPass"), request->getParam(F("mqttPass"))->value());
// saveConfig();
// myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
// request->send(200);
// }
// //secondary
// if (request->hasArg(F("mqttServer2"))) {
// jsonWriteStr(configSetupJson, F("mqttServer2"), request->getParam(F("mqttServer2"))->value());
// saveConfig();
// myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
// request->send(200);
// }
// if (request->hasArg(F("mqttPort2"))) {
// int port = (request->getParam(F("mqttPort2"))->value()).toInt();
// jsonWriteInt(configSetupJson, F("mqttPort2"), port);
// saveConfig();
// myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
// request->send(200);
// }
// if (request->hasArg(F("mqttPrefix2"))) {
// jsonWriteStr(configSetupJson, F("mqttPrefix2"), request->getParam(F("mqttPrefix2"))->value());
// saveConfig();
// myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
// request->send(200);
// }
// if (request->hasArg(F("mqttUser2"))) {
// jsonWriteStr(configSetupJson, F("mqttUser2"), request->getParam(F("mqttUser2"))->value());
// saveConfig();
// myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
// request->send(200);
// }
// if (request->hasArg(F("mqttPass2"))) {
// jsonWriteStr(configSetupJson, F("mqttPass2"), request->getParam(F("mqttPass2"))->value());
// saveConfig();
// myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
// request->send(200);
// }
//
// if (request->hasArg("mqttsend")) {
// //myNotAsyncActions->make(do_MQTTUDP);
// request->send(200);
// }
//
// if (request->hasArg("mqttcheck")) {
// String buf = "<button class=\"close\" onclick=\"toggle('my-block')\">×</button>" + getStateStr();
//
// String payload = "{}";
// jsonWriteStr(payload, "title", buf);
// jsonWriteStr(payload, "class", "pop-up");
//
// request->send(200, "text/html", payload);
// }
//
// //==============================telegram settings=============================================
// if (request->hasArg("telegramApi")) {
// jsonWriteStr(configSetupJson, "telegramApi", request->getParam("telegramApi")->value());
// saveConfig();
// request->send(200);
// }
// if (request->hasArg("autos")) {
// bool value = request->getParam("autos")->value().toInt();
// jsonWriteBool(configSetupJson, "autos", value);
// saveConfig();
// request->send(200);
// }
// if (request->hasArg("chatId")) {
// jsonWriteStr(configSetupJson, "chatId", request->getParam("chatId")->value());
// saveConfig();
// request->send(200);
// }
// if (request->hasArg("telegonof")) {
// bool value = request->getParam("telegonof")->value().toInt();
// jsonWriteBool(configSetupJson, "telegonof", value);
// saveConfig();
// request->send(200);
// }
// if (request->hasArg("teleginput")) {
// bool value = request->getParam("teleginput")->value().toInt();
// jsonWriteBool(configSetupJson, "teleginput", value);
// saveConfig();
// request->send(200);
// }
//
// //==============================utilities settings=============================================
// if (request->hasArg("i2c")) {
// myNotAsyncActions->make(do_BUSSCAN);
// request->redirect("/?set.utilities");
// }
// if (request->hasArg("uart")) {
// bool value = request->getParam("uart")->value().toInt();
// jsonWriteBool(configSetupJson, "uart", value);
// saveConfig();
//#ifdef EnableUart
// uartInit();
//#endif
// request->send(200);
// }
// if (request->hasArg("uartEvents")) {
// bool value = request->getParam("uartEvents")->value().toInt();
// jsonWriteBool(configSetupJson, "uartEvents", value);
// saveConfig();
// request->send(200);
// }
// if (request->hasArg("uartS")) {
// jsonWriteStr(configSetupJson, "uartS", request->getParam("uartS")->value());
// saveConfig();
//#ifdef EnableUart
// uartInit();
//#endif
// request->send(200);
// }
// if (request->hasArg("uartTX")) {
// jsonWriteStr(configSetupJson, "uartTX", request->getParam("uartTX")->value());
// saveConfig();
//#ifdef EnableUart
// uartInit();
//#endif
// request->send(200);
// }
// if (request->hasArg("uartRX")) {
// jsonWriteStr(configSetupJson, "uartRX", request->getParam("uartRX")->value());
// saveConfig();
//#ifdef EnableUart
// uartInit();
//#endif
// request->send(200);
// }
//
// //==============================developer settings=============================================
// if (request->hasArg("serverip")) {
// jsonWriteStr(configSetupJson, "serverip", request->getParam("serverip")->value());
// saveConfig();
// serverIP = jsonReadStr(configSetupJson, "serverip");
// request->send(200);
// }
// //set?order=button_1
// if (request->hasArg("order")) {
// String order = request->getParam("order")->value();
// order.replace("_", " ");
// loopCmdAdd(order + ",");
// request->send(200, "text/html", order);
// }
//
// if (request->hasArg("grafmax")) {
// int value = request->getParam("grafmax")->value().toInt();
// jsonWriteInt(configSetupJson, "grafmax", value);
// saveConfig();
// request->send(200);
// }
//
// //gate mode
//
// if (request->hasArg("gateAuto")) {
// bool value = request->getParam("gateAuto")->value().toInt();
// jsonWriteBool(configSetupJson, "gateAuto", value);
// saveConfig();
// request->send(200);
// }
//
// });
//
// //server.on("/del", HTTP_GET, [](AsyncWebServerRequest* request) {
// // if (request->hasArg("file") && request->hasArg("line")) {
// // String fileName = request->getParam("file")->value();
// // Serial.println(fileName);
// // int line = request->getParam("line")->value().toInt();
// // Serial.println(line);
// // myNotAsyncActions->make(do_delChoosingItems);
// // request->redirect(F("/?set.device"));
// // }
// //});
//
// server.on("/check", HTTP_GET, [](AsyncWebServerRequest* request) {
// myNotAsyncActions->make(do_GETLASTVERSION);
// SerialPrint("I", "Update", "firmware version: " + String(lastVersion));
//
// String msg = "";
//
// if (USE_OTA) {
// if (lastVersion == FIRMWARE_VERSION) {
// msg = F("Актуальная версия прошивки уже установлена.");
// } else if (lastVersion > FIRMWARE_VERSION) {
// msg = F("Новая версия прошивки<a href=\"#\" class=\"btn btn-block btn-danger\" onclick=\"send_request(this, '/upgrade');setTimeout(function(){ location.href='/?set.device'; }, 90000);html('my-block','<span class=loader></span>Идет обновление прошивки, после обновления страница перезагрузится автоматически...')\">Установить</a>");
// } else if (lastVersion == -1) {
// msg = F("Cервер не найден. Попробуйте повторить позже...");
// } else if (lastVersion == -2) {
// msg = F("Устройство не подключено к роутеру!");
// } else if (lastVersion < FIRMWARE_VERSION) {
// msg = F("Ошибка версии. Попробуйте повторить позже...");
// }
// } else {
// msg = F("Обновление невозможно, память устройства 1 мб");
// }
//
// String tmp = "{}";
// jsonWriteStr(tmp, "title", "<button class=\"close\" onclick=\"toggle('my-block')\">×</button>" + msg);
// jsonWriteStr(tmp, "class", "pop-up");
// request->send(200, "text/html", tmp);
// });
//
// /*
// * Upgrade
// */
// server.on("/upgrade", HTTP_GET, [](AsyncWebServerRequest* request) {
// myNotAsyncActions->make(do_UPGRADE);
// request->send(200, "text/html");
// });
server.on("/set", HTTP_GET, [](AsyncWebServerRequest* request) {
//==============================set.device.json====================================================================================================
if (request->hasArg(F("addItem"))) {
addItem2(request->getParam("addItem")->value().toInt());
request->redirect("/?set.device");
}
if (request->hasArg(F("addPreset"))) {
addPreset2(request->getParam(F("addPreset"))->value().toInt());
jsonWriteStr(configSetupJson, F("warning1"), F("<div style='margin-top:10px;margin-bottom:10px;'><font color='black'><p style='border: 1px solid #DCDCDC; border-radius: 3px; background-color: #ffc7c7; padding: 10px;'>Требуется перезагрузка</p></font></div>"));
request->redirect(F("/?set.device"));
}
if (request->hasArg(F("delChoosingItems"))) {
jsonWriteStr(configSetupJson, F("warning1"), F("<div style='margin-top:10px;margin-bottom:10px;'><font color='black'><p style='border: 1px solid #DCDCDC; border-radius: 3px; background-color: #ffc7c7; padding: 10px;'>Требуется перезагрузка</p></font></div>"));
myNotAsyncActions->make(do_delChoosingItems);
request->send(200);
}
if (request->hasArg(F("delAllItems"))) {
delAllItems();
#ifdef EnableLogging
cleanLogAndData();
#endif
jsonWriteStr(configSetupJson, F("warning1"), F("<div style='margin-top:10px;margin-bottom:10px;'><font color='black'><p style='border: 1px solid #DCDCDC; border-radius: 3px; background-color: #ffc7c7; padding: 10px;'>Требуется перезагрузка</p></font></div>"));
request->redirect(F("/?set.device"));
}
if (request->hasArg(F("saveItems"))) {
myNotAsyncActions->make(do_deviceInit);
savedFromWeb = true;
request->send(200);
}
if (request->hasArg(F("scen"))) {
bool value = request->getParam(F("scen"))->value().toInt();
jsonWriteBool(configSetupJson, F("scen"), value);
saveConfig();
loadScenario();
request->send(200);
}
if (request->hasArg(F("sceninit"))) {
loadScenario();
request->send(200);
}
if (request->hasArg(F("MqttIn"))) {
bool value = request->getParam(F("MqttIn"))->value().toInt();
jsonWriteBool(configSetupJson, "MqttIn", value);
saveConfig();
mqtt.subscribe((mqttPrefix + "/+/+/event").c_str());
mqtt.subscribe((mqttPrefix + "/+/+/info").c_str());
request->send(200);
}
if (request->hasArg(F("MqttOut"))) {
bool value = request->getParam(F("MqttOut"))->value().toInt();
jsonWriteBool(configSetupJson, F("MqttOut"), value);
saveConfig();
request->send(200);
}
if (request->hasArg(F("scenMqtt"))) {
myNotAsyncActions->make(do_sendScenMQTT);
request->send(200);
}
if (request->hasArg(F("cleanlog"))) {
#ifdef EnableLogging
cleanLogAndData();
#endif
request->send(200);
}
//==============================wifi settings=============================================
if (request->hasArg(F("devname"))) {
jsonWriteStr(configSetupJson, F("name"), request->getParam(F("devname"))->value());
saveConfig();
request->send(200);
}
if (request->hasArg(F("routerssid"))) {
jsonWriteStr(configSetupJson, F("routerssid"), request->getParam(F("routerssid"))->value());
saveConfig();
request->send(200);
}
if (request->hasArg(F("routerpass"))) {
jsonWriteStr(configSetupJson, F("routerpass"), request->getParam(F("routerpass"))->value());
saveConfig();
request->send(200);
}
if (request->hasArg(F("apssid"))) {
jsonWriteStr(configSetupJson, F("apssid"), request->getParam(F("apssid"))->value());
saveConfig();
request->send(200, "text/text", "OK");
}
if (request->hasArg(F("appass"))) {
jsonWriteStr(configSetupJson, F("appass"), request->getParam(F("appass"))->value());
saveConfig();
request->send(200);
}
if (request->hasArg(F("weblogin"))) {
jsonWriteStr(configSetupJson, F("weblogin"), request->getParam(F("weblogin"))->value());
saveConfig();
request->send(200);
}
if (request->hasArg(F("webpass"))) {
jsonWriteStr(configSetupJson, F("webpass"), request->getParam(F("webpass"))->value());
saveConfig();
request->send(200);
}
if (request->hasArg(F("timezone"))) {
String timezoneStr = request->getParam(F("timezone"))->value();
jsonWriteStr(configSetupJson, F("timezone"), timezoneStr);
saveConfig();
timeNow->setTimezone(timezoneStr.toInt());
request->send(200);
}
if (request->hasArg(F("ntp"))) {
String ntpStr = request->getParam(F("ntp"))->value();
jsonWriteStr(configSetupJson, F("ntp"), ntpStr);
saveConfig();
timeNow->setNtpPool(ntpStr);
request->send(200);
}
if (request->hasArg(F("blink"))) {
bool value = request->getParam(F("blink"))->value().toInt();
jsonWriteBool(configSetupJson, F("blink"), value);
saveConfig();
request->send(200);
}
if (request->hasArg(F("reqReset"))) {
String tmp = "{}";
jsonWriteStr(tmp, "title", F("<button class=\"close\" onclick=\"toggle('reset-block')\">×</button>Вы действительно хотите перезагрузить устройство?<a href=\"#\" class=\"btn btn-block btn-danger\" onclick=\"send_request(this, '/set?reset');setTimeout(function(){ location.href='/?set.device'; }, 15000);html('reset-block','<span class=loader></span>Идет перезагрузка устройства')\">Перезагрузить</a>"));
jsonWriteStr(tmp, "class", "pop-up");
request->send(200, "text/html", tmp);
}
if (request->hasArg(F("reset"))) {
ESP.restart();
request->send(200);
}
//==============================mqtt settings=============================================
// primary
if (request->hasArg(F("mqttServer"))) {
jsonWriteStr(configSetupJson, F("mqttServer"), request->getParam(F("mqttServer"))->value());
saveConfig();
myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
request->send(200);
}
if (request->hasArg(F("mqttPort"))) {
int port = (request->getParam(F("mqttPort"))->value()).toInt();
jsonWriteInt(configSetupJson, F("mqttPort"), port);
saveConfig();
myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
request->send(200);
}
if (request->hasArg(F("mqttPrefix"))) {
jsonWriteStr(configSetupJson, F("mqttPrefix"), request->getParam(F("mqttPrefix"))->value());
saveConfig();
myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
request->send(200);
}
if (request->hasArg(F("mqttUser"))) {
jsonWriteStr(configSetupJson, F("mqttUser"), request->getParam(F("mqttUser"))->value());
saveConfig();
myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
request->send(200);
}
if (request->hasArg(F("mqttPass"))) {
jsonWriteStr(configSetupJson, F("mqttPass"), request->getParam(F("mqttPass"))->value());
saveConfig();
myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
request->send(200);
}
// secondary
if (request->hasArg(F("mqttServer2"))) {
jsonWriteStr(configSetupJson, F("mqttServer2"), request->getParam(F("mqttServer2"))->value());
saveConfig();
myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
request->send(200);
}
if (request->hasArg(F("mqttPort2"))) {
int port = (request->getParam(F("mqttPort2"))->value()).toInt();
jsonWriteInt(configSetupJson, F("mqttPort2"), port);
saveConfig();
myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
request->send(200);
}
if (request->hasArg(F("mqttPrefix2"))) {
jsonWriteStr(configSetupJson, F("mqttPrefix2"), request->getParam(F("mqttPrefix2"))->value());
saveConfig();
myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
request->send(200);
}
if (request->hasArg(F("mqttUser2"))) {
jsonWriteStr(configSetupJson, F("mqttUser2"), request->getParam(F("mqttUser2"))->value());
saveConfig();
myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
request->send(200);
}
if (request->hasArg(F("mqttPass2"))) {
jsonWriteStr(configSetupJson, F("mqttPass2"), request->getParam(F("mqttPass2"))->value());
saveConfig();
myNotAsyncActions->make(do_MQTTPARAMSCHANGED);
request->send(200);
}
if (request->hasArg("mqttsend")) {
// myNotAsyncActions->make(do_MQTTUDP);
request->send(200);
}
if (request->hasArg("mqttcheck")) {
String buf = "<button class=\"close\" onclick=\"toggle('my-block')\">×</button>" + getStateStr();
String payload = "{}";
jsonWriteStr(payload, "title", buf);
jsonWriteStr(payload, "class", "pop-up");
request->send(200, "text/html", payload);
}
//==============================telegram settings=============================================
if (request->hasArg("telegramApi")) {
jsonWriteStr(configSetupJson, "telegramApi", request->getParam("telegramApi")->value());
saveConfig();
request->send(200);
}
if (request->hasArg("autos")) {
bool value = request->getParam("autos")->value().toInt();
jsonWriteBool(configSetupJson, "autos", value);
saveConfig();
request->send(200);
}
if (request->hasArg("chatId")) {
jsonWriteStr(configSetupJson, "chatId", request->getParam("chatId")->value());
saveConfig();
request->send(200);
}
if (request->hasArg("telegonof")) {
bool value = request->getParam("telegonof")->value().toInt();
jsonWriteBool(configSetupJson, "telegonof", value);
saveConfig();
request->send(200);
}
if (request->hasArg("teleginput")) {
bool value = request->getParam("teleginput")->value().toInt();
jsonWriteBool(configSetupJson, "teleginput", value);
saveConfig();
request->send(200);
}
//==============================utilities settings=============================================
if (request->hasArg("i2c")) {
myNotAsyncActions->make(do_BUSSCAN);
request->redirect("/?set.utilities");
}
if (request->hasArg("uart")) {
bool value = request->getParam("uart")->value().toInt();
jsonWriteBool(configSetupJson, "uart", value);
saveConfig();
#ifdef EnableUart
uartInit();
#endif
request->send(200);
}
if (request->hasArg("uartEvents")) {
bool value = request->getParam("uartEvents")->value().toInt();
jsonWriteBool(configSetupJson, "uartEvents", value);
saveConfig();
request->send(200);
}
if (request->hasArg("uartS")) {
jsonWriteStr(configSetupJson, "uartS", request->getParam("uartS")->value());
saveConfig();
#ifdef EnableUart
uartInit();
#endif
request->send(200);
}
if (request->hasArg("uartTX")) {
jsonWriteStr(configSetupJson, "uartTX", request->getParam("uartTX")->value());
saveConfig();
#ifdef EnableUart
uartInit();
#endif
request->send(200);
}
if (request->hasArg("uartRX")) {
jsonWriteStr(configSetupJson, "uartRX", request->getParam("uartRX")->value());
saveConfig();
#ifdef EnableUart
uartInit();
#endif
request->send(200);
}
//==============================developer settings=============================================
if (request->hasArg("serverip")) {
jsonWriteStr(configSetupJson, "serverip", request->getParam("serverip")->value());
saveConfig();
serverIP = jsonReadStr(configSetupJson, "serverip");
request->send(200);
}
// set?order=button_1
if (request->hasArg("order")) {
String order = request->getParam("order")->value();
order.replace("_", " ");
loopCmdAdd(order + ",");
request->send(200, "text/html", order);
}
if (request->hasArg("grafmax")) {
int value = request->getParam("grafmax")->value().toInt();
jsonWriteInt(configSetupJson, "grafmax", value);
saveConfig();
request->send(200);
}
// gate mode
if (request->hasArg("gateAuto")) {
bool value = request->getParam("gateAuto")->value().toInt();
jsonWriteBool(configSetupJson, "gateAuto", value);
saveConfig();
request->send(200);
}
});
// server.on("/del", HTTP_GET, [](AsyncWebServerRequest* request) {
// if (request->hasArg("file") && request->hasArg("line")) {
// String fileName = request->getParam("file")->value();
// Serial.println(fileName);
// int line = request->getParam("line")->value().toInt();
// Serial.println(line);
// myNotAsyncActions->make(do_delChoosingItems);
// request->redirect(F("/?set.device"));
// }
// });
server.on("/check", HTTP_GET, [](AsyncWebServerRequest* request) {
myNotAsyncActions->make(do_GETLASTVERSION);
SerialPrint("I", "Update", "firmware version: " + String(lastVersion));
String msg = "";
if (USE_OTA) {
if (lastVersion == FIRMWARE_VERSION) {
msg = F("Актуальная версия прошивки уже установлена.");
} else if (lastVersion > FIRMWARE_VERSION) {
msg = F("Новая версия прошивки<a href=\"#\" class=\"btn btn-block btn-danger\" onclick=\"send_request(this, '/upgrade');setTimeout(function(){ location.href='/?set.device'; }, 90000);html('my-block','<span class=loader></span>Идет обновление прошивки, после обновления страница перезагрузится автоматически...')\">Установить</a>");
} else if (lastVersion == -1) {
msg = F("Cервер не найден. Попробуйте повторить позже...");
} else if (lastVersion == -2) {
msg = F("Устройство не подключено к роутеру!");
} else if (lastVersion < FIRMWARE_VERSION) {
msg = F("Ошибка версии. Попробуйте повторить позже...");
}
} else {
msg = F("Обновление невозможно, память устройства 1 мб");
}
String tmp = "{}";
jsonWriteStr(tmp, "title", "<button class=\"close\" onclick=\"toggle('my-block')\">×</button>" + msg);
jsonWriteStr(tmp, "class", "pop-up");
request->send(200, "text/html", tmp);
});
/*
* Upgrade
*/
server.on("/upgrade", HTTP_GET, [](AsyncWebServerRequest* request) {
myNotAsyncActions->make(do_UPGRADE);
request->send(200, "text/html");
});
SerialPrint("I", F("Web"), F("WebAdmin Init"));
}

26
src/WebServer.cpp
View File

@@ -11,7 +11,6 @@ AsyncWebSocket ws("/ws");
AsyncEventSource events("/events");
void HttpServerinit() {
String login = jsonReadStr(configSetupJson, "weblogin");
String pass = jsonReadStr(configSetupJson, "webpass");
#ifdef ESP32
@@ -20,6 +19,12 @@ void HttpServerinit() {
server.addHandler(new FSEditor(login, pass));
#endif
//#ifdef CORS_DEBUG
DefaultHeaders::Instance().addHeader(F("Access-Control-Allow-Origin"), F("*"));
DefaultHeaders::Instance().addHeader(F("Access-Control-Allow-Headers"), F("content-type"));
//#endif
// server.sendHeader("Access-Control-Allow-Origin", "*");
server.serveStatic("/css/", FileFS, "/css/").setCacheControl("max-age=600");
server.serveStatic("/js/", FileFS, "/js/").setCacheControl("max-age=600");
server.serveStatic("/favicon.ico", FileFS, "/favicon.ico").setCacheControl("max-age=600");
@@ -32,9 +37,17 @@ void HttpServerinit() {
server.serveStatic("/", FileFS, "/").setDefaultFile("index.htm").setAuthentication(login.c_str(), pass.c_str());
#endif
//server.onNotFound([](AsyncWebServerRequest *request) {
// SerialPrint("[E]", "WebServer", "not found:\n" + getRequestInfo(request));
// request->send(404);
//});
server.onNotFound([](AsyncWebServerRequest *request) {
SerialPrint("[E]", "WebServer", "not found:\n" + getRequestInfo(request));
request->send(404);
if (request->method() == HTTP_OPTIONS) {
request->send(200);
} else {
request->send(404);
}
});
server.onFileUpload([](AsyncWebServerRequest *request, const String &filename, size_t index, uint8_t *data, size_t len, bool final) {
@@ -47,6 +60,11 @@ void HttpServerinit() {
}
});
server.on("/file.json", HTTP_GET, [](AsyncWebServerRequest *request) {
String file = readFile("file.json", 1024);
request->send(200, "application/json", file);
});
// динамические данные
server.on("/config.live.json", HTTP_GET, [](AsyncWebServerRequest *request) {
request->send(200, "application/json", configLiveJson);
@@ -117,7 +135,7 @@ void onWsEvent(AsyncWebSocket *server, AsyncWebSocketClient *client, AwsEventTyp
if (msg.startsWith("/config")) {
// myNotAsyncActions->make(do_webSocketSendSetup);
wsSetupFlag = true;
// wsSetupFlag = true;
}
if (info->opcode == WS_TEXT) {

86
src/WebSocket.cpp
View File

@@ -6,58 +6,58 @@
#include "Global.h"
void wsInit() {
myWsBuffer = new TCircularBuffer<char*, 20480>;
// myNotAsyncActions->add(
// do_webSocketSendSetup, [&](void*) {
// delay(100);
// wsSendSetup();
// },
// nullptr);
// myWsBuffer = new TCircularBuffer<char*, 20480>;
// myNotAsyncActions->add(
// do_webSocketSendSetup, [&](void*) {
// delay(100);
// wsSendSetup();
// },
// nullptr);
}
void wsPublishData(String topic, String data) {
if (ws.enabled()) {
// if (ws.availableForWriteAll()) {
data = "[" + topic + "]" + data;
ws.textAll(data);
//}
if (ws.availableForWriteAll()) {
data = "[" + topic + "]" + data;
ws.textAll(data);
}
}
}
//отправка setup массива в sockets способом через буфер string, рабочий способ но буфер стринг - плохой метод
// void wsSendSetup3() {
// File file = seekFile("/setup.json");
// DynamicJsonDocument doc(2048);
// int i = 0;
// file.find("[");
// SerialPrint("I", F("WS"), F("start send config"));
// do {
// i++;
// deserializeJson(doc, file);
// wsBuf += doc.as<String>() + "\n";
// } while (file.findUntil(",", "]"));
// SerialPrint("I", F("WS"), F("completed send config"));
//}
void wsSendSetup3() {
File file = seekFile("/setup.json");
DynamicJsonDocument doc(2048);
int i = 0;
file.find("[");
SerialPrint("I", F("WS"), F("start send config"));
do {
i++;
deserializeJson(doc, file);
wsBuf += doc.as<String>() + "\n";
} while (file.findUntil(",", "]"));
SerialPrint("I", F("WS"), F("completed send config"));
}
// void loopWsExecute3() {
// static int attampts = wsAttempts;
// if (wsBuf.length()) {
// if (attampts > 0) {
// if (ws.availableForWriteAll()) {
// String tmp = selectToMarker(wsBuf, "\n");
// wsPublishData("config", tmp);
// wsBuf = deleteBeforeDelimiter(wsBuf, "\n");
// attampts = wsAttempts;
// } else {
// attampts--;
// SerialPrint("I", F("WS"), String(attampts));
// }
// } else {
// SerialPrint("I", F("WS"), F("socket fatal error"));
// attampts = wsAttempts;
// }
// }
// }
void loopWsExecute3() {
static int attampts = wsAttempts;
if (wsBuf.length()) {
if (attampts > 0) {
if (ws.availableForWriteAll()) {
String tmp = selectToMarker(wsBuf, "\n");
wsPublishData("config", tmp);
wsBuf = deleteBeforeDelimiter(wsBuf, "\n");
attampts = wsAttempts;
} else {
attampts--;
SerialPrint("I", F("WS"), String(attampts));
}
} else {
SerialPrint("I", F("WS"), F("socket fatal error"));
attampts = wsAttempts;
}
}
}
//отправка setup массива в sockets способом через кольцевой буфер char
// void wsSendSetup() {

10
src/main.cpp
View File

@@ -113,12 +113,12 @@ void loop() {
testLoop();
if (wsSetupFlag) {
wsSetupFlag = false;
wsSendSetup();
}
// if (wsSetupFlag) {
// wsSetupFlag = false;
// wsSendSetup();
//}
loopWsExecute();
// loopWsExecute();
#ifdef OTA_UPDATES_ENABLED
ArduinoOTA.handle();