Support SupportedKinds in ListenerStatus

Author: ciarams87

docs/gateway-api-compatibility.md

@@ -97,7 +97,7 @@ Fields:
           Gateway. NKG only supports a single Gateway.
     * `listeners`
         * `name` - supported.
-        * `supportedKinds` - not supported.
+        * `supportedKinds` - supported.
         * `attachedRoutes` - supported.
         * `conditions` - Supported (Condition/Status/Reason):
             * `Accepted/True/Accepted`

internal/state/change_processor_test.go

@@ -451,6 +451,7 @@ var _ = Describe("ChangeProcessor", func() {
 								Routes: map[types.NamespacedName]*graph.Route{
 									{Namespace: "test", Name: "hr-1"}: expRouteHR1,
 								},
+								SupportedKinds: []v1beta1.RouteGroupKind{{Kind: "HTTPRoute"}},
 							},
 							"listener-443-1": {
 								Source: gw1.Spec.Listeners[1],
@@ -459,6 +460,7 @@ var _ = Describe("ChangeProcessor", func() {
 									{Namespace: "test", Name: "hr-1"}: expRouteHR1,
 								},
 								ResolvedSecret: helpers.GetPointer(client.ObjectKeyFromObject(diffNsTLSSecret)),
+								SupportedKinds: []v1beta1.RouteGroupKind{{Kind: "HTTPRoute"}},
 							},
 						},
 						Valid: true,
@@ -544,6 +546,7 @@ var _ = Describe("ChangeProcessor", func() {
 						Conditions: conditions.NewListenerRefNotPermitted(
 							"Certificate ref to secret cert-ns/different-ns-tls-secret not permitted by any ReferenceGrant",
 						),
+						SupportedKinds: []v1beta1.RouteGroupKind{{Kind: "HTTPRoute"}},
 					}
 
 					expAttachment := &graph.ParentRefAttachmentStatus{

internal/state/graph/gateway_listener.go

@@ -28,6 +28,8 @@ type Listener struct {
 	ResolvedSecret *types.NamespacedName
 	// Conditions holds the conditions of the Listener.
 	Conditions []conditions.Condition
+	// SupportedKinds is the list of RouteGroupKinds allowed by the listener.
+	SupportedKinds []v1beta1.RouteGroupKind
 	// Valid shows whether the Listener is valid.
 	// A Listener is considered valid if NKG can generate valid NGINX configuration for it.
 	Valid bool
@@ -87,7 +89,6 @@ func newListenerConfiguratorFactory(
 		},
 		http: &listenerConfigurator{
 			validators: []listenerValidator{
-				validateListenerAllowedRouteKind,
 				validateListenerLabelSelector,
 				validateListenerHostname,
 				validateHTTPListener,
@@ -98,7 +99,6 @@ func newListenerConfiguratorFactory(
 		},
 		https: &listenerConfigurator{
 			validators: []listenerValidator{
-				validateListenerAllowedRouteKind,
 				validateListenerLabelSelector,
 				validateListenerHostname,
 				createHTTPSListenerValidator(),
@@ -158,11 +158,15 @@ func (c *listenerConfigurator) configure(listener v1beta1.Listener) *Listener {
 		}
 	}
 
+	cnds, supportedKinds := getAndValidateSupportedKinds(listener)
+	conds = append(conds, cnds...)
+
 	if len(conds) > 0 {
 		return &Listener{
-			Source:     listener,
-			Conditions: conds,
-			Valid:      false,
+			Source:         listener,
+			Conditions:     conds,
+			Valid:          false,
+			SupportedKinds: supportedKinds,
 		}
 	}
 
@@ -171,6 +175,7 @@ func (c *listenerConfigurator) configure(listener v1beta1.Listener) *Listener {
 		AllowedRouteLabelSelector: allowedRouteSelector,
 		Routes:                    make(map[types.NamespacedName]*Route),
 		Valid:                     true,
+		SupportedKinds:            supportedKinds,
 	}
 
 	// resolvers might add different conditions to the listener, so we run them all.
@@ -206,7 +211,18 @@ func validateListenerHostname(listener v1beta1.Listener) []conditions.Condition
 	return nil
 }
 
-func validateListenerAllowedRouteKind(listener v1beta1.Listener) []conditions.Condition {
+func getAndValidateSupportedKinds(listener v1beta1.Listener) ([]conditions.Condition, []v1beta1.RouteGroupKind) {
+	if listener.AllowedRoutes == nil || listener.AllowedRoutes.Kinds == nil {
+		return nil, []v1beta1.RouteGroupKind{
+			{
+				Kind: "HTTPRoute",
+			},
+		}
+	}
+	var conds []conditions.Condition
+
+	supportedKinds := make([]v1beta1.RouteGroupKind, 0, len(listener.AllowedRoutes.Kinds))
+
 	validHTTPRouteKind := func(kind v1beta1.RouteGroupKind) bool {
 		if kind.Kind != v1beta1.Kind("HTTPRoute") {
 			return false
@@ -219,17 +235,16 @@ func validateListenerAllowedRouteKind(listener v1beta1.Listener) []conditions.Co
 
 	switch listener.Protocol {
 	case v1beta1.HTTPProtocolType, v1beta1.HTTPSProtocolType:
-		if listener.AllowedRoutes != nil {
-			for _, kind := range listener.AllowedRoutes.Kinds {
-				if !validHTTPRouteKind(kind) {
-					msg := fmt.Sprintf("Unsupported route kind \"%s/%s\"", *kind.Group, kind.Kind)
-					return conditions.NewListenerInvalidRouteKinds(msg)
-				}
+		for _, kind := range listener.AllowedRoutes.Kinds {
+			if !validHTTPRouteKind(kind) {
+				msg := fmt.Sprintf("Unsupported route kind \"%s/%s\"", *kind.Group, kind.Kind)
+				conds = append(conds, conditions.NewListenerInvalidRouteKinds(msg)...)
+				continue
 			}
+			supportedKinds = append(supportedKinds, kind)
 		}
 	}
-
-	return nil
+	return conds, supportedKinds
 }
 
 func validateListenerLabelSelector(listener v1beta1.Listener) []conditions.Condition {

internal/state/graph/gateway_listener_test.go

@@ -220,17 +220,27 @@ func TestValidateListenerHostname(t *testing.T) {
 }
 
 func TestValidateListenerAllowedRouteKind(t *testing.T) {
+	expectedKinds := []v1beta1.RouteGroupKind{
+		{
+			Kind:  "HTTPRoute",
+			Group: helpers.GetPointer[v1beta1.Group](v1beta1.GroupName),
+		},
+	}
 	tests := []struct {
 		protocol  v1beta1.ProtocolType
 		kind      v1beta1.Kind
 		group     v1beta1.Group
 		name      string
+		expected  []v1beta1.RouteGroupKind
 		expectErr bool
 	}{
 		{
 			protocol:  v1beta1.TCPProtocolType,
 			expectErr: false,
 			name:      "unsupported protocol is ignored",
+			kind:      "TCPRoute",
+			group:     v1beta1.GroupName,
+			expected:  []v1beta1.RouteGroupKind{},
 		},
 		{
 			protocol:  v1beta1.HTTPProtocolType,
@@ -252,37 +262,58 @@ func TestValidateListenerAllowedRouteKind(t *testing.T) {
 			kind:      "HTTPRoute",
 			expectErr: false,
 			name:      "valid HTTP",
+			expected:  expectedKinds,
 		},
 		{
 			protocol:  v1beta1.HTTPSProtocolType,
 			group:     v1beta1.GroupName,
 			kind:      "HTTPRoute",
 			expectErr: false,
 			name:      "valid HTTPS",
+			expected:  expectedKinds,
+		},
+		{
+			protocol:  v1beta1.HTTPSProtocolType,
+			expectErr: false,
+			name:      "valid HTTPS no kind specified",
+			expected: []v1beta1.RouteGroupKind{
+				{
+					Kind: "HTTPRoute",
+				},
+			},
 		},
 	}
 
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
 			g := NewGomegaWithT(t)
+			var listener v1beta1.Listener
 
-			listener := v1beta1.Listener{
-				Protocol: test.protocol,
-				AllowedRoutes: &v1beta1.AllowedRoutes{
-					Kinds: []v1beta1.RouteGroupKind{
-						{
-							Kind:  test.kind,
-							Group: &test.group,
+			if test.kind != "" {
+				listener = v1beta1.Listener{
+					Protocol: test.protocol,
+					AllowedRoutes: &v1beta1.AllowedRoutes{
+						Kinds: []v1beta1.RouteGroupKind{
+							{
+								Kind:  test.kind,
+								Group: &test.group,
+							},
 						},
 					},
-				},
+				}
+			} else {
+				listener = v1beta1.Listener{
+					Protocol: test.protocol,
+				}
 			}
 
-			conds := validateListenerAllowedRouteKind(listener)
+			conds, kinds := getAndValidateSupportedKinds(listener)
 			if test.expectErr {
 				g.Expect(conds).ToNot(BeEmpty())
+				g.Expect(kinds).To(BeEmpty())
 			} else {
 				g.Expect(conds).To(BeEmpty())
+				g.Expect(helpers.Diff(test.expected, kinds)).To(BeEmpty())
 			}
 		})
 	}