feat: add flux formatter

bridge/flux.go

@@ -0,0 +1,59 @@
+package bridge
+
+import (
+	"encoding/json"
+	"fmt"
+	"io"
+	"log/slog"
+	"strings"
+	"time"
+)
+
+type FluxNotification struct {
+	InvolvedObject struct {
+		APIVersion string `json:"apiVersion"`
+		Kind       string `json:"kind"`
+		Name       string `json:"name"`
+		Namespace  string `json:"namespace"`
+		UID        string `json:"uid"`
+	} `json:"involvedObject"`
+	Metadata struct {
+		KustomizeToolkitFluxcdIoRevision string `json:"kustomize.toolkit.fluxcd.io/revision"`
+	} `json:"metadata"`
+	Severity            string    `json:"severity"`
+	Reason              string    `json:"reason"`
+	Message             string    `json:"message"`
+	ReportingController string    `json:"reportingController"`
+	ReportingInstance   string    `json:"reportingInstance"`
+	Timestamp           time.Time `json:"timestamp"`
+}
+
+type FluxHandler struct{}
+
+func NewFluxHandler() FluxHandler {
+	return FluxHandler{}
+}
+
+func (f FluxHandler) FormatNotification(r io.Reader) (Notification, error) {
+	l := slog.With(slog.String("handler", "flux"))
+	dec := json.NewDecoder(r)
+
+	var not FluxNotification
+	if err := dec.Decode(&not); err != nil {
+		l.Error("invalid message format in flux", "error", err)
+		return Notification{}, err
+	}
+
+	title := fmt.Sprintf("[%s] %s %s/%s.%s", not.Severity, not.Reason,
+		strings.ToLower(not.InvolvedObject.Kind), not.InvolvedObject.Namespace, not.InvolvedObject.Name)
+	body := not.Message + "\n\n**revision**\n" + not.Metadata.KustomizeToolkitFluxcdIoRevision
+
+	l.Debug("flux notification", slog.Group("notification",
+		slog.String("title", title),
+		slog.String("body", body)))
+	return Notification{
+		Title:      title,
+		Body:       body,
+		IsMarkdown: true,
+	}, nil
+}