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

@@ -71,18 +71,32 @@ 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))
-	}
+	var prevCsvRunningDeployments bool
+	if csv.Spec.Replaces != "" {
+
+		prevCsv := &opv1a1.ClusterServiceVersion{}
+		key := client.ObjectKey{Name: csv.Spec.Replaces, Namespace: csv.Namespace}
+
+		if err := r.Client.Get(ctx, key, prevCsv); err != nil {
+			if errors.IsNotFound(err) {
+				logger.Info("previous CSV not found", "csv", csv.Spec.Replaces)
+			} else {
+				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 {
+			logger.Info("previous CSV found", "csv", prevCsv.Name)
+
+			prevCsvRunningDeployments = r.isCsvHasRunningDeployments(prevCsv)
+			r.syncNewCsvWithPrevCsv(prevCsv, csv)
+		}
 
-	if running {
-		logger.Info("ignoring csv as the previous csv deployments are running")
-		return admission.Allowed("previous csv deployments are running")
 	}
 
-	r.scaleDownCsvDeployments(logger, csv)
+	if !prevCsvRunningDeployments {
+		logger.Info("scaling down deployments")
+		r.scaleDownCsvDeployments(logger, csv)
+	}
 
 	marshaledCsv, err := json.Marshal(csv)
 	if err != nil {
@@ -123,35 +137,35 @@ 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}
+	for i := range prevDeployments {
+		prevDeployment := &prevDeployments[i]
 
-	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 j := range newDeployments {
+			newDeployment := &newDeployments[j]
+
+			if prevDeployment.Name == newDeployment.Name {
+				newDeployment.Spec.Template.Spec.HostNetwork = prevDeployment.Spec.Template.Spec.HostNetwork
+			}
+		}
 	}
+}
+
+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) {