refactor: skip notification via err

bridge/bridge.go

@@ -11,6 +11,10 @@ import (
 	"strings"
 )
 
+var (
+	errSkipNotification = errors.New("notification skipped")
+)
+
 type Handler interface {
 	FormatNotification(r io.Reader) (Notification, error)
 }
@@ -131,16 +135,14 @@ func (b Bridge) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	not, err := b.h.FormatNotification(r.Body)
 	defer r.Body.Close()
 
-	if err != nil {
+	if errors.Is(err, errSkipNotification) {
-		slog.Error("failed to format notification")
+		w.WriteHeader(http.StatusOK)
-		w.WriteHeader(http.StatusBadRequest)
 		return
 	}
 
-	// If notification is empty, that means it should be ignored.
+	if err != nil {
-	// TODO: maybe return an error instead of empty notification
+		slog.Error("failed to format notification")
-	if not.IsEmpty() {
+		w.WriteHeader(http.StatusBadRequest)
-		w.WriteHeader(http.StatusOK)
 		return
 	}
 

bridge/flux.go

@@ -62,7 +62,7 @@ func (f FluxHandler) FormatNotification(r io.Reader) (Notification, error) {
 	if not.Reason == "ReconciliationSucceeded" {
 		if ok := f.reconciliations[obj]; !ok {
 			// Filter out spammy ReconciliationSucceeded notification
-			return Notification{}, nil
+			return Notification{}, errSkipNotification
 		}
 
 		// we will print the object so skip it next time it spam