fix: failing enable workflow

The prefill operation uses commands which require the mirroring
module to be enabled. Previously it was being managed externally,
However, this should be done by microceph automatically.

Signed-off-by: Utkarsh Bhatt <utkarsh.bhatt@canonical.com>

Author: UtkarshBhatthere

microceph/ceph/manager.go

@@ -5,6 +5,11 @@ import (
 	"fmt"
 	"path/filepath"
 	"strings"
+	"time"
+
+	"github.com/Rican7/retry"
+	"github.com/Rican7/retry/backoff"
+	"github.com/Rican7/retry/strategy"
 
 	"github.com/canonical/microceph/microceph/common"
 	"github.com/canonical/microceph/microceph/constants"
@@ -66,7 +71,21 @@ func EnableMgrModule(ctx context.Context, module string, remote string, local st
 		return err
 	}
 
-	return verifyMgrModuleEnabled(ctx, module, remote, local)
+	err = retry.Retry(func(i uint) error {
+		err := verifyMgrModuleEnabled(ctx, module, remote, local)
+		if err != nil {
+			logger.Debugf("Attempt %d: Failed verifying enablement of mirroring module", i)
+			return err
+		}
+
+		return nil
+	}, strategy.Delay(2*time.Second), strategy.Limit(10), strategy.Backoff(backoff.Linear(10*time.Second)))
+	if err != nil {
+		logger.Errorf("Failed to enable %s cluster mgr module %s: %v", remote, module, err)
+		return err
+	}
+
+	return nil
 }
 
 func verifyMgrModuleEnabled(ctx context.Context, module string, remote string, local string) error {

microceph/ceph/replication_cephfs.go

@@ -65,6 +65,12 @@ func (rh *CephfsReplicationHandler) PreFill(ctx context.Context, request types.R
 	req := request.(types.CephfsReplicationRequest)
 	rh.Request = req
 
+	// Enable ceph-mgr mirroring module on local cluster
+	err = EnableMgrModule(ctx, constants.MgrModuleMirroring, "", "")
+	if err != nil {
+		return fmt.Errorf("failed to enable mgr module %s: %w", constants.MgrModuleMirroring, err)
+	}
+
 	// fetch snapshot mirror daemon status
 	rh.FsMirrorDaemonStatus, err = GetCephFSSnapshotMirrorDaemonStatus(ctx)
 	if err != nil {
@@ -146,8 +152,11 @@ func (rh *CephfsReplicationHandler) EnableHandler(ctx context.Context, args ...a
 		return err
 	}
 
-	err = enableCephFSMgrModules(ctx, dbRec[0].Name, dbRec[0].LocalName)
+	// Enable the mgr module on the remote cluster.
+	err = EnableMgrModule(ctx, constants.MgrModuleMirroring, dbRec[0].Name, dbRec[0].LocalName)
 	if err != nil {
+		err := fmt.Errorf("failed to enable mgr module %s on remote cluster %s: %w", constants.MgrModuleMirroring, dbRec[0].Name, err)
+		logger.Error(err.Error())
 		return err
 	}