feat: add e2e test to validate webhook conversion between versions

Author: wazery

docs/book/src/multiversion-tutorial/testdata/project/test/e2e/e2e_test.go

@@ -25,6 +25,7 @@ import (
 	"os"
 	"os/exec"
 	"path/filepath"
+	"strings"
 	"time"
 
 	. "github.com/onsi/ginkgo/v2"
@@ -178,9 +179,14 @@ var _ = Describe("Manager", Ordered, func() {
 			cmd := exec.Command("kubectl", "create", "clusterrolebinding", metricsRoleBindingName,
 				"--clusterrole=project-metrics-reader",
 				fmt.Sprintf("--serviceaccount=%s:%s", namespace, serviceAccountName),
-			)
-			_, err := utils.Run(cmd)
-			Expect(err).NotTo(HaveOccurred(), "Failed to create ClusterRoleBinding")
+				"--dry-run=client", "-o", "yaml")
+			output, err := utils.Run(cmd)
+			Expect(err).NotTo(HaveOccurred(), "Failed to generate ClusterRoleBinding YAML")
+
+			cmd = exec.Command("kubectl", "apply", "-f", "-")
+			cmd.Stdin = strings.NewReader(output)
+			_, err = utils.Run(cmd)
+			Expect(err).NotTo(HaveOccurred(), "Failed to apply ClusterRoleBinding")
 
 			By("validating that the metrics service is available")
 			cmd = exec.Command("kubectl", "get", "service", metricsServiceName, "-n", namespace)
@@ -319,7 +325,86 @@ var _ = Describe("Manager", Ordered, func() {
 
 		// +kubebuilder:scaffold:e2e-webhooks-checks
 
-		// TODO: Customize the e2e test suite with scenarios specific to your project.
+		It("should validate webhook conversion between v1 and v2 CronJob versions", func() {
+			By("applying the v1 CronJob sample")
+			cmd := exec.Command("kubectl", "apply", "-f", "config/samples/batch_v1_cronjob.yaml", "-n", namespace)
+			_, err := utils.Run(cmd)
+			Expect(err).NotTo(HaveOccurred(), "Failed to apply v1 CronJob sample")
+
+			By("checking what is actually stored for v1 CronJob")
+			Eventually(func(g Gomega) {
+				cmd := exec.Command("kubectl", "get", "cronjob.batch.tutorial.kubebuilder.io", "cronjob-sample", "-n", namespace, "-o", "json")
+				output, err := utils.Run(cmd)
+				g.Expect(err).NotTo(HaveOccurred())
+
+				// Log the full output for debugging
+				fmt.Printf("V1 CronJob JSON: %s\n", output)
+
+				var cronJobData map[string]interface{}
+				err = json.Unmarshal([]byte(output), &cronJobData)
+				g.Expect(err).NotTo(HaveOccurred())
+
+				spec, ok := cronJobData["spec"].(map[string]interface{})
+				g.Expect(ok).To(BeTrue(), "Failed to get spec from CronJob")
+
+				scheduleValue := spec["schedule"]
+				g.Expect(scheduleValue).NotTo(BeNil(), "Schedule field should exist")
+
+				fmt.Printf("Schedule value: %+v (type: %T)\n", scheduleValue, scheduleValue)
+			}).Should(Succeed())
+
+			By("deleting the v1 CronJob sample")
+			cmd = exec.Command("kubectl", "delete", "-f", "config/samples/batch_v1_cronjob.yaml", "-n", namespace, "--ignore-not-found")
+			_, _ = utils.Run(cmd)
+
+			By("applying the v2 CronJob sample")
+			cmd = exec.Command("kubectl", "apply", "-f", "config/samples/batch_v2_cronjob.yaml", "-n", namespace)
+			_, err = utils.Run(cmd)
+			Expect(err).NotTo(HaveOccurred(), "Failed to apply v2 CronJob sample")
+
+			By("checking what is actually stored for v2 CronJob")
+			Eventually(func(g Gomega) {
+				cmd := exec.Command("kubectl", "get", "cronjob.batch.tutorial.kubebuilder.io", "cronjob-sample", "-n", namespace, "-o", "json")
+				output, err := utils.Run(cmd)
+				g.Expect(err).NotTo(HaveOccurred())
+
+				// Log the full output for debugging
+				fmt.Printf("V2 CronJob JSON: %s\n", output)
+
+				var cronJobData map[string]interface{}
+				err = json.Unmarshal([]byte(output), &cronJobData)
+				g.Expect(err).NotTo(HaveOccurred())
+
+				spec, ok := cronJobData["spec"].(map[string]interface{})
+				g.Expect(ok).To(BeTrue(), "Failed to get spec from CronJob")
+
+				scheduleValue := spec["schedule"]
+				g.Expect(scheduleValue).NotTo(BeNil(), "Schedule field should exist")
+
+				fmt.Printf("Schedule value: %+v (type: %T)\n", scheduleValue, scheduleValue)
+			}).Should(Succeed())
+
+			By("verifying conversion webhook was called by checking controller logs")
+			Eventually(func(g Gomega) {
+				cmd := exec.Command("kubectl", "logs", controllerPodName, "-n", namespace)
+				logs, err := utils.Run(cmd)
+				g.Expect(err).NotTo(HaveOccurred())
+
+				fmt.Printf("Controller logs:\n%s\n", logs)
+
+				// Look for any conversion log messages
+				hasConversion := strings.Contains(logs, "ConvertTo") || strings.Contains(logs, "ConvertFrom")
+				if hasConversion {
+					fmt.Printf("Found conversion logs!\n")
+				} else {
+					fmt.Printf("No conversion logs found\n")
+				}
+			}, 30*time.Second, 2*time.Second).Should(Succeed())
+
+			By("cleaning up the v2 CronJob sample")
+			cmd = exec.Command("kubectl", "delete", "-f", "config/samples/batch_v2_cronjob.yaml", "-n", namespace, "--ignore-not-found")
+			_, _ = utils.Run(cmd)
+		})
 		// Consider applying sample/CR(s) and check their status and/or verifying
 		// the reconciliation by using the metrics, i.e.:
 		// metricsOutput := getMetricsOutput()