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

Merge pull request #20 from IoTManagerProject/ver4dev

Browse Source 
452 исправлен баг пропадания виджетов в приложении
This commit is contained in:
Mit4el
2023-10-07 09:44:07 +03:00
committed by GitHub
parent e35225e7be 9eb6122fe1
commit 0b3289a0ea
6 changed files with 367 additions and 351 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
data_svelte/build/bundle.css.gz
View File

Binary file not shown.

BIN
data_svelte/build/bundle.js.gz
View File

Binary file not shown.

6
data_svelte/index.html
View File

@@ -4,12 +4,12 @@
<meta charset="utf-8" /> <meta charset="utf-8" />
<meta name="viewport" content="width=device-width,initial-scale=1" /> <meta name="viewport" content="width=device-width,initial-scale=1" />
<title>IoT Manager 4.5.1</title> <title>IoT Manager 4.5.2</title>
<link rel="icon" type="image/png" href="/favicon.ico" /> <link rel="icon" type="image/png" href="/favicon.ico" />
<link rel="stylesheet" href="/build/bundle.css?4511" /> <link rel="stylesheet" href="/build/bundle.css?4520" />
<script defer src="/build/bundle.js?4511"></script> <script defer src="/build/bundle.js?4520"></script>
</head> </head>
<body></body> <body></body>

38
include/Const.h
View File

@@ -2,7 +2,7 @@
#include "BuildTime.h" #include "BuildTime.h"
// Версия прошивки // Версия прошивки
#define FIRMWARE_VERSION 451 #define FIRMWARE_VERSION 452
#ifdef esp8266_1mb_ota #ifdef esp8266_1mb_ota
#define FIRMWARE_NAME "esp8266_1mb_ota" #define FIRMWARE_NAME "esp8266_1mb_ota"
@@ -45,7 +45,7 @@
#endif #endif
// Размер буфера json // Размер буфера json
#define JSON_BUFFER_SIZE 4096 // держим 2 кб не меняем #define JSON_BUFFER_SIZE 4096 // держим 2 кб не меняем
/* /*
WEB_SOCKETS_FRAME_SIZE создан для того что бы не загружать оперативку. WEB_SOCKETS_FRAME_SIZE создан для того что бы не загружать оперативку.
@@ -74,22 +74,22 @@ WEB_SOCKETS_FRAME_SIZE создан для того что бы не загру
#define USE_LITTLEFS true #define USE_LITTLEFS true
#define START_DATETIME 1661990400 // 01.09.2022 00:00:00 константа для сокращения unix time #define START_DATETIME 1661990400 // 01.09.2022 00:00:00 константа для сокращения unix time
#define MIN_DATETIME 1575158400 #define MIN_DATETIME 1575158400
#define LEAP_YEAR(Y) (((1970 + Y) > 0) && !((1970 + Y) % 4) && (((1970 + Y) % 100) || !((1970 + Y) % 400))) #define LEAP_YEAR(Y) (((1970 + Y) > 0) && !((1970 + Y) % 4) && (((1970 + Y) % 100) || !((1970 + Y) % 400)))
// задачи таскера // задачи таскера
enum TimerTask_t { WIFI_SCAN, enum TimerTask_t { WIFI_SCAN,
WIFI_MQTT_CONNECTION_CHECK, WIFI_MQTT_CONNECTION_CHECK,
TIME, TIME,
TIME_SYNC, TIME_SYNC,
UPTIME, UPTIME,
UDP, // UDPP UDP, // UDPP
TIMES, // периодические секундные проверки TIMES, // периодические секундные проверки
PTASK, PTASK,
ST, ST,
END }; END };
// задачи которые надо протащить через loop // задачи которые надо протащить через loop
enum NotAsyncActions { enum NotAsyncActions {
@@ -100,13 +100,13 @@ enum NotAsyncActions {
// состояния обновления // состояния обновления
enum UpdateStates { NOT_STARTED, enum UpdateStates { NOT_STARTED,
UPDATE_FS_IN_PROGRESS, UPDATE_FS_IN_PROGRESS,
UPDATE_FS_COMPLETED, UPDATE_FS_COMPLETED,
UPDATE_FS_FAILED, UPDATE_FS_FAILED,
UPDATE_BUILD_IN_PROGRESS, UPDATE_BUILD_IN_PROGRESS,
UPDATE_BUILD_COMPLETED, UPDATE_BUILD_COMPLETED,
UPDATE_BUILD_FAILED, UPDATE_BUILD_FAILED,
PATH_ERROR PATH_ERROR
}; };
enum distination { enum distination {

58
src/EspFileSystem.cpp
View File

@@ -1,7 +1,8 @@
#include "EspFileSystem.h" #include "EspFileSystem.h"
#include "Global.h" #include "Global.h"
bool fileSystemInit() { bool fileSystemInit()
{
if (!FileFS.begin()) { if (!FileFS.begin()) {
SerialPrint(F("E"), F("FS"), F("Init ERROR, may be FS was not flashed")); SerialPrint(F("E"), F("FS"), F("Init ERROR, may be FS was not flashed"));
return false; return false;
@@ -10,7 +11,8 @@ bool fileSystemInit() {
return true; return true;
} }
void globalVarsSync() { void globalVarsSync()
{
settingsFlashJson = readFile(F("settings.json"), 4096); settingsFlashJson = readFile(F("settings.json"), 4096);
settingsFlashJson.replace("\r\n", ""); settingsFlashJson.replace("\r\n", "");
@@ -18,44 +20,42 @@ void globalVarsSync() {
valuesFlashJson.replace("\r\n", ""); valuesFlashJson.replace("\r\n", "");
mqttPrefix = jsonReadStr(settingsFlashJson, F("mqttPrefix")); mqttPrefix = jsonReadStr(settingsFlashJson, F("mqttPrefix"));
mqttRootDevice = mqttPrefix + "/" + chipId;
jsonWriteStr_(settingsFlashJson, "root", mqttRootDevice);
jsonWriteStr_(settingsFlashJson, "id", chipId); jsonWriteStr_(settingsFlashJson, "id", chipId);
// jsonWriteStr_(errorsHeapJson, "errors_", ""); //метка для парсинга удалить mqttRootDevice = mqttPrefix + "/" + chipId;
// jsonWriteStr_(ssidListHeapJson, "ssids_", ""); //метка для парсинга удалить
// это не используется - удалить в последствии
jsonWriteStr_(settingsFlashJson, "root", mqttRootDevice);
} }
// к удалению. не используется void syncSettingsFlashJson()
// String getParamsJson() { {
// String json;
// serializeJson(*getLocalItemsAsJSON(), json);
// jsonWriteStr_(json, "params", "");
// return json;
// }
void syncSettingsFlashJson() {
writeFile(F("settings.json"), settingsFlashJson); writeFile(F("settings.json"), settingsFlashJson);
} }
void syncValuesFlashJson() { void syncValuesFlashJson()
{
writeFile(F("values.json"), valuesFlashJson); writeFile(F("values.json"), valuesFlashJson);
} }
const String getChipId() { const String getChipId()
return String(ESP_getChipId()) + "-" + String(getFlashChipIdNew()); // + "v" + String(FIRMWARE_VERSION); {
return String(ESP_getChipId()) + "-" + String(getFlashChipIdNew()); // + "v" + String(FIRMWARE_VERSION);
} }
void setChipId() { void setChipId()
{
chipId = getChipId(); chipId = getChipId();
SerialPrint("i", "System", "id: " + chipId); SerialPrint("i", "System", "id: " + chipId);
} }
const String getUniqueId(const char* name) { const String getUniqueId(const char* name)
{
return String(name) + getMacAddress(); return String(name) + getMacAddress();
} }
const String getWebVersion() { const String getWebVersion()
{
String text = readFile("/index.html", 2000); String text = readFile("/index.html", 2000);
text = selectFromMarkerToMarker(text, "title", 1); text = selectFromMarkerToMarker(text, "title", 1);
text = selectFromMarkerToMarker(text, " ", 2); text = selectFromMarkerToMarker(text, " ", 2);
@@ -64,7 +64,8 @@ const String getWebVersion() {
return text; return text;
} }
uint32_t ESP_getChipId(void) { uint32_t ESP_getChipId(void)
{
#ifdef ESP32 #ifdef ESP32
uint32_t id = 0; uint32_t id = 0;
for (uint32_t i = 0; i < 17; i = i + 8) { for (uint32_t i = 0; i < 17; i = i + 8) {
@@ -78,7 +79,8 @@ uint32_t ESP_getChipId(void) {
// устарела используем новую функцию ниже // устарела используем новую функцию ниже
#ifndef esp32s2_4mb #ifndef esp32s2_4mb
uint32_t ESP_getFlashChipId(void) { uint32_t ESP_getFlashChipId(void)
{
#ifdef ESP32 #ifdef ESP32
// Нет аналогичной (без доп.кода) функций в 32 // Нет аналогичной (без доп.кода) функций в 32
// надо использовать другой id - варианты есть // надо использовать другой id - варианты есть
@@ -92,7 +94,8 @@ uint32_t ESP_getFlashChipId(void) {
// https://github.com/espressif/arduino-esp32/issues/6945#issuecomment-1199900892 // https://github.com/espressif/arduino-esp32/issues/6945#issuecomment-1199900892
// получение flash ch id из проекта esp easy // получение flash ch id из проекта esp easy
uint32_t getFlashChipIdNew() { uint32_t getFlashChipIdNew()
{
// Cache since size does not change // Cache since size does not change
static uint32_t flashChipId = 0; static uint32_t flashChipId = 0;
@@ -109,14 +112,15 @@ uint32_t getFlashChipIdNew() {
// esp_flash_read_id(nullptr, &flashChipId); // esp_flash_read_id(nullptr, &flashChipId);
#elif defined(ESP8266) #elif defined(ESP8266)
flashChipId = ESP.getFlashChipId(); flashChipId = ESP.getFlashChipId();
#endif // ifdef ESP32 #endif // ifdef ESP32
} }
return flashChipId; return flashChipId;
} }
const String getMacAddress() { const String getMacAddress()
{
uint8_t mac[6]; uint8_t mac[6];
char buf[13] = {0}; char buf[13] = { 0 };
#if defined(ESP8266) #if defined(ESP8266)
WiFi.macAddress(mac); WiFi.macAddress(mac);
sprintf(buf, MACSTR, MAC2STR(mac)); sprintf(buf, MACSTR, MAC2STR(mac));

616
src/WsServer.cpp
View File

@@ -3,334 +3,339 @@
extern IoTScenario iotScen; extern IoTScenario iotScen;
#ifdef STANDARD_WEB_SOCKETS #ifdef STANDARD_WEB_SOCKETS
void standWebSocketsInit() { void standWebSocketsInit()
{
standWebSocket.begin(); standWebSocket.begin();
standWebSocket.onEvent(webSocketEvent); standWebSocket.onEvent(webSocketEvent);
SerialPrint("i", "WS", "WS server initialized"); SerialPrint("i", "WS", "WS server initialized");
} }
void webSocketEvent(uint8_t num, WStype_t type, uint8_t* payload, void webSocketEvent(uint8_t num, WStype_t type, uint8_t* payload,
size_t length) { size_t length)
{
switch (type) { switch (type) {
case WStype_ERROR: { case WStype_ERROR: {
Serial.printf("[%u] Error!\n", num); Serial.printf("[%u] Error!\n", num);
} break; } break;
case WStype_DISCONNECTED: { case WStype_DISCONNECTED: {
Serial.printf("[%u] Disconnected!\n", num); Serial.printf("[%u] Disconnected!\n", num);
} break; } break;
case WStype_CONNECTED: { case WStype_CONNECTED: {
// IPAddress ip = standWebSocket.remoteIP(num); // IPAddress ip = standWebSocket.remoteIP(num);
SerialPrint("i", "WS " + String(num), "WS client connected"); SerialPrint("i", "WS " + String(num), "WS client connected");
if (num >= 3) { if (num >= 3) {
SerialPrint("E", "WS", "Too many clients, connection closed!!!"); SerialPrint("E", "WS", "Too many clients, connection closed!!!");
jsonWriteInt(errorsHeapJson, "wse1", 1); jsonWriteInt(errorsHeapJson, "wse1", 1);
standWebSocket.close(); standWebSocket.close();
standWebSocketsInit(); standWebSocketsInit();
}
// Serial.printf("[%u] Connected from %d.%d.%d.%d url: %s\n", num, ip[0],
// ip[1], ip[2], ip[3], payload); standWebSocket.sendTXT(num,
// "Connected");
} break;
case WStype_TEXT: {
bool endOfHeaderFound = false;
size_t maxAllowedHeaderSize = 15; // максимальное количество символов заголовка
size_t headerLenth = 0;
String headerStr;
for (size_t i = 0; i <= maxAllowedHeaderSize; i++) {
headerLenth++;
char s = (char)payload[i];
headerStr += s;
if (s == '|') {
endOfHeaderFound = true;
break;
} }
// Serial.printf("[%u] Connected from %d.%d.%d.%d url: %s\n", num, ip[0], }
// ip[1], ip[2], ip[3], payload); standWebSocket.sendTXT(num, if (!endOfHeaderFound) {
// "Connected"); SerialPrint("E", "WS " + String(num), "Package without header");
} break; }
case WStype_TEXT: { //----------------------------------------------------------------------//
bool endOfHeaderFound = false; // Страница веб интерфейса dashboard
size_t maxAllowedHeaderSize = 15; // максимальное количество символов заголовка //----------------------------------------------------------------------//
size_t headerLenth = 0;
String headerStr;
for (size_t i = 0; i <= maxAllowedHeaderSize; i++) {
headerLenth++;
char s = (char)payload[i];
headerStr += s;
if (s == '|') {
endOfHeaderFound = true;
break;
}
}
if (!endOfHeaderFound) {
SerialPrint("E", "WS " + String(num), "Package without header");
}
//----------------------------------------------------------------------// // публикация всех виджетов
// Страница веб интерфейса dashboard if (headerStr == "/|") {
//----------------------------------------------------------------------// sendFileToWsByFrames("/layout.json", "layout", "", num, WEB_SOCKETS_FRAME_SIZE);
}
// публикация всех виджетов if (headerStr == "/params|") {
if (headerStr == "/|") { // публикация всех статус сообщений при подключении svelte приложения
sendFileToWsByFrames("/layout.json", "layout", "", num, WEB_SOCKETS_FRAME_SIZE); String params = "{}";
} for (std::list<IoTItem*>::iterator it = IoTItems.begin();
it != IoTItems.end(); ++it) {
if (headerStr == "/params|") { if ((*it)->getSubtype() != "Loging") {
// публикация всех статус сообщений при подключении svelte приложения if ((*it)->getSubtype() != "LogingDaily") {
String params = "{}"; if ((*it)->iAmLocal)
for (std::list<IoTItem*>::iterator it = IoTItems.begin(); jsonWriteStr(params, (*it)->getID(), (*it)->getValue());
it != IoTItems.end(); ++it) {
if ((*it)->getSubtype() != "Loging") {
if ((*it)->getSubtype() != "LogingDaily") {
if ((*it)->iAmLocal)
jsonWriteStr(params, (*it)->getID(), (*it)->getValue());
}
}
}
sendStringToWs("params", params, num);
// генерация события подключения в модулях
for (std::list<IoTItem*>::iterator it = IoTItems.begin();
it != IoTItems.end(); ++it) {
if ((*it)->iAmLocal) (*it)->onMqttWsAppConnectEvent();
}
}
// отвечаем на запрос графиков
if (headerStr == "/charts|") {
// обращение к логированию из ядра
// отправка данных графиков только в выбранный сокет
for (std::list<IoTItem*>::iterator it = IoTItems.begin();
it != IoTItems.end(); ++it) {
// сбрасываем даты графиков
// if ((*it)->getID().endsWith("-date")) {
// (*it)->setTodayDate();
// }
if ((*it)->getSubtype() == "Loging" || "LogingDaily") {
(*it)->setPublishDestination(TO_WS, num);
(*it)->publishValue();
} }
} }
} }
sendStringToWs("params", params, num);
//----------------------------------------------------------------------// // генерация события подключения в модулях
// Страница веб интерфейса configutation for (std::list<IoTItem*>::iterator it = IoTItems.begin();
//----------------------------------------------------------------------// it != IoTItems.end(); ++it) {
if ((*it)->iAmLocal)
// отвечаем данными на запрос страницы (*it)->onMqttWsAppConnectEvent();
if (headerStr == "/config|") {
sendFileToWsByFrames("/items.json", "itemsj", "", num, WEB_SOCKETS_FRAME_SIZE);
sendFileToWsByFrames("/widgets.json", "widget", "", num, WEB_SOCKETS_FRAME_SIZE);
sendFileToWsByFrames("/config.json", "config", "", num, WEB_SOCKETS_FRAME_SIZE);
sendFileToWsByFrames("/scenario.txt", "scenar", "", num, WEB_SOCKETS_FRAME_SIZE);
sendStringToWs("settin", settingsFlashJson, num);
} }
}
// обработка кнопки сохранить // отвечаем на запрос графиков
if (headerStr == "/gifnoc|") { if (headerStr == "/charts|") {
writeFileUint8tByFrames("config.json", payload, length, headerLenth, // обращение к логированию из ядра
256); // отправка данных графиков только в выбранный сокет
} for (std::list<IoTItem*>::iterator it = IoTItems.begin();
if (headerStr == "/tuoyal|") { it != IoTItems.end(); ++it) {
writeFileUint8tByFrames("layout.json", payload, length, headerLenth, // сбрасываем даты графиков
256); // if ((*it)->getID().endsWith("-date")) {
} // (*it)->setTodayDate();
if (headerStr == "/oiranecs|") { // }
writeFileUint8tByFrames("scenario.txt", payload, length, headerLenth, if ((*it)->getSubtype() == "Loging" || "LogingDaily") {
256); (*it)->setPublishDestination(TO_WS, num);
clearConfigure(); (*it)->publishValue();
configure("/config.json");
iotScen.loadScenario("/scenario.txt");
// создаем событие завершения конфигурирования для возможности
// выполнения блока кода при загрузке
createItemFromNet("onStart", "1", 1);
}
//----------------------------------------------------------------------//
// Страница веб интерфейса connection
//----------------------------------------------------------------------//
// отвечаем данными на запрос страницы
if (headerStr == "/connection|") {
sendStringToWs("settin", settingsFlashJson, num);
sendStringToWs("ssidli", ssidListHeapJson, num);
sendStringToWs("errors", errorsHeapJson, num);
// запуск асинхронного сканирования wifi сетей при переходе на страницу
// соединений RouterFind(jsonReadStr(settingsFlashJson,
// F("routerssid")));
}
// обработка кнопки сохранить settings.json
if (headerStr == "/sgnittes|") {
writeUint8tToString(payload, length, headerLenth, settingsFlashJson);
writeFileUint8tByFrames("settings.json", payload, length, headerLenth,
256);
sendStringToWs("errors", errorsHeapJson, num);
// если не было создано приема данных по udp - то создадим его
addThisDeviceToList();
}
// обработка кнопки сохранить настройки mqtt
if (headerStr == "/mqtt|") {
sendStringToWs("settin", settingsFlashJson,
num); // отправляем в ответ новые полученные настройки
handleMqttStatus(false, 8); // меняем статус на неопределенный
mqttReconnect(); // начинаем переподключение
sendStringToWs("errors", errorsHeapJson,
num); // отправляем что статус неопределен
sendStringToWs("ssidli", ssidListHeapJson, num);
}
// запуск асинхронного сканирования wifi сетей при нажатии выпадающего
// списка
if (headerStr == "/scan|") {
std::vector<String> jArray;
jsonReadArray(settingsFlashJson, "routerssid", jArray);
RouterFind(jArray);
sendStringToWs("ssidli", ssidListHeapJson, num);
}
//----------------------------------------------------------------------//
// Страница веб интерфейса list
//----------------------------------------------------------------------//
// отвечаем данными на запрос страницы list
if (headerStr == "/list|") {
sendStringToWs("settin", settingsFlashJson, num);
// отправим список устройств в зависимости от того что выбрал user
// sendDeviceList(num);
}
// отвечаем на запрос списка устройств (это отдельный запрос который
// делает приложение при подключении)
if (headerStr == "/devlist|") {
// отправим список устройств в зависимости от того что выбрал user
sendDeviceList(num);
}
// сохраняем данные листа
if (headerStr == "/tsil|") {
writeFileUint8tByFrames("devlist.json", payload, length, headerLenth,
256);
}
//----------------------------------------------------------------------//
// Страница веб интерфейса system
//----------------------------------------------------------------------//
// отвечаем данными на запрос страницы
if (headerStr == "/system|") {
sendStringToWs("errors", errorsHeapJson, num);
sendStringToWs("settin", settingsFlashJson, num);
}
//----------------------------------------------------------------------//
// Страница веб интерфейса dev
//----------------------------------------------------------------------//
if (headerStr == "/dev|") {
sendStringToWs("errors", errorsHeapJson, num);
sendStringToWs("settin", settingsFlashJson, num);
sendFileToWsByFrames("/config.json", "config", "", num, WEB_SOCKETS_FRAME_SIZE);
sendFileToWsByFrames("/items.json", "itemsj", "", num, WEB_SOCKETS_FRAME_SIZE);
// sendFileToWsByFrames("/layout.json", "layout", "", num,
// WEB_SOCKETS_FRAME_SIZE);
}
//----------------------------------------------------------------------//
// Страница веб интерфейса update
//----------------------------------------------------------------------//
if (headerStr == "/profile|") {
sendFileToWsByFrames("/myProfile.json", "prfile", "", num,
WEB_SOCKETS_FRAME_SIZE);
}
//----------------------------------------------------------------------//
// отдельные команды веб интерфейса
//----------------------------------------------------------------------//
// переписать любое поле в errors json
if (headerStr == "/rorre|") {
writeUint8tValueToJsonString(payload, length, headerLenth, errorsHeapJson);
}
// команда перезагрузки esp
if (headerStr == "/reboot|") {
ESP.restart();
}
// команда очистки всех логов esp
if (headerStr == "/clean|") {
cleanLogs();
}
// команда обновления прошивки esp
if (headerStr == "/update|") {
String path;
writeUint8tToString(payload, length, headerLenth, path);
upgrade_firmware(3, path);
}
// Прием команд control c dashboard
if (headerStr == "/control|") {
String msg;
writeUint8tToString(payload, length, headerLenth, msg);
String key = selectFromMarkerToMarker(msg, "/", 0);
String value = selectFromMarkerToMarker(msg, "/", 1);
generateOrder(key, value);
SerialPrint("i", F("=>WS"), "Msg from svelte web, WS No: " + String(num) + ", msg: " + msg);
}
if (headerStr == "/tst|") {
standWebSocket.sendTXT(num, "/tstr|");
}
// получаем команду посланную из модуля
if (headerStr == "/order|") {
String json;
writeUint8tToString(payload, length, headerLenth, json);
String id, key, value;
jsonRead(json, "id", id);
jsonRead(json, "key", key);
jsonRead(json, "value", value);
SerialPrint("i", F("=>WS"), "Msg from module, id: " + id);
for (std::list<IoTItem*>::iterator it = IoTItems.begin();
it != IoTItems.end(); ++it) {
if ((*it)->getID() == id) {
(*it)->onModuleOrder(key, value);
}
} }
} }
}
} break; //----------------------------------------------------------------------//
// Страница веб интерфейса configutation
//----------------------------------------------------------------------//
case WStype_BIN: { // отвечаем данными на запрос страницы
Serial.printf("[%u] get binary length: %u\n", num, length); if (headerStr == "/config|") {
// hexdump(payload, length); sendFileToWsByFrames("/items.json", "itemsj", "", num, WEB_SOCKETS_FRAME_SIZE);
// standWebSocket.sendBIN(num, payload, length); sendFileToWsByFrames("/widgets.json", "widget", "", num, WEB_SOCKETS_FRAME_SIZE);
} break; sendFileToWsByFrames("/config.json", "config", "", num, WEB_SOCKETS_FRAME_SIZE);
sendFileToWsByFrames("/scenario.txt", "scenar", "", num, WEB_SOCKETS_FRAME_SIZE);
sendStringToWs("settin", settingsFlashJson, num);
}
case WStype_FRAGMENT_TEXT_START: { // обработка кнопки сохранить
Serial.printf("[%u] fragment test start: %u\n", num, length); if (headerStr == "/gifnoc|") {
} break; writeFileUint8tByFrames("config.json", payload, length, headerLenth,
256);
}
if (headerStr == "/tuoyal|") {
writeFileUint8tByFrames("layout.json", payload, length, headerLenth,
256);
}
if (headerStr == "/oiranecs|") {
writeFileUint8tByFrames("scenario.txt", payload, length, headerLenth,
256);
clearConfigure();
configure("/config.json");
iotScen.loadScenario("/scenario.txt");
// создаем событие завершения конфигурирования для возможности
// выполнения блока кода при загрузке
createItemFromNet("onStart", "1", 1);
}
case WStype_FRAGMENT_BIN_START: { //----------------------------------------------------------------------//
Serial.printf("[%u] fragment bin start: %u\n", num, length); // Страница веб интерфейса connection
} break; //----------------------------------------------------------------------//
case WStype_FRAGMENT: { // отвечаем данными на запрос страницы
Serial.printf("[%u] fragment: %u\n", num, length); if (headerStr == "/connection|") {
} break; sendFileToWsByFrames("/widgets.json", "widget", "", num, WEB_SOCKETS_FRAME_SIZE);
sendFileToWsByFrames("/config.json", "config", "", num, WEB_SOCKETS_FRAME_SIZE);
sendStringToWs("settin", settingsFlashJson, num);
sendStringToWs("ssidli", ssidListHeapJson, num);
sendStringToWs("errors", errorsHeapJson, num);
// запуск асинхронного сканирования wifi сетей при переходе на страницу
// соединений RouterFind(jsonReadStr(settingsFlashJson,
// F("routerssid")));
}
case WStype_FRAGMENT_FIN: { // обработка кнопки сохранить settings.json
Serial.printf("[%u] fragment finish: %u\n", num, length); if (headerStr == "/sgnittes|") {
} break; writeUint8tToString(payload, length, headerLenth, settingsFlashJson);
writeFileUint8tByFrames("settings.json", payload, length, headerLenth, 256);
sendStringToWs("errors", errorsHeapJson, num);
// если не было создано приема данных по udp - то создадим его
addThisDeviceToList();
}
case WStype_PING: { // обработка кнопки сохранить настройки mqtt
Serial.printf("[%u] ping: %u\n", num, length); if (headerStr == "/mqtt|") {
} break; sendStringToWs("settin", settingsFlashJson,
num); // отправляем в ответ новые полученные настройки
handleMqttStatus(false, 8); // меняем статус на неопределенный
mqttReconnect(); // начинаем переподключение
sendStringToWs("errors", errorsHeapJson,
num); // отправляем что статус неопределен
sendStringToWs("ssidli", ssidListHeapJson, num);
}
case WStype_PONG: { // запуск асинхронного сканирования wifi сетей при нажатии выпадающего
Serial.printf("[%u] pong: %u\n", num, length); // списка
} break; if (headerStr == "/scan|") {
std::vector<String> jArray;
jsonReadArray(settingsFlashJson, "routerssid", jArray);
RouterFind(jArray);
sendStringToWs("ssidli", ssidListHeapJson, num);
}
default: { //----------------------------------------------------------------------//
Serial.printf("[%u] not recognized: %u\n", num, length); // Страница веб интерфейса list
} break; //----------------------------------------------------------------------//
// отвечаем данными на запрос страницы list
if (headerStr == "/list|") {
sendStringToWs("settin", settingsFlashJson, num);
// отправим список устройств в зависимости от того что выбрал user
// sendDeviceList(num);
}
// отвечаем на запрос списка устройств (это отдельный запрос который
// делает приложение при подключении)
if (headerStr == "/devlist|") {
// отправим список устройств в зависимости от того что выбрал user
sendDeviceList(num);
}
// сохраняем данные листа
if (headerStr == "/tsil|") {
writeFileUint8tByFrames("devlist.json", payload, length, headerLenth,
256);
}
//----------------------------------------------------------------------//
// Страница веб интерфейса system
//----------------------------------------------------------------------//
// отвечаем данными на запрос страницы
if (headerStr == "/system|") {
sendStringToWs("errors", errorsHeapJson, num);
sendStringToWs("settin", settingsFlashJson, num);
}
//----------------------------------------------------------------------//
// Страница веб интерфейса dev
//----------------------------------------------------------------------//
if (headerStr == "/dev|") {
sendStringToWs("errors", errorsHeapJson, num);
sendStringToWs("settin", settingsFlashJson, num);
sendFileToWsByFrames("/config.json", "config", "", num, WEB_SOCKETS_FRAME_SIZE);
sendFileToWsByFrames("/items.json", "itemsj", "", num, WEB_SOCKETS_FRAME_SIZE);
// sendFileToWsByFrames("/layout.json", "layout", "", num,
// WEB_SOCKETS_FRAME_SIZE);
}
//----------------------------------------------------------------------//
// Страница веб интерфейса update
//----------------------------------------------------------------------//
if (headerStr == "/profile|") {
sendFileToWsByFrames("/myProfile.json", "prfile", "", num,
WEB_SOCKETS_FRAME_SIZE);
}
//----------------------------------------------------------------------//
// отдельные команды веб интерфейса
//----------------------------------------------------------------------//
// переписать любое поле в errors json
if (headerStr == "/rorre|") {
writeUint8tValueToJsonString(payload, length, headerLenth, errorsHeapJson);
}
// команда перезагрузки esp
if (headerStr == "/reboot|") {
ESP.restart();
}
// команда очистки всех логов esp
if (headerStr == "/clean|") {
cleanLogs();
}
// команда обновления прошивки esp
if (headerStr == "/update|") {
String path;
writeUint8tToString(payload, length, headerLenth, path);
upgrade_firmware(3, path);
}
// Прием команд control c dashboard
if (headerStr == "/control|") {
String msg;
writeUint8tToString(payload, length, headerLenth, msg);
String key = selectFromMarkerToMarker(msg, "/", 0);
String value = selectFromMarkerToMarker(msg, "/", 1);
generateOrder(key, value);
SerialPrint("i", F("=>WS"), "Msg from svelte web, WS No: " + String(num) + ", msg: " + msg);
}
if (headerStr == "/tst|") {
standWebSocket.sendTXT(num, "/tstr|");
}
// получаем команду посланную из модуля
if (headerStr == "/order|") {
String json;
writeUint8tToString(payload, length, headerLenth, json);
String id, key, value;
jsonRead(json, "id", id);
jsonRead(json, "key", key);
jsonRead(json, "value", value);
SerialPrint("i", F("=>WS"), "Msg from module, id: " + id);
for (std::list<IoTItem*>::iterator it = IoTItems.begin();
it != IoTItems.end(); ++it) {
if ((*it)->getID() == id) {
(*it)->onModuleOrder(key, value);
}
}
}
} break;
case WStype_BIN: {
Serial.printf("[%u] get binary length: %u\n", num, length);
// hexdump(payload, length);
// standWebSocket.sendBIN(num, payload, length);
} break;
case WStype_FRAGMENT_TEXT_START: {
Serial.printf("[%u] fragment test start: %u\n", num, length);
} break;
case WStype_FRAGMENT_BIN_START: {
Serial.printf("[%u] fragment bin start: %u\n", num, length);
} break;
case WStype_FRAGMENT: {
Serial.printf("[%u] fragment: %u\n", num, length);
} break;
case WStype_FRAGMENT_FIN: {
Serial.printf("[%u] fragment finish: %u\n", num, length);
} break;
case WStype_PING: {
Serial.printf("[%u] ping: %u\n", num, length);
} break;
case WStype_PONG: {
Serial.printf("[%u] pong: %u\n", num, length);
} break;
default: {
Serial.printf("[%u] not recognized: %u\n", num, length);
} break;
} }
} }
// публикация статус сообщений в ws (недостаток в том что делаем бродкаст всем // публикация статус сообщений в ws (недостаток в том что делаем бродкаст всем
// клиентам поднятым в свелте!!!) // клиентам поднятым в свелте!!!)
void publishStatusWs(const String& topic, const String& data) { void publishStatusWs(const String& topic, const String& data)
{
String path = mqttRootDevice + "/" + topic; String path = mqttRootDevice + "/" + topic;
String json = "{}"; String json = "{}";
jsonWriteStr(json, "status", data); jsonWriteStr(json, "status", data);
@@ -339,7 +344,8 @@ void publishStatusWs(const String& topic, const String& data) {
} }
// публикация дополнительных json сообщений в ws // публикация дополнительных json сообщений в ws
void publishJsonWs(const String& topic, String& json) { void publishJsonWs(const String& topic, String& json)
{
String path = mqttRootDevice + "/" + topic; String path = mqttRootDevice + "/" + topic;
jsonWriteStr(json, "topic", path); jsonWriteStr(json, "topic", path);
// TO DO отправка полей в веб // TO DO отправка полей в веб
@@ -347,7 +353,8 @@ void publishJsonWs(const String& topic, String& json) {
} }
// данные которые мы отправляем в сокеты переодически // данные которые мы отправляем в сокеты переодически
void periodicWsSend() { void periodicWsSend()
{
sendStringToWs("ssidli", ssidListHeapJson, -1); sendStringToWs("ssidli", ssidListHeapJson, -1);
sendStringToWs("errors", errorsHeapJson, -1); sendStringToWs("errors", errorsHeapJson, -1);
// отправляем переодичестки только в авто режиме // отправляем переодичестки только в авто режиме
@@ -357,10 +364,11 @@ void periodicWsSend() {
} }
#ifdef ESP32 #ifdef ESP32
void hexdump(const void* mem, uint32_t len, uint8_t cols = 16) { void hexdump(const void* mem, uint32_t len, uint8_t cols = 16)
{
const uint8_t* src = (const uint8_t*)mem; const uint8_t* src = (const uint8_t*)mem;
Serial.printf("\n[HEXDUMP] Address: 0x%08X len: 0x%X (%d)", (ptrdiff_t)src, Serial.printf("\n[HEXDUMP] Address: 0x%08X len: 0x%X (%d)", (ptrdiff_t)src,
len, len); len, len);
for (uint32_t i = 0; i < len; i++) { for (uint32_t i = 0; i < len; i++) {
if (i % cols == 0) { if (i % cols == 0) {
Serial.printf("\n[0x%08X] 0x%08X: ", (ptrdiff_t)src, i); Serial.printf("\n[0x%08X] 0x%08X: ", (ptrdiff_t)src, i);
@@ -374,7 +382,8 @@ void hexdump(const void* mem, uint32_t len, uint8_t cols = 16) {
#endif #endif
void sendFileToWsByFrames(const String& filename, const String& header, void sendFileToWsByFrames(const String& filename, const String& header,
const String& json, int client_id, size_t frameSize) { const String& json, int client_id, size_t frameSize)
{
if (header.length() != 6) { if (header.length() != 6) {
SerialPrint("E", "FS", F("wrong header size")); SerialPrint("E", "FS", F("wrong header size"));
return; return;
@@ -447,7 +456,8 @@ void sendFileToWsByFrames(const String& filename, const String& header,
file.close(); file.close();
} }
void sendStringToWs(const String& header, String& payload, int client_id) { void sendStringToWs(const String& header, String& payload, int client_id)
{
if ((!getNumAPClients() && !isNetworkActive()) || !getNumWSClients()) { if ((!getNumAPClients() && !isNetworkActive()) || !getNumWSClients()) {
// standWebSocket.disconnect(); // это и ниже надо сделать при - // standWebSocket.disconnect(); // это и ниже надо сделать при -
// standWebSocket.close(); // - отключении AP И WiFi(STA), надо менять ядро WiFi. Сейчас не закрывается сессия клиента при пропаже AP И WiFi(STA) // standWebSocket.close(); // - отключении AP И WiFi(STA), надо менять ядро WiFi. Сейчас не закрывается сессия клиента при пропаже AP И WiFi(STA)
@@ -471,7 +481,8 @@ void sendStringToWs(const String& header, String& payload, int client_id) {
} }
} }
void sendDeviceList(uint8_t num) { void sendDeviceList(uint8_t num)
{
if (jsonReadInt(settingsFlashJson, F("udps")) != 0) { if (jsonReadInt(settingsFlashJson, F("udps")) != 0) {
// если включен автопоиск то отдаем список из оперативной памяти // если включен автопоиск то отдаем список из оперативной памяти
SerialPrint("i", "FS", "heap list"); SerialPrint("i", "FS", "heap list");
@@ -479,11 +490,12 @@ void sendDeviceList(uint8_t num) {
} else { } else {
// если выключен автопоиск то отдаем список из флешь памяти // если выключен автопоиск то отдаем список из флешь памяти
sendFileToWsByFrames("/devlist.json", "devlis", "", num, sendFileToWsByFrames("/devlist.json", "devlis", "", num,
WEB_SOCKETS_FRAME_SIZE); WEB_SOCKETS_FRAME_SIZE);
SerialPrint("i", "FS", "flash list"); SerialPrint("i", "FS", "flash list");
} }
} }
int getNumWSClients() { int getNumWSClients()
{
return standWebSocket.connectedClients(false); return standWebSocket.connectedClients(false);
} }