Add test and fuzz test

Signed-off-by: Adrian Fernandez De La Torre <adri1197@gmail.com>

Author: Adrian Fernandez De La Torre

internal/notifier/otel.go

@@ -1,3 +1,19 @@
+/*
+Copyright 2025 The Flux authors
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
 package notifier
 
 import (

internal/notifier/otel_fuzz_test.go

@@ -0,0 +1,70 @@
+/*
+Copyright 2025 The Flux authors
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package notifier
+
+import (
+	"context"
+	"crypto/tls"
+	"fmt"
+	"io"
+	"net/http"
+	"net/http/httptest"
+	"testing"
+
+	fuzz "github.com/AdaLogics/go-fuzz-headers"
+	eventv1 "github.com/fluxcd/pkg/apis/event/v1beta1"
+)
+
+func Fuzz_Otel(f *testing.F) {
+	f.Add("", "error", "", "commit-hash-1", []byte{}, []byte{})
+	f.Add("", "info", "", "commit-hash-1", []byte{}, []byte{})
+
+	f.Fuzz(func(t *testing.T,
+		urlSuffix, severity, message string, commitHash string, seed, response []byte) {
+		ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+			w.Write(response)
+			io.Copy(io.Discard, r.Body)
+			r.Body.Close()
+		}))
+		defer ts.Close()
+
+		var tlsConfig tls.Config
+		_ = fuzz.NewConsumer(seed).GenerateStruct(&tlsConfig)
+
+		otel, err := NewOTELTraceNotifier(fmt.Sprintf("%s/%s", ts.URL, urlSuffix), "", nil, &tlsConfig)
+		if err != nil {
+			return
+		}
+
+		event := eventv1.Event{}
+		_ = fuzz.NewConsumer(seed).GenerateStruct(&event)
+
+		if event.Metadata == nil {
+			event.Metadata = map[string]string{}
+		}
+
+		event.Severity = severity
+		event.Message = message
+		event.Metadata["revision"] = commitHash
+
+		ctx := context.WithValue(context.TODO(), "alertUID", "test-alert-uid")
+		ctx = context.WithValue(ctx, "alertName", "test-alert")
+		ctx = context.WithValue(ctx, "alertNamespace", "test-namespace")
+
+		_ = otel.Post(context.TODO(), event)
+	})
+}

internal/notifier/otel_test.go

@@ -0,0 +1,67 @@
+/*
+Copyright 2025 The Flux authors
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package notifier
+
+import (
+	"context"
+	"net/http"
+	"net/http/httptest"
+	"testing"
+
+	"github.com/fluxcd/pkg/apis/event/v1beta1"
+	"github.com/stretchr/testify/require"
+)
+
+func TestOTEL_Post(t *testing.T) {
+	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		w.WriteHeader(http.StatusOK)
+
+	}))
+	defer ts.Close()
+
+	tests := []struct {
+		name  string
+		event func() v1beta1.Event
+	}{
+		{
+			name:  "test event",
+			event: testEvent,
+		},
+		{
+			name: "test event with empty metadata",
+			event: func() v1beta1.Event {
+				events := testEvent()
+				events.Metadata = nil
+				return events
+			},
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			ctx := context.WithValue(context.TODO(), "alertUID", "test-alert-uid")
+			ctx = context.WithValue(ctx, "alertName", "test-alert")
+			ctx = context.WithValue(ctx, "alertNamespace", "test-namespace")
+
+			otelTrace, err := NewOTELTraceNotifier(ts.URL, "", nil, nil)
+			require.NoError(t, err)
+
+			err = otelTrace.Post(ctx, tt.event())
+			require.NoError(t, err)
+		})
+	}
+}