chore: add tests for k3s (#391)

Author: sandeepbh5

config/rbac/role.yaml

@@ -28,9 +28,9 @@ rules:
 - apiGroups:
   - controlplane.cluster.x-k8s.io
   resources:
-  - kubeadmcontrolplanetemplates
   - kthreescontrolplanes
-  - kthreescontrolplanetemplates  
+  - kthreescontrolplanetemplates
+  - kubeadmcontrolplanetemplates
   verbs:
   - create
   - delete

examples/cluster_v1alpha1_clustertemplate_k3s.yaml

@@ -0,0 +1,24 @@
+# SPDX-FileCopyrightText: (C) 2026 Intel Corporation
+# SPDX-License-Identifier: Apache-2.0
+
+apiVersion: edge-orchestrator.intel.com/v1alpha1
+kind: ClusterTemplate
+metadata:
+  labels:
+    app.kubernetes.io/name: template-controller
+    app.kubernetes.io/managed-by: kustomize
+  name: clustertemplate-k3s-sample
+spec:
+  controlPlaneProviderType: k3s
+  infraProviderType: intel
+  kubernetesVersion: v1.33.5+k3s1
+  clusterConfiguration: '{"kind":"KThreesControlPlaneTemplate","apiVersion":"controlplane.cluster.x-k8s.io/v1beta2","spec":{"template":{"spec":{"kthreesConfigSpec":{"agentConfig":{"airGapped":false},"preK3sCommands":["echo hello"]}}}}}'
+  clusterNetwork:
+    pods:
+      cidrBlocks:
+      - 10.42.0.0/16
+    services:
+      cidrBlocks:
+      - 10.43.0.0/16
+  clusterLabels:
+    default-extension: baseline

internal/controller/clustertemplate_controller.go

@@ -40,6 +40,8 @@ type ClusterTemplateReconciler struct {
 // +kubebuilder:rbac:groups=infrastructure.cluster.x-k8s.io,resources=intelmachinetemplates,verbs=get;list;watch;create;delete
 // +kubebuilder:rbac:groups=infrastructure.cluster.x-k8s.io,resources=intelclustertemplates,verbs=get;list;watch;create;delete
 // +kubebuilder:rbac:groups=controlplane.cluster.x-k8s.io,resources=kubeadmcontrolplanetemplates,verbs=get;list;watch;create;delete
+// +kubebuilder:rbac:groups=controlplane.cluster.x-k8s.io,resources=kthreescontrolplanes,verbs=get;list;watch;create;delete
+// +kubebuilder:rbac:groups=controlplane.cluster.x-k8s.io,resources=kthreescontrolplanetemplates,verbs=get;list;watch;create;delete
 // +kubebuilder:rbac:groups=cluster.x-k8s.io,resources=clusterclasses,verbs=get;list;watch;create;delete
 // +kubebuilder:rbac:groups=cluster.x-k8s.io,resources=clusters,verbs=get;list;watch;create;delete
 

internal/controller/clustertemplate_controller_test.go

@@ -19,6 +19,8 @@ import (
 	kubeadmcpv1beta1 "sigs.k8s.io/cluster-api/controlplane/kubeadm/api/v1beta1"
 	dockerv1beta1 "sigs.k8s.io/cluster-api/test/infrastructure/docker/api/v1beta1"
 
+	intelv1alpha1 "github.com/open-edge-platform/cluster-api-provider-intel/api/v1alpha1"
+	kthreescpv1beta2 "github.com/k3s-io/cluster-api-k3s/controlplane/api/v1beta2"
 	clusterv1alpha1 "github.com/open-edge-platform/cluster-manager/v2/api/v1alpha1"
 )
 
@@ -134,5 +136,47 @@ var _ = Describe("ClusterTemplate Controller", func() {
 				Expect(err).NotTo(HaveOccurred())
 			},
 		),
+
+		Entry("for K3s CP and Docker Infra",
+			"k3s", "docker", "v1.33.5+k3s1",
+			"{\"kind\":\"KThreesControlPlaneTemplate\",\"apiVersion\":\"controlplane.cluster.x-k8s.io/v1beta2\",\"spec\":{\"template\":{\"spec\":{\"kthreesConfigSpec\":{\"agentConfig\":{\"airGapped\":false},\"preK3sCommands\":[\"echo hello\"]}}}}}",
+			func() {
+				By("validating the DockerMachineTemplate is created")
+				err := k8sClient.Get(ctx, types.NamespacedName{
+					Name:      fmt.Sprintf("%s-controlplane", typeNamespacedName.Name),
+					Namespace: typeNamespacedName.Namespace,
+				}, &dockerv1beta1.DockerMachineTemplate{})
+				Expect(err).NotTo(HaveOccurred())
+
+				By("validating the DockerClusterTemplate is created")
+				err = k8sClient.Get(ctx, typeNamespacedName, &dockerv1beta1.DockerClusterTemplate{})
+				Expect(err).NotTo(HaveOccurred())
+
+				By("validating the KThreesControlPlaneTemplate is created")
+				err = k8sClient.Get(ctx, typeNamespacedName, &kthreescpv1beta2.KThreesControlPlaneTemplate{})
+				Expect(err).NotTo(HaveOccurred())
+			},
+		),
+
+		Entry("for K3s CP and Intel Infra",
+			"k3s", "intel", "v1.33.5+k3s1",
+			"{\"kind\":\"KThreesControlPlaneTemplate\",\"apiVersion\":\"controlplane.cluster.x-k8s.io/v1beta2\",\"spec\":{\"template\":{\"spec\":{\"kthreesConfigSpec\":{\"agentConfig\":{\"airGapped\":false},\"preK3sCommands\":[\"echo hello\"]}}}}}",
+			func() {
+				By("validating the IntelMachineTemplate is created")
+				err := k8sClient.Get(ctx, types.NamespacedName{
+					Name:      fmt.Sprintf("%s-controlplane", typeNamespacedName.Name),
+					Namespace: typeNamespacedName.Namespace,
+				}, &intelv1alpha1.IntelMachineTemplate{})
+				Expect(err).NotTo(HaveOccurred())
+
+				By("validating the IntelClusterTemplate is created")
+				err = k8sClient.Get(ctx, typeNamespacedName, &intelv1alpha1.IntelClusterTemplate{})
+				Expect(err).NotTo(HaveOccurred())
+
+				By("validating the KThreesControlPlaneTemplate is created")
+				err = k8sClient.Get(ctx, typeNamespacedName, &kthreescpv1beta2.KThreesControlPlaneTemplate{})
+				Expect(err).NotTo(HaveOccurred())
+			},
+		),
 	)
 })

internal/controller/suite_test.go

@@ -29,6 +29,8 @@ import (
 
 	// Imports for CAPI resources
 	intelv1alpha1 "github.com/open-edge-platform/cluster-api-provider-intel/api/v1alpha1"
+	kthreesbootstrapv1beta2 "github.com/k3s-io/cluster-api-k3s/bootstrap/api/v1beta2"
+	kthreescpv1beta2 "github.com/k3s-io/cluster-api-k3s/controlplane/api/v1beta2"
 	capi "sigs.k8s.io/cluster-api/api/v1beta1"
 	kubeadmbootstrapv1beta1 "sigs.k8s.io/cluster-api/bootstrap/kubeadm/api/v1beta1"
 	kubeadmcp "sigs.k8s.io/cluster-api/controlplane/kubeadm/api/v1beta1"
@@ -82,6 +84,7 @@ func getModuleVersionFromGoMod(modulePath string) string {
 func buildCRDPaths() []string {
 	capiVersion := getModuleVersionFromGoMod("sigs.k8s.io/cluster-api")
 	intelVersion := getModuleVersionFromGoMod("github.com/open-edge-platform/cluster-api-provider-intel")
+	k3sVersion := getModuleVersionFromGoMod("github.com/k3s-io/cluster-api-k3s")
 
 	modPath := filepath.Join(build.Default.GOPATH, "pkg", "mod")
 
@@ -92,6 +95,9 @@ func buildCRDPaths() []string {
 		// note: cluster-api/test is a separate module with different path structure
 		filepath.Join(modPath, "sigs.k8s.io", "cluster-api", "test@"+capiVersion, "infrastructure", "docker", "config", "crd", "bases"),
 		filepath.Join(modPath, "github.com", "open-edge-platform", "cluster-api-provider-intel@"+intelVersion, "config", "crd", "bases"),
+		// K3s control plane and bootstrap provider CRDs
+		filepath.Join(modPath, "github.com", "k3s-io", "cluster-api-k3s@"+k3sVersion, "controlplane", "config", "crd", "bases"),
+		filepath.Join(modPath, "github.com", "k3s-io", "cluster-api-k3s@"+k3sVersion, "bootstrap", "config", "crd", "bases"),
 	}
 
 	return paths
@@ -126,6 +132,15 @@ var _ = BeforeSuite(func() {
 	err = kubeadmcp.AddToScheme(scheme.Scheme)
 	Expect(err).NotTo(HaveOccurred())
 
+	// ---- K3S CONTROL PLANE PROVIDER ----
+	// Add scheme for K3s bootstrap provider
+	err = kthreesbootstrapv1beta2.AddToScheme(scheme.Scheme)
+	Expect(err).NotTo(HaveOccurred())
+
+	// Add scheme for K3s control plane provider
+	err = kthreescpv1beta2.AddToScheme(scheme.Scheme)
+	Expect(err).NotTo(HaveOccurred())
+
 	// ----  CAPI ----
 	// Add scheme for Cluster API core resources
 	err = capi.AddToScheme(scheme.Scheme)

internal/webhook/v1alpha1/clustertemplate_webhook_test.go

@@ -57,6 +57,17 @@ var _ = Describe("ClusterTemplate Webhook", func() {
 			By("validating the kubeadm template")
 			_, err = validator.ValidateCreate(ctx, kubeadmTemplate)
 			Expect(err).To(BeNil(), "Expected kubeadm template to be valid")
+
+			By("reading the k3s template from file")
+			k3sTemplate := &clusterv1alpha1.ClusterTemplate{}
+			k3sTemplateFile, err := os.ReadFile("../../../examples/cluster_v1alpha1_clustertemplate_k3s.yaml")
+			Expect(err).NotTo(HaveOccurred(), "Failed to read k3s template file")
+			err = yaml.Unmarshal(k3sTemplateFile, k3sTemplate)
+			Expect(err).NotTo(HaveOccurred(), "Failed to unmarshal k3s template")
+
+			By("validating the k3s template")
+			_, err = validator.ValidateCreate(ctx, k3sTemplate)
+			Expect(err).To(BeNil(), "Expected k3s template to be valid")
 		})
 
 		It("Should only allow deletion of ClusterTemplates not in use", func() {})