fix: custom backend weight not set properly

internal/gatewayapi/route.go

@@ -1427,7 +1427,11 @@ func (t *Translator) processDestination(name string, backendRefContext BackendRe
 		if t.isCustomBackendResource(backendRef.Group, KindDerefOr(backendRef.Kind, resource.KindService)) {
 			// Add the custom backend resource to ExtensionRefFilters so it can be processed by the extension system
 			unstructuredRef = t.processBackendExtensions(backendRef.BackendObjectReference, backendNamespace, resources)
-			return nil, unstructuredRef, nil
+			return &ir.DestinationSetting{
+				Name:            name,
+				Weight:          &weight,
+				IsCustomBackend: true,
+			}, unstructuredRef, nil
 		}
 	}
 

internal/gatewayapi/testdata/extensions/httproute-with-custom-backend-invalid-apiversion.out.yaml

@@ -130,8 +130,16 @@ xdsIR:
         mergeSlashes: true
       port: 10080
       routes:
-      - directResponse:
-          statusCode: 500
+      - destination:
+          metadata:
+            kind: HTTPRoute
+            name: httproute-1
+            namespace: default
+          name: httproute/default/httproute-1/rule/1
+          settings:
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/1/backend/0
+            weight: 1
         hostname: gateway.envoyproxy.io
         isHTTP2: false
         metadata:
@@ -143,8 +151,16 @@ xdsIR:
           distinct: false
           name: ""
           prefix: /lambda
-      - directResponse:
-          statusCode: 500
+      - destination:
+          metadata:
+            kind: HTTPRoute
+            name: httproute-1
+            namespace: default
+          name: httproute/default/httproute-1/rule/0
+          settings:
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/0/backend/0
+            weight: 1
         hostname: gateway.envoyproxy.io
         isHTTP2: false
         metadata:

internal/gatewayapi/testdata/extensions/httproute-with-custom-backend-mixed-multiple.out.yaml

@@ -160,6 +160,12 @@ xdsIR:
             name: httproute/default/httproute-1/rule/0/backend/0
             protocol: HTTP
             weight: 1
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/0/backend/1
+            weight: 1
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/0/backend/2
+            weight: 1
         extensionRefs:
         - object:
             apiVersion: storage.example.io/v1alpha1
@@ -199,6 +205,12 @@ xdsIR:
             namespace: default
           name: httproute/default/httproute-1/rule/1
           settings:
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/1/backend/0
+            weight: 1
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/1/backend/1
+            weight: 1
           - addressType: IP
             endpoints:
             - host: 7.7.7.7

internal/gatewayapi/testdata/extensions/httproute-with-custom-backend-mixed.out.yaml

@@ -152,6 +152,9 @@ xdsIR:
             name: httproute/default/httproute-1/rule/0/backend/0
             protocol: HTTP
             weight: 1
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/0/backend/1
+            weight: 1
         extensionRefs:
         - object:
             apiVersion: storage.example.io/v1alpha1
@@ -181,6 +184,9 @@ xdsIR:
             namespace: default
           name: httproute/default/httproute-1/rule/1
           settings:
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/1/backend/0
+            weight: 1
           - addressType: IP
             endpoints:
             - host: 7.7.7.7

internal/gatewayapi/testdata/extensions/httproute-with-custom-backend-multiple.out.yaml

@@ -138,8 +138,19 @@ xdsIR:
         mergeSlashes: true
       port: 10080
       routes:
-      - directResponse:
-          statusCode: 500
+      - destination:
+          metadata:
+            kind: HTTPRoute
+            name: httproute-1
+            namespace: default
+          name: httproute/default/httproute-1/rule/0
+          settings:
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/0/backend/0
+            weight: 1
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/0/backend/1
+            weight: 1
         extensionRefs:
         - object:
             apiVersion: storage.example.io/v1alpha1
@@ -172,8 +183,19 @@ xdsIR:
           distinct: false
           name: ""
           prefix: /service
-      - directResponse:
-          statusCode: 500
+      - destination:
+          metadata:
+            kind: HTTPRoute
+            name: httproute-1
+            namespace: default
+          name: httproute/default/httproute-1/rule/1
+          settings:
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/1/backend/0
+            weight: 1
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/1/backend/1
+            weight: 1
         extensionRefs:
         - object:
             apiVersion: storage.example.io/v1alpha1

internal/gatewayapi/testdata/extensions/httproute-with-custom-backend.out.yaml

@@ -130,8 +130,16 @@ xdsIR:
         mergeSlashes: true
       port: 10080
       routes:
-      - directResponse:
-          statusCode: 500
+      - destination:
+          metadata:
+            kind: HTTPRoute
+            name: httproute-1
+            namespace: default
+          name: httproute/default/httproute-1/rule/1
+          settings:
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/1/backend/0
+            weight: 1
         extensionRefs:
         - object:
             apiVersion: compute.example.io/v1alpha1
@@ -154,8 +162,16 @@ xdsIR:
           distinct: false
           name: ""
           prefix: /lambda
-      - directResponse:
-          statusCode: 500
+      - destination:
+          metadata:
+            kind: HTTPRoute
+            name: httproute-1
+            namespace: default
+          name: httproute/default/httproute-1/rule/0
+          settings:
+          - isCustomBackend: true
+            name: httproute/default/httproute-1/rule/0/backend/0
+            weight: 1
         extensionRefs:
         - object:
             apiVersion: storage.example.io/v1alpha1

internal/ir/xds.go

@@ -1600,6 +1600,8 @@ func (r *RouteDestination) ToBackendWeights() *BackendWeights {
 		switch {
 		case s.IsDynamicResolver: // Dynamic resolver has no endpoints
 			w.Valid += *s.Weight
+		case s.IsCustomBackend: // Custom backends has no endpoints
+			w.Valid += *s.Weight
 		case len(s.Endpoints) > 0:
 			w.Valid += *s.Weight
 		default:
@@ -1620,6 +1622,9 @@ type DestinationSetting struct {
 	// A dynamic resolver is a destination that is resolved dynamically using the request's host header.
 	IsDynamicResolver bool `json:"isDynamicResolver,omitempty" yaml:"isDynamicResolver,omitempty"`
 
+	// IsCustomBackend specifies whether the destination is a custom backend.
+	IsCustomBackend bool `json:"isCustomBackend,omitempty" yaml:"isCustomBackend,omitempty"`
+
 	// Weight associated with this destination,
 	// invalid endpoints are represents with a
 	// non-zero weight with an empty endpoints list

internal/provider/kubernetes/controller.go

@@ -657,7 +657,7 @@ func (r *gatewayAPIReconciler) processBackendRefs(ctx context.Context, gwcResour
 				}
 				if !resourceMappings.allAssociatedBackendRefExtensionFilters.Has(key) {
 					resourceMappings.allAssociatedBackendRefExtensionFilters.Insert(key)
-					if extRefFilter, exists := resourceMappings.extensionRefFilters[key]; !exists {
+					if extRefFilter, exists := resourceMappings.extensionRefFilters[key]; exists {
 						resourceMappings.extensionRefFilters[key] = extRefFilter
 						gwcResource.ExtensionRefFilters = append(gwcResource.ExtensionRefFilters, extRefFilter)
 						r.log.Info("added custom backend resource to resource tree",

internal/provider/kubernetes/controller_test.go

@@ -318,18 +318,8 @@ func TestProcessBackendRefsWithCustomBackends(t *testing.T) {
 
 			// Call the function under test
 			require.NoError(t, r.processBackendRefs(ctx, gwcResource, resourceMappings))
-
-			// Verify results
-			// Note: Due to a bug in the current implementation (line 542 in controller.go),
-			// custom backends are not properly added to ExtensionRefFilters when they exist
-			// in the extensionRefFilters map. The logic should be `exists` instead of `!exists`.
-			// For now, we test the current (buggy) behavior.
-			if tc.name == "skip non-custom backends" {
-				require.Len(t, gwcResource.ExtensionRefFilters, tc.expectedExtFiltersCount)
-			} else {
-				// Current buggy behavior: custom backends are not added to ExtensionRefFilters
-				require.Empty(t, gwcResource.ExtensionRefFilters)
-			}
+			// Compare the results
+			require.Len(t, gwcResource.ExtensionRefFilters, tc.expectedExtFiltersCount)
 
 			for _, expectedNS := range tc.expectedNamespaces {
 				require.True(t, resourceMappings.allAssociatedNamespaces.Has(expectedNS))