object: add check specific to name and namespace for ceph cosi driver

The name for cephcosi driver should be ceph-cosi-driver and namespace
should same as the rook operator. Otherwise request need to be failed.

Fixes: #13025
Signed-off-by: Jiffin Tony Thottan <thottanjiffin@gmail.com>

pkg/operator/ceph/object/cosi/controller.go

@@ -118,8 +118,18 @@ func (r *ReconcileCephCOSIDriver) Reconcile(context context.Context, request rec
 func (r *ReconcileCephCOSIDriver) reconcile(request reconcile.Request) (reconcile.Result, cephv1.CephCOSIDriver, error) {
 	cephCOSIDriver := &cephv1.CephCOSIDriver{}
 
+	// Check No of instances of CephCOSIDriver
+	cephCOSIDriverList := &cephv1.CephCOSIDriverList{}
+	err := r.client.List(r.opManagerContext, cephCOSIDriverList)
+	if err != nil {
+		return reconcile.Result{}, *cephCOSIDriver, errors.Wrap(err, "failed to list CephCOSIDriver")
+	}
+	if len(cephCOSIDriverList.Items) > 1 {
+		return reconcile.Result{}, *cephCOSIDriver, errors.New("more than one instance of CephCOSIDriver found")
+	}
+
 	// Fetch the CephCOSIDriver instance
-	err := r.client.Get(r.opManagerContext, request.NamespacedName, cephCOSIDriver)
+	cephCOSIDriver := cephCOSIDriverList.Items[0]
 	logger.Debugf("CephCOSIDriver: %+v", cephCOSIDriver)
 	if err != nil && client.IgnoreNotFound(err) != nil {
 		return reconcile.Result{}, *cephCOSIDriver, errors.Wrapf(err, "failed to get Ceph COSI Driver %s", request.NamespacedName)
@@ -157,9 +167,9 @@ func (r *ReconcileCephCOSIDriver) reconcile(request reconcile.Request) (reconcil
 		cephCOSIDriver.Name = CephCOSIDriverName
 	}
 
-	// Set the default CephCOSIDriver namespace if not already set
-	if cephCOSIDriver.Namespace == "" {
-		cephCOSIDriver.Namespace = os.Getenv(k8sutil.PodNamespaceEnvVar)
+	// The ceph-cosi-driver CRD should be same namespace as the operator
+	if cephCOSIDriver.Namespace != os.Getenv(k8sutil.PodNamespaceEnvVar) {
+		return reconcile.Result{}, *cephCOSIDriver, errors.New("Ceph COSI Driver namespace must be same as operator")
 	}
 
 	// Check whether object store is running

pkg/operator/ceph/object/cosi/controller_test.go

@@ -255,4 +255,60 @@ func TestCephCOSIDriverController(t *testing.T) {
 		assert.NoError(t, err)
 		assert.Equal(t, "quay.io/ceph/cosi:custom", cephCOSIDriverDeployment.Spec.Template.Spec.Containers[0].Image)
 	})
+
+	t.Run("ceph cosi driver CRD with custom namespace", func(t *testing.T) {
+		cephCOSIDriver := &cephv1.CephCOSIDriver{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      CephCOSIDriverName,
+				Namespace: "custom-namespace",
+			},
+			Spec: cephv1.CephCOSIDriverSpec{
+				Image:              "quay.io/ceph/cosi:custom",
+				DeploymentStrategy: cephv1.COSIDeploymentStrategyAuto,
+			},
+		}
+		r := setupNewEnvironment(cephCOSIDriver)
+		req := reconcile.Request{
+			NamespacedName: types.NamespacedName{
+				Name:      CephCOSIDriverName,
+				Namespace: "custom-namespace",
+			},
+		}
+		res, err := r.Reconcile(ctx, req)
+		assert.Error(t, err)
+		assert.Equal(t, false, res.Requeue)
+	})
+
+	t.Run("multiple ceph cosi driver CRDs", func(t *testing.T) {
+		cephCOSIDriver1 := &cephv1.CephCOSIDriver{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      "ceph-cosi-driver-1",
+				Namespace: namespace,
+			},
+			Spec: cephv1.CephCOSIDriverSpec{
+				Image:              "quay.io/ceph/cosi:custom",
+				DeploymentStrategy: cephv1.COSIDeploymentStrategyAuto,
+			},
+		}
+		cephCOSIDriver2 := &cephv1.CephCOSIDriver{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      "ceph-cosi-driver-2",
+				Namespace: namespace,
+			},
+			Spec: cephv1.CephCOSIDriverSpec{
+				Image:              "quay.io/ceph/cosi:custom",
+				DeploymentStrategy: cephv1.COSIDeploymentStrategyAuto,
+			},
+		}
+		r := setupNewEnvironment(cephCOSIDriver1, cephCOSIDriver2)
+		req := reconcile.Request{
+			NamespacedName: types.NamespacedName{
+				Name:      "ceph-cosi-driver-1",
+				Namespace: namespace,
+			},
+		}
+		res, err := r.Reconcile(ctx, req)
+		assert.Error(t, err)
+		assert.Equal(t, false, res.Requeue)
+	})
 }