Move mqtt dtu topic publishing to separate class

This commit is contained in:
Thomas Basler 2022-12-14 19:32:24 +01:00
parent 723a2c6dbe
commit aab72fd0d8
4 changed files with 54 additions and 8 deletions

15
include/MqttHandleDtu.h Normal file
View File

@ -0,0 +1,15 @@
// SPDX-License-Identifier: GPL-2.0-or-later
#pragma once
#include <Arduino.h>
class MqttHandleDtuClass {
public:
void init();
void loop();
private:
uint32_t _lastPublish;
};
extern MqttHandleDtuClass MqttHandleDtu;

35
src/MqttHandleDtu.cpp Normal file
View File

@ -0,0 +1,35 @@
// SPDX-License-Identifier: GPL-2.0-or-later
/*
* Copyright (C) 2022 Thomas Basler and others
*/
#include "MqttHandleDtu.h"
#include "Configuration.h"
#include "MqttSettings.h"
#include "NetworkSettings.h"
#include <Hoymiles.h>
MqttHandleDtuClass MqttHandleDtu;
void MqttHandleDtuClass::init()
{
}
void MqttHandleDtuClass::loop()
{
if (!MqttSettings.getConnected() || !Hoymiles.getRadio()->isIdle()) {
return;
}
const CONFIG_T& config = Configuration.get();
if (millis() - _lastPublish > (config.Mqtt_PublishInterval * 1000)) {
MqttSettings.publish("dtu/uptime", String(millis() / 1000));
MqttSettings.publish("dtu/ip", NetworkSettings.localIP().toString());
MqttSettings.publish("dtu/hostname", NetworkSettings.getHostname());
if (NetworkSettings.NetworkMode() == network_mode::WiFi) {
MqttSettings.publish("dtu/rssi", String(WiFi.RSSI()));
}
_lastPublish = millis();
}
}

View File

@ -4,7 +4,6 @@
*/
#include "MqttHandleInverter.h"
#include "MqttSettings.h"
#include "NetworkSettings.h"
#include <ctime>
MqttHandleInverterClass MqttHandleInverter;
@ -22,13 +21,6 @@ void MqttHandleInverterClass::loop()
const CONFIG_T& config = Configuration.get();
if (millis() - _lastPublish > (config.Mqtt_PublishInterval * 1000)) {
MqttSettings.publish("dtu/uptime", String(millis() / 1000));
MqttSettings.publish("dtu/ip", NetworkSettings.localIP().toString());
MqttSettings.publish("dtu/hostname", NetworkSettings.getHostname());
if (NetworkSettings.NetworkMode() == network_mode::WiFi) {
MqttSettings.publish("dtu/rssi", String(WiFi.RSSI()));
}
// Loop all inverters
for (uint8_t i = 0; i < Hoymiles.getNumInverters(); i++) {
auto inv = Hoymiles.getInverterByPos(i);

View File

@ -4,6 +4,7 @@
*/
#include "Configuration.h"
#include "Hoymiles.h"
#include "MqttHandleDtu.h"
#include "MqttHandleHass.h"
#include "MqttHandleInverter.h"
#include "MqttSettings.h"
@ -68,6 +69,7 @@ void setup()
// Initialize MqTT
Serial.print(F("Initialize MqTT... "));
MqttSettings.init();
MqttHandleDtu.init();
MqttHandleInverter.init();
MqttHandleHass.init();
Serial.println(F("done"));
@ -133,6 +135,8 @@ void loop()
yield();
Hoymiles.loop();
yield();
MqttHandleDtu.loop();
yield();
MqttHandleInverter.loop();
yield();
MqttHandleHass.loop();