Add e2e test for Parallel

knative · May 8, 2024 · 32f59d4 · 32f59d4
1 parent 0599d49
commit 32f59d4
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/test/rekt/features/parallel/oidc_feature.go b/test/rekt/features/parallel/oidc_feature.go
@@ -144,7 +144,19 @@ func ParallelWithTwoBranchesOIDC(channelTemplate channel_template.ChannelTemplat
 		Must("deliver event from subscriber 2 to reply", assert.OnStore(sink).
 			MatchEvent(test.HasId(event.ID()), test.HasData([]byte("appended data 2"))).
 			AtLeast(1),
-		)
+		).
+		Must("use parallels identity for OIDC to subscriber1", assert.OnStore(subscriber1).MatchWithContext(
+			assert.MatchKind(eventshub.EventReceived).WithContext(),
+			assert.MatchOIDCUserFromResource(parallel.GVR(), parallelName)).AtLeast(1)).
+		Must("use parallels identity for OIDC to subscriber2", assert.OnStore(subscriber2).MatchWithContext(
+			assert.MatchKind(eventshub.EventReceived).WithContext(),
+			assert.MatchOIDCUserFromResource(parallel.GVR(), parallelName)).AtLeast(1)).
+		Must("use parallels identity for OIDC to filter1", assert.OnStore(filter1).MatchWithContext(
+			assert.MatchKind(eventshub.EventReceived).WithContext(),
+			assert.MatchOIDCUserFromResource(parallel.GVR(), parallelName)).AtLeast(1)).
+		Must("use parallels identity for OIDC to sink", assert.OnStore(sink).MatchWithContext(
+			assert.MatchKind(eventshub.EventReceived).WithContext(),
+			assert.MatchOIDCUserFromResource(parallel.GVR(), parallelName)).AtLeast(1))
 
 	return f
 }