fix: better errors

Signed-off-by: bupd <[email protected]>

Author: bupd

src/controller/replication/execution.go

@@ -125,7 +125,7 @@ func (c *controller) Start(ctx context.Context, policy *replicationmodel.Policy,
 			},
 		})
 		if err != nil {
-			return 0, err
+			return 0, fmt.Errorf("failed to count running executions for policy ID: %d: %v", policy.ID, err)
 		}
 
 		if count > 1 {

src/controller/replication/flow/copy.go

@@ -136,7 +136,7 @@ func (c *copyFlow) createTasks(ctx context.Context, srcResources, dstResources [
 			Metadata: &job.Metadata{
 				JobKind: job.KindGeneric,
 			},
-			Parameters: map[string]interface{}{
+			Parameters: map[string]any{
 				"src_resource":  string(src),
 				"dst_resource":  string(dest),
 				"speed":         speed,

src/server/v2.0/handler/replication.go

@@ -115,7 +115,7 @@ func (r *replicationAPI) CreateReplicationPolicy(ctx context.Context, params ope
 
 	if params.Policy.SingleActiveReplication != nil {
 		// Validate and assign SingleActiveReplication only for non-event_based triggers
-		if params.Policy.Trigger.Type == "event_based" && *params.Policy.SingleActiveReplication == true {
+		if params.Policy.Trigger.Type == model.TriggerTypeEventBased && *params.Policy.SingleActiveReplication == true {
 			return r.SendError(ctx, fmt.Errorf("single active replication is not allowed for event_based triggers"))
 		}
 		policy.SingleActiveReplication = *params.Policy.SingleActiveReplication