mirror of
https://github.com/rstrouse/ESPSomfy-RTS.git
synced 2025-12-13 11:02:12 +01:00
71e5b8a648
Added api services to support blind definitions in Home Assistant. Stop tilt function when my button is pressed and the tilt operation is in progress. Bump to v1.3.2
1380 lines
54 KiB
C++
1380 lines
54 KiB
C++
#include <Arduino.h>
|
|
#include <WiFi.h>
|
|
#include <WebServer.h>
|
|
#include <LittleFS.h>
|
|
#include <Update.h>
|
|
#include "ConfigSettings.h"
|
|
#include "Web.h"
|
|
#include "Utils.h"
|
|
#include "SSDP.h"
|
|
#include "Somfy.h"
|
|
|
|
extern ConfigSettings settings;
|
|
extern SSDPClass SSDP;
|
|
extern rebootDelay_t rebootDelay;
|
|
extern SomfyShadeController somfy;
|
|
extern Web webServer;
|
|
|
|
#define WEB_MAX_RESPONSE 16384
|
|
static char g_content[WEB_MAX_RESPONSE];
|
|
|
|
// General responses
|
|
static const char _response_404[] = "404: Service Not Found";
|
|
|
|
// Encodings
|
|
static const char _encoding_text[] = "text/plain";
|
|
static const char _encoding_html[] = "text/html";
|
|
static const char _encoding_json[] = "application/json";
|
|
|
|
WebServer apiServer(8081);
|
|
WebServer server(80);
|
|
void Web::startup() {
|
|
Serial.println("Launching web server...");
|
|
}
|
|
void Web::loop() {
|
|
apiServer.handleClient();
|
|
server.handleClient();
|
|
}
|
|
void Web::sendCORSHeaders() {
|
|
//server.sendHeader(F("Access-Control-Allow-Origin"), F("*"));
|
|
//server.sendHeader(F("Access-Control-Max-Age"), F("600"));
|
|
//server.sendHeader(F("Access-Control-Allow-Methods"), F("PUT,POST,GET,OPTIONS"));
|
|
//server.sendHeader(F("Access-Control-Allow-Headers"), F("*"));
|
|
}
|
|
void Web::sendCacheHeaders(uint32_t seconds) {
|
|
server.sendHeader(F("Cache-Control"), F("public, max-age=604800, immutable"));
|
|
}
|
|
void Web::end() {
|
|
//server.end();
|
|
}
|
|
void Web::begin() {
|
|
Serial.println("Creating Web MicroServices...");
|
|
server.enableCORS(true);
|
|
apiServer.enableCORS(true);
|
|
apiServer.on("/discovery", []() {
|
|
HTTPMethod method = apiServer.method();
|
|
if (method == HTTP_POST || method == HTTP_GET) {
|
|
Serial.println("Discovery Requested");
|
|
DynamicJsonDocument doc(16384);
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
obj["serverId"] = settings.serverId;
|
|
obj["version"] = settings.fwVersion;
|
|
obj["model"] = "ESPSomfyRTS";
|
|
JsonArray arr = obj.createNestedArray("shades");
|
|
somfy.toJSON(arr);
|
|
serializeJson(doc, g_content);
|
|
apiServer.send(200, _encoding_json, g_content);
|
|
}
|
|
apiServer.send(500, _encoding_text, "Invalid http method");
|
|
});
|
|
apiServer.on("/shades", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = apiServer.method();
|
|
if (method == HTTP_POST || method == HTTP_GET) {
|
|
DynamicJsonDocument doc(16384);
|
|
JsonArray arr = doc.to<JsonArray>();
|
|
somfy.toJSON(arr);
|
|
serializeJson(doc, g_content);
|
|
apiServer.send(200, _encoding_json, g_content);
|
|
}
|
|
else apiServer.send(404, _encoding_text, _response_404);
|
|
});
|
|
apiServer.onNotFound([]() {
|
|
Serial.print("Request 404:");
|
|
HTTPMethod method = apiServer.method();
|
|
switch (method) {
|
|
case HTTP_POST:
|
|
Serial.print("POST ");
|
|
break;
|
|
case HTTP_GET:
|
|
Serial.print("GET ");
|
|
break;
|
|
case HTTP_PUT:
|
|
Serial.print("PUT ");
|
|
break;
|
|
default:
|
|
Serial.print("[");
|
|
Serial.print(method);
|
|
Serial.print("]");
|
|
break;
|
|
|
|
}
|
|
snprintf(g_content, sizeof(g_content), "404 Service Not Found: %s", apiServer.uri().c_str());
|
|
apiServer.send(404, _encoding_text, g_content);
|
|
});
|
|
apiServer.on("/controller", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = apiServer.method();
|
|
if (method == HTTP_POST || method == HTTP_GET) {
|
|
DynamicJsonDocument doc(16384);
|
|
somfy.toJSON(doc);
|
|
serializeJson(doc, g_content);
|
|
apiServer.send(200, _encoding_json, g_content);
|
|
}
|
|
else apiServer.send(404, _encoding_text, _response_404);
|
|
});
|
|
apiServer.on("/shadeCommand", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = apiServer.method();
|
|
uint8_t shadeId = 255;
|
|
uint8_t target = 255;
|
|
somfy_commands command = somfy_commands::My;
|
|
if (method == HTTP_GET || method == HTTP_PUT || method == HTTP_POST) {
|
|
if (apiServer.hasArg("shadeId")) {
|
|
shadeId = atoi(apiServer.arg("shadeId").c_str());
|
|
if (apiServer.hasArg("command")) command = translateSomfyCommand(apiServer.arg("command"));
|
|
else if(apiServer.hasArg("target")) target = atoi(apiServer.arg("target").c_str());
|
|
}
|
|
else if (apiServer.hasArg("plain")) {
|
|
Serial.println("Sending Shade Command");
|
|
DynamicJsonDocument doc(256);
|
|
DeserializationError err = deserializeJson(doc, apiServer.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
return;
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) shadeId = obj["shadeId"];
|
|
else apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade id was supplied.\"}"));
|
|
if (obj.containsKey("command")) {
|
|
String scmd = obj["command"];
|
|
command = translateSomfyCommand(scmd);
|
|
}
|
|
else if(obj.containsKey("target")) {
|
|
target = obj["target"].as<uint8_t>();
|
|
}
|
|
}
|
|
}
|
|
else apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade object supplied.\"}"));
|
|
}
|
|
SomfyShade* shade = somfy.getShadeById(shadeId);
|
|
if (shade) {
|
|
Serial.print("Received:");
|
|
Serial.println(apiServer.arg("plain"));
|
|
// Send the command to the shade.
|
|
if(target >= 0 && target <= 100)
|
|
shade->moveToTarget(target);
|
|
else
|
|
shade->sendCommand(command);
|
|
DynamicJsonDocument sdoc(256);
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
shade->toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
apiServer.send(200, _encoding_json, g_content);
|
|
}
|
|
else {
|
|
apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade with the specified id not found.\"}"));
|
|
}
|
|
});
|
|
apiServer.on("/tiltCommand", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = apiServer.method();
|
|
uint8_t shadeId = 255;
|
|
uint8_t target = 255;
|
|
somfy_commands command = somfy_commands::My;
|
|
if (method == HTTP_GET || method == HTTP_PUT || method == HTTP_POST) {
|
|
if (server.hasArg("shadeId")) {
|
|
shadeId = atoi(apiServer.arg("shadeId").c_str());
|
|
if (apiServer.hasArg("command")) command = translateSomfyCommand(apiServer.arg("command"));
|
|
else if(apiServer.hasArg("target")) target = atoi(apiServer.arg("target").c_str());
|
|
}
|
|
else if (apiServer.hasArg("plain")) {
|
|
Serial.println("Sending Shade Tilt Command");
|
|
DynamicJsonDocument doc(256);
|
|
DeserializationError err = deserializeJson(doc, apiServer.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
return;
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) shadeId = obj["shadeId"];
|
|
else apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade id was supplied.\"}"));
|
|
if (obj.containsKey("command")) {
|
|
String scmd = obj["command"];
|
|
command = translateSomfyCommand(scmd);
|
|
}
|
|
else if(obj.containsKey("target")) {
|
|
target = obj["target"].as<uint8_t>();
|
|
}
|
|
}
|
|
}
|
|
else apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade object supplied.\"}"));
|
|
}
|
|
SomfyShade* shade = somfy.getShadeById(shadeId);
|
|
if (shade) {
|
|
Serial.print("Received:");
|
|
Serial.println(apiServer.arg("plain"));
|
|
// Send the command to the shade.
|
|
if(target >= 0 && target <= 100)
|
|
shade->moveToTiltTarget(target);
|
|
else
|
|
shade->sendTiltCommand(command);
|
|
DynamicJsonDocument sdoc(256);
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
shade->toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
apiServer.send(200, _encoding_json, g_content);
|
|
}
|
|
else {
|
|
apiServer.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade with the specified id not found.\"}"));
|
|
}
|
|
});
|
|
|
|
server.on("/upnp.xml", []() {
|
|
SSDP.schema(server.client());
|
|
});
|
|
server.on("/", []() {
|
|
webServer.sendCacheHeaders(604800);
|
|
webServer.sendCORSHeaders();
|
|
int statusCode = 200;
|
|
// Load the index html page from the data directory.
|
|
Serial.println("Loading file index.html");
|
|
File file = LittleFS.open("/index.html", "r");
|
|
if (!file) {
|
|
Serial.println("Error opening data/index.html");
|
|
server.send(500, _encoding_html, "Unable to open data/index.html");
|
|
}
|
|
server.streamFile(file, _encoding_html);
|
|
file.close();
|
|
});
|
|
server.on("/configRadio", []() {
|
|
webServer.sendCORSHeaders();
|
|
// Load the index html page from the data directory.
|
|
Serial.println("Loading file configRadio.html");
|
|
File file = LittleFS.open("/configRadio.html", "r");
|
|
if (!file) {
|
|
Serial.println("Error opening configRadio.html");
|
|
server.send(500, _encoding_text, "configRadio.html");
|
|
}
|
|
server.streamFile(file, _encoding_html);
|
|
file.close();
|
|
});
|
|
server.on("/index.js", []() {
|
|
webServer.sendCacheHeaders(604800);
|
|
webServer.sendCORSHeaders();
|
|
// Load the index html page from the data directory.
|
|
Serial.println("Loading file index.js");
|
|
File file = LittleFS.open("/index.js", "r");
|
|
if (!file) {
|
|
Serial.println("Error opening data/index.js");
|
|
server.send(500, _encoding_text, "Unable to open data/index.js");
|
|
}
|
|
server.streamFile(file, "text/javascript");
|
|
file.close();
|
|
});
|
|
server.on("/main.css", []() {
|
|
webServer.sendCacheHeaders(604800);
|
|
webServer.sendCORSHeaders();
|
|
// Load the index html page from the data directory.
|
|
Serial.println("Loading file main.css");
|
|
File file = LittleFS.open("/main.css", "r");
|
|
if (!file) {
|
|
Serial.println("Error opening data/main.css");
|
|
server.send(500, _encoding_text, "Unable to open data/main.css");
|
|
}
|
|
server.streamFile(file, "text/css");
|
|
file.close();
|
|
});
|
|
server.on("/icons.css", []() {
|
|
webServer.sendCacheHeaders(604800);
|
|
webServer.sendCORSHeaders();
|
|
// Load the index html page from the data directory.
|
|
Serial.println("Loading file icons.css");
|
|
File file = LittleFS.open("/icons.css", "r");
|
|
if (!file) {
|
|
Serial.println("Error opening data/icons.css");
|
|
server.send(500, _encoding_text, "Unable to open data/icons.css");
|
|
}
|
|
server.streamFile(file, "text/css");
|
|
file.close();
|
|
});
|
|
server.on("/favicon.png", []() {
|
|
webServer.sendCacheHeaders(604800);
|
|
webServer.sendCORSHeaders();
|
|
|
|
// Load the index html page from the data directory.
|
|
Serial.println("Loading file favicon.png");
|
|
File file = LittleFS.open("/favicon.png", "r");
|
|
if (!file) {
|
|
Serial.println("Error opening data/favicon.png");
|
|
server.send(500, _encoding_text, "Unable to open data/icons.css");
|
|
}
|
|
server.streamFile(file, "image/png");
|
|
file.close();
|
|
});
|
|
server.onNotFound([]() {
|
|
Serial.print("Request 404:");
|
|
HTTPMethod method = server.method();
|
|
switch (method) {
|
|
case HTTP_POST:
|
|
Serial.print("POST ");
|
|
break;
|
|
case HTTP_GET:
|
|
Serial.print("GET ");
|
|
break;
|
|
case HTTP_PUT:
|
|
Serial.print("PUT ");
|
|
break;
|
|
default:
|
|
Serial.print("[");
|
|
Serial.print(method);
|
|
Serial.print("]");
|
|
break;
|
|
|
|
}
|
|
snprintf(g_content, sizeof(g_content), "404 Service Not Found: %s", server.uri().c_str());
|
|
server.send(404, _encoding_text, g_content);
|
|
});
|
|
server.on("/controller", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_POST || method == HTTP_GET) {
|
|
DynamicJsonDocument doc(16384);
|
|
somfy.toJSON(doc);
|
|
serializeJson(doc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else server.send(404, _encoding_text, _response_404);
|
|
});
|
|
server.on("/shades", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_POST || method == HTTP_GET) {
|
|
DynamicJsonDocument doc(16384);
|
|
JsonArray arr = doc.to<JsonArray>();
|
|
somfy.toJSON(arr);
|
|
serializeJson(doc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else server.send(404, _encoding_text, _response_404);
|
|
});
|
|
server.on("/getNextShade", []() {
|
|
webServer.sendCORSHeaders();
|
|
StaticJsonDocument<128> doc;
|
|
uint8_t shadeId = somfy.getNextShadeId();
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
obj["shadeId"] = shadeId;
|
|
obj["remoteAddress"] = somfy.getNextRemoteAddress(shadeId);
|
|
serializeJson(doc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
});
|
|
server.on("/addShade", []() {
|
|
HTTPMethod method = server.method();
|
|
SomfyShade* shade;
|
|
if (method == HTTP_POST || method == HTTP_PUT) {
|
|
Serial.println("Adding a shade");
|
|
DynamicJsonDocument doc(256);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
Serial.println("Counting shades");
|
|
if (somfy.shadeCount() > SOMFY_MAX_SHADES) {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Maximum number of shades exceeded.\"}"));
|
|
}
|
|
else {
|
|
Serial.println("Adding shade");
|
|
shade = somfy.addShade(obj);
|
|
if (shade) {
|
|
DynamicJsonDocument sdoc(256);
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
shade->toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Error adding shade.\"}"));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (shade) {
|
|
//Serial.println("Serializing shade");
|
|
DynamicJsonDocument doc(256);
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
shade->toJSON(obj);
|
|
serializeJson(doc, g_content);
|
|
Serial.println(g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Error saving Somfy Shade.\"}"));
|
|
}
|
|
});
|
|
server.on("/shade", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_GET) {
|
|
if (server.hasArg("shadeId")) {
|
|
int shadeId = atoi(server.arg("shadeId").c_str());
|
|
SomfyShade* shade = somfy.getShadeById(shadeId);
|
|
if (shade) {
|
|
DynamicJsonDocument doc(512);
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
shade->toJSON(obj);
|
|
serializeJson(doc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade Id not found.\"}"));
|
|
}
|
|
else {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"You must supply a valid shade id.\"}"));
|
|
}
|
|
}
|
|
else if (method == HTTP_PUT || method == HTTP_POST) {
|
|
// We are updating an existing shade.
|
|
if (server.hasArg("plain")) {
|
|
Serial.println("Updating a shade");
|
|
DynamicJsonDocument doc(512);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) {
|
|
SomfyShade* shade = somfy.getShadeById(obj["shadeId"]);
|
|
if (shade) {
|
|
shade->fromJSON(obj);
|
|
shade->save();
|
|
DynamicJsonDocument sdoc(512);
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
shade->toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade Id not found.\"}"));
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade id was supplied.\"}"));
|
|
}
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade object supplied.\"}"));
|
|
}
|
|
});
|
|
server.on("/saveShade", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_PUT || method == HTTP_POST) {
|
|
// We are updating an existing shade.
|
|
if (server.hasArg("plain")) {
|
|
Serial.println("Updating a shade");
|
|
DynamicJsonDocument doc(512);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) {
|
|
SomfyShade* shade = somfy.getShadeById(obj["shadeId"]);
|
|
if (shade) {
|
|
shade->fromJSON(obj);
|
|
shade->save();
|
|
DynamicJsonDocument sdoc(512);
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
shade->toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade Id not found.\"}"));
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade id was supplied.\"}"));
|
|
}
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade object supplied.\"}"));
|
|
}
|
|
});
|
|
server.on("/tiltCommand", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
uint8_t shadeId = 255;
|
|
uint8_t target = 255;
|
|
somfy_commands command = somfy_commands::My;
|
|
if (method == HTTP_GET || method == HTTP_PUT || method == HTTP_POST) {
|
|
if (server.hasArg("shadeId")) {
|
|
shadeId = atoi(server.arg("shadeId").c_str());
|
|
if (server.hasArg("command")) command = translateSomfyCommand(server.arg("command"));
|
|
else if(server.hasArg("target")) target = atoi(server.arg("target").c_str());
|
|
}
|
|
else if (server.hasArg("plain")) {
|
|
Serial.println("Sending Shade Tilt Command");
|
|
DynamicJsonDocument doc(256);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
return;
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) shadeId = obj["shadeId"];
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade id was supplied.\"}"));
|
|
if (obj.containsKey("command")) {
|
|
String scmd = obj["command"];
|
|
command = translateSomfyCommand(scmd);
|
|
}
|
|
else if(obj.containsKey("target")) {
|
|
target = obj["target"].as<uint8_t>();
|
|
}
|
|
}
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade object supplied.\"}"));
|
|
}
|
|
SomfyShade* shade = somfy.getShadeById(shadeId);
|
|
if (shade) {
|
|
Serial.print("Received:");
|
|
Serial.println(server.arg("plain"));
|
|
// Send the command to the shade.
|
|
if(target >= 0 && target <= 100)
|
|
shade->moveToTiltTarget(target);
|
|
else
|
|
shade->sendTiltCommand(command);
|
|
DynamicJsonDocument sdoc(256);
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
shade->toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade with the specified id not found.\"}"));
|
|
}
|
|
});
|
|
server.on("/shadeCommand", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
uint8_t shadeId = 255;
|
|
uint8_t target = 255;
|
|
somfy_commands command = somfy_commands::My;
|
|
if (method == HTTP_GET || method == HTTP_PUT || method == HTTP_POST) {
|
|
if (server.hasArg("shadeId")) {
|
|
shadeId = atoi(server.arg("shadeId").c_str());
|
|
if (server.hasArg("command")) command = translateSomfyCommand(server.arg("command"));
|
|
else if(server.hasArg("target")) target = atoi(server.arg("target").c_str());
|
|
}
|
|
else if (server.hasArg("plain")) {
|
|
Serial.println("Sending Shade Command");
|
|
DynamicJsonDocument doc(256);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
return;
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) shadeId = obj["shadeId"];
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade id was supplied.\"}"));
|
|
if (obj.containsKey("command")) {
|
|
String scmd = obj["command"];
|
|
command = translateSomfyCommand(scmd);
|
|
}
|
|
else if(obj.containsKey("target")) {
|
|
target = obj["target"].as<uint8_t>();
|
|
}
|
|
}
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade object supplied.\"}"));
|
|
}
|
|
SomfyShade* shade = somfy.getShadeById(shadeId);
|
|
if (shade) {
|
|
Serial.print("Received:");
|
|
Serial.println(server.arg("plain"));
|
|
// Send the command to the shade.
|
|
if(target >= 0 && target <= 100)
|
|
shade->moveToTarget(target);
|
|
else
|
|
shade->sendCommand(command);
|
|
DynamicJsonDocument sdoc(256);
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
shade->toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade with the specified id not found.\"}"));
|
|
}
|
|
});
|
|
server.on("/setMyPosition", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
uint8_t shadeId = 255;
|
|
uint8_t target = 255;
|
|
|
|
if (method == HTTP_GET || method == HTTP_PUT || method == HTTP_POST) {
|
|
if (server.hasArg("shadeId")) {
|
|
shadeId = atoi(server.arg("shadeId").c_str());
|
|
if(server.hasArg("target")) target = atoi(server.arg("target").c_str());
|
|
}
|
|
else if (server.hasArg("plain")) {
|
|
DynamicJsonDocument doc(256);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
return;
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) shadeId = obj["shadeId"];
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade id was supplied.\"}"));
|
|
if(obj.containsKey("target")) {
|
|
target = obj["target"].as<uint8_t>();
|
|
}
|
|
}
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade object supplied.\"}"));
|
|
}
|
|
SomfyShade* shade = somfy.getShadeById(shadeId);
|
|
if (shade) {
|
|
// Send the command to the shade.
|
|
if(target == 255) target = shade->myPos;
|
|
if(target >= 0 && target <= 100)
|
|
shade->setMyPosition(target);
|
|
DynamicJsonDocument sdoc(256);
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
shade->toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade with the specified id not found.\"}"));
|
|
}
|
|
});
|
|
server.on("/setRollingCode", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_PUT || method == HTTP_POST) {
|
|
uint8_t shadeId = 255;
|
|
uint16_t rollingCode = 0;
|
|
if (server.hasArg("plain")) {
|
|
// Its coming in the body.
|
|
StaticJsonDocument<129> doc;
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) shadeId = obj["shadeId"];
|
|
if(obj.containsKey("rollingCode")) rollingCode = obj["rollingCode"];
|
|
}
|
|
}
|
|
else if (server.hasArg("shadeId")) {
|
|
shadeId = atoi(server.arg("shadeId").c_str());
|
|
rollingCode = atoi(server.arg("rollingCode").c_str());
|
|
}
|
|
SomfyShade* shade = nullptr;
|
|
if (shadeId != 255) shade = somfy.getShadeById(shadeId);
|
|
if (!shade) {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade not found to set rolling code\"}"));
|
|
}
|
|
else {
|
|
shade->setRollingCode(rollingCode);
|
|
StaticJsonDocument<256> doc;
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
shade->toJSON(obj);
|
|
serializeJson(doc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
}
|
|
});
|
|
server.on("/pairShade", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_PUT || method == HTTP_POST) {
|
|
uint8_t shadeId = 255;
|
|
if (server.hasArg("plain")) {
|
|
// Its coming in the body.
|
|
StaticJsonDocument<129> doc;
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) shadeId = obj["shadeId"];
|
|
}
|
|
}
|
|
else if (server.hasArg("shadeId"))
|
|
shadeId = atoi(server.arg("shadeId").c_str());
|
|
SomfyShade* shade = nullptr;
|
|
if (shadeId != 255) shade = somfy.getShadeById(shadeId);
|
|
if (!shade) {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade not found to pair\"}"));
|
|
}
|
|
else {
|
|
shade->sendCommand(somfy_commands::Prog, 4);
|
|
shade->paired = true;
|
|
shade->save();
|
|
StaticJsonDocument<256> doc;
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
shade->toJSON(obj);
|
|
serializeJson(doc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
}
|
|
});
|
|
server.on("/unpairShade", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_PUT || method == HTTP_POST) {
|
|
uint8_t shadeId = 255;
|
|
if (server.hasArg("plain")) {
|
|
// Its coming in the body.
|
|
StaticJsonDocument<129> doc;
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) shadeId = obj["shadeId"];
|
|
}
|
|
}
|
|
else if (server.hasArg("shadeId"))
|
|
shadeId = atoi(server.arg("shadeId").c_str());
|
|
SomfyShade* shade = nullptr;
|
|
if (shadeId != 255) shade = somfy.getShadeById(shadeId);
|
|
if (!shade) {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade not found to unpair\"}"));
|
|
}
|
|
else {
|
|
shade->sendCommand(somfy_commands::Prog, 4);
|
|
shade->paired = false;
|
|
shade->save();
|
|
StaticJsonDocument<256> doc;
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
shade->toJSON(obj);
|
|
serializeJson(doc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
}
|
|
});
|
|
server.on("/unlinkRemote", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_PUT || method == HTTP_POST) {
|
|
// We are updating an existing shade by adding a linked remote.
|
|
if (server.hasArg("plain")) {
|
|
DynamicJsonDocument doc(256);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) {
|
|
SomfyShade* shade = somfy.getShadeById(obj["shadeId"]);
|
|
if (shade) {
|
|
if (obj.containsKey("remoteAddress")) {
|
|
shade->unlinkRemote(obj["remoteAddress"]);
|
|
}
|
|
else {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Remote address not provided.\"}"));
|
|
}
|
|
DynamicJsonDocument sdoc(512);
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
shade->toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade Id not found.\"}"));
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade id was supplied.\"}"));
|
|
}
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No remote object supplied.\"}"));
|
|
}
|
|
});
|
|
server.on("/linkRemote", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_PUT || method == HTTP_POST) {
|
|
// We are updating an existing shade by adding a linked remote.
|
|
if (server.hasArg("plain")) {
|
|
Serial.println("Linking a remote");
|
|
DynamicJsonDocument doc(256);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) {
|
|
SomfyShade* shade = somfy.getShadeById(obj["shadeId"]);
|
|
if (shade) {
|
|
if (obj.containsKey("remoteAddress")) {
|
|
if (obj.containsKey("rollingCode")) shade->linkRemote(obj["remoteAddress"], obj["rollingCode"]);
|
|
else shade->linkRemote(obj["remoteAddress"]);
|
|
}
|
|
else {
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Remote address not provided.\"}"));
|
|
}
|
|
DynamicJsonDocument sdoc(512);
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
shade->toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade Id not found.\"}"));
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade id was supplied.\"}"));
|
|
}
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No remote object supplied.\"}"));
|
|
}
|
|
});
|
|
server.on("/deleteShade", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
uint8_t shadeId = 255;
|
|
if (method == HTTP_GET || method == HTTP_PUT || method == HTTP_POST) {
|
|
if (server.hasArg("shadeId")) {
|
|
shadeId = atoi(server.arg("shadeId").c_str());
|
|
}
|
|
else if (server.hasArg("plain")) {
|
|
Serial.println("Deleting a shade");
|
|
DynamicJsonDocument doc(256);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
if (obj.containsKey("shadeId")) shadeId = obj["shadeId"];//obj.getMember("shadeId").as<uint8_t>();
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade id was supplied.\"}"));
|
|
}
|
|
}
|
|
else server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No shade object supplied.\"}"));
|
|
}
|
|
SomfyShade* shade = somfy.getShadeById(shadeId);
|
|
if (!shade) server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Shade with the specified id not found.\"}"));
|
|
else {
|
|
somfy.deleteShade(shadeId);
|
|
server.send(200, _encoding_json, F("{\"status\":\"SUCCESS\",\"desc\":\"Shade deleted.\"}"));
|
|
}
|
|
});
|
|
server.on("/updateFirmware", HTTP_POST, []() {
|
|
webServer.sendCORSHeaders();
|
|
if (Update.hasError())
|
|
server.send(500, _encoding_json, "{\"status\":\"ERROR\",\"desc\":\"Error updating firmware: \"}");
|
|
else
|
|
server.send(200, _encoding_json, "{\"status\":\"ERROR\",\"desc\":\"Updating firmware: \"}");
|
|
rebootDelay.reboot = true;
|
|
rebootDelay.rebootTime = millis() + 500;
|
|
}, []() {
|
|
HTTPUpload& upload = server.upload();
|
|
if (upload.status == UPLOAD_FILE_START) {
|
|
Serial.printf("Update: %s\n", upload.filename.c_str());
|
|
if (!Update.begin(UPDATE_SIZE_UNKNOWN)) { //start with max available size
|
|
Update.printError(Serial);
|
|
}
|
|
}
|
|
else if (upload.status == UPLOAD_FILE_WRITE) {
|
|
/* flashing firmware to ESP*/
|
|
if (Update.write(upload.buf, upload.currentSize) != upload.currentSize) {
|
|
Update.printError(Serial);
|
|
}
|
|
}
|
|
else if (upload.status == UPLOAD_FILE_END) {
|
|
if (Update.end(true)) { //true to set the size to the current progress
|
|
Serial.printf("Update Success: %u\nRebooting...\n", upload.totalSize);
|
|
}
|
|
else {
|
|
Update.printError(Serial);
|
|
}
|
|
}
|
|
});
|
|
server.on("/updateApplication", HTTP_POST, []() {
|
|
webServer.sendCORSHeaders();
|
|
server.sendHeader("Connection", "close");
|
|
server.send(200, _encoding_json, "{\"status\":\"ERROR\",\"desc\":\"Updating Application: \"}");
|
|
rebootDelay.reboot = true;
|
|
rebootDelay.rebootTime = millis() + 500;
|
|
}, []() {
|
|
HTTPUpload& upload = server.upload();
|
|
if (upload.status == UPLOAD_FILE_START) {
|
|
Serial.printf("Update: %s\n", upload.filename.c_str());
|
|
if (!Update.begin(UPDATE_SIZE_UNKNOWN, U_SPIFFS)) { //start with max available size and tell it we are updating the file system.
|
|
Update.printError(Serial);
|
|
}
|
|
}
|
|
else if (upload.status == UPLOAD_FILE_WRITE) {
|
|
/* flashing firmware to ESP*/
|
|
if (Update.write(upload.buf, upload.currentSize) != upload.currentSize) {
|
|
Update.printError(Serial);
|
|
}
|
|
}
|
|
else if (upload.status == UPLOAD_FILE_END) {
|
|
if (Update.end(true)) { //true to set the size to the current progress
|
|
Serial.printf("Update Success: %u\nRebooting...\n", upload.totalSize);
|
|
}
|
|
else {
|
|
Update.printError(Serial);
|
|
}
|
|
}
|
|
});
|
|
server.on("/scanaps", []() {
|
|
webServer.sendCORSHeaders();
|
|
int statusCode = 200;
|
|
int n = WiFi.scanNetworks();
|
|
Serial.print("Scanned ");
|
|
Serial.print(n);
|
|
Serial.println(" networks");
|
|
DynamicJsonDocument doc(16384);
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
JsonObject connected = obj.createNestedObject("connected");
|
|
connected["name"] = settings.WIFI.ssid;
|
|
connected["passphrase"] = settings.WIFI.passphrase;
|
|
connected["strength"] = WiFi.RSSI();
|
|
connected["channel"] = WiFi.channel();
|
|
JsonArray arr = obj.createNestedArray("accessPoints");
|
|
for(int i = 0; i < n; ++i) {
|
|
if(WiFi.SSID(i).length() == 0 || WiFi.RSSI(i) < -95) continue; // Ignore hidden and weak networks that we cannot connect to anyway.
|
|
JsonObject a = arr.createNestedObject();
|
|
a["name"] = WiFi.SSID(i);
|
|
a["channel"] = WiFi.channel(i);
|
|
a["encryption"] = settings.WIFI.mapEncryptionType(WiFi.encryptionType(i));
|
|
a["strength"] = WiFi.RSSI(i);
|
|
a["macAddress"] = WiFi.BSSIDstr(i);
|
|
}
|
|
serializeJson(doc, g_content);
|
|
/*
|
|
String content = "{\"connected\": {\"name\":\"" + String(settings.WIFI.ssid) + "\",\"passphrase\":\"" + String(settings.WIFI.passphrase) + "\",\"strength\":" + WiFi.RSSI() + ",\"channel\":" + WiFi.channel() + "}, \"accessPoints\":[";
|
|
for (int i = 0; i < n; ++i) {
|
|
if (i != 0) content += ",";
|
|
content += "{\"name\":\"" + WiFi.SSID(i) + "\",\"channel\":" + WiFi.channel(i) + ",\"encryption\":\"" + settings.WIFI.mapEncryptionType(WiFi.encryptionType(i)) + "\",\"strength\":" + WiFi.RSSI(i) + ",\"macAddress\":\"" + WiFi.BSSIDstr(i) + "\"}";
|
|
delay(10);
|
|
}
|
|
content += "]}";
|
|
*/
|
|
server.send(statusCode, "application/json", g_content);
|
|
});
|
|
server.on("/reboot", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_POST || method == HTTP_PUT) {
|
|
Serial.println("Rebooting ESP...");
|
|
rebootDelay.reboot = true;
|
|
rebootDelay.rebootTime = millis() + 500;
|
|
server.send(200, "application/json", "{\"status\":\"OK\",\"desc\":\"Successfully started reboot\"}");
|
|
}
|
|
else {
|
|
server.send(201, _encoding_json, "{\"status\":\"ERROR\",\"desc\":\"Invalid HTTP Method: \"}");
|
|
}
|
|
});
|
|
server.on("/saveRadio", []() {
|
|
webServer.sendCORSHeaders();
|
|
DynamicJsonDocument doc(512);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
Serial.print("Error parsing JSON ");
|
|
Serial.println(err.c_str());
|
|
String msg = err.c_str();
|
|
server.send(400, _encoding_html, "Error parsing JSON body<br>" + msg);
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_POST || method == HTTP_PUT) {
|
|
somfy.transceiver.fromJSON(obj);
|
|
somfy.transceiver.save();
|
|
DynamicJsonDocument sdoc(1024);
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
somfy.transceiver.toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
//server.send(200, "application/json", "{\"status\":\"OK\",\"desc\":\"Successfully saved radio\"}");
|
|
}
|
|
else {
|
|
server.send(201, "application/json", "{\"status\":\"ERROR\",\"desc\":\"Invalid HTTP Method: \"}");
|
|
}
|
|
}
|
|
});
|
|
server.on("/getRadio", []() {
|
|
webServer.sendCORSHeaders();
|
|
DynamicJsonDocument doc(1024);
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
somfy.transceiver.toJSON(obj);
|
|
serializeJson(doc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
});
|
|
server.on("/sendRemoteCommand", []() {
|
|
webServer.sendCORSHeaders();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_GET || method == HTTP_PUT || method == HTTP_POST) {
|
|
somfy_frame_t frame;
|
|
uint8_t repeats = 0;
|
|
if (server.hasArg("address")) {
|
|
frame.remoteAddress = atoi(server.arg("address").c_str());
|
|
if (server.hasArg("encKey")) frame.encKey = atoi(server.arg("encKey").c_str());
|
|
if (server.hasArg("command")) frame.cmd = translateSomfyCommand(server.arg("command"));
|
|
if (server.hasArg("rcode")) frame.rollingCode = atoi(server.arg("rcode").c_str());
|
|
if (server.hasArg("repeats")) repeats = atoi(server.arg("repeats").c_str());
|
|
}
|
|
else if (server.hasArg("plain")) {
|
|
StaticJsonDocument<128> doc;
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
switch (err.code()) {
|
|
case DeserializationError::InvalidInput:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Invalid JSON payload\"}"));
|
|
break;
|
|
case DeserializationError::NoMemory:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"Out of memory parsing JSON\"}"));
|
|
break;
|
|
default:
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"General JSON Deserialization failed\"}"));
|
|
break;
|
|
}
|
|
return;
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
String scmd;
|
|
if (obj.containsKey("address")) frame.remoteAddress = obj["address"];
|
|
if (obj.containsKey("command")) scmd = obj["command"].as<String>();
|
|
if (obj.containsKey("repeats")) repeats = obj["repeats"];
|
|
if (obj.containsKey("rcode")) frame.rollingCode = obj["rcode"];
|
|
if (obj.containsKey("encKey")) frame.encKey = obj["encKey"];
|
|
frame.cmd = translateSomfyCommand(scmd.c_str());
|
|
}
|
|
}
|
|
if (frame.remoteAddress > 0 && frame.rollingCode > 0) {
|
|
somfy.sendFrame(frame, repeats);
|
|
server.send(200, _encoding_json, F("{\"status\":\"SUCCESS\",\"desc\":\"Command Sent\"}"));
|
|
}
|
|
else
|
|
server.send(500, _encoding_json, F("{\"status\":\"ERROR\",\"desc\":\"No address or rolling code provided\"}"));
|
|
}
|
|
});
|
|
server.on("/setgeneral", []() {
|
|
webServer.sendCORSHeaders();
|
|
int statusCode = 200;
|
|
DynamicJsonDocument doc(256);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
Serial.print("Error parsing JSON ");
|
|
Serial.println(err.c_str());
|
|
String msg = err.c_str();
|
|
server.send(400, _encoding_html, "Error parsing JSON body<br>" + msg);
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_POST || method == HTTP_PUT) {
|
|
// Parse out all the inputs.
|
|
if (obj.containsKey("hostname") || obj.containsKey("ssdpBroadcast")) {
|
|
settings.fromJSON(obj);
|
|
settings.save();
|
|
}
|
|
if (obj.containsKey("ntpServer") || obj.containsKey("ntpServer")) {
|
|
settings.NTP.fromJSON(obj);
|
|
settings.NTP.save();
|
|
}
|
|
server.send(200, "application/json", "{\"status\":\"OK\",\"desc\":\"Successfully set General Settings\"}");
|
|
}
|
|
else {
|
|
server.send(201, "application/json", "{\"status\":\"ERROR\",\"desc\":\"Invalid HTTP Method: \"}");
|
|
}
|
|
}
|
|
});
|
|
server.on("/setNetwork", []() {
|
|
webServer.sendCORSHeaders();
|
|
DynamicJsonDocument doc(1024);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
Serial.print("Error parsing JSON ");
|
|
Serial.println(err.c_str());
|
|
String msg = err.c_str();
|
|
server.send(400, _encoding_html, "Error parsing JSON body<br>" + msg);
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
HTTPMethod method = server.method();
|
|
if (method == HTTP_POST || method == HTTP_PUT) {
|
|
// Parse out all the inputs.
|
|
bool reboot = false;
|
|
if(obj.containsKey("connType") && obj["connType"].as<uint8_t>() != static_cast<uint8_t>(settings.connType)) {
|
|
settings.connType = static_cast<conn_types>(obj["connType"].as<uint8_t>());
|
|
settings.save();
|
|
reboot = true;
|
|
}
|
|
if(settings.connType == conn_types::wifi) {
|
|
if(obj.containsKey("ssid") && obj["ssid"].as<String>().compareTo(settings.WIFI.ssid) != 0) reboot = true;
|
|
if(obj.containsKey("passphrase") && obj["passphrase"].as<String>().compareTo(settings.WIFI.passphrase) != 0) reboot = true;
|
|
}
|
|
else {
|
|
// This is an ethernet connection so if anything changes we need to reboot.
|
|
reboot = true;
|
|
}
|
|
JsonObject objWifi = obj["wifi"];
|
|
JsonObject objEth = obj["ethernet"];
|
|
settings.WIFI.fromJSON(objWifi);
|
|
settings.Ethernet.fromJSON(objEth);
|
|
|
|
settings.WIFI.save();
|
|
settings.Ethernet.save();
|
|
if (reboot) {
|
|
Serial.println("Rebooting ESP for new Network settings...");
|
|
rebootDelay.reboot = true;
|
|
rebootDelay.rebootTime = millis() + 1000;
|
|
}
|
|
server.send(200, "application/json", "{\"status\":\"OK\",\"desc\":\"Successfully set Network Settings\"}");
|
|
}
|
|
else {
|
|
server.send(201, "application/json", "{\"status\":\"ERROR\",\"desc\":\"Invalid HTTP Method: \"}");
|
|
}
|
|
}
|
|
});
|
|
server.on("/connectwifi", []() {
|
|
webServer.sendCORSHeaders();
|
|
int statusCode = 200;
|
|
Serial.println("Settings WIFI connection...");
|
|
DynamicJsonDocument doc(512);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
Serial.print("Error parsing JSON ");
|
|
Serial.println(err.c_str());
|
|
String msg = err.c_str();
|
|
server.send(400, "text/html", "Error parsing JSON body<br>" + msg);
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
HTTPMethod method = server.method();
|
|
//Serial.print(F("HTTP Method: "));
|
|
//Serial.println(server.method());
|
|
if (method == HTTP_POST || method == HTTP_PUT) {
|
|
String ssid = "";
|
|
String passphrase = "";
|
|
if (obj.containsKey("ssid")) ssid = obj["ssid"].as<String>();
|
|
if (obj.containsKey("passphrase")) passphrase = obj["passphrase"].as<String>();
|
|
bool reboot;
|
|
if (ssid.compareTo(settings.WIFI.ssid) != 0) reboot = true;
|
|
if (passphrase.compareTo(settings.WIFI.passphrase) != 0) reboot = true;
|
|
if (!settings.WIFI.ssidExists(ssid.c_str()) && ssid.length() > 0) {
|
|
server.send(400, _encoding_json, "{\"status\":\"ERROR\",\"desc\":\"WiFi Network Does not exist\"}");
|
|
}
|
|
else {
|
|
SETCHARPROP(settings.WIFI.ssid, ssid.c_str(), sizeof(settings.WIFI.ssid));
|
|
SETCHARPROP(settings.WIFI.passphrase, passphrase.c_str(), sizeof(settings.WIFI.passphrase));
|
|
settings.WIFI.save();
|
|
settings.WIFI.print();
|
|
server.send(201, _encoding_json, "{\"status\":\"OK\",\"desc\":\"Successfully set server connection\"}");
|
|
if (reboot) {
|
|
Serial.println("Rebooting ESP for new WiFi settings...");
|
|
rebootDelay.reboot = true;
|
|
rebootDelay.rebootTime = millis() + 1000;
|
|
}
|
|
}
|
|
}
|
|
else {
|
|
server.send(201, _encoding_json, "{\"status\":\"ERROR\",\"desc\":\"Invalid HTTP Method: \"}");
|
|
}
|
|
}
|
|
});
|
|
server.on("/modulesettings", []() {
|
|
webServer.sendCORSHeaders();
|
|
DynamicJsonDocument doc(512);
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
doc["fwVersion"] = settings.fwVersion;
|
|
settings.toJSON(obj);
|
|
//settings.Ethernet.toJSON(obj);
|
|
//settings.WIFI.toJSON(obj);
|
|
settings.NTP.toJSON(obj);
|
|
serializeJson(doc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
});
|
|
server.on("/networksettings", []() {
|
|
webServer.sendCORSHeaders();
|
|
DynamicJsonDocument doc(1024);
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
doc["fwVersion"] = settings.fwVersion;
|
|
settings.toJSON(obj);
|
|
JsonObject eth = obj.createNestedObject("ethernet");
|
|
settings.Ethernet.toJSON(eth);
|
|
JsonObject wifi = obj.createNestedObject("wifi");
|
|
settings.WIFI.toJSON(wifi);
|
|
serializeJson(doc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
});
|
|
server.on("/connectmqtt", []() {
|
|
DynamicJsonDocument doc(512);
|
|
DeserializationError err = deserializeJson(doc, server.arg("plain"));
|
|
if (err) {
|
|
Serial.print("Error parsing JSON ");
|
|
Serial.println(err.c_str());
|
|
String msg = err.c_str();
|
|
server.send(400, F("text/html"), "Error parsing JSON body<br>" + msg);
|
|
}
|
|
else {
|
|
JsonObject obj = doc.as<JsonObject>();
|
|
HTTPMethod method = server.method();
|
|
Serial.print(F("HTTP Method: "));
|
|
Serial.println(server.method());
|
|
if (method == HTTP_POST || method == HTTP_PUT) {
|
|
settings.MQTT.fromJSON(obj);
|
|
settings.MQTT.save();
|
|
StaticJsonDocument<512> sdoc;
|
|
JsonObject sobj = sdoc.to<JsonObject>();
|
|
settings.MQTT.toJSON(sobj);
|
|
serializeJson(sdoc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
}
|
|
else {
|
|
server.send(201, "application/json", "{\"status\":\"ERROR\",\"desc\":\"Invalid HTTP Method: \"}");
|
|
}
|
|
}
|
|
});
|
|
server.on("/mqttsettings", []() {
|
|
webServer.sendCORSHeaders();
|
|
DynamicJsonDocument doc(512);
|
|
JsonObject obj = doc.to<JsonObject>();
|
|
settings.MQTT.toJSON(obj);
|
|
serializeJson(doc, g_content);
|
|
server.send(200, _encoding_json, g_content);
|
|
});
|
|
server.begin();
|
|
apiServer.begin();
|
|
}
|