OADP-600: Validate volsync install for data mover

controllers/datamover.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"context"
 	"fmt"
+
 	"github.com/go-logr/logr"
 	oadpv1alpha1 "github.com/openshift/oadp-operator/api/v1alpha1"
 	"github.com/openshift/oadp-operator/pkg/common"
@@ -12,8 +13,10 @@ import (
 	k8serror "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
+	"k8s.io/client-go/kubernetes"
 	"k8s.io/utils/pointer"
 	"sigs.k8s.io/controller-runtime/pkg/client"
+	"sigs.k8s.io/controller-runtime/pkg/client/config"
 	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 )
 
@@ -25,6 +28,29 @@ func (r *DPAReconciler) ReconcileDataMoverController(log logr.Logger) (bool, err
 		return false, err
 	}
 
+	// check volSync is installed/deployment exists to use data mover
+	if dpa.Spec.Features != nil && dpa.Spec.Features.EnableDataMover {
+
+		// create new client for deployments outside of adp namespace
+		kubeConf := config.GetConfigOrDie()
+
+		clientset, err := kubernetes.NewForConfig(kubeConf)
+		if err != nil {
+			return false, err
+		}
+
+		_, err = clientset.AppsV1().Deployments(common.VolSyncDeploymentNamespace).Get(context.TODO(), common.VolSyncDeploymentName, metav1.GetOptions{})
+		if err != nil {
+
+			if k8serror.IsNotFound(err) {
+
+				return false, fmt.Errorf("volSync operator not found. Please install")
+			}
+
+			return false, err
+		}
+	}
+
 	dataMoverDeployment := &appsv1.Deployment{
 		ObjectMeta: metav1.ObjectMeta{
 			Name:      common.DataMover,

pkg/common/common.go

@@ -12,6 +12,8 @@ const (
 	DataMoverController          = "data-mover-controller"
 	DataMoverControllerContainer = "data-mover-controller-container"
 	OADPOperatorServiceAccount   = "openshift-adp-controller-manager"
+	VolSyncDeploymentName        = "volsync-controller-manager"
+	VolSyncDeploymentNamespace   = "openshift-operators"
 )
 
 // Images