Added test for multiple sinks, multiple triggers (#7350)

Signed-off-by: Calum Murray <cmurray@redhat.com>
knative · Oct 19, 2023 · 4d14c21 · 4d14c21
1 parent a261e06
commit 4d14c21
Show file tree

Hide file tree

Showing 2 changed files with 97 additions and 0 deletions.
diff --git a/test/rekt/features/new_trigger_filters/feature.go b/test/rekt/features/new_trigger_filters/feature.go
@@ -258,3 +258,84 @@ func AllFilterFeature(brokerName string) *feature.Feature {
 
 	return f
 }
+
+func MultipleTriggersAndSinksFeature(brokerName string) *feature.Feature {
+	f := feature.NewFeature()
+
+	eventContextsFirstSink := []CloudEventsContext{
+		{
+			eventType:     "type1",
+			shouldDeliver: true,
+		},
+		{
+			eventType:     "both.should.match",
+			shouldDeliver: true,
+		},
+		{
+			eventType:     "type2",
+			shouldDeliver: false,
+		},
+		{
+			eventType:     "type3",
+			shouldDeliver: false,
+		},
+	}
+
+	filtersFirstTrigger := []eventingv1.SubscriptionsAPIFilter{
+		{
+			Any: []eventingv1.SubscriptionsAPIFilter{
+				{
+					Exact: map[string]string{
+						"type": "type1",
+					},
+				},
+				{
+					Prefix: map[string]string{
+						"type": "both",
+					},
+				},
+			},
+		},
+	}
+
+	eventContextsSecondSink := []CloudEventsContext{
+		{
+			eventType:     "type1",
+			shouldDeliver: false,
+		},
+		{
+			eventType:     "both.should.match",
+			shouldDeliver: true,
+		},
+		{
+			eventType:     "type2",
+			shouldDeliver: true,
+		},
+		{
+			eventType:     "type3",
+			shouldDeliver: false,
+		},
+	}
+
+	filtersSecondTrigger := []eventingv1.SubscriptionsAPIFilter{
+		{
+			Any: []eventingv1.SubscriptionsAPIFilter{
+				{
+					Exact: map[string]string{
+						"type": "type2",
+					},
+				},
+				{
+					Prefix: map[string]string{
+						"type": "both",
+					},
+				},
+			},
+		},
+	}
+
+	f = newEventFilterFeature(eventContextsFirstSink, filtersFirstTrigger, f, brokerName)
+	f = newEventFilterFeature(eventContextsSecondSink, filtersSecondTrigger, f, brokerName)
+
+	return f
+}
diff --git a/test/rekt/new_trigger_filters_test.go b/test/rekt/new_trigger_filters_test.go
@@ -79,3 +79,19 @@ func TestMTChannelBrokerAllTriggerFilters(t *testing.T) {
 	env.Prerequisite(ctx, t, broker.InstallMTBroker(brokerName))
 	env.Test(ctx, t, newfilters.AllFilterFeature(brokerName))
 }
+
+func TestMultipleSinksMultipleTriggers(t *testing.T) {
+	t.Parallel()
+
+	ctx, env := global.Environment(
+		knative.WithKnativeNamespace(system.Namespace()),
+		knative.WithLoggingConfig,
+		knative.WithTracingConfig,
+		k8s.WithEventListener,
+		environment.Managed(t),
+	)
+	brokerName := "default"
+
+	env.Prerequisite(ctx, t, broker.InstallMTBroker(brokerName))
+	env.Test(ctx, t, newfilters.MultipleTriggersAndSinksFeature(brokerName))
+}