patrick/OpenDTU-old
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

reinitialize mqqt subscription after reconnect

Browse Source
This commit is contained in:
helgeerbe 2023-03-22 17:47:15 +01:00
parent 5d5124dd5b
commit 55dc4dbdfc
3 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/WebApi_mqtt.cpp
View File

@ -10,6 +10,8 @@
#include "WebApi.h"
#include "WebApi_errors.h"
#include "helper.h"
#include "PowerLimiter.h"
#include "PowerMeter.h"
#include <AsyncJson.h>
void WebApiMqttClass::init(AsyncWebServer* server)
@ -318,6 +320,8 @@ void WebApiMqttClass::onMqttAdminPost(AsyncWebServerRequest* request)
MqttSettings.performReconnect();
MqttHandleHass.forceUpdate();
MqttHandleVedirectHass.forceUpdate();
PowerMeter.init();
PowerLimiter.init();
}
String WebApiMqttClass::getRootCaCertInfo(const char* cert)

7
src/WebApi_powerlimiter.cpp
View File

@ -8,7 +8,9 @@
#include "AsyncJson.h"
#include "Configuration.h"
#include "MqttHandleHass.h"
#include "MqttHandleVedirectHass.h"
#include "MqttSettings.h"
#include "PowerMeter.h"
#include "PowerLimiter.h"
#include "WebApi.h"
#include "helper.h"
@ -141,6 +143,9 @@ void WebApiPowerLimiterClass::onAdminPost(AsyncWebServerRequest* request)
response->setLength();
request->send(response);
MqttSettings.performReconnect(); // TODO(helge) is this really needed
MqttSettings.performReconnect();
PowerLimiter.init();
PowerMeter.init();
MqttHandleHass.forceUpdate();
MqttHandleVedirectHass.forceUpdate();
}

10
src/WebApi_powermeter.cpp
View File

@ -7,8 +7,10 @@
#include "ArduinoJson.h"
#include "AsyncJson.h"
#include "Configuration.h"
#include "MqttHandleVedirectHass.h"
#include "MqttHandleHass.h"
#include "MqttSettings.h"
#include "PowerLimiter.h"
#include "PowerMeter.h"
#include "WebApi.h"
#include "helper.h"
@ -115,9 +117,11 @@ void WebApiPowerMeterClass::onAdminPost(AsyncWebServerRequest* request)
response->setLength();
request->send(response);
MqttSettings.performReconnect();
PowerMeter.init();
MqttSettings.performReconnect();
PowerLimiter.init();
MqttHandleHass.forceUpdate();
MqttHandleVedirectHass.forceUpdate();
}