integration tests added

backends/pkg/reconciler/eventmesh/integration_test.go

@@ -0,0 +1,68 @@
+package eventmesh
+
+import (
+	"context"
+	"testing"
+
+	authenticationv1 "k8s.io/api/authentication/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	kubeclient "knative.dev/pkg/client/injection/kube/client"
+	"knative.dev/reconciler-test/pkg/environment"
+	"knative.dev/reconciler-test/pkg/eventshub"
+	"knative.dev/reconciler-test/pkg/eventshub/assert"
+	"knative.dev/reconciler-test/pkg/feature"
+)
+
+var global environment.GlobalEnvironment
+
+func TestIntegration(t *testing.T) {
+	t.Parallel()
+
+	ctx, env := global.Environment(environment.Managed(t))
+	env.Test(ctx, t, TesAuth())
+}
+
+func TesAuth() *feature.Feature {
+	f := feature.NewFeature()
+
+	authenticatedClientName := feature.MakeRandomK8sName("authenticated-client")
+	unauthenticatedClientName := feature.MakeRandomK8sName("unauthenticated-client")
+
+	SAName := "sa"
+	SANamespace := "default"
+
+	f.Setup("request with authenticated client", func(ctx context.Context, t feature.T) {
+		tr := &authenticationv1.TokenRequest{
+			// TODO: fill up
+		}
+		tr, err := kubeclient.Get(ctx).
+			CoreV1().
+			ServiceAccounts(SANamespace).
+			CreateToken(ctx, SAName, tr, metav1.CreateOptions{})
+		if err != nil {
+			t.Fatal("Failed to create token for SA", err)
+		}
+		eventshub.Install(authenticatedClientName,
+			eventshub.StartSenderURL("TODO_backstage_backend_url"),
+			eventshub.InputHeader("Authorization", "Bearer "+tr.Status.Token),
+			eventshub.InputMethod("GET"),
+		)(ctx, t)
+	})
+
+	f.Setup("request with unauthenticated client", eventshub.Install(
+		unauthenticatedClientName,
+		eventshub.StartSenderURL("localhost:8080"),
+		eventshub.InputMethod("GET")),
+	)
+
+	f.Assert("assert response with authenticated client", assert.OnStore(authenticatedClientName).
+		Match(assert.MatchKind(eventshub.EventResponse)).
+		Match(assert.MatchStatusCode(202)).
+		AtLeast(1))
+	f.Assert("assert response with unauthenticated client", assert.OnStore(unauthenticatedClientName).
+		Match(assert.MatchKind(eventshub.EventResponse)).
+		Match(assert.MatchStatusCode(401)).
+		AtLeast(1))
+
+	return f
+}

go.mod

@@ -13,6 +13,7 @@ require (
 	knative.dev/eventing v0.39.1
 	knative.dev/hack v0.0.0-20231122182901-eb352426ecc1
 	knative.dev/pkg v0.0.0-20231204120332-9386ad6703ee
+	knative.dev/reconciler-test v0.0.0-20231024072442-5fb93a792b99
 )
 
 require (
@@ -103,7 +104,6 @@ require (
 	k8s.io/klog/v2 v2.90.1 // indirect
 	k8s.io/kube-openapi v0.0.0-20230501164219-8b0f38b5fd1f // indirect
 	k8s.io/utils v0.0.0-20230209194617-a36077c30491 // indirect
-	knative.dev/reconciler-test v0.0.0-20231024072442-5fb93a792b99 // indirect
 	sigs.k8s.io/json v0.0.0-20221116044647-bc3834ca7abd // indirect
 	sigs.k8s.io/structured-merge-diff/v4 v4.2.3 // indirect
 	sigs.k8s.io/yaml v1.4.0 // indirect