Dedicated listNodeSets logic in Deployment controller

Signed-off-by: Brendan Shephard <bshephar@redhat.com>

Author: bshephar

controllers/dataplane/openstackdataplanedeployment_controller.go

@@ -149,44 +149,12 @@ func (r *OpenStackDataPlaneDeploymentReconciler) Reconcile(ctx context.Context,
 	}()
 
 	// Ensure NodeSets
-	nodeSets := dataplanev1.OpenStackDataPlaneNodeSetList{}
-	for _, nodeSet := range instance.Spec.NodeSets {
-
-		// Fetch the OpenStackDataPlaneNodeSet instance
-		nodeSetInstance := &dataplanev1.OpenStackDataPlaneNodeSet{}
-		err := r.Client.Get(
-			ctx,
-			types.NamespacedName{
-				Namespace: instance.GetNamespace(),
-				Name:      nodeSet,
-			},
-			nodeSetInstance)
-		if err != nil {
-			// NodeSet not found, force a requeue
-			if k8s_errors.IsNotFound(err) {
-				Log.Info("NodeSet not found", "NodeSet", nodeSet)
-				return ctrl.Result{RequeueAfter: time.Second * time.Duration(instance.Spec.DeploymentRequeueTime)}, nil
-			}
-			instance.Status.Conditions.MarkFalse(
-				dataplanev1.SetupReadyCondition,
-				condition.ErrorReason,
-				condition.SeverityError,
-				dataplanev1.DataPlaneNodeSetErrorMessage,
-				err.Error())
-			// Error reading the object - requeue the request.
-			return ctrl.Result{}, err
-		}
-		if err = nodeSetInstance.Spec.ValidateTLS(instance.GetNamespace(), r.Client, ctx); err != nil {
-			Log.Info("error while comparing TLS settings of nodeset %s with control plane: %w", nodeSet, err)
-			instance.Status.Conditions.MarkFalse(
-				dataplanev1.SetupReadyCondition,
-				condition.ErrorReason,
-				condition.SeverityError,
-				dataplanev1.DataPlaneNodeSetErrorMessage,
-				err.Error())
-			return ctrl.Result{}, err
+	nodeSets, err := r.listNodeSets(ctx, &Log, instance)
+	if err != nil {
+		if k8s_errors.IsNotFound(err) {
+			return ctrl.Result{RequeueAfter: time.Second * time.Duration(instance.Spec.DeploymentRequeueTime)}, nil
 		}
-		nodeSets.Items = append(nodeSets.Items, *nodeSetInstance)
+		return ctrl.Result{}, err
 	}
 
 	globalInventorySecrets := map[string]string{}
@@ -385,7 +353,7 @@ func (r *OpenStackDataPlaneDeploymentReconciler) Reconcile(ctx context.Context,
 	if version != nil {
 		instance.Status.DeployedVersion = version.Spec.TargetVersion
 	}
-	err = r.setHashes(ctx, helper, instance, nodeSets)
+	err = r.setHashes(ctx, helper, instance, *nodeSets)
 	if err != nil {
 		Log.Error(err, "Error setting service hashes")
 	}
@@ -493,3 +461,38 @@ func (r *OpenStackDataPlaneDeploymentReconciler) SetupWithManager(mgr ctrl.Manag
 			handler.EnqueueRequestsFromMapFunc(certFn)).
 		Complete(r)
 }
+
+func (r *OpenStackDataPlaneDeploymentReconciler) listNodeSets(ctx context.Context, Log *logr.Logger, instance *dataplanev1.OpenStackDataPlaneDeployment) (*dataplanev1.OpenStackDataPlaneNodeSetList, error) {
+
+	var nodeSets = dataplanev1.OpenStackDataPlaneNodeSetList{}
+	var err error
+
+	for _, nodeSet := range instance.Spec.NodeSets {
+
+		// Fetch the OpenStackDataPlaneNodeSet instance
+		nodeSetInstance := &dataplanev1.OpenStackDataPlaneNodeSet{}
+		err := r.Client.Get(
+			ctx,
+			types.NamespacedName{
+				Namespace: instance.GetNamespace(),
+				Name:      nodeSet,
+			},
+			nodeSetInstance)
+		if err != nil {
+			Log.Info("NodeSet not found", "NodeSet", nodeSet)
+			return &nodeSets, err
+		}
+		if err = nodeSetInstance.Spec.ValidateTLS(instance.GetNamespace(), r.Client, ctx); err != nil {
+			Log.Info("error while comparing TLS settings of nodeset %s with control plane: %w", nodeSet, err)
+			instance.Status.Conditions.MarkFalse(
+				dataplanev1.SetupReadyCondition,
+				condition.ErrorReason,
+				condition.SeverityError,
+				dataplanev1.DataPlaneNodeSetErrorMessage,
+				err.Error())
+			return &nodeSets, err
+		}
+		nodeSets.Items = append(nodeSets.Items, *nodeSetInstance)
+	}
+	return &nodeSets, err
+}