Merge branch origin/feat/support_global_rules

Author: dspo

test/e2e/gatewayapi/gatewayproxy.go

@@ -0,0 +1,223 @@
+package gatewayapi
+
+import (
+	"fmt"
+	"time"
+
+	. "github.com/onsi/ginkgo/v2"
+	. "github.com/onsi/gomega"
+
+	"github.com/api7/api7-ingress-controller/test/e2e/scaffold"
+)
+
+var _ = FDescribe("Test GatewayProxy", func() {
+	s := scaffold.NewDefaultScaffold()
+
+	var defaultGatewayClass = `
+apiVersion: gateway.networking.k8s.io/v1
+kind: GatewayClass
+metadata:
+  name: %s
+spec:
+  controllerName: %s
+`
+
+	var gatewayWithProxy = `
+apiVersion: gateway.networking.k8s.io/v1
+kind: Gateway
+metadata:
+  name: api7
+spec:
+  gatewayClassName: %s
+  listeners:
+    - name: http
+      protocol: HTTP
+      port: 80
+  infrastructure:
+    parametersRef:
+      group: gateway.apisix.io
+      kind: GatewayProxy
+      name: api7-proxy-config
+`
+
+	var gatewayWithoutProxy = `
+apiVersion: gateway.networking.k8s.io/v1
+kind: Gateway
+metadata:
+  name: api7
+spec:
+  gatewayClassName: %s
+  listeners:
+    - name: http
+      protocol: HTTP
+      port: 80
+`
+
+	var gatewayProxyWithEnabledPlugin = `
+apiVersion: gateway.apisix.io/v1alpha1
+kind: GatewayProxy
+metadata:
+  name: api7-proxy-config
+spec:
+  plugins:
+  - name: response-rewrite
+    enabled: true
+    config: 
+      headers:
+        X-Proxy-Test: "enabled"
+`
+
+	var gatewayProxyWithDisabledPlugin = `
+apiVersion: gateway.apisix.io/v1alpha1
+kind: GatewayProxy
+metadata:
+  name: api7-proxy-config
+spec:
+  plugins:
+  - name: response-rewrite
+    enabled: false
+    config: 
+      headers:
+        X-Proxy-Test: "disabled"
+`
+
+	var httpRouteForTest = `
+apiVersion: gateway.networking.k8s.io/v1
+kind: HTTPRoute
+metadata:
+  name: test-route
+spec:
+  parentRefs:
+  - name: %s
+  hostnames:
+  - example.com
+  rules:
+  - matches:
+    - path:
+        type: Exact
+        value: /get
+    backendRefs:
+    - name: httpbin-service-e2e-test
+      port: 80
+`
+
+	var ResourceApplied = func(resourType, resourceName, resourceRaw string, observedGeneration int) {
+		Expect(s.CreateResourceFromString(resourceRaw)).
+			NotTo(HaveOccurred(), fmt.Sprintf("creating %s", resourType))
+
+		Eventually(func() string {
+			hryaml, err := s.GetResourceYaml(resourType, resourceName)
+			Expect(err).NotTo(HaveOccurred(), fmt.Sprintf("getting %s yaml", resourType))
+			return hryaml
+		}, "8s", "2s").
+			Should(
+				SatisfyAll(
+					ContainSubstring(`status: "True"`),
+					ContainSubstring(fmt.Sprintf("observedGeneration: %d", observedGeneration)),
+				),
+				fmt.Sprintf("checking %s condition status", resourType),
+			)
+		time.Sleep(1 * time.Second)
+	}
+
+	var (
+		gatewayClassName string
+	)
+
+	BeforeEach(func() {
+		By("Create GatewayClass")
+		gatewayClassName = fmt.Sprintf("api7-%d", time.Now().Unix())
+		err := s.CreateResourceFromStringWithNamespace(fmt.Sprintf(defaultGatewayClass, gatewayClassName, s.GetControllerName()), "")
+		Expect(err).NotTo(HaveOccurred(), "creating GatewayClass")
+		time.Sleep(5 * time.Second)
+
+		By("Check GatewayClass condition")
+		gcYaml, err := s.GetResourceYaml("GatewayClass", gatewayClassName)
+		Expect(err).NotTo(HaveOccurred(), "getting GatewayClass yaml")
+		Expect(gcYaml).To(ContainSubstring(`status: "True"`), "checking GatewayClass condition status")
+		Expect(gcYaml).To(ContainSubstring("message: the gatewayclass has been accepted by the api7-ingress-controller"), "checking GatewayClass condition message")
+
+		By("Create GatewayProxy with enabled plugin")
+		err = s.CreateResourceFromString(gatewayProxyWithEnabledPlugin)
+		Expect(err).NotTo(HaveOccurred(), "creating GatewayProxy with enabled plugin")
+		time.Sleep(5 * time.Second)
+
+		By("Create Gateway with GatewayProxy")
+		err = s.CreateResourceFromString(fmt.Sprintf(gatewayWithProxy, gatewayClassName))
+		Expect(err).NotTo(HaveOccurred(), "creating Gateway with GatewayProxy")
+		time.Sleep(5 * time.Second)
+
+		By("check Gateway condition")
+		gwyaml, err := s.GetResourceYaml("Gateway", "api7")
+		Expect(err).NotTo(HaveOccurred(), "getting Gateway yaml")
+		Expect(gwyaml).To(ContainSubstring(`status: "True"`), "checking Gateway condition status")
+		Expect(gwyaml).To(ContainSubstring("message: the gateway has been accepted by the api7-ingress-controller"), "checking Gateway condition message")
+	})
+
+	AfterEach(func() {
+		By("Clean up resources")
+		_ = s.DeleteResourceFromString(gatewayProxyWithEnabledPlugin)
+		_ = s.DeleteResourceFromString(gatewayProxyWithDisabledPlugin)
+		_ = s.DeleteResourceFromString(fmt.Sprintf(httpRouteForTest, "api7"))
+		_ = s.DeleteResourceFromString(fmt.Sprintf(gatewayWithProxy, gatewayClassName))
+	})
+
+	Context("Test Gateway with enabled GatewayProxy plugin", func() {
+		It("Should apply plugin configuration when enabled", func() {
+			By("Create HTTPRoute for Gateway with GatewayProxy")
+			ResourceApplied("HTTPRoute", "test-route", fmt.Sprintf(httpRouteForTest, "api7"), 1)
+
+			By("Check if the plugin is applied")
+			resp := s.NewAPISIXClient().
+				GET("/get").
+				WithHost("example.com").
+				Expect().
+				Status(200)
+
+			resp.Header("X-Proxy-Test").IsEqual("enabled")
+		})
+	})
+
+	Context("Test Gateway with disabled GatewayProxy plugin", func() {
+		It("Should not apply plugin configuration when disabled", func() {
+			By("Update GatewayProxy with disabled plugin")
+			err := s.CreateResourceFromString(gatewayProxyWithDisabledPlugin)
+			Expect(err).NotTo(HaveOccurred(), "updating GatewayProxy with disabled plugin")
+			time.Sleep(5 * time.Second)
+
+			By("Create HTTPRoute for Gateway with GatewayProxy")
+			ResourceApplied("HTTPRoute", "test-route", fmt.Sprintf(httpRouteForTest, "api7"), 1)
+
+			By("Check if the plugin is not applied")
+			resp := s.NewAPISIXClient().
+				GET("/get").
+				WithHost("example.com").
+				Expect().
+				Status(200)
+
+			resp.Header("X-Proxy-Test").IsEmpty()
+		})
+	})
+
+	Context("Test Gateway without GatewayProxy", func() {
+		It("Should work normally without GatewayProxy", func() {
+			By("Update Gateway without GatewayProxy")
+			err := s.CreateResourceFromString(fmt.Sprintf(gatewayWithoutProxy, gatewayClassName))
+			Expect(err).NotTo(HaveOccurred(), "updating Gateway without GatewayProxy")
+			time.Sleep(5 * time.Second)
+
+			By("Create HTTPRoute for Gateway without GatewayProxy")
+			ResourceApplied("HTTPRoute", "test-route", fmt.Sprintf(httpRouteForTest, "api7"), 1)
+
+			By("Check if the route works without plugin")
+			resp := s.NewAPISIXClient().
+				GET("/get").
+				WithHost("example.com").
+				Expect().
+				Status(200)
+
+			resp.Header("X-Proxy-Test").IsEmpty()
+		})
+	})
+
+})