fix: consumer provisions feature flags

Signed-off-by: Calum Murray <cmurray@redhat.com>
knative-extensions · Aug 20, 2024 · e07ee21 · e07ee21
1 parent 2263a6b
commit e07ee21
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/control-plane/pkg/reconciler/consumer/consumer.go b/control-plane/pkg/reconciler/consumer/consumer.go
@@ -20,6 +20,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"knative.dev/eventing/pkg/apis/feature"
 	"strings"
 
 	"go.uber.org/zap"
@@ -137,6 +138,9 @@ func (r *Reconciler) reconcileContractResource(ctx context.Context, c *kafkainte
 		Auth:                nil, // Auth will be added by reconcileAuth
 		CloudEventOverrides: reconcileCEOverrides(c),
 		Reference:           userFacingResourceRef,
+		FeatureFlags: &contract.FeatureFlags{
+			EnableEventTypeAutocreate: feature.FromContext(ctx).IsEnabled(feature.EvenTypeAutoCreate),
+		},
 	}
 
 	if err := r.reconcileAuth(ctx, c, resource); err != nil {

diff --git a/control-plane/pkg/reconciler/consumer/consumer_test.go b/control-plane/pkg/reconciler/consumer/consumer_test.go
@@ -132,6 +132,7 @@ func TestReconcileKind(t *testing.T) {
 								Namespace: ConsumerNamespace,
 								Name:      SourceName,
 							},
+							FeatureFlags: FeatureFlagsETAutocreate(false),
 						},
 					},
 				},
@@ -234,6 +235,7 @@ func TestReconcileKind(t *testing.T) {
 								Namespace: ConsumerNamespace,
 								Name:      SourceName,
 							},
+							FeatureFlags: FeatureFlagsETAutocreate(false),
 						},
 					},
 				},
@@ -336,6 +338,7 @@ func TestReconcileKind(t *testing.T) {
 								Namespace: ConsumerNamespace,
 								Name:      SourceName,
 							},
+							FeatureFlags: FeatureFlagsETAutocreate(false),
 						},
 					},
 				},
@@ -451,6 +454,7 @@ func TestReconcileKind(t *testing.T) {
 								Namespace: ConsumerNamespace,
 								Name:      SourceName,
 							},
+							FeatureFlags: FeatureFlagsETAutocreate(false),
 						},
 					},
 				},
@@ -867,6 +871,7 @@ func TestReconcileKind(t *testing.T) {
 								Namespace: ConsumerNamespace,
 								Name:      SourceName,
 							},
+							FeatureFlags: FeatureFlagsETAutocreate(false),
 						},
 					},
 				},