diff --git a/coap/api/transport.go b/coap/api/transport.go index 417c24255fc..fcbcb315be6 100644 --- a/coap/api/transport.go +++ b/coap/api/transport.go @@ -107,7 +107,7 @@ func handler(w mux.ResponseWriter, m *mux.Message) { isObs, err = handleGet(context.Background(), m, w, msg, key) case codes.POST: resp.Code = codes.Created - err = nil + err = service.Publish(m.Context(), key, msg) default: err = svcerr.ErrNotFound } diff --git a/coap/client.go b/coap/client.go index ea8a52e17a4..08a26f36f8f 100644 --- a/coap/client.go +++ b/coap/client.go @@ -102,5 +102,8 @@ func (c *client) Handle(msg *messaging.Message) error { for _, option := range opts { pm.SetOptionBytes(option.ID, option.Value) } - return c.client.Conn().WriteMessage(pm) + if err = c.client.Conn().WriteMessage(pm); err != nil { + return err + } + return nil }