From 853e3fd5f2b4e622d4e35c0e3c2fad6c358cb8ae Mon Sep 17 00:00:00 2001 From: xengineering Date: Sat, 20 Dec 2025 13:00:52 +0100 Subject: Add cache implementation This avoids frequent MQTT messages containing the same state. --- main.go | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) (limited to 'main.go') diff --git a/main.go b/main.go index 6ef4c63..051deef 100644 --- a/main.go +++ b/main.go @@ -35,14 +35,18 @@ func main() { log.Fatalf("Failed startup process: %v", err) } + cache := NewCache(client) + for { start := time.Now() - err = Poll(req, inventory, client) + states, err := Poll(req, inventory) if err != nil { log.Fatalf("Failed to poll states: %v", err) } + cache.Update(states) + WaitUntil(start.Add(POLLING_PERIOD)) } }() @@ -102,21 +106,20 @@ func Stop(c mqtt.Client) { log.Println("Disconnected from MQTT broker.") } -func Poll(req homematic.Requester, inventory homematic.Devices, client mqtt.Client) error { +func Poll(req homematic.Requester, inventory homematic.Devices) (States, error) { + states := make(States) + for _, device := range inventory { if device.Type == `SHUTTER_CONTACT` { state, err := req.GetValue(device.Address) if err != nil { - return fmt.Errorf("Failed to get value: %w", err) + return states, fmt.Errorf("Failed to get value: %w", err) } - - topic := fmt.Sprintf("%s/contact/%s/state", TOPIC_PREFIX, device.Address) - payload := []byte(fmt.Sprintf("%t", state)) - _ = client.Publish(topic, QOS, RETAINED, payload) + states[device.Address] = state } } - return nil + return states, nil } func Await(signals ...syscall.Signal) { -- cgit v1.2.3-70-g09d2