From 24c1a4636015c345b6851122c9e08ed749d51ea5 Mon Sep 17 00:00:00 2001 From: Jordan Hotmann Date: Tue, 21 May 2024 16:30:36 -0600 Subject: [PATCH] Request for attributes --- internal/homeassistant/subscriber.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/homeassistant/subscriber.go b/internal/homeassistant/subscriber.go index 4a3d4b0..96e4e18 100644 --- a/internal/homeassistant/subscriber.go +++ b/internal/homeassistant/subscriber.go @@ -147,7 +147,7 @@ func handleMessages() { cleanedState := stateReplacer.Replace(message.Event.Data.NewState.State) if message.Event.Data.NewState.State == message.Event.Data.OldState.State { logger.Debug("State unchanged, publishing to attributes topic") - nats.Publish(fmt.Sprintf("homeassistant.attributes.%s.%s", message.Event.Data.EntityId, cleanedState), data) + nats.PublishRequest(fmt.Sprintf("homeassistant.attributes.%s.%s", message.Event.Data.EntityId, cleanedState), data, defaultTimeout, 1) } else { nats.PublishRequest(fmt.Sprintf("homeassistant.states.%s.%s", message.Event.Data.EntityId, cleanedState), data, defaultTimeout, 2) }