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

не рабочая версия

Browse Source
This commit is contained in:
Dmitry Borisenko
2022-08-23 13:06:01 +02:00
parent f7849894e5
commit 99e2fcfcb8
5 changed files with 808 additions and 750 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
data_svelte/scenario.json Normal file
View File

@@ -0,0 +1,3 @@
{
"scen": ""
}

2
src/Main.cpp
View File

@@ -63,7 +63,7 @@ void setup() {
asyncUdpInit();
//загрузка сценария
iotScen.loadScenario("/scenario.txt");
iotScen.loadScenario("/scenario.json");
// создаем событие завершения конфигурирования для возможности выполнения блока кода при загрузке
IoTItems.push_back((IoTItem *)new externalVariable("{\"id\":\"onStart\",\"val\":1,\"int\":60}"));
generateEvent("onStart", "");

14
src/WsServer.cpp
View File

@@ -63,7 +63,7 @@ void webSocketEvent(uint8_t num, WStype_t type, uint8_t* payload, size_t length)
sendFileToWs("/items.json", num, 1024);
sendFileToWs("/widgets.json", num, 1024);
sendFileToWs("/config.json", num, 1024);
sendFileToWs("/scenario.txt", num, 1024);
sendFileToWs("/scenario.json", num, 1024);
standWebSocket.sendTXT(num, settingsFlashJson);
}
//**сохранение**//
@@ -73,7 +73,7 @@ void webSocketEvent(uint8_t num, WStype_t type, uint8_t* payload, size_t length)
clearConfigure();
Serial.println("Start config");
configure("/config.json");
iotScen.loadScenario("/scenario.txt");
iotScen.loadScenario("/scenario.json");
}
//**сохранение**//
if (headerStr == "/tuoyal|") {
@@ -81,13 +81,9 @@ void webSocketEvent(uint8_t num, WStype_t type, uint8_t* payload, size_t length)
}
//**сохранение**//
if (headerStr == "/oiranecs|") {
if (length - headerLenth == 0) {
SerialPrint("i", "WS", "Scenario file empty");
writeFile("/scenario.txt", "");
} else {
writeFileUint8tByFrames("scenario.txt", payload, length, headerLenth, 256);
iotScen.loadScenario("/scenario.txt");
}
writeFileUint8tByFrames("scenario.json", payload, length, headerLenth, 256);
iotScen.loadScenario("/scenario.json");
// создаем событие завершения конфигурирования для возможности выполнения блока кода при загрузке
IoTItems.push_back((IoTItem*)new externalVariable("{\"id\":\"onStart\",\"val\":1,\"int\":60}"));
generateEvent("onStart", "");

195
src/classes/IoTScenario.cpp
View File

@@ -9,23 +9,28 @@
bool isIotScenException; // признак исключения и попытки прекратить выполнение сценария заранее
// Лексический анализатор возвращает токены [0-255], если это неизвестны,
// иначе одну из известных единиц кода
enum Token {
tok_eof = -1,
// операнды (первичные выражения: идентификаторы, числа)
tok_identifier = -4, tok_number = -5, tok_string = -3,
tok_identifier = -4,
tok_number = -5,
tok_string = -3,
// двухсимвольные операторы бинарных операций
tok_equal = -2, tok_notequal = -9, tok_lesseq = -10, tok_greateq = -11,
tok_equal = -2,
tok_notequal = -9,
tok_lesseq = -10,
tok_greateq = -11,
// управление
tok_if = -6, tok_then = -7, tok_else = -8
tok_if = -6,
tok_then = -7,
tok_else = -8
};
//===----------------------------------------------------------------------===//
// Abstract Syntax Tree (Абстрактное Синтаксическое Дерево или Дерево Парсинга)
//===----------------------------------------------------------------------===//
@@ -40,6 +45,7 @@ bool ExprAST::hasEventIdName(String eventIdName) {return false;} // по умо
/// NumberExprAST - Класс узла выражения для числовых литералов (Например, "1.0").
class NumberExprAST : public ExprAST {
IoTValue Val;
public:
NumberExprAST(float val) { Val.valD = val; }
@@ -53,8 +59,12 @@ public:
/// StringExprAST - Класс узла выражения для строковых литералов (Например, "Example with spaces and quotes").
class StringExprAST : public ExprAST {
IoTValue Val;
public:
StringExprAST(String val) { Val.isDecimal = false; Val.valS = val;}
StringExprAST(String val) {
Val.isDecimal = false;
Val.valS = val;
}
IoTValue *exec() {
if (isIotScenException) return nullptr;
@@ -76,8 +86,10 @@ public:
int setValue(IoTValue *val) {
if (!ItemIsLocal) Item = findIoTItem(Name);
if (Item) Item->setValue(*val);
else return 0;
if (Item)
Item->setValue(*val);
else
return 0;
return 1;
}
@@ -117,11 +129,16 @@ public:
if (isIotScenException) return nullptr;
String printStr = "";
if (Op == tok_equal) printStr = "==";
else if (Op == tok_notequal) printStr = "!=";
else if (Op == tok_lesseq) printStr = "<=";
else if (Op == tok_greateq) printStr = ">=";
else printStr = printStr + (char)Op;
if (Op == tok_equal)
printStr = "==";
else if (Op == tok_notequal)
printStr = "!=";
else if (Op == tok_lesseq)
printStr = "<=";
else if (Op == tok_greateq)
printStr = ">=";
else
printStr = printStr + (char)Op;
// Serial.printf("Call from BinaryExprAST: %s\n", printStr.c_str());
@@ -167,8 +184,10 @@ public:
val.valD = lhs->valD * rhs->valD;
break;
case '/':
if (rhs->valD != 0) val.valD = lhs->valD / rhs->valD;
else val.valD = 3.4E+38;
if (rhs->valD != 0)
val.valD = lhs->valD / rhs->valD;
else
val.valD = 3.4E+38;
break;
case '|':
@@ -185,8 +204,14 @@ public:
}
if (!lhs->isDecimal || !rhs->isDecimal) {
if (lhs->isDecimal) lhsStr = lhs->valD; else lhsStr = lhs->valS;
if (rhs->isDecimal) rhsStr = rhs->valD; else rhsStr = rhs->valS;
if (lhs->isDecimal)
lhsStr = lhs->valD;
else
lhsStr = lhs->valS;
if (rhs->isDecimal)
rhsStr = rhs->valD;
else
rhsStr = rhs->valS;
switch (Op) {
case tok_equal:
val.valD = compStr(lhsStr, rhsStr);
@@ -216,7 +241,6 @@ public:
return true; // str1 == str2;
}
};
/// CallExprAST - Класс узла выражения для вызова команды.
@@ -239,8 +263,10 @@ public:
if (Cmd == "exit" || Callee == "exit") { // если системная команда, то выполняем и выходим
IoTValue *tmp;
if (Args.size() > 0 && Args[0]) tmp = Args[0]->exec();
else SerialPrint("i", "SysExt", "Exit");
if (Args.size() > 0 && Args[0])
tmp = Args[0]->exec();
else
SerialPrint("i", "SysExt", "Exit");
if (tmp) SerialPrint("i", "SysExt", "Exit = '" + tmp->valS + "'");
isIotScenException = true;
@@ -255,8 +281,10 @@ public:
for (unsigned int i = 0; i < Args.size(); i++) {
if (Args[i] == nullptr) return nullptr;
IoTValue *tmp = Args[i]->exec();
if (tmp != nullptr) ArgsAsIoTValue.push_back(*tmp);
else return nullptr; //ArgsAsIoTValue.push_back(zeroIotVal);
if (tmp != nullptr)
ArgsAsIoTValue.push_back(*tmp);
else
return nullptr; // ArgsAsIoTValue.push_back(zeroIotVal);
}
ret = Item->execute(Cmd, ArgsAsIoTValue); // вызываем команду из модуля напрямую с передачей всех аргументов
@@ -275,7 +303,6 @@ public:
}
};
// Для сокращения количества преобразований используем числовые коды для фиксации названия системной функции,
// которые поддерживает прошивка
enum SysOp {
@@ -402,23 +429,41 @@ class SysCallExprAST : public ExprAST {
public:
SysCallExprAST(const String &callee, std::vector<ExprAST *> &args)
: Callee(callee), Args(args) {
if (Callee == "reboot") operation = sysop_reboot; else
if (Callee == "digitalRead") operation = sysop_digitalRead; else
if (Callee == "analogRead") operation = sysop_analogRead; else
if (Callee == "digitalWrite") operation = sysop_digitalWrite; else
if (Callee == "digitalInvert") operation = sysop_digitalInvert; else
if (Callee == "deepSleep") operation = sysop_deepSleep; else
if (Callee == "getTime") operation = sysop_getTime; else
if (Callee == "getHours") operation = sysop_getHours; else
if (Callee == "getMinutes") operation = sysop_getMinutes; else
if (Callee == "getSeconds") operation = sysop_getSeconds; else
if (Callee == "getMonth") operation = sysop_getMonth; else
if (Callee == "getDay") operation = sysop_getDay; else
if (Callee == "getIP") operation = sysop_getIP; else
if (Callee == "mqttPub") operation = sysop_mqttPub; else
if (Callee == "gethhmm") operation = sysop_gethhmm; else
if (Callee == "gethhmmss") operation = sysop_gethhmmss; else
if (Callee == "getTime") operation = sysop_getTime; else
if (Callee == "reboot")
operation = sysop_reboot;
else if (Callee == "digitalRead")
operation = sysop_digitalRead;
else if (Callee == "analogRead")
operation = sysop_analogRead;
else if (Callee == "digitalWrite")
operation = sysop_digitalWrite;
else if (Callee == "digitalInvert")
operation = sysop_digitalInvert;
else if (Callee == "deepSleep")
operation = sysop_deepSleep;
else if (Callee == "getTime")
operation = sysop_getTime;
else if (Callee == "getHours")
operation = sysop_getHours;
else if (Callee == "getMinutes")
operation = sysop_getMinutes;
else if (Callee == "getSeconds")
operation = sysop_getSeconds;
else if (Callee == "getMonth")
operation = sysop_getMonth;
else if (Callee == "getDay")
operation = sysop_getDay;
else if (Callee == "getIP")
operation = sysop_getIP;
else if (Callee == "mqttPub")
operation = sysop_mqttPub;
else if (Callee == "gethhmm")
operation = sysop_gethhmm;
else if (Callee == "gethhmmss")
operation = sysop_gethhmmss;
else if (Callee == "getTime")
operation = sysop_getTime;
else
operation = sysop_notfound;
}
@@ -432,8 +477,10 @@ public:
for (unsigned int i = 0; i < Args.size(); i++) {
if (Args[i] == nullptr) return nullptr;
IoTValue *tmp = Args[i]->exec();
if (tmp != nullptr) ArgsAsIoTValue.push_back(*tmp);
else return nullptr;
if (tmp != nullptr)
ArgsAsIoTValue.push_back(*tmp);
else
return nullptr;
}
ret = sysExecute(operation, ArgsAsIoTValue); // вызываем функцию интерпретатор с передачей всех аргументов
@@ -460,7 +507,8 @@ public:
: Cond(cond), Then(then), Else(_else) {
if (IDNames) {
_IDNames = *IDNames;
} else _IDNames = "";
} else
_IDNames = "";
}
bool hasEventIdName(String eventIdName) {
@@ -534,12 +582,10 @@ public:
}
};
//===----------------------------------------------------------------------===//
// Lexer (Лексический анализатор)
//===----------------------------------------------------------------------===//
char IoTScenario::getLastChar() {
strIterator++;
return strFromFile->charAt(strIterator - 1);
@@ -547,7 +593,6 @@ public:
/// gettok - Возвращает следующий токен из стандартного потока ввода.
int IoTScenario::gettok() {
// Пропускаем пробелы.
while (isspace(LastChar))
LastChar = getLastChar();
@@ -607,7 +652,8 @@ public:
if (LastChar == '=') {
LastChar = getLastChar();
return tok_equal;
} else return '=';
} else
return '=';
}
if (LastChar == '!') {
@@ -615,7 +661,8 @@ public:
if (LastChar == '=') {
LastChar = getLastChar();
return tok_notequal;
} else return '!';
} else
return '!';
}
if (LastChar == '<') {
@@ -623,7 +670,8 @@ public:
if (LastChar == '=') {
LastChar = getLastChar();
return tok_lesseq;
} else return '<';
} else
return '<';
}
if (LastChar == '>') {
@@ -631,7 +679,8 @@ public:
if (LastChar == '=') {
LastChar = getLastChar();
return tok_greateq;
} else return '>';
} else
return '>';
}
// В противном случае просто возвращаем символ как значение ASCII
@@ -640,12 +689,10 @@ public:
return ThisChar;
}
//===----------------------------------------------------------------------===//
// Parser (Парсер или Синтаксический Анализатор)
//===----------------------------------------------------------------------===//
/// CurTok/getNextToken - Предоставляет простой буфер токенов. CurTok - это текущий
/// токен, просматриваемый парсером. getNextToken получает следующий токен от
/// лексического анализатора и обновляет CurTok.
@@ -665,8 +712,10 @@ public:
}
/// Error* - Это небольшие вспомогательные функции для обработки ошибок.
ExprAST* IoTScenario::Error(const char *Str) { Serial.printf("Error: %s\n", Str); return nullptr;}
ExprAST *IoTScenario::Error(const char *Str) {
Serial.printf("Error: %s\n", Str);
return nullptr;
}
/// identifierexpr
/// ::= identifier
@@ -716,7 +765,6 @@ public:
return new SysCallExprAST(IdName, Args); // создаем объект запуска системной функции
else
return new CallExprAST(IdName, Cmd, Args, tmpItem); // создаем объект запуска функции в любом случае даж если не нашли Item
}
/// numberexpr ::= number
@@ -751,11 +799,12 @@ public:
if (CurTok != ';')
return Error("Expected ';' in operation list");
int ttok = getNextToken();
if (!ttok) { Error("Expected '}'"); break; }
if (!ttok) {
Error("Expected '}'");
break;
}
if (CurTok == '}') break;
}
}
@@ -803,7 +852,8 @@ public:
/// ::= parenexpr
ExprAST *IoTScenario::ParsePrimary(String *IDNames) {
switch (CurTok) {
default: return Error("unknown token when expecting an expression");
default:
return Error("unknown token when expecting an expression");
case tok_identifier: {
if (IDNames) {
String tmpstr = *IDNames;
@@ -811,11 +861,16 @@ public:
}
return ParseIdentifierExpr(IDNames);
}
case tok_number: return ParseNumberExpr();
case '(': return ParseParenExpr();
case '{': return ParseBracketsExpr();
case tok_string: return ParseQuotesExpr();
case tok_if: return ParseIfExpr(IDNames);
case tok_number:
return ParseNumberExpr();
case '(':
return ParseParenExpr();
case '{':
return ParseBracketsExpr();
case tok_string:
return ParseQuotesExpr();
case tok_if:
return ParseIfExpr(IDNames);
}
}
@@ -852,7 +907,6 @@ public:
}
}
/// expression
/// ::= primary binoprhs
///
@@ -877,6 +931,8 @@ public:
if (myfile.available()) {
strFromFile = new String("");
*strFromFile = myfile.readString();
Serial.println(*strFromFile);
jsonRead(*strFromFile, "scen", *strFromFile, true);
myfile.close();
getNextToken();
@@ -891,12 +947,16 @@ public:
// Serial.printf("vvvvvvvvvvvvvvvv %s", IDNames.c_str());
break;
}
default: getNextToken(); break;
default:
getNextToken();
break;
}
}
delete strFromFile;
strIterator = 0;
} else {Error("Open file scenario error");}
} else {
Error("Open file scenario error");
}
}
void IoTScenario::ExecScenario(String eventIdName) { // запускаем поочереди все корневые элементы выражений в сценарии, ожидаемо - это IFы
@@ -910,7 +970,6 @@ public:
}
}
IoTScenario::IoTScenario() {
// Задаём стандартные бинарные операторы.
// 1 - наименьший приоритет.