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

много изменений

Browse Source
This commit is contained in:
Dmitry Borisenko
2021-12-21 19:01:43 +01:00
parent a5d2650507
commit b0b8203fec
9 changed files with 137 additions and 119 deletions
Download Patch File Download Diff File Expand all files Collapse all files

198
src/WebSocket.cpp
View File

@@ -1,11 +1,12 @@
#include "WebSocket.h"
#include "ArduinoJson.h"
#include "Class/CircularBuffer.h"
#include "Class/NotAsync.h"
#include "Class/TCircularBuffer.h"
#include "Global.h"
void wsInit() {
myWsBuffer = new TCircularBuffer<char*, 20480>;
// myNotAsyncActions->add(
// do_webSocketSendSetup, [&](void*) {
// delay(100);
@@ -24,104 +25,111 @@ void wsPublishData(String topic, String data) {
}
//отправка setup массива в sockets способом через буфер string, рабочий способ но буфер стринг - плохой метод
void wsSendSetup() {
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 loopWsExecute() {
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 wsSendSetup2() {
// myWsBuffer = new CircularBuffer<char*, 20480>;
// 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);
// char* element = "";
// serializeJson(doc, (char*)element, 1024);
// Serial.println(element);
// myWsBuffer->push(element);
//
//} while (file.findUntil(",", "]"));
// SerialPrint("I", F("WS"), F("completed send config"));
}
//отправка setup массива в sockets способом через кольцевой буфер char
// void wsSendSetup() {
// 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);
// char* element;
// char* element = new char[1024];
// serializeJson(doc, (char*)element, 1024);
// Serial.println(element);
//
// } while (file.findUntil(",", "]"));
// SerialPrint("I", F("WS"), F("completed send config"));
//
// char* itemsend = "element";
// myWsBuffer->push(itemsend);
//
// char* item;
// while (myWsBuffer->pop(item)) {
// Serial.println(item);
// }
//}
void loopWsExecute2() {
// char* item;
// if (myWsBuffer->pop(item)) {
// Serial.println(item);
// }
}
// void loopWsExecute() {
// char* item;
// if (myWsBuffer->pop(item)) {
// Serial.println(item);
// }
// }
//отправка setup массива в sockets способом прямой загрузки в ws buffer
void wsSendSetupBuffer() {
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);
size_t len = measureJson(doc);
AsyncWebSocketMessageBuffer* buffer = ws.makeBuffer(len);
if (buffer) {
serializeJson(doc, (char*)buffer->get(), len);
if (ws.enabled()) {
if (ws.availableForWriteAll()) {
ws.textAll(buffer);
}
}
}
// Serial.println(doc.as<String>());
} while (file.findUntil(",", "]"));
SerialPrint("I", F("WS"), F("completed send config"));
}
// void wsSendSetupBuffer() {
// 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);
// size_t len = measureJson(doc);
// AsyncWebSocketMessageBuffer* buffer = ws.makeBuffer(len);
// if (buffer) {
// serializeJson(doc, (char*)buffer->get(), len);
// if (ws.enabled()) {
// if (ws.availableForWriteAll()) {
// ws.textAll(buffer);
// }
// }
// }
// // Serial.println(doc.as<String>());
// } while (file.findUntil(",", "]"));
// SerialPrint("I", F("WS"), F("completed send config"));
//}
//Пример прямого доступа к web socket buffer переделанный для arduino json 6
void sendDataWs() {
DynamicJsonDocument doc(1024);
doc["a"] = "abc";
doc["b"] = "abcd";
doc["c"] = "abcde";
doc["d"] = "abcdef";
doc["e"] = "abcdefg";
size_t len = measureJson(doc);
AsyncWebSocketMessageBuffer* buffer = ws.makeBuffer(len);
if (buffer) {
serializeJson(doc, (char*)buffer->get(), len);
ws.textAll(buffer);
}
}
// void sendDataWs() {
// DynamicJsonDocument doc(1024);
// doc["a"] = "abc";
// doc["b"] = "abcd";
// doc["c"] = "abcde";
// doc["d"] = "abcdef";
// doc["e"] = "abcdefg";
// size_t len = measureJson(doc);
// AsyncWebSocketMessageBuffer* buffer = ws.makeBuffer(len);
// if (buffer) {
// serializeJson(doc, (char*)buffer->get(), len);
// ws.textAll(buffer);
// }
//}