pim/lightswitch
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Ensure MQTT messages are only set if state actually changed

Browse Source
This commit is contained in:
Pim van Pelt
2018-11-05 08:04:21 +01:00
parent b7467e3be1
commit 06241f2581
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/channel.c
View File

@ -327,8 +327,10 @@ void channel_override_set(int idx) {
match = timespec_match_now(s_channels[idx].timespec); match = timespec_match_now(s_channels[idx].timespec);
if (match != s_channels[idx].relay_state) { if (match != s_channels[idx].relay_state) {
LOG(LL_INFO, ("User state disagrees with timespec, setting override")); LOG(LL_INFO, ("User state disagrees with timespec, setting override"));
s_channels[idx].channel_override = true; if (!s_channels[idx].channel_override) {
mqtt_publish_stat("override", "{idx: %d, relay_state: %d, override: %B}", idx, s_channels[idx].relay_state, s_channels[idx].channel_override); s_channels[idx].channel_override = true;
mqtt_publish_stat("override", "{idx: %d, relay_state: %d, override: %B}", idx, s_channels[idx].relay_state, s_channels[idx].channel_override);
}
return; return;
} }
if (s_channels[idx].channel_override && (match == s_channels[idx].relay_state)) { if (s_channels[idx].channel_override && (match == s_channels[idx].relay_state)) {
@ -345,8 +347,10 @@ void channel_override_clear(int idx) {
return; return;
} }
s_channels[idx].channel_override = false; if (s_channels[idx].channel_override) {
mqtt_publish_stat("override", "{idx: %d, relay_state: %d, override: %B}", idx, s_channels[idx].relay_state, s_channels[idx].channel_override); mqtt_publish_stat("override", "{idx: %d, relay_state: %d, override: %B}", idx, s_channels[idx].relay_state, s_channels[idx].channel_override);
s_channels[idx].channel_override = false;
}
return; return;
} }