diff --git a/internal/domains/sensors/handlers.go b/internal/domains/sensors/handlers.go index 27c2c6f..ab3248b 100644 --- a/internal/domains/sensors/handlers.go +++ b/internal/domains/sensors/handlers.go @@ -31,9 +31,11 @@ func NewHandlers(service *Service, iot *iot.IoTDevice) *Handlers { func handleRequest[Req any, Res any](msg *nats.Msg, handler func(Req) (Res, error)) { var req Req - if err := json.Unmarshal(msg.Data, &req); err != nil { - msg.Respond([]byte(`{"error":"invalid request"}`)) - return + if len(msg.Data) > 0 { + if err := json.Unmarshal(msg.Data, &req); err != nil { + msg.Respond([]byte(`{"error":"invalid request"}`)) + return + } } result, err := handler(req)