fix: allow user rules to overwrite default passthrough rule

Signed-off-by: Mike Beaumont <mjboamail@gmail.com>
kumahq · Jan 5, 2023 · ed4f1ad · ed4f1ad
1 parent ff06e06
commit ed4f1ad
Show file tree

Hide file tree

Showing 3 changed files with 60 additions and 26 deletions.
diff --git a/pkg/plugins/policies/meshhttproute/plugin/v1alpha1/listeners.go b/pkg/plugins/policies/meshhttproute/plugin/v1alpha1/listeners.go
@@ -85,6 +85,27 @@ func FindRoutes(
 ) []Route {
 	var unmergedRules []RuleAcc
 
+	// Prepend a rule to passthrough unmatched traffic
+	rules = append([]ToRouteRule{{
+		Subset: core_xds.MeshService(serviceName),
+		Rules: []api.Rule{{
+			Matches: []api.Match{{
+				Path: api.PathMatch{
+					Prefix: "/",
+				},
+			}},
+			Default: api.RuleConf{
+				BackendRefs: &[]api.BackendRef{{
+					TargetRef: common_api.TargetRef{
+						Kind: common_api.MeshService,
+						Name: serviceName,
+					},
+					Weight: 100,
+				}},
+			},
+		}},
+	}}, rules...)
+
 	for _, rule := range rules {
 		if !rule.Subset.IsSubset(core_xds.MeshService(serviceName)) {
 			continue
@@ -132,23 +153,6 @@ func FindRoutes(
 		routes = append(routes, route)
 	}
 
-	// append the default route
-	routes = append(routes, Route{
-		Matches: []api.Match{{
-			Path: api.PathMatch{
-				Prefix: "/",
-			},
-		}},
-		Filters: nil,
-		BackendRefs: []api.BackendRef{{
-			TargetRef: common_api.TargetRef{
-				Kind: common_api.MeshService,
-				Name: serviceName,
-			},
-			Weight: 100,
-		}},
-	})
-
 	return routes
 }
 

diff --git a/pkg/plugins/policies/meshhttproute/plugin/v1alpha1/plugin_test.go b/pkg/plugins/policies/meshhttproute/plugin/v1alpha1/plugin_test.go
@@ -194,6 +194,18 @@ var _ = Describe("MeshHTTPRoute", func() {
 		}},
 		serviceName: "backend",
 		expectedRoutes: []plugin.Route{{
+			Matches: []api.Match{{
+				Path: api.PathMatch{
+					Prefix: "/",
+				},
+			}},
+			BackendRefs: []api.BackendRef{
+				{
+					TargetRef: builders.TargetRefService("backend"),
+					Weight:    100,
+				},
+			},
+		}, {
 			Matches: []api.Match{{
 				Path: api.PathMatch{
 					Prefix: "/v1",
@@ -217,21 +229,39 @@ var _ = Describe("MeshHTTPRoute", func() {
 					Weight:    100,
 				},
 			},
-		}, {
+		}},
+	}), Entry("overwrite-passthrough-rule", routesTestCase{
+		rules: []plugin.ToRouteRule{{
+			Subset: core_xds.MeshService("backend"),
+			Rules: []api.Rule{{
+				Matches: []api.Match{{
+					Path: api.PathMatch{
+						Prefix: "/",
+					},
+				}},
+				Default: api.RuleConf{
+					BackendRefs: &[]api.BackendRef{{
+						TargetRef: builders.TargetRefService("other-service"),
+						Weight:    100,
+					}},
+				},
+			}},
+		}},
+		serviceName: "backend",
+		expectedRoutes: []plugin.Route{{
 			Matches: []api.Match{{
 				Path: api.PathMatch{
 					Prefix: "/",
 				},
 			}},
 			BackendRefs: []api.BackendRef{
 				{
-					TargetRef: builders.TargetRefService("backend"),
+					TargetRef: builders.TargetRefService("other-service"),
 					Weight:    100,
 				},
 			},
 		}},
-	}),
-	)
+	}))
 	type outboundsTestCase struct {
 		proxy      core_xds.Proxy
 		xdsContext xds_context.Context

diff --git a/pkg/plugins/policies/meshhttproute/plugin/v1alpha1/testdata/basic.listeners.golden.yaml b/pkg/plugins/policies/meshhttproute/plugin/v1alpha1/testdata/basic.listeners.golden.yaml
@@ -28,19 +28,19 @@ resources:
               name: backend
               routes:
               - match:
-                  prefix: /v1
+                  prefix: /
                 route:
                   cluster: backend
                   timeout: 0s
               - match:
-                  prefix: /v2
+                  prefix: /v1
                 route:
-                  cluster: backend-_0_
+                  cluster: backend
                   timeout: 0s
               - match:
-                  prefix: /
+                  prefix: /v2
                 route:
-                  cluster: backend
+                  cluster: backend-_0_
                   timeout: 0s
           statPrefix: backend
     metadata: