Reconcile related drpcs when drcluster is deleted

- Watch also DRCluster delete events
- When filtering drpcs consider all drpcs referencing a deleted
  drcluster.

With this change, when a drcluster is deleted, the drpc controller
should update the VRG ManifestWork on the remaining cluster. Previously
this happened minutes after a drcluster was deleted.

Signed-off-by: Nir Soffer <[email protected]>

controllers/drplacementcontrol_controller.go

@@ -266,7 +266,9 @@ func DRClusterPredicateFunc() predicate.Funcs {
 			return false
 		},
 		DeleteFunc: func(e event.DeleteEvent) bool {
-			return false
+			log.Info("Delete event")
+
+			return true
 		},
 		GenericFunc: func(e event.GenericEvent) bool {
 			return false
@@ -347,7 +349,16 @@ func getFailoverActivatedCondition(mMode rmn.ClusterMaintenanceMode) *metav1.Con
 func (r *DRPlacementControlReconciler) FilterDRCluster(drcluster *rmn.DRCluster) []ctrl.Request {
 	log := ctrl.Log.WithName("DRPCFilter").WithName("DRCluster").WithValues("cluster", drcluster)
 
-	drpcCollections, err := DRPCsFailingOverToCluster(r.Client, log, drcluster.GetName())
+	var drpcCollections []DRPCAndPolicy
+
+	var err error
+
+	if drClusterIsDeleted(drcluster) {
+		drpcCollections, err = DRPCsUsingDRCluster(r.Client, log, drcluster)
+	} else {
+		drpcCollections, err = DRPCsFailingOverToCluster(r.Client, log, drcluster.GetName())
+	}
+
 	if err != nil {
 		log.Info("Failed to process filter")
 
@@ -373,6 +384,76 @@ type DRPCAndPolicy struct {
 	drPolicy *rmn.DRPolicy
 }
 
+// DRPCsUsingDRCluster finds DRPC resources using the DRcluster.
+func DRPCsUsingDRCluster(k8sclient client.Client, log logr.Logger, drcluster *rmn.DRCluster) ([]DRPCAndPolicy, error) {
+	drpolicies := &rmn.DRPolicyList{}
+	if err := k8sclient.List(context.TODO(), drpolicies); err != nil {
+		log.Error(err, "Failed to list DRPolicies", "drcluster", drcluster.GetName())
+
+		return nil, err
+	}
+
+	found := []DRPCAndPolicy{}
+
+	for i := range drpolicies.Items {
+		drpolicy := &drpolicies.Items[i]
+
+		for _, clusterName := range drpolicy.Spec.DRClusters {
+			if clusterName != drcluster.GetName() {
+				continue
+			}
+
+			log.Info("Found DRPolicy referencing DRCluster", "drpolicy", drpolicy.GetName())
+
+			drpcs, err := DRPCsUsingDRPolicy(k8sclient, log, drpolicy)
+			if err != nil {
+				return nil, err
+			}
+
+			for _, drpc := range drpcs {
+				found = append(found, DRPCAndPolicy{drpc: drpc, drPolicy: drpolicy})
+			}
+
+			break
+		}
+	}
+
+	return found, nil
+}
+
+// DRPCsUsingDRPolicy finds DRPC resources that reference the DRPolicy.
+func DRPCsUsingDRPolicy(
+	k8sclient client.Client,
+	log logr.Logger,
+	drpolicy *rmn.DRPolicy,
+) ([]*rmn.DRPlacementControl, error) {
+	drpcs := &rmn.DRPlacementControlList{}
+	if err := k8sclient.List(context.TODO(), drpcs); err != nil {
+		log.Error(err, "Failed to list DRPCs", "drpolicy", drpolicy.GetName())
+
+		return nil, err
+	}
+
+	found := []*rmn.DRPlacementControl{}
+
+	for i := range drpcs.Items {
+		drpc := &drpcs.Items[i]
+
+		if drpc.Spec.DRPolicyRef.Name != drpolicy.GetName() {
+			continue
+		}
+
+		log.Info("Found DRPC referencing drpolicy",
+			"name", drpc.GetName(),
+			"namespace", drpc.GetNamespace(),
+			"drpolicy", drpolicy.GetName())
+
+		found = append(found, drpc)
+	}
+
+	return found, nil
+}
+
 // DRPCsFailingOverToCluster lists DRPC resources that are failing over to the passed in drcluster
 //
 //nolint:gocognit