andry/EMS-ESP32
1
0
Fork 0
mirror of https://github.com/emsesp/EMS-ESP32.git synced 2025-12-17 21:29:52 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2821 from MichaelDvP/dev

Browse Source 
mqtt publish on change: wait for queue empty
This commit is contained in:
Proddy
2025-12-16 22:35:30 +01:00
committed by GitHub
parent f8cc688241 1890948924
commit 15d895fd0a
3 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/core/analogsensor.cpp
View File

@@ -600,7 +600,7 @@ bool AnalogSensor::update(uint8_t gpio, const char * org_name, double offset, do
// check to see if values have been updated // check to see if values have been updated
bool AnalogSensor::updated_values() { bool AnalogSensor::updated_values() {
if (changed_) { if (changed_ && Mqtt::publish_queued() == 0) {
changed_ = false; changed_ = false;
return true; return true;
} }

14
src/core/emsesp.cpp
View File

@@ -1191,15 +1191,19 @@ bool EMSESP::process_telegram(std::shared_ptr<const Telegram> telegram) {
found_device = emsdevice.get(); found_device = emsdevice.get();
if (emsdevice->handle_telegram(telegram)) { if (emsdevice->handle_telegram(telegram)) {
telegram_found = true; telegram_found = true;
if (Mqtt::connected() if (Mqtt::connected()) {
&& ((mqtt_.get_publish_onchange(found_device->device_type()) && found_device->has_update()) // publish device data if it was a validate after write
|| (telegram->type_id == publish_id_ && telegram->dest == EMSbus::ems_bus_id()))) { if (telegram->type_id == publish_id_ && telegram->dest == EMSbus::ems_bus_id()) {
if (telegram->type_id == publish_id_) {
publish_id_ = 0; publish_id_ = 0;
found_device->has_update(false); // reset flag
publish_device_values(found_device->device_type()); // publish to MQTT if we explicitly have too
} }
// auto publish: timeinterval 0 and publish single not set, only if queue is empty
else if (mqtt_.get_publish_onchange(found_device->device_type()) && found_device->has_update() && mqtt_.publish_queued() == 0) {
found_device->has_update(false); // reset flag found_device->has_update(false); // reset flag
if (!Mqtt::publish_single()) { if (!Mqtt::publish_single()) {
publish_device_values(found_device->device_type()); // publish to MQTT if we explicitly have too publish_device_values(found_device->device_type());
}
} }
} }
break; // remove this to handle same telegrams on multiple devices break; // remove this to handle same telegrams on multiple devices

2
src/core/temperaturesensor.cpp
View File

@@ -370,7 +370,7 @@ bool TemperatureSensor::update(const char * id, const char * name, int16_t offse
// check to see if values have been updated // check to see if values have been updated
bool TemperatureSensor::updated_values() { bool TemperatureSensor::updated_values() {
if (changed_) { if (changed_ && Mqtt::publish_queued() == 0) {
changed_ = false; changed_ = false;
return true; return true;
} }