Adding feature flag

Signed-off-by: Ahmed Abdalla <aabdelre@redhat.com>

Author: devguyio

config/core/configmaps/features.yaml

@@ -39,3 +39,8 @@ data:
   # ALPHA feature: The subscriber-strict flag force subscriptions to define a subscriber
   # For more details: https://github.com/knative/eventing/issues/5756
   strict-subscriber: "disabled"
+
+  # ALPHA feature: The new-trigger-filters flag allows you to use the new `filters` field
+  # in Trigger objects with its rich filtering capabilities.
+  # For more details: https://github.com/knative/eventing/issues/5204
+  new-trigger-filters: "disabled"

pkg/apis/eventing/v1/trigger_validation.go

@@ -22,6 +22,8 @@ import (
 	"fmt"
 	"regexp"
 
+	"knative.dev/eventing/pkg/apis/feature"
+
 	"knative.dev/eventing/pkg/apis/eventing"
 
 	corev1 "k8s.io/api/core/v1"
@@ -55,7 +57,7 @@ func (ts *TriggerSpec) Validate(ctx context.Context) (errs *apis.FieldError) {
 	return errs.Also(
 		ValidateAttributeFilters(ts.Filter).ViaField("filter"),
 	).Also(
-		ValidateSubscriptionAPIFiltersList(ts.Filters).ViaField("filters"),
+		ValidateSubscriptionAPIFiltersList(ctx, ts.Filters).ViaField("filters"),
 	).Also(
 		ts.Subscriber.Validate(ctx).ViaField("subscriber"),
 	).Also(
@@ -181,19 +183,19 @@ func ValidateSingleAttributeMap(expr map[string]string) (errs *apis.FieldError)
 	return errs
 }
 
-func ValidateSubscriptionAPIFiltersList(filters []SubscriptionsAPIFilter) (errs *apis.FieldError) {
-	if filters == nil {
+func ValidateSubscriptionAPIFiltersList(ctx context.Context, filters []SubscriptionsAPIFilter) (errs *apis.FieldError) {
+	if filters == nil || !feature.FromContext(ctx).IsEnabled(feature.NewTriggerFilters) {
 		return nil
 	}
 
 	for i, f := range filters {
 		f := f
-		errs = errs.Also(ValidateSubscriptionAPIFilter(&f)).ViaIndex(i)
+		errs = errs.Also(ValidateSubscriptionAPIFilter(ctx, &f)).ViaIndex(i)
 	}
 	return errs
 }
 
-func ValidateSubscriptionAPIFilter(filter *SubscriptionsAPIFilter) (errs *apis.FieldError) {
+func ValidateSubscriptionAPIFilter(ctx context.Context, filter *SubscriptionsAPIFilter) (errs *apis.FieldError) {
 	if filter == nil {
 		return nil
 	}
@@ -206,10 +208,10 @@ func ValidateSubscriptionAPIFilter(filter *SubscriptionsAPIFilter) (errs *apis.F
 	).Also(
 		ValidateSingleAttributeMap(filter.Suffix).ViaField("suffix"),
 	).Also(
-		ValidateSubscriptionAPIFiltersList(filter.All).ViaField("all"),
+		ValidateSubscriptionAPIFiltersList(ctx, filter.All).ViaField("all"),
 	).Also(
-		ValidateSubscriptionAPIFiltersList(filter.Any).ViaField("any"),
-	).Also(ValidateSubscriptionAPIFilter(filter.Not).ViaField("not"))
+		ValidateSubscriptionAPIFiltersList(ctx, filter.Any).ViaField("any"),
+	).Also(ValidateSubscriptionAPIFilter(ctx, filter.Not).ViaField("not"))
 	return errs
 }
 

pkg/apis/eventing/v1/trigger_validation_test.go

@@ -21,6 +21,8 @@ import (
 	"fmt"
 	"testing"
 
+	"knative.dev/eventing/pkg/apis/feature"
+
 	"github.com/google/go-cmp/cmp"
 	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
@@ -488,6 +490,9 @@ func TestTriggerSpecValidation(t *testing.T) {
 }
 
 func TestFilterSpecValidation(t *testing.T) {
+	newTriggerFiltersEnabledCtx := feature.ToContext(context.TODO(), feature.Flags{
+		feature.NewTriggerFilters: feature.Enabled,
+	})
 	tests := []struct {
 		name    string
 		filter  *TriggerFilter
@@ -727,7 +732,7 @@ func TestFilterSpecValidation(t *testing.T) {
 				Filters:    test.filters,
 				Subscriber: validSubscriber,
 			}
-			got := ts.Validate(context.TODO())
+			got := ts.Validate(newTriggerFiltersEnabledCtx)
 			if diff := cmp.Diff(test.want.Error(), got.Error()); diff != "" {
 				t.Errorf("Validate TriggerSpec (-want, +got) =\n%s", diff)
 			}

pkg/apis/feature/flag_names.go

@@ -21,4 +21,5 @@ const (
 	DeliveryTimeout   = "delivery-timeout"
 	KReferenceMapping = "kreference-mapping"
 	StrictSubscriber  = "strict-subscriber"
+	NewTriggerFilters = "new-trigger-filters"
 )