controllers: ensure CSV inherits hostNetwork from previous deployment

The webhook now mutates the ClusterServiceVersion (CSV) to set
`hostNetwork` on deployments if the replaced CSV had it enabled.
This ensures continuity of networking configuration across
operator upgrades and avoids potential deployment issues caused
by missing `hostNetwork` in the new CSV.

Signed-off-by: Nitin Goyal <[email protected]>
Signed-off-by: Rohan Gupta <[email protected]>

Author: iamniting

webhook/csv.go

@@ -25,7 +25,6 @@ import (
 
 	"github.com/go-logr/logr"
 	opv1a1 "github.com/operator-framework/api/pkg/operators/v1alpha1"
-	"k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/utils/ptr"
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
@@ -71,19 +70,25 @@ func (r *ClusterServiceVersionDeploymentScaler) Handle(ctx context.Context, req
 		return admission.Allowed("csv is not managed by ODF")
 	}
 
-	running, err := r.isPreviousCsvHasRunningDeployments(ctx, logger, csv)
-	if err != nil {
-		logger.Error(err, "failed getting replicas from csv")
-		return admission.Errored(http.StatusInternalServerError, fmt.Errorf("failed getting replicas from csv: %v", err))
+	prevCsv := &opv1a1.ClusterServiceVersion{}
+	if csv.Spec.Replaces != "" {
+		key := client.ObjectKey{Name: csv.Spec.Replaces, Namespace: csv.Namespace}
+		if err := r.Client.Get(ctx, key, prevCsv); client.IgnoreNotFound(err) != nil {
+			logger.Error(err, "failed to get previous CSV", "csv", csv.Spec.Replaces)
+			return admission.Errored(http.StatusInternalServerError, fmt.Errorf("failed getting previous csv %q: %w", csv.Spec.Replaces, err))
+		} else if prevCsv.UID != "" {
+			logger.Info("previous CSV found", "csv", prevCsv.Name)
+			r.syncNewCsvWithPrevCsv(prevCsv, csv)
+		} else {
+			logger.Info("previous CSV not found", "csv", csv.Spec.Replaces)
+		}
 	}
 
-	if running {
-		logger.Info("ignoring csv as the previous csv deployments are running")
-		return admission.Allowed("previous csv deployments are running")
+	if prevCsv.UID != "" && !r.isCsvHasRunningDeployments(prevCsv) {
+		logger.Info("scaling down deployments")
+		r.scaleDownCsvDeployments(logger, csv)
 	}
 
-	r.scaleDownCsvDeployments(logger, csv)
-
 	marshaledCsv, err := json.Marshal(csv)
 	if err != nil {
 		logger.Error(err, "failed marshaling csv")
@@ -123,35 +128,36 @@ func (r *ClusterServiceVersionDeploymentScaler) loadOdfConfigMapData(ctx context
 	return nil
 }
 
-func (r *ClusterServiceVersionDeploymentScaler) isPreviousCsvHasRunningDeployments(ctx context.Context, logger logr.Logger, csv *opv1a1.ClusterServiceVersion) (bool, error) {
+func (r *ClusterServiceVersionDeploymentScaler) syncNewCsvWithPrevCsv(prevCsv *opv1a1.ClusterServiceVersion, newCsv *opv1a1.ClusterServiceVersion) {
 
-	if csv.Spec.Replaces == "" {
-		logger.Info("csv.Spec.Replaces is not populated")
-		return false, nil
-	}
+	prevDeployments := prevCsv.Spec.InstallStrategy.StrategySpec.DeploymentSpecs
+	newDeployments := newCsv.Spec.InstallStrategy.StrategySpec.DeploymentSpecs
 
-	prevCsv := &opv1a1.ClusterServiceVersion{}
-	key := client.ObjectKey{Name: csv.Spec.Replaces, Namespace: csv.Namespace}
-
-	if err := r.Client.Get(ctx, key, prevCsv); errors.IsNotFound(err) {
-		// new install where an previous csv does not exists
-		return false, nil
-	} else if err != nil {
-		logger.Error(err, "failed getting previous csv")
-		return false, err
+	for i := range prevDeployments {
+		prevDeployment := &prevDeployments[i]
+
+		for j := range newDeployments {
+			newDeployment := &newDeployments[j]
+
+			if prevDeployment.Name == newDeployment.Name {
+				newDeployment.Spec.Template.Spec.HostNetwork = prevDeployment.Spec.Template.Spec.HostNetwork
+				newDeployment.Spec.Replicas = prevDeployment.Spec.Replicas
+			}
+		}
 	}
+}
+
+func (r *ClusterServiceVersionDeploymentScaler) isCsvHasRunningDeployments(csv *opv1a1.ClusterServiceVersion) bool {
 
-	deployments := prevCsv.Spec.InstallStrategy.StrategySpec.DeploymentSpecs
+	deployments := csv.Spec.InstallStrategy.StrategySpec.DeploymentSpecs
 	for i := range deployments {
 		deployment := &deployments[i]
 		if deployment.Spec.Replicas == nil || *deployment.Spec.Replicas > 0 {
-			// upgrade case where an older csv is found with replica 1
-			return true, nil
+			return true
 		}
 	}
 
-	// upgrade case where an older csv is found with replica 0
-	return false, nil
+	return false
 }
 
 func (r *ClusterServiceVersionDeploymentScaler) scaleDownCsvDeployments(logger logr.Logger, csv *opv1a1.ClusterServiceVersion) {