mirror of https://github.com/lumapu/ahoy.git
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
810 lines
37 KiB
810 lines
37 KiB
//-----------------------------------------------------------------------------
|
|
// 2023 Ahoy, https://ahoydtu.de
|
|
// Creative Commons - http://creativecommons.org/licenses/by-nc-sa/3.0/de/
|
|
//-----------------------------------------------------------------------------
|
|
|
|
#ifndef __WEB_API_H__
|
|
#define __WEB_API_H__
|
|
|
|
#include "../utils/dbg.h"
|
|
#include "../config/config.h"
|
|
#ifdef ESP32
|
|
#include "AsyncTCP.h"
|
|
#else
|
|
#include "ESPAsyncTCP.h"
|
|
#endif
|
|
#include "../appInterface.h"
|
|
#include "../hm/hmSystem.h"
|
|
#include "../utils/helper.h"
|
|
#include "AsyncJson.h"
|
|
#include "ESPAsyncWebServer.h"
|
|
#include "../plugins/SML_OBIS_Parser.h"
|
|
|
|
#if defined(F) && defined(ESP32)
|
|
#undef F
|
|
#define F(sl) (sl)
|
|
#endif
|
|
|
|
const uint8_t acList[] = {FLD_UAC, FLD_IAC, FLD_PAC, FLD_F, FLD_PF, FLD_T, FLD_YT, FLD_YD, FLD_PDC, FLD_EFF, FLD_Q, FLD_MP};
|
|
const uint8_t dcList[] = {FLD_UDC, FLD_IDC, FLD_PDC, FLD_YD, FLD_YT, FLD_IRR, FLD_MP};
|
|
|
|
template <class HMSYSTEM>
|
|
class RestApi {
|
|
public:
|
|
RestApi() {
|
|
mTimezoneOffset = 0;
|
|
mHeapFree = 0;
|
|
mHeapFreeBlk = 0;
|
|
mHeapFrag = 0;
|
|
nr = 0;
|
|
}
|
|
|
|
void setup(IApp *app, HMSYSTEM *sys, AsyncWebServer *srv, settings_t *config) {
|
|
mApp = app;
|
|
mSrv = srv;
|
|
mSys = sys;
|
|
mConfig = config;
|
|
mSrv->on("/api", HTTP_GET, std::bind(&RestApi::onApi, this, std::placeholders::_1));
|
|
mSrv->on("/api", HTTP_POST, std::bind(&RestApi::onApiPost, this, std::placeholders::_1)).onBody(
|
|
std::bind(&RestApi::onApiPostBody, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3, std::placeholders::_4, std::placeholders::_5));
|
|
mSrv->on("/get_setup", HTTP_GET, std::bind(&RestApi::onDwnldSetup, this, std::placeholders::_1));
|
|
mSrv->on("/get_chartdata", HTTP_GET, std::bind(&RestApi::onGetChartData, this, std::placeholders::_1));
|
|
}
|
|
|
|
uint32_t getTimezoneOffset(void) {
|
|
return mTimezoneOffset;
|
|
}
|
|
|
|
void ctrlRequest(JsonObject obj) {
|
|
/*char out[128];
|
|
serializeJson(obj, out, 128);
|
|
DPRINTLN(DBG_INFO, "RestApi: " + String(out));*/
|
|
DynamicJsonDocument json(128);
|
|
JsonObject dummy = json.as<JsonObject>();
|
|
if(obj[F("path")] == "ctrl")
|
|
setCtrl(obj, dummy);
|
|
else if(obj[F("path")] == "setup")
|
|
setSetup(obj, dummy);
|
|
}
|
|
|
|
private:
|
|
void onApi(AsyncWebServerRequest *request) {
|
|
mHeapFree = ESP.getFreeHeap();
|
|
#ifndef ESP32
|
|
mHeapFreeBlk = ESP.getMaxFreeBlockSize();
|
|
mHeapFrag = ESP.getHeapFragmentation();
|
|
#endif
|
|
|
|
|
|
String path = request->url().substring(5);
|
|
AsyncJsonResponse* response = new AsyncJsonResponse(false, 6000);
|
|
JsonObject root = response->getRoot();
|
|
if(path == "html/system") getHtmlSystem(request, root);
|
|
else if(path == "html/logout") getHtmlLogout(request, root);
|
|
else if(path == "html/reboot") getHtmlReboot(request, root);
|
|
else if(path == "html/save") getHtmlSave(request, root);
|
|
else if(path == "system") getSysInfo(request, root);
|
|
else if(path == "generic") getGeneric(request, root);
|
|
else if(path == "reboot") getReboot(request, root);
|
|
else if(path == "statistics") getStatistics(root);
|
|
else if(path == "inverter/list") getInverterList(root);
|
|
else if(path == "index") getIndex(request, root);
|
|
else if(path == "setup") getSetup(request, root);
|
|
else if(path == "setup/networks") getNetworks(root);
|
|
else if(path == "live") getLive(request, root);
|
|
else if(path == "record/info") getRecord(root, InverterDevInform_All);
|
|
else if(path == "record/alarm") getRecord(root, AlarmData);
|
|
else if(path == "record/config") getRecord(root, SystemConfigPara);
|
|
else if(path == "record/live") getRecord(root, RealTimeRunData_Debug);
|
|
else {
|
|
if(path.substring(0, 12) == "inverter/id/")
|
|
getInverter(root, request->url().substring(17).toInt());
|
|
else
|
|
getNotFound(root, F("http://") + request->host() + F("/api/"));
|
|
}
|
|
//DPRINTLN(DBG_INFO, "API mem usage: " + String(root.memoryUsage()));
|
|
response->addHeader("Access-Control-Allow-Origin", "*");
|
|
response->addHeader("Access-Control-Allow-Headers", "content-type");
|
|
response->setLength();
|
|
request->send(response);
|
|
}
|
|
|
|
void onApiPost(AsyncWebServerRequest *request) {
|
|
DPRINTLN(DBG_VERBOSE, "onApiPost");
|
|
}
|
|
|
|
void onApiPostBody(AsyncWebServerRequest *request, uint8_t *data, size_t len, size_t index, size_t total) {
|
|
DPRINTLN(DBG_VERBOSE, "onApiPostBody");
|
|
DynamicJsonDocument json(200);
|
|
AsyncJsonResponse* response = new AsyncJsonResponse(false, 200);
|
|
JsonObject root = response->getRoot();
|
|
|
|
DeserializationError err = deserializeJson(json, (const char *)data, len);
|
|
JsonObject obj = json.as<JsonObject>();
|
|
root[F("success")] = (err) ? false : true;
|
|
if(!err) {
|
|
String path = request->url().substring(5);
|
|
if(path == "ctrl")
|
|
root[F("success")] = setCtrl(obj, root);
|
|
else if(path == "setup")
|
|
root[F("success")] = setSetup(obj, root);
|
|
else {
|
|
root[F("success")] = false;
|
|
root[F("error")] = "Path not found: " + path;
|
|
}
|
|
}
|
|
else {
|
|
switch (err.code()) {
|
|
case DeserializationError::Ok: break;
|
|
case DeserializationError::InvalidInput: root[F("error")] = F("Invalid input"); break;
|
|
case DeserializationError::NoMemory: root[F("error")] = F("Not enough memory"); break;
|
|
default: root[F("error")] = F("Deserialization failed"); break;
|
|
}
|
|
}
|
|
|
|
response->setLength();
|
|
request->send(response);
|
|
}
|
|
|
|
void getNotFound(JsonObject obj, String url) {
|
|
JsonObject ep = obj.createNestedObject("avail_endpoints");
|
|
ep[F("system")] = url + F("system");
|
|
ep[F("statistics")] = url + F("statistics");
|
|
ep[F("inverter/list")] = url + F("inverter/list");
|
|
ep[F("index")] = url + F("index");
|
|
ep[F("setup")] = url + F("setup");
|
|
ep[F("live")] = url + F("live");
|
|
ep[F("record/info")] = url + F("record/info");
|
|
ep[F("record/alarm")] = url + F("record/alarm");
|
|
ep[F("record/config")] = url + F("record/config");
|
|
ep[F("record/live")] = url + F("record/live");
|
|
}
|
|
|
|
unsigned int get_int_length (int value)
|
|
{
|
|
unsigned int length = 1;
|
|
unsigned int base10 = 10, last_base10;
|
|
|
|
if (value < 0) {
|
|
length++;
|
|
value = -value;
|
|
}
|
|
while ((unsigned int)value >= base10) {
|
|
length++;
|
|
last_base10 = base10;
|
|
base10 *= 10;
|
|
if (base10 <= last_base10) {
|
|
break;
|
|
}
|
|
}
|
|
return length;
|
|
}
|
|
|
|
void onDwnldSetup(AsyncWebServerRequest *request) {
|
|
AsyncWebServerResponse *response;
|
|
|
|
File fp = LittleFS.open("/settings.json", "r");
|
|
if(!fp) {
|
|
DPRINTLN(DBG_ERROR, F("failed to load settings"));
|
|
response = request->beginResponse(200, F("application/json; charset=utf-8"), "{}");
|
|
}
|
|
else {
|
|
String tmp = fp.readString();
|
|
int i = 0;
|
|
// remove all passwords
|
|
while (i != -1) {
|
|
i = tmp.indexOf("\"pwd\":", i);
|
|
if(-1 != i) {
|
|
i+=7;
|
|
tmp.remove(i, tmp.indexOf("\"", i)-i);
|
|
}
|
|
}
|
|
response = request->beginResponse(200, F("application/json; charset=utf-8"), tmp);
|
|
}
|
|
|
|
response->addHeader("Content-Type", "application/octet-stream");
|
|
response->addHeader("Content-Description", "File Transfer");
|
|
response->addHeader("Content-Disposition", "attachment; filename=ahoy_setup.json");
|
|
request->send(response);
|
|
fp.close();
|
|
}
|
|
|
|
void onGetChartData(AsyncWebServerRequest *request) {
|
|
AsyncWebServerResponse *response;
|
|
File ac_hist;
|
|
unsigned char *ac_hist_buf = NULL, *cur_ac_hist_buf, *end_ac_hist_buf;
|
|
uint16_t ac_power, cur_interval, length = 0;
|
|
size_t ac_hist_size = 0;
|
|
|
|
// phase 1: count mem needed for CSV String
|
|
|
|
if ((ac_hist = mSys->open_hist()) &&
|
|
(ac_hist_size = ac_hist.size()) &&
|
|
(ac_hist_size <= (AHOY_MAX_PAC_SUN_HOUR - AHOY_MIN_PAC_SUN_HOUR) * 60 / AHOY_PAC_INTERVAL * 4) &&
|
|
(ac_hist_buf = (unsigned char *)malloc (ac_hist_size))) {
|
|
ac_hist.read (ac_hist_buf, ac_hist_size);
|
|
mSys->close_hist (ac_hist);
|
|
ac_hist.close();
|
|
cur_ac_hist_buf = ac_hist_buf;
|
|
end_ac_hist_buf = cur_ac_hist_buf + ac_hist_size;
|
|
while (cur_ac_hist_buf < end_ac_hist_buf) {
|
|
cur_interval = *cur_ac_hist_buf++;
|
|
cur_interval += (*cur_ac_hist_buf++) << 8;
|
|
ac_power = *cur_ac_hist_buf++;
|
|
ac_power += (*cur_ac_hist_buf++) << 8;
|
|
if (cur_interval < 600 / AHOY_PAC_INTERVAL) {
|
|
length += 1 + 4 + 1; // +1: comma, +1: lf
|
|
} else {
|
|
length += 1 + 5 + 1;
|
|
}
|
|
length += get_int_length (ac_power);
|
|
#ifdef AHOY_SML_OBIS_SUPPORT
|
|
if (mConfig->sml_obis.ir_connected) {
|
|
length += 1 + 6; // reserve longest power value ,-abcde
|
|
}
|
|
#endif
|
|
}
|
|
}
|
|
if (mSys->get_cur_value (&cur_interval, &ac_power)) {
|
|
if (cur_interval < 600 / AHOY_PAC_INTERVAL) {
|
|
length += 1 + 4 + 1;
|
|
} else {
|
|
length += 1 + 5 + 1;
|
|
}
|
|
length += get_int_length (ac_power);
|
|
#ifdef AHOY_SML_OBIS_SUPPORT
|
|
if (mConfig->sml_obis.ir_connected) {
|
|
length += 1 + 6; // reserve longest power value ,-abcde
|
|
}
|
|
#endif
|
|
}
|
|
if (length) {
|
|
length += mConfig->sml_obis.ir_connected ? sizeof (AHOY_CHARTDATA_WITH_GRID_HDR) : sizeof (AHOY_CHARTDATA_HDR);
|
|
}
|
|
|
|
// phase 2: concatenate CSV string
|
|
|
|
if (length) {
|
|
char *content = NULL;
|
|
unsigned int index;
|
|
|
|
if ((content = (char *)malloc (length))) {
|
|
uint16_t minutes;
|
|
#ifdef AHOY_SML_OBIS_SUPPORT
|
|
int sml_power;
|
|
File sml_hist;
|
|
|
|
if (mConfig->sml_obis.ir_connected) {
|
|
sml_hist = sml_open_hist ();
|
|
strcpy (content, AHOY_CHARTDATA_WITH_GRID_HDR);
|
|
} else
|
|
#endif
|
|
{
|
|
strcpy (content, AHOY_CHARTDATA_HDR);
|
|
}
|
|
index = strlen (content);
|
|
|
|
cur_ac_hist_buf = ac_hist_buf;
|
|
end_ac_hist_buf = cur_ac_hist_buf + ac_hist_size;
|
|
while (cur_ac_hist_buf < end_ac_hist_buf) {
|
|
cur_interval = *cur_ac_hist_buf++;
|
|
cur_interval += (*cur_ac_hist_buf++) << 8;
|
|
ac_power = *cur_ac_hist_buf++;
|
|
ac_power += (*cur_ac_hist_buf++) << 8;
|
|
|
|
minutes = cur_interval * AHOY_PAC_INTERVAL;
|
|
|
|
#ifdef AHOY_SML_OBIS_SUPPORT
|
|
if (mConfig->sml_obis.ir_connected) {
|
|
if ((sml_power = sml_find_hist_power(sml_hist, cur_interval)) == INT32_MIN) {
|
|
snprintf (&content[index], length - index, "\n%u:%02u,%u,",
|
|
minutes / 60, minutes % 60, ac_power);
|
|
} else {
|
|
snprintf (&content[index], length - index, "\n%u:%02u,%u,%d",
|
|
minutes / 60, minutes % 60, ac_power, sml_power);
|
|
}
|
|
} else
|
|
#endif
|
|
{
|
|
snprintf (&content[index], length - index, "\n%u:%02u,%u",
|
|
minutes / 60, minutes % 60, ac_power);
|
|
}
|
|
index += strlen (&content[index]);
|
|
}
|
|
if (ac_hist_buf) {
|
|
free (ac_hist_buf);
|
|
}
|
|
if (mSys->get_cur_value (&cur_interval, &ac_power)) {
|
|
uint16_t minutes = cur_interval * AHOY_PAC_INTERVAL;
|
|
|
|
#ifdef AHOY_SML_OBIS_SUPPORT
|
|
if (mConfig->sml_obis.ir_connected) {
|
|
if ((sml_power = sml_find_hist_power(sml_hist, cur_interval)) == INT32_MIN) {
|
|
snprintf (&content[index], length - index, "\n%u:%02u,%u,",
|
|
minutes / 60, minutes % 60, ac_power);
|
|
} else {
|
|
snprintf (&content[index], length - index, "\n%u:%02u,%u,%d",
|
|
minutes / 60, minutes % 60, ac_power, sml_power);
|
|
}
|
|
} else
|
|
#endif
|
|
{
|
|
snprintf (&content[index], length - index, "\n%u:%02u,%u",
|
|
minutes / 60, minutes % 60, ac_power);
|
|
}
|
|
index += strlen (&content[index]);
|
|
}
|
|
#ifdef AHOY_SML_OBIS_SUPPORT
|
|
if (mConfig->sml_obis.ir_connected) {
|
|
sml_close_hist (sml_hist);
|
|
}
|
|
#endif
|
|
response = request->beginResponse(200, F("text/plain"), content);
|
|
free (content);
|
|
} else if (mConfig->sml_obis.ir_connected) {
|
|
response = request->beginResponse(200, F("text/plain"), AHOY_CHARTDATA_WITH_GRID_HDR "\nno memory");
|
|
} else {
|
|
response = request->beginResponse(200, F("text/plain"), AHOY_CHARTDATA_HDR "\nno memory");
|
|
}
|
|
} else if (mConfig->sml_obis.ir_connected) {
|
|
response = request->beginResponse(200, F("text/plain"), AHOY_CHARTDATA_WITH_GRID_HDR "\nno value found");
|
|
} else {
|
|
response = request->beginResponse(200, F("text/plain"), AHOY_CHARTDATA_HDR "\nno value found");
|
|
}
|
|
if (response) {
|
|
response->addHeader("Content-Description", "File Transfer");
|
|
response->addHeader("Content-Disposition", "attachment; filename=chartdata.csv");
|
|
request->send(response);
|
|
} else {
|
|
request->send(404);
|
|
}
|
|
}
|
|
|
|
void getGeneric(AsyncWebServerRequest *request, JsonObject obj) {
|
|
obj[F("wifi_rssi")] = (WiFi.status() != WL_CONNECTED) ? 0 : WiFi.RSSI();
|
|
obj[F("ts_uptime")] = mApp->getUptime();
|
|
obj[F("menu_prot")] = mApp->getProtection(request);
|
|
obj[F("menu_mask")] = (uint16_t)(mConfig->sys.protectionMask );
|
|
obj[F("menu_protEn")] = (bool) (strlen(mConfig->sys.adminPwd) > 0);
|
|
|
|
#if defined(ESP32)
|
|
obj[F("esp_type")] = F("ESP32");
|
|
#else
|
|
obj[F("esp_type")] = F("ESP8266");
|
|
#endif
|
|
}
|
|
|
|
void getSysInfo(AsyncWebServerRequest *request, JsonObject obj) {
|
|
obj[F("ssid")] = mConfig->sys.stationSsid;
|
|
obj[F("device_name")] = mConfig->sys.deviceName;
|
|
obj[F("dark_mode")] = (bool)mConfig->sys.darkMode;
|
|
|
|
obj[F("mac")] = WiFi.macAddress();
|
|
obj[F("hostname")] = mConfig->sys.deviceName;
|
|
obj[F("pwd_set")] = (strlen(mConfig->sys.adminPwd) > 0);
|
|
obj[F("prot_mask")] = mConfig->sys.protectionMask;
|
|
|
|
obj[F("sdk")] = ESP.getSdkVersion();
|
|
obj[F("cpu_freq")] = ESP.getCpuFreqMHz();
|
|
obj[F("heap_free")] = mHeapFree;
|
|
obj[F("sketch_total")] = ESP.getFreeSketchSpace();
|
|
obj[F("sketch_used")] = ESP.getSketchSize() / 1024; // in kb
|
|
getGeneric(request, obj);
|
|
|
|
getRadio(obj.createNestedObject(F("radio")));
|
|
getStatistics(obj.createNestedObject(F("statistics")));
|
|
|
|
#if defined(ESP32)
|
|
obj[F("heap_total")] = ESP.getHeapSize();
|
|
obj[F("chip_revision")] = ESP.getChipRevision();
|
|
obj[F("chip_model")] = ESP.getChipModel();
|
|
obj[F("chip_cores")] = ESP.getChipCores();
|
|
//obj[F("core_version")] = F("n/a");
|
|
//obj[F("flash_size")] = F("n/a");
|
|
//obj[F("heap_frag")] = F("n/a");
|
|
//obj[F("max_free_blk")] = F("n/a");
|
|
//obj[F("reboot_reason")] = F("n/a");
|
|
#else
|
|
//obj[F("heap_total")] = F("n/a");
|
|
//obj[F("chip_revision")] = F("n/a");
|
|
//obj[F("chip_model")] = F("n/a");
|
|
//obj[F("chip_cores")] = F("n/a");
|
|
obj[F("core_version")] = ESP.getCoreVersion();
|
|
obj[F("flash_size")] = ESP.getFlashChipRealSize() / 1024; // in kb
|
|
obj[F("heap_frag")] = mHeapFrag;
|
|
obj[F("max_free_blk")] = mHeapFreeBlk;
|
|
obj[F("reboot_reason")] = ESP.getResetReason();
|
|
#endif
|
|
//obj[F("littlefs_total")] = LittleFS.totalBytes();
|
|
//obj[F("littlefs_used")] = LittleFS.usedBytes();
|
|
|
|
uint8_t max;
|
|
mApp->getSchedulerInfo(&max);
|
|
obj[F("schMax")] = max;
|
|
}
|
|
|
|
void getHtmlSystem(AsyncWebServerRequest *request, JsonObject obj) {
|
|
getSysInfo(request, obj.createNestedObject(F("system")));
|
|
getGeneric(request, obj.createNestedObject(F("generic")));
|
|
obj[F("html")] = F("<a href=\"/factory\" class=\"btn\">Factory Reset</a><br/><br/><a href=\"/reboot\" class=\"btn\">Reboot</a>");
|
|
}
|
|
|
|
void getHtmlLogout(AsyncWebServerRequest *request, JsonObject obj) {
|
|
getGeneric(request, obj.createNestedObject(F("generic")));
|
|
obj[F("refresh")] = 3;
|
|
obj[F("refresh_url")] = "/";
|
|
obj[F("html")] = F("succesfully logged out");
|
|
}
|
|
|
|
void getHtmlReboot(AsyncWebServerRequest *request, JsonObject obj) {
|
|
getGeneric(request, obj.createNestedObject(F("generic")));
|
|
obj[F("refresh")] = 20;
|
|
obj[F("refresh_url")] = "/";
|
|
obj[F("html")] = F("rebooting ...");
|
|
}
|
|
|
|
void getHtmlSave(AsyncWebServerRequest *request, JsonObject obj) {
|
|
getGeneric(request, obj.createNestedObject(F("generic")));
|
|
obj["pending"] = (bool)mApp->getSavePending();
|
|
obj["success"] = (bool)mApp->getLastSaveSucceed();
|
|
obj["reboot"] = (bool)mApp->getShouldReboot();
|
|
}
|
|
|
|
void getReboot(AsyncWebServerRequest *request, JsonObject obj) {
|
|
getGeneric(request, obj.createNestedObject(F("generic")));
|
|
obj[F("refresh")] = 10;
|
|
obj[F("refresh_url")] = "/";
|
|
obj[F("html")] = F("reboot. Autoreload after 10 seconds");
|
|
}
|
|
|
|
void getStatistics(JsonObject obj) {
|
|
statistics_t *stat = mApp->getStatistics();
|
|
obj[F("rx_success")] = stat->rxSuccess;
|
|
obj[F("rx_fail")] = stat->rxFail;
|
|
obj[F("rx_fail_answer")] = stat->rxFailNoAnser;
|
|
obj[F("frame_cnt")] = stat->frmCnt;
|
|
obj[F("tx_cnt")] = mSys->Radio.mSendCnt;
|
|
obj[F("retransmits")] = mSys->Radio.mRetransmits;
|
|
}
|
|
|
|
void getInverterList(JsonObject obj) {
|
|
JsonArray invArr = obj.createNestedArray(F("inverter"));
|
|
|
|
Inverter<> *iv;
|
|
for(uint8_t i = 0; i < MAX_NUM_INVERTERS; i ++) {
|
|
iv = mSys->getInverterByPos(i);
|
|
if(NULL != iv) {
|
|
JsonObject obj2 = invArr.createNestedObject();
|
|
obj2[F("enabled")] = (bool)iv->config->enabled;
|
|
obj2[F("id")] = i;
|
|
obj2[F("name")] = String(iv->config->name);
|
|
obj2[F("serial")] = String(iv->config->serial.u64, HEX);
|
|
obj2[F("channels")] = iv->channels;
|
|
obj2[F("version")] = String(iv->getFwVersion());
|
|
|
|
for(uint8_t j = 0; j < iv->channels; j ++) {
|
|
obj2[F("ch_yield_cor")][j] = iv->config->yieldCor[j];
|
|
obj2[F("ch_name")][j] = iv->config->chName[j];
|
|
obj2[F("ch_max_pwr")][j] = iv->config->chMaxPwr[j];
|
|
}
|
|
}
|
|
}
|
|
obj[F("interval")] = String(mConfig->nrf.sendInterval);
|
|
obj[F("retries")] = String(mConfig->nrf.maxRetransPerPyld);
|
|
obj[F("max_num_inverters")] = MAX_NUM_INVERTERS;
|
|
obj[F("rstMid")] = (bool)mConfig->inst.rstYieldMidNight;
|
|
obj[F("rstNAvail")] = (bool)mConfig->inst.rstValsNotAvail;
|
|
obj[F("rstComStop")] = (bool)mConfig->inst.rstValsCommStop;
|
|
}
|
|
|
|
void getInverter(JsonObject obj, uint8_t id) {
|
|
Inverter<> *iv = mSys->getInverterByPos(id);
|
|
if(NULL != iv) {
|
|
record_t<> *rec = iv->getRecordStruct(RealTimeRunData_Debug);
|
|
obj[F("id")] = id;
|
|
obj[F("enabled")] = (bool)iv->config->enabled;
|
|
obj[F("name")] = String(iv->config->name);
|
|
obj[F("serial")] = String(iv->config->serial.u64, HEX);
|
|
obj[F("version")] = String(iv->getFwVersion());
|
|
obj[F("power_limit_read")] = ah::round3(iv->actPowerLimit);
|
|
obj[F("ts_last_success")] = rec->ts;
|
|
#ifdef AHOY_SML_OBIS_SUPPORT
|
|
if (mConfig->sml_obis.ir_connected) {
|
|
// design: no value of inverter but I want this value to be displayed prominently
|
|
obj[F("grid_power")] = sml_get_obis_pac ();
|
|
}
|
|
#endif
|
|
|
|
JsonArray ch = obj.createNestedArray("ch");
|
|
|
|
// AC
|
|
uint8_t pos;
|
|
obj[F("ch_name")][0] = "AC";
|
|
JsonArray ch0 = ch.createNestedArray();
|
|
for (uint8_t fld = 0; fld < sizeof(acList); fld++) {
|
|
pos = (iv->getPosByChFld(CH0, acList[fld], rec));
|
|
ch0[fld] = (0xff != pos) ? ah::round3(iv->getValue(pos, rec)) : 0.0;
|
|
}
|
|
|
|
// DC
|
|
for(uint8_t j = 0; j < iv->channels; j ++) {
|
|
obj[F("ch_name")][j+1] = iv->config->chName[j];
|
|
obj[F("ch_max_pwr")][j+1] = iv->config->chMaxPwr[j];
|
|
JsonArray cur = ch.createNestedArray();
|
|
for (uint8_t fld = 0; fld < sizeof(dcList); fld++) {
|
|
pos = (iv->getPosByChFld((j+1), dcList[fld], rec));
|
|
cur[fld] = (0xff != pos) ? ah::round3(iv->getValue(pos, rec)) : 0.0;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
void getMqtt(JsonObject obj) {
|
|
obj[F("broker")] = String(mConfig->mqtt.broker);
|
|
obj[F("port")] = String(mConfig->mqtt.port);
|
|
obj[F("user")] = String(mConfig->mqtt.user);
|
|
obj[F("pwd")] = (strlen(mConfig->mqtt.pwd) > 0) ? F("{PWD}") : String("");
|
|
obj[F("topic")] = String(mConfig->mqtt.topic);
|
|
obj[F("interval")] = String(mConfig->mqtt.interval);
|
|
}
|
|
|
|
void getNtp(JsonObject obj) {
|
|
obj[F("addr")] = String(mConfig->ntp.addr);
|
|
obj[F("port")] = String(mConfig->ntp.port);
|
|
}
|
|
|
|
void getSun(JsonObject obj) {
|
|
obj[F("lat")] = mConfig->sun.lat ? String(mConfig->sun.lat, 5) : "";
|
|
obj[F("lon")] = mConfig->sun.lat ? String(mConfig->sun.lon, 5) : "";
|
|
obj[F("disnightcom")] = mConfig->sun.disNightCom;
|
|
obj[F("offs")] = mConfig->sun.offsetSec;
|
|
}
|
|
|
|
void getPinout(JsonObject obj) {
|
|
obj[F("cs")] = mConfig->nrf.pinCs;
|
|
obj[F("ce")] = mConfig->nrf.pinCe;
|
|
obj[F("irq")] = mConfig->nrf.pinIrq;
|
|
obj[F("sclk")] = mConfig->nrf.pinSclk;
|
|
obj[F("mosi")] = mConfig->nrf.pinMosi;
|
|
obj[F("miso")] = mConfig->nrf.pinMiso;
|
|
obj[F("led0")] = mConfig->led.led0;
|
|
obj[F("led1")] = mConfig->led.led1;
|
|
obj[F("led_high_active")] = mConfig->led.led_high_active;
|
|
}
|
|
|
|
void getRadio(JsonObject obj) {
|
|
obj[F("power_level")] = mConfig->nrf.amplifierPower;
|
|
obj[F("isconnected")] = mSys->Radio.isChipConnected();
|
|
obj[F("DataRate")] = mSys->Radio.getDataRate();
|
|
obj[F("isPVariant")] = mSys->Radio.isPVariant();
|
|
}
|
|
|
|
void getSerial(JsonObject obj) {
|
|
obj[F("interval")] = (uint16_t)mConfig->serial.interval;
|
|
obj[F("show_live_data")] = mConfig->serial.showIv;
|
|
obj[F("debug")] = mConfig->serial.debug;
|
|
}
|
|
|
|
void getStaticIp(JsonObject obj) {
|
|
char buf[16];
|
|
ah::ip2Char(mConfig->sys.ip.ip, buf); obj[F("ip")] = String(buf);
|
|
ah::ip2Char(mConfig->sys.ip.mask, buf); obj[F("mask")] = String(buf);
|
|
ah::ip2Char(mConfig->sys.ip.dns1, buf); obj[F("dns1")] = String(buf);
|
|
ah::ip2Char(mConfig->sys.ip.dns2, buf); obj[F("dns2")] = String(buf);
|
|
ah::ip2Char(mConfig->sys.ip.gateway, buf); obj[F("gateway")] = String(buf);
|
|
}
|
|
|
|
void getDisplay(JsonObject obj) {
|
|
obj[F("disp_typ")] = (uint8_t)mConfig->plugin.display.type;
|
|
obj[F("disp_pwr")] = (bool)mConfig->plugin.display.pwrSaveAtIvOffline;
|
|
obj[F("disp_pxshift")] = (bool)mConfig->plugin.display.pxShift;
|
|
obj[F("disp_rot")] = (uint8_t)mConfig->plugin.display.rot;
|
|
obj[F("disp_cont")] = (uint8_t)mConfig->plugin.display.contrast;
|
|
obj[F("disp_clk")] = (mConfig->plugin.display.type == 0) ? DEF_PIN_OFF : mConfig->plugin.display.disp_clk;
|
|
obj[F("disp_data")] = (mConfig->plugin.display.type == 0) ? DEF_PIN_OFF : mConfig->plugin.display.disp_data;
|
|
obj[F("disp_cs")] = (mConfig->plugin.display.type < 3) ? DEF_PIN_OFF : mConfig->plugin.display.disp_cs;
|
|
obj[F("disp_dc")] = (mConfig->plugin.display.type < 3) ? DEF_PIN_OFF : mConfig->plugin.display.disp_dc;
|
|
obj[F("disp_rst")] = (mConfig->plugin.display.type < 3) ? DEF_PIN_OFF : mConfig->plugin.display.disp_reset;
|
|
obj[F("disp_bsy")] = (mConfig->plugin.display.type < 10) ? DEF_PIN_OFF : mConfig->plugin.display.disp_busy;
|
|
}
|
|
|
|
void getSML(JsonObject obj) {
|
|
obj[F("show_grid_data")] = mConfig->sml_obis.ir_connected;
|
|
}
|
|
|
|
void getIndex(AsyncWebServerRequest *request, JsonObject obj) {
|
|
getGeneric(request, obj.createNestedObject(F("generic")));
|
|
obj[F("ts_now")] = mApp->getTimestamp();
|
|
obj[F("ts_sunrise")] = mApp->getSunrise();
|
|
obj[F("ts_sunset")] = mApp->getSunset();
|
|
obj[F("ts_offset")] = mConfig->sun.offsetSec;
|
|
obj[F("disNightComm")] = mConfig->sun.disNightCom;
|
|
|
|
JsonArray inv = obj.createNestedArray(F("inverter"));
|
|
Inverter<> *iv;
|
|
for(uint8_t i = 0; i < MAX_NUM_INVERTERS; i ++) {
|
|
iv = mSys->getInverterByPos(i);
|
|
if(NULL != iv) {
|
|
record_t<> *rec = iv->getRecordStruct(RealTimeRunData_Debug);
|
|
JsonObject invObj = inv.createNestedObject();
|
|
invObj[F("enabled")] = (bool)iv->config->enabled;
|
|
invObj[F("id")] = i;
|
|
invObj[F("name")] = String(iv->config->name);
|
|
invObj[F("version")] = String(iv->getFwVersion());
|
|
invObj[F("is_avail")] = iv->isAvailable(mApp->getTimestamp());
|
|
invObj[F("is_producing")] = iv->isProducing(mApp->getTimestamp());
|
|
invObj[F("ts_last_success")] = iv->getLastTs(rec);
|
|
}
|
|
}
|
|
|
|
JsonArray warn = obj.createNestedArray(F("warnings"));
|
|
if(!mSys->Radio.isChipConnected())
|
|
warn.add(F("your NRF24 module can't be reached, check the wiring and pinout"));
|
|
else if(!mSys->Radio.isPVariant())
|
|
warn.add(F("your NRF24 module isn't a plus version(+), maybe incompatible"));
|
|
if(!mApp->getSettingsValid())
|
|
warn.add(F("your settings are invalid"));
|
|
if(mApp->getRebootRequestState())
|
|
warn.add(F("reboot your ESP to apply all your configuration changes"));
|
|
if(0 == mApp->getTimestamp())
|
|
warn.add(F("time not set. No communication to inverter possible"));
|
|
/*if(0 == mSys->getNumInverters())
|
|
warn.add(F("no inverter configured"));*/
|
|
#ifdef AHOY_MQTT_SUPPORT
|
|
if((!mApp->getMqttIsConnected()) && (String(mConfig->mqtt.broker).length() > 0))
|
|
warn.add(F("MQTT is not connected"));
|
|
JsonArray info = obj.createNestedArray(F("infos"));
|
|
if(mApp->getMqttIsConnected())
|
|
info.add(F("MQTT is connected, ") + String(mApp->getMqttTxCnt()) + F(" packets sent, ") + String(mApp->getMqttRxCnt()) + F(" packets received"));
|
|
if(mConfig->mqtt.interval > 0)
|
|
info.add(F("MQTT publishes in a fixed interval of ") + String(mConfig->mqtt.interval) + F(" seconds"));
|
|
#endif
|
|
}
|
|
|
|
void getSetup(AsyncWebServerRequest *request, JsonObject obj) {
|
|
getGeneric(request, obj.createNestedObject(F("generic")));
|
|
getSysInfo(request, obj.createNestedObject(F("system")));
|
|
//getInverterList(obj.createNestedObject(F("inverter")));
|
|
getMqtt(obj.createNestedObject(F("mqtt")));
|
|
getNtp(obj.createNestedObject(F("ntp")));
|
|
getSun(obj.createNestedObject(F("sun")));
|
|
getPinout(obj.createNestedObject(F("pinout")));
|
|
getRadio(obj.createNestedObject(F("radio")));
|
|
getSerial(obj.createNestedObject(F("serial")));
|
|
getStaticIp(obj.createNestedObject(F("static_ip")));
|
|
getDisplay(obj.createNestedObject(F("display")));
|
|
getSML(obj.createNestedObject(F("sml_obis")));
|
|
}
|
|
|
|
void getNetworks(JsonObject obj) {
|
|
mApp->getAvailNetworks(obj);
|
|
}
|
|
|
|
void getLive(AsyncWebServerRequest *request, JsonObject obj) {
|
|
getGeneric(request, obj.createNestedObject(F("generic")));
|
|
obj[F("refresh")] = mConfig->nrf.sendInterval;
|
|
#ifdef AHOY_SML_OBIS_SUPPORT
|
|
if (mConfig->sml_obis.ir_connected) {
|
|
// additionally here for correct chart titles
|
|
obj[F("grid_power")] = sml_get_obis_pac ();
|
|
}
|
|
#endif
|
|
|
|
for (uint8_t fld = 0; fld < sizeof(acList); fld++) {
|
|
obj[F("ch0_fld_units")][fld] = String(units[fieldUnits[acList[fld]]]);
|
|
obj[F("ch0_fld_names")][fld] = String(fields[acList[fld]]);
|
|
}
|
|
for (uint8_t fld = 0; fld < sizeof(dcList); fld++) {
|
|
obj[F("fld_units")][fld] = String(units[fieldUnits[dcList[fld]]]);
|
|
obj[F("fld_names")][fld] = String(fields[dcList[fld]]);
|
|
}
|
|
|
|
Inverter<> *iv;
|
|
|
|
for(uint8_t i = 0; i < MAX_NUM_INVERTERS; i ++) {
|
|
iv = mSys->getInverterByPos(i);
|
|
bool parse = false;
|
|
if(NULL != iv)
|
|
parse = iv->config->enabled;
|
|
obj[F("iv")][i] = parse;
|
|
}
|
|
}
|
|
|
|
void getRecord(JsonObject obj, uint8_t recType) {
|
|
JsonArray invArr = obj.createNestedArray(F("inverter"));
|
|
|
|
Inverter<> *iv;
|
|
record_t<> *rec;
|
|
uint8_t pos;
|
|
for(uint8_t i = 0; i < MAX_NUM_INVERTERS; i ++) {
|
|
iv = mSys->getInverterByPos(i);
|
|
if(NULL != iv) {
|
|
rec = iv->getRecordStruct(recType);
|
|
JsonArray obj2 = invArr.createNestedArray();
|
|
for(uint8_t j = 0; j < rec->length; j++) {
|
|
byteAssign_t *assign = iv->getByteAssign(j, rec);
|
|
pos = (iv->getPosByChFld(assign->ch, assign->fieldId, rec));
|
|
obj2[j]["fld"] = (0xff != pos) ? String(iv->getFieldName(pos, rec)) : notAvail;
|
|
obj2[j]["unit"] = (0xff != pos) ? String(iv->getUnit(pos, rec)) : notAvail;
|
|
obj2[j]["val"] = (0xff != pos) ? String(iv->getValue(pos, rec)) : notAvail;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
bool setCtrl(JsonObject jsonIn, JsonObject jsonOut) {
|
|
Inverter<> *iv = mSys->getInverterByPos(jsonIn[F("id")]);
|
|
bool accepted = true;
|
|
if(NULL == iv) {
|
|
jsonOut[F("error")] = F("inverter index invalid: ") + jsonIn[F("id")].as<String>();
|
|
return false;
|
|
}
|
|
|
|
if(F("power") == jsonIn[F("cmd")])
|
|
accepted = iv->setDevControlRequest((jsonIn[F("val")] == 1) ? TurnOn : TurnOff);
|
|
else if(F("restart") == jsonIn[F("restart")])
|
|
accepted = iv->setDevControlRequest(Restart);
|
|
else if(0 == strncmp("limit_", jsonIn[F("cmd")].as<const char*>(), 6)) {
|
|
iv->powerLimit[0] = jsonIn["val"];
|
|
if(F("limit_persistent_relative") == jsonIn[F("cmd")])
|
|
iv->powerLimit[1] = RelativPersistent;
|
|
else if(F("limit_persistent_absolute") == jsonIn[F("cmd")])
|
|
iv->powerLimit[1] = AbsolutPersistent;
|
|
else if(F("limit_nonpersistent_relative") == jsonIn[F("cmd")])
|
|
iv->powerLimit[1] = RelativNonPersistent;
|
|
else if(F("limit_nonpersistent_absolute") == jsonIn[F("cmd")])
|
|
iv->powerLimit[1] = AbsolutNonPersistent;
|
|
|
|
accepted = iv->setDevControlRequest(ActivePowerContr);
|
|
}
|
|
else if(F("dev") == jsonIn[F("cmd")]) {
|
|
DPRINTLN(DBG_INFO, F("dev cmd"));
|
|
iv->enqueCommand<InfoCommand>(jsonIn[F("val")].as<int>());
|
|
}
|
|
else {
|
|
jsonOut[F("error")] = F("unknown cmd: '") + jsonIn["cmd"].as<String>() + "'";
|
|
return false;
|
|
}
|
|
|
|
if(!accepted) {
|
|
jsonOut[F("error")] = F("inverter does not accept dev control request at this moment");
|
|
return false;
|
|
} else
|
|
mApp->ivSendHighPrio(iv);
|
|
|
|
return true;
|
|
}
|
|
|
|
bool setSetup(JsonObject jsonIn, JsonObject jsonOut) {
|
|
if(F("scan_wifi") == jsonIn[F("cmd")])
|
|
mApp->scanAvailNetworks();
|
|
else if(F("set_time") == jsonIn[F("cmd")])
|
|
mApp->setTimestamp(jsonIn[F("val")]);
|
|
else if(F("sync_ntp") == jsonIn[F("cmd")])
|
|
mApp->setTimestamp(0); // 0: update ntp flag
|
|
else if(F("serial_utc_offset") == jsonIn[F("cmd")])
|
|
mTimezoneOffset = jsonIn[F("val")];
|
|
#ifdef AHOY_MQTT_SUPPORT
|
|
else if(F("discovery_cfg") == jsonIn[F("cmd")])
|
|
mApp->setMqttDiscoveryFlag(); // for homeassistant
|
|
#endif
|
|
else {
|
|
jsonOut[F("error")] = F("unknown cmd");
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
IApp *mApp;
|
|
HMSYSTEM *mSys;
|
|
AsyncWebServer *mSrv;
|
|
settings_t *mConfig;
|
|
|
|
uint32_t mTimezoneOffset;
|
|
uint32_t mHeapFree, mHeapFreeBlk;
|
|
uint8_t mHeapFrag;
|
|
uint16_t nr;
|
|
};
|
|
|
|
#endif /*__WEB_API_H__*/
|
|
|