Make getHelmValues working in deflux operator

operator/internal/controller/redpanda/managed_decommission_controller.go

@@ -195,7 +195,7 @@ func decommissionStatus(ctx context.Context, l logr.Logger, c k8sclient.Client,
 	decommissionNodeID := int(*rp.Status.ManagedDecommissioningNode)
 	log := l.WithName("decommissionStatus").WithValues("decommission-node-id", decommissionNodeID)
 
-	valuesMap, err := getHelmValues(l, rp.GetHelmReleaseName(), rp.Namespace)
+	valuesMap, err := getHelmValues(ctx, c, l, rp.GetHelmReleaseName(), rp.Namespace, true)
 	if err != nil {
 		return fmt.Errorf("get helm values: %w", err)
 	}
@@ -304,7 +304,7 @@ func getPodFromRedpandaNodeID(ctx context.Context, l logr.Logger, c k8sclient.Cl
 		return nil, fmt.Errorf("get Redpanda Node ID pod list: %w", err)
 	}
 
-	valuesMap, err := getHelmValues(l, rp.GetHelmReleaseName(), rp.Namespace)
+	valuesMap, err := getHelmValues(ctx, c, l, rp.GetHelmReleaseName(), rp.Namespace, true)
 	if err != nil {
 		return nil, fmt.Errorf("get helm values: %w", err)
 	}
@@ -371,7 +371,7 @@ func reconcilePodsDecommission(ctx context.Context, l logr.Logger, c k8sclient.C
 		return err
 	}
 
-	valuesMap, err := getHelmValues(l, rp.GetHelmReleaseName(), rp.Namespace)
+	valuesMap, err := getHelmValues(ctx, c, l, rp.GetHelmReleaseName(), rp.Namespace, true)
 	if err != nil {
 		return fmt.Errorf("get helm values: %w", err)
 	}

operator/internal/controller/redpanda/redpanda_controller.go

@@ -295,7 +295,7 @@ func (r *RedpandaReconciler) reconcile(ctx context.Context, rp *v1alpha2.Redpand
 	}
 
 	for _, sts := range redpandaStatefulSets {
-		decommission, err := needsDecommission(ctx, sts, log)
+		decommission, err := needsDecommission(ctx, sts, log, r.Client, true)
 		if err != nil {
 			return rp, err
 		}

operator/internal/controller/redpanda/redpanda_controller_utils.go

@@ -11,11 +11,16 @@ package redpanda
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
 	"os"
 
 	"github.com/fluxcd/pkg/runtime/logger"
 	"github.com/go-logr/logr"
+	"github.com/redpanda-data/helm-charts/charts/redpanda"
+	"github.com/redpanda-data/helm-charts/pkg/gotohelm/helmette"
+	"github.com/redpanda-data/helm-charts/pkg/kube"
+	"github.com/redpanda-data/redpanda-operator/operator/api/redpanda/v1alpha2"
 	"helm.sh/helm/v3/pkg/action"
 	"helm.sh/helm/v3/pkg/cli"
 	corev1 "k8s.io/api/core/v1"
@@ -59,7 +64,31 @@ func isValidReleaseName(releaseName string, redpandaNameList []string) bool {
 	return false
 }
 
-func getHelmValues(log logr.Logger, releaseName, namespace string) (map[string]interface{}, error) {
+func getHelmValues(ctx context.Context, c client.Client, log logr.Logger, releaseName, namespace string, operatorMode bool) (map[string]interface{}, error) {
+	if operatorMode {
+		rp := v1alpha2.Redpanda{}
+		err := c.Get(ctx, client.ObjectKey{Name: releaseName, Namespace: namespace}, &rp)
+		if err != nil {
+			return nil, fmt.Errorf("getting Redpanda customer resource: %w", err)
+		}
+
+		values := redpanda.Values{}
+		b, err := json.Marshal(rp.Spec.ClusterSpec)
+		if err != nil {
+			return nil, fmt.Errorf("marshalling cluster spec: %w", err)
+		}
+
+		err = json.Unmarshal(b, &values)
+		if err != nil {
+			return nil, fmt.Errorf("unmarshalling cluster spec into redpanda Values: %w", err)
+		}
+
+		d, err := redpanda.Chart.Dot(kube.Config{}, helmette.Release{Name: releaseName, Namespace: namespace, IsInstall: true, IsUpgrade: true, Service: "operator"}, values)
+		if err != nil {
+			return nil, fmt.Errorf("compute chart values: %w", err)
+		}
+		return d.Values.AsMap(), nil
+	}
 	settings := cli.New()
 	actionConfig := new(action.Configuration)
 	if err := actionConfig.Init(settings.RESTClientGetter(), namespace, os.Getenv("HELM_DRIVER"), func(format string, v ...interface{}) { Debugf(log, format, v) }); err != nil {

operator/internal/controller/redpanda/redpanda_decommission_controller.go

@@ -206,7 +206,7 @@ func (r *DecommissionReconciler) verifyIfNeedDecommission(ctx context.Context, s
 
 	requestedReplicas := ptr.Deref(sts.Spec.Replicas, 0)
 
-	valuesMap, err := getHelmValues(log, releaseName, namespace)
+	valuesMap, err := getHelmValues(ctx, r, log, releaseName, namespace, r.OperatorMode)
 	if err != nil {
 		return ctrl.Result{}, fmt.Errorf("could not retrieve values, probably not a valid managed helm release: %w", err)
 	}
@@ -319,7 +319,7 @@ func (r *DecommissionReconciler) reconcileDecommission(ctx context.Context, log
 		return ctrl.Result{Requeue: true, RequeueAfter: 10 * time.Second}, nil
 	}
 
-	valuesMap, err := getHelmValues(log, releaseName, namespace)
+	valuesMap, err := getHelmValues(ctx, r, log, releaseName, namespace, r.OperatorMode)
 	if err != nil {
 		return ctrl.Result{}, fmt.Errorf("could not retrieve values, probably not a valid managed helm release: %w", err)
 	}
@@ -727,7 +727,7 @@ func getConditionOfTypeAndListWithout(conditionType appsv1.StatefulSetConditionT
 	return oldCondition, newConditions
 }
 
-func needsDecommission(ctx context.Context, sts *appsv1.StatefulSet, log logr.Logger) (bool, error) {
+func needsDecommission(ctx context.Context, sts *appsv1.StatefulSet, log logr.Logger, c client.Client, operatorMode bool) (bool, error) {
 	namespace := sts.Namespace
 
 	releaseName, ok := sts.Labels[K8sInstanceLabelKey]
@@ -737,7 +737,7 @@ func needsDecommission(ctx context.Context, sts *appsv1.StatefulSet, log logr.Lo
 	}
 
 	requestedReplicas := ptr.Deref(sts.Spec.Replicas, 0)
-	valuesMap, err := getHelmValues(log, releaseName, namespace)
+	valuesMap, err := getHelmValues(ctx, c, log, releaseName, namespace, operatorMode)
 	if err != nil {
 		return false, fmt.Errorf("could not retrieve values, probably not a valid managed helm release: %w", err)
 	}

operator/internal/controller/redpanda/redpanda_node_pvc_controller.go

@@ -147,7 +147,7 @@ func (r *RedpandaNodePVCReconciler) reconcile(ctx context.Context, req ctrl.Requ
 			}
 
 			if !foundKey {
-				valuesMap, err := getHelmValues(log, releaseName, req.Namespace)
+				valuesMap, err := getHelmValues(ctx, r, log, releaseName, req.Namespace, r.OperatorMode)
 				if err != nil {
 					Infof(log, "could not retrieve values for release %q, probably not a valid managed helm release: %s", releaseName, err)
 					continue