jhot
/
hats
1
0
Fork 0
Code Actions

Request in goroutine

main
Jordan Hotmann 2023-12-06 22:30:51 -07:00
parent 45192b0c1c
commit fe87cd50c7
No known key found for this signature in database
GPG Key ID: 01B504170C2A2EA3
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/homeassistant/subscriber.go
View File

@ -156,8 +156,7 @@ func handleMessages() {
data, _ := json.Marshal(message.Event.Data) data, _ := json.Marshal(message.Event.Data)
nats.Publish(fmt.Sprintf("homeassistant.zwave-scene.%s", message.Event.Data.DeviceId), data) nats.Publish(fmt.Sprintf("homeassistant.zwave-scene.%s", message.Event.Data.DeviceId), data)
case timerFinishedEventId: case timerFinishedEventId:
// nats.PublishString(fmt.Sprintf("homeassistant.%s.finished", message.Event.Data.EntityId), "finished") go nats.PublishRequest(fmt.Sprintf("homeassistant.%s.finished", message.Event.Data.EntityId), []byte("finished"), 500*time.Millisecond, 3)
nats.PublishRequest(fmt.Sprintf("homeassistant.%s.finished", message.Event.Data.EntityId), []byte("finished"), 500*time.Millisecond, 3)
} }
} }
} }

2
internal/nats/client.go
View File

@ -94,7 +94,7 @@ func PublishRequest(subject string, message []byte, timeout time.Duration, retri
resp, err := client.Conn.Request(subject, message, timeout) resp, err := client.Conn.Request(subject, message, timeout)
if err == nil { if err == nil {
logger.Debug("Request response received", "response", string(resp.Data)) logger.Debug("Request response received", "response", string(resp.Data), "attempts", attempts)
return return
} }
} }