From 630d85487c25d2bfa84ebee9fca433b4346b7ea3 Mon Sep 17 00:00:00 2001 From: Jordan Hotmann Date: Thu, 7 Dec 2023 12:45:38 -0700 Subject: [PATCH] Don't use request for attribute changes --- internal/homeassistant/subscriber.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/homeassistant/subscriber.go b/internal/homeassistant/subscriber.go index fed8e44..e245dc7 100644 --- a/internal/homeassistant/subscriber.go +++ b/internal/homeassistant/subscriber.go @@ -144,9 +144,9 @@ func handleMessages() { go nats.SetKeyValueString(fmt.Sprintf("homeassistant.states.%s", message.Event.Data.EntityId), 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.PublishRequest(fmt.Sprintf("homeassistant.attributues.%s.%s", message.Event.Data.EntityId, message.Event.Data.NewState.State), data, defaultTimeout, 2) + nats.Publish(fmt.Sprintf("homeassistant.attributues.%s.%s", message.Event.Data.EntityId, message.Event.Data.NewState.State), data) } else { - nats.Publish(fmt.Sprintf("homeassistant.states.%s.%s", message.Event.Data.EntityId, message.Event.Data.NewState.State), data) + nats.PublishRequest(fmt.Sprintf("homeassistant.states.%s.%s", message.Event.Data.EntityId, message.Event.Data.NewState.State), data, defaultTimeout, 2) } case zhaEventId: data, _ := json.Marshal(message.Event.Data)