Add logs and improve error handling

kyma-project · Sep 12, 2023 · ea88ae0 · ea88ae0
1 parent f57472d
commit ea88ae0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/hack/e2e/sink/cmd/main.go b/hack/e2e/sink/cmd/main.go
@@ -22,6 +22,6 @@ func main() {
 	sHandler := handler.NewSinkHandler(logger)
 	err = sHandler.Start(port)
 	if err != nil {
-		logger.Error("failed to start SinkHandler", zap.Error(err))
+		logger.Fatal("failed to start SinkHandler", zap.Error(err))
 	}
 }
diff --git a/hack/e2e/sink/internal/handler/handler.go b/hack/e2e/sink/internal/handler/handler.go
@@ -49,9 +49,6 @@ type sinkEvent struct {
 }
 
 func (h *SinkHandler) StoreEvent(w http.ResponseWriter, r *http.Request) {
-
-	// TODO: event received information with headers and body
-
 	event, err := extractCloudEventFromRequest(r)
 	if err != nil {
 		h.namedLogger().With().Error("failed to extract CloudEvent from request", zap.Error(err))
@@ -61,6 +58,7 @@ func (h *SinkHandler) StoreEvent(w http.ResponseWriter, r *http.Request) {
 		}
 		return
 	}
+	h.namedLogger().With().Info("received", zap.String("event", event.String()))
 
 	// store the event in memory
 	h.events[event.ID()] = &sinkEvent{