fix: handle error

waku-org · Oct 21, 2023 · 40e7409 · 40e7409
1 parent 0161bcb
commit 40e7409
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/cmd/waku/server/rest/lightpush_rest.go b/cmd/waku/server/rest/lightpush_rest.go
@@ -54,7 +54,8 @@ func (serv *LightpushService) postMessagev1(w http.ResponseWriter, req *http.Req
 
 	if err := msg.Check(); err != nil {
 		w.WriteHeader(http.StatusBadRequest)
-		w.Write([]byte(err.Error()))
+		_, err = w.Write([]byte(err.Error()))
+		serv.log.Error("writing response", zap.Error(err))
 		return
 	}
 	//
@@ -67,7 +68,8 @@ func (serv *LightpushService) postMessagev1(w http.ResponseWriter, req *http.Req
 	_, err := serv.node.Lightpush().Publish(req.Context(), msg.Message, lightpush.WithPubSubTopic(msg.PubSubTopic))
 	if err != nil {
 		w.WriteHeader(http.StatusServiceUnavailable)
-		w.Write([]byte(err.Error()))
+		_, err = w.Write([]byte(err.Error()))
+		serv.log.Error("writing response", zap.Error(err))
 	} else {
 		w.WriteHeader(http.StatusOK)
 	}