50635ee2ce
the update frequency of Victron MPPT charger data, the battery Soc, the huawei charger power, and the power meter differ from one another, and differ in particular from the inverter update frequency. the OnBattery-specific data is now handled in a new method, outside the upstream code, which merely call the new function(s). the new function will update the websocket independently from inverter updates. also, it adds the respective data if it actually changed since it was last updated through the websocket. for the webapp to be able to recover in case of errors, all values are also written to the websocket with a fixed interval of 10 seconds.
47 lines
1.6 KiB
C++
47 lines
1.6 KiB
C++
// SPDX-License-Identifier: GPL-2.0-or-later
|
|
#pragma once
|
|
|
|
#include "Configuration.h"
|
|
#include <ArduinoJson.h>
|
|
#include <ESPAsyncWebServer.h>
|
|
#include <Hoymiles.h>
|
|
#include <TaskSchedulerDeclarations.h>
|
|
|
|
class WebApiWsLiveClass {
|
|
public:
|
|
WebApiWsLiveClass();
|
|
void init(AsyncWebServer& server, Scheduler& scheduler);
|
|
|
|
private:
|
|
static void generateInverterCommonJsonResponse(JsonObject& root, std::shared_ptr<InverterAbstract> inv);
|
|
static void generateInverterChannelJsonResponse(JsonObject& root, std::shared_ptr<InverterAbstract> inv);
|
|
static void generateCommonJsonResponse(JsonVariant& root);
|
|
|
|
void generateOnBatteryJsonResponse(JsonVariant& root, bool all);
|
|
void sendOnBatteryStats();
|
|
|
|
static void addField(JsonObject& root, std::shared_ptr<InverterAbstract> inv, const ChannelType_t type, const ChannelNum_t channel, const FieldId_t fieldId, String topic = "");
|
|
static void addTotalField(JsonObject& root, const String& name, const float value, const String& unit, const uint8_t digits);
|
|
|
|
void onLivedataStatus(AsyncWebServerRequest* request);
|
|
void onWebsocketEvent(AsyncWebSocket* server, AsyncWebSocketClient* client, AwsEventType type, void* arg, uint8_t* data, size_t len);
|
|
|
|
AsyncWebSocket _ws;
|
|
|
|
uint32_t _lastPublishOnBatteryFull = 0;
|
|
uint32_t _lastPublishVictron = 0;
|
|
uint32_t _lastPublishHuawei = 0;
|
|
uint32_t _lastPublishBattery = 0;
|
|
uint32_t _lastPublishPowerMeter = 0;
|
|
|
|
uint32_t _lastPublishStats[INV_MAX_COUNT] = { 0 };
|
|
|
|
std::mutex _mutex;
|
|
|
|
Task _wsCleanupTask;
|
|
void wsCleanupTaskCb();
|
|
|
|
Task _sendDataTask;
|
|
void sendDataTaskCb();
|
|
};
|