Move new trigger tests to conformance suite

test/conformance/main_test.go

@@ -27,11 +27,14 @@ import (
 	"testing"
 
 	"knative.dev/pkg/system"
+	pkgtest "knative.dev/pkg/test"
 
 	"knative.dev/eventing/test"
 	testlib "knative.dev/eventing/test/lib"
 	"knative.dev/eventing/test/lib/setupclientoptions"
 	"knative.dev/pkg/test/zipkin"
+
+	"knative.dev/reconciler-test/pkg/environment"
 )
 
 const (
@@ -44,6 +47,8 @@ var sourcesTestRunner testlib.ComponentsTestRunner
 var brokerTestRunner testlib.ComponentsTestRunner
 var brokerClass string
 
+var global environment.GlobalEnvironment
+
 func TestMain(m *testing.M) {
 	os.Exit(func() int {
 		test.InitializeEventingFlags()
@@ -65,6 +70,12 @@ func TestMain(m *testing.M) {
 		}
 		brokerClass = test.BrokerClass
 
+		cfg, err := pkgtest.Flags.GetRESTConfig()
+		if err != nil {
+			panic("failed to get rest config")
+		}
+		global = environment.NewGlobalEnvironmentWithRestConfig(cfg)
+
 		addSourcesInitializers()
 		// Any tests may SetupZipkinTracing, it will only actually be done once. This should be the ONLY
 		// place that cleans it up. If an individual test calls this instead, then it will break other

test/rekt/new_trigger_filters_test.go → test/conformance/new_trigger_filters_test.go

@@ -17,7 +17,7 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-package rekt
+package conformance
 
 import (
 	"testing"

vendor/knative.dev/reconciler-test/pkg/environment/standard.go

@@ -1,4 +1,4 @@
 /*
 Copyright 2022 The Knative Authors
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
@@ -86,6 +86,40 @@
 	return NewGlobalEnvironment(ctx, startInformers)
 }
 
+func NewGlobalEnvironmentWithRestConfig(cfg *rest.Config, opts ...ConfigurationOption) GlobalEnvironment {
+	opts = append(opts, initIstioFlags())
+	config := resolveConfiguration(opts)
+	config.Config = cfg
+	ctx := testlog.NewContext(config.Context)
+
+	InitFlags(config.Flags.Get(ctx))
+
+	// We get a chance to parse flags to include the framework flags for the
+	// framework as well as any additional flags included in the integration.
+	if err := config.Flags.Parse(ctx); err != nil {
+		logging.FromContext(ctx).Fatal(err)
+	}
+
+	if ipFilePath != nil && *ipFilePath != "" {
+		ctx = withImageProducer(ctx, file.ImageProducer(*ipFilePath))
+	}
+
+	if testNamespace != nil && *testNamespace != "" {
+		ctx = withNamespace(ctx, *testNamespace)
+	}
+
+	// EnableInjectionOrDie will enable client injection, this is used by the
+	// testing framework for namespace management, and could be leveraged by
+	// features to pull Kubernetes clients or the test environment out of the
+	// context passed in the features.
+	var startInformers func()
+	ctx, startInformers = injection.EnableInjectionOrDie(ctx, config.Config)
+
+	// global is used to make instances of Environments, NewGlobalEnvironment
+	// is passing and saving the client injection enabled context for use later.
+	return NewGlobalEnvironment(ctx, startInformers)
+}
+
 func resolveConfiguration(opts []ConfigurationOption) Configuration {
 	cfg := Configuration{
 		Flags:   commandlineFlags{},