Added webhook for validating port against 6443 and kubebuilder tags t…

…o avoid duplicates.
kubernetes-sigs · May 20, 2024 · 94dbb22 · 94dbb22
1 parent bfb33f1
commit 94dbb22
Show file tree

Hide file tree

Showing 2 changed files with 56 additions and 8 deletions.
diff --git a/api/v1beta2/ibmpowervscluster_webhook.go b/api/v1beta2/ibmpowervscluster_webhook.go
@@ -17,6 +17,7 @@ limitations under the License.
 package v1beta2
 
 import (
+	"fmt"
 	"strconv"
 
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
@@ -78,7 +79,7 @@ func (r *IBMPowerVSCluster) validateIBMPowerVSCluster() (admission.Warnings, err
 	}
 
 	if err := r.validateIBMPowerVSClusterCreateInfraPrereq(); err != nil {
-		allErrs = append(allErrs, err)
+		allErrs = append(allErrs, err...)
 	}
 
 	if len(allErrs) == 0 {
@@ -97,7 +98,42 @@ func (r *IBMPowerVSCluster) validateIBMPowerVSClusterNetwork() *field.Error {
 	return nil
 }
 
-func (r *IBMPowerVSCluster) validateIBMPowerVSClusterCreateInfraPrereq() *field.Error {
+func (r *IBMPowerVSCluster) validateIBMPowerVSClusterLoadBalancerPort() (allErrs field.ErrorList) {
+	for i, loadbalancer := range r.Spec.LoadBalancers {
+		for j, listerner := range loadbalancer.AdditionalListeners {
+			if listerner.Port == int64(DefaultAPIServerPort) {
+				allErrs = append(allErrs, field.Invalid(field.NewPath("spec", fmt.Sprintf("loadbalancers[%d]", i), fmt.Sprintf("additionalListeners[%d]", j), "port"), listerner.Port, fmt.Sprintf("value of port should not be equal to (%d) as Port (%d) will be by default configured to loadbalancer ", DefaultAPIServerPort, DefaultAPIServerPort)))
+			}
+		}
+	}
+	return allErrs
+}
+
+func (r *IBMPowerVSCluster) validateIBMPowerVSClusterLoadBalancerNames() (allErrs field.ErrorList) {
+	found := make(map[string]bool)
+	for i, loadbalancer := range r.Spec.LoadBalancers {
+		if found[loadbalancer.Name] {
+			allErrs = append(allErrs, field.Duplicate(field.NewPath("spec", fmt.Sprintf("loadbalancers[%d]", i)), map[string]interface{}{"Name": loadbalancer.Name}))
+		}
+		found[loadbalancer.Name] = true
+	}
+
+	return allErrs
+}
+
+func (r *IBMPowerVSCluster) validateIBMPowerVSClusterVPCSubnetNames() (allErrs field.ErrorList) {
+	found := make(map[string]bool)
+	for i, subnet := range r.Spec.VPCSubnets {
+		if found[*subnet.Name] {
+			allErrs = append(allErrs, field.Duplicate(field.NewPath("spec", fmt.Sprintf("vpcSubnets[%d]", i)), map[string]interface{}{"Name": *subnet.Name}))
+		}
+		found[*subnet.Name] = true
+	}
+
+	return allErrs
+}
+
+func (r *IBMPowerVSCluster) validateIBMPowerVSClusterCreateInfraPrereq() (allErrs field.ErrorList) {
 	annotations := r.GetAnnotations()
 	if len(annotations) == 0 {
 		return nil
@@ -110,28 +146,39 @@ func (r *IBMPowerVSCluster) validateIBMPowerVSClusterCreateInfraPrereq() *field.
 
 	createInfra, err := strconv.ParseBool(value)
 	if err != nil {
-		return field.Invalid(field.NewPath("annotations"), r.Annotations, "value of powervs.cluster.x-k8s.io/create-infra should be boolean")
+		allErrs = append(allErrs, field.Invalid(field.NewPath("annotations"), r.Annotations, "value of powervs.cluster.x-k8s.io/create-infra should be boolean"))
 	}
 
 	if !createInfra {
 		return nil
 	}
 
 	if r.Spec.Zone == nil {
-		return field.Invalid(field.NewPath("spec.zone"), r.Spec.Zone, "value of zone is empty")
+		allErrs = append(allErrs, field.Invalid(field.NewPath("spec.zone"), r.Spec.Zone, "value of zone is empty"))
 	}
 
 	if r.Spec.VPC == nil {
-		return field.Invalid(field.NewPath("spec.vpc"), r.Spec.VPC, "value of VPC is empty")
+		allErrs = append(allErrs, field.Invalid(field.NewPath("spec.vpc"), r.Spec.VPC, "value of VPC is empty"))
 	}
 
 	if r.Spec.VPC.Region == nil {
-		return field.Invalid(field.NewPath("spec.vpc.region"), r.Spec.VPC.Region, "value of VPC region is empty")
+		allErrs = append(allErrs, field.Invalid(field.NewPath("spec.vpc.region"), r.Spec.VPC.Region, "value of VPC region is empty"))
 	}
 
 	if r.Spec.ResourceGroup == nil {
-		return field.Invalid(field.NewPath("spec.resourceGroup"), r.Spec.ResourceGroup, "value of resource group is empty")
+		allErrs = append(allErrs, field.Invalid(field.NewPath("spec.resourceGroup"), r.Spec.ResourceGroup, "value of resource group is empty"))
+	}
+	if err := r.validateIBMPowerVSClusterVPCSubnetNames(); err != nil {
+		allErrs = append(allErrs, err...)
 	}
 
-	return nil
+	if err := r.validateIBMPowerVSClusterLoadBalancerNames(); err != nil {
+		allErrs = append(allErrs, err...)
+	}
+
+	if err := r.validateIBMPowerVSClusterLoadBalancerPort(); err != nil {
+		allErrs = append(allErrs, err...)
+	}
+
+	return allErrs
 }
diff --git a/api/v1beta2/ibmvpccluster_types.go b/api/v1beta2/ibmvpccluster_types.go
@@ -81,6 +81,7 @@ type VPCLoadBalancerSpec struct {
 	// +listType=map
 	// +listMapKey=port
 	// +optional
+	// ++kubebuilder:validation:UniqueItems=true
 	AdditionalListeners []AdditionalListenerSpec `json:"additionalListeners,omitempty"`
 }