update old gitops subscriptions to be owned by operator and add logic to determine if sync is in progress during finalization of pattern

Author: dminnear-rh

internal/controller/argo.go

@@ -21,6 +21,7 @@ import (
 	"fmt"
 	"log"
 	"os"
+	"slices"
 	"strconv"
 	"strings"
 
@@ -962,17 +963,25 @@ func updateHelmParameter(goal api.PatternParameter, actual []argoapi.HelmParamet
 	return false
 }
 
-func syncApplicationWithPrune(client argoclient.Interface, app *argoapi.Application, namespace string) error {
+// syncApplicationWithPrune syncs the application with prune and force options if such a sync is not already in progress.
+// Returns true if a sync with prune and force is already in progress, false otherwise
+func syncApplicationWithPrune(client argoclient.Interface, app *argoapi.Application, namespace string) (bool, error) {
+
+	if app.Operation != nil && app.Operation.Sync != nil && app.Operation.Sync.Prune && slices.Contains(app.Operation.Sync.SyncOptions, "Force=true") {
+		return true, nil
+	}
+
 	app.Operation = &argoapi.Operation{
 		Sync: &argoapi.SyncOperation{
-			Prune: true,
+			Prune:       true,
+			SyncOptions: []string{"Force=true"},
 		},
 	}
 
 	_, err := client.ArgoprojV1alpha1().Applications(namespace).Update(context.Background(), app, metav1.UpdateOptions{})
 	if err != nil {
-		return fmt.Errorf("failed to sync application %q with prune: %w", app.Name, err)
+		return false, fmt.Errorf("failed to sync application %q with prune: %w", app.Name, err)
 	}
 
-	return nil
+	return true, nil
 }

internal/controller/pattern_controller.go

@@ -162,7 +162,8 @@ func (r *PatternReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ct
 
 	// -- GitOps Subscription
 	targetSub, _ := newSubscriptionFromConfigMap(r.fullClient)
-	if operatorConfigMap, err := GetOperatorConfigmap(); err == nil {
+	operatorConfigMap, err := GetOperatorConfigmap()
+	if err == nil {
 		if err := controllerutil.SetOwnerReference(operatorConfigMap, targetSub, r.Scheme); err != nil {
 			return r.actionPerformed(qualifiedInstance, "error setting owner of gitops subscription", err)
 		}
@@ -182,7 +183,20 @@ func (r *PatternReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ct
 			return r.actionPerformed(qualifiedInstance, "update gitops subscription", errSub)
 		}
 	} else {
-		logOnce("The gitops subscription is not owned by us, leaving untouched")
+		// Historically the subscription was owned by the pattern, not the operator. If this is the case,
+		// we update the owner reference to the operator itself.
+		if err := controllerutil.RemoveOwnerReference(qualifiedInstance, sub, r.Scheme); err == nil {
+			if err := controllerutil.SetOwnerReference(operatorConfigMap, sub, r.Scheme); err != nil {
+				return r.actionPerformed(qualifiedInstance, "error setting patterns operator owner reference of gitops subscription", err)
+			}
+			// Persist the updated ownerReferences on the Subscription
+			if _, err := r.olmClient.OperatorsV1alpha1().Subscriptions(SubscriptionNamespace).Update(context.Background(), sub, metav1.UpdateOptions{}); err != nil {
+				return r.actionPerformed(qualifiedInstance, "error updating gitops subscription owner references", err)
+			}
+			return r.actionPerformed(qualifiedInstance, "updated patterns operator owner reference of gitops subscription", nil)
+		} else {
+			logOnce("The gitops subscription is not owned by us, leaving untouched")
+		}
 	}
 	logOnce("subscription found")
 
@@ -534,8 +548,14 @@ func (r *PatternReconciler) finalizeObject(instance *api.Pattern) error {
 			return fmt.Errorf("updated application %q for removal", app.Name)
 		}
 
-		if err := syncApplicationWithPrune(r.argoClient, app, ns); err != nil {
-			return err
+		if app.Status.Sync.Status == argoapi.SyncStatusCodeOutOfSync {
+			inProgress, err := syncApplicationWithPrune(r.argoClient, app, ns)
+			if err != nil {
+				return err
+			}
+			if inProgress {
+				return fmt.Errorf("sync with prune and force is already in progress for application %q", app.Name)
+			}
 		}
 
 		if haveACMHub(r) {