feat: implement replay feature without backup and validation

.gitignore

@@ -20,6 +20,7 @@ jobs
 /resources/resource_fs.go
 __pycache__
 .optimus.yaml
+coverage.txt
 
 # git ignore generate files related to gRPC and proto
 /proton/

api/handler/v1/runtime.go

@@ -727,7 +727,44 @@ func (sv *RuntimeServiceServer) ListResourceSpecification(ctx context.Context, r
 	}, nil
 }
 
-func (sv *RuntimeServiceServer) ReplayDryRun(ctx context.Context, req *pb.ReplayDryRunRequest) (*pb.ReplayDryRunResponse, error) {
+func (sv *RuntimeServiceServer) ReplayDryRun(ctx context.Context, req *pb.ReplayRequest) (*pb.ReplayDryRunResponse, error) {
+	replayWorkerRequest, err := sv.parseReplayRequest(req)
+	if err != nil {
+		return nil, status.Error(codes.Internal, fmt.Sprintf("error while parsing replay dry run request: %v", err))
+	}
+
+	rootNode, err := sv.jobSvc.ReplayDryRun(replayWorkerRequest)
+	if err != nil {
+		return nil, status.Error(codes.Internal, fmt.Sprintf("error while processing replay dry run: %v", err))
+	}
+
+	node, err := sv.adapter.ToReplayExecutionTreeNode(rootNode)
+	if err != nil {
+		return nil, status.Error(codes.Internal, fmt.Sprintf("error while preparing replay dry run response: %v", err))
+	}
+	return &pb.ReplayDryRunResponse{
+		Success:  true,
+		Response: node,
+	}, nil
+}
+
+func (sv *RuntimeServiceServer) Replay(ctx context.Context, req *pb.ReplayRequest) (*pb.ReplayResponse, error) {
+	replayWorkerRequest, err := sv.parseReplayRequest(req)
+	if err != nil {
+		return nil, status.Error(codes.Internal, fmt.Sprintf("error while parsing replay request: %v", err))
+	}
+
+	replayUUID, err := sv.jobSvc.Replay(replayWorkerRequest)
+	if err != nil {
+		return nil, status.Error(codes.Internal, fmt.Sprintf("error while processing replay: %v", err))
+	}
+
+	return &pb.ReplayResponse{
+		Id: replayUUID,
+	}, nil
+}
+
+func (sv *RuntimeServiceServer) parseReplayRequest(req *pb.ReplayRequest) (*models.ReplayWorkerRequest, error) {
 	projectRepo := sv.projectRepoFactory.New()
 	projSpec, err := projectRepo.GetByName(req.GetProjectName())
 	if err != nil {
@@ -760,20 +797,13 @@ func (sv *RuntimeServiceServer) ReplayDryRun(ctx context.Context, req *pb.Replay
 	if endDate.Before(startDate) {
 		return nil, status.Error(codes.InvalidArgument, fmt.Sprintf("replay end date cannot be before start date"))
 	}
-
-	rootNode, err := sv.jobSvc.ReplayDryRun(namespaceSpec, jobSpec, startDate, endDate)
-	if err != nil {
-		return nil, status.Error(codes.Internal, fmt.Sprintf("error while processing replay: %v", err))
-	}
-
-	node, err := sv.adapter.ToReplayExecutionTreeNode(rootNode)
-	if err != nil {
-		return nil, status.Error(codes.Internal, fmt.Sprintf("error while processing replay: %v", err))
+	replayRequest := models.ReplayWorkerRequest{
+		Job:     jobSpec,
+		Start:   startDate,
+		End:     endDate,
+		Project: projSpec,
 	}
-	return &pb.ReplayDryRunResponse{
-		Success:  true,
-		Response: node,
-	}, nil
+	return &replayRequest, nil
 }
 
 func NewRuntimeServiceServer(

api/handler/v1/runtime_test.go

@@ -1479,11 +1479,17 @@ func TestRuntimeServiceServer(t *testing.T) {
 						},
 					}),
 			}
+			replayWorkerRequest := &models.ReplayWorkerRequest{
+				Job:     jobSpec,
+				Start:   startDate,
+				End:     endDate,
+				Project: projectSpec,
+			}
 			dagNode := tree.NewTreeNode(jobSpec)
 
 			jobService := new(mock.JobService)
 			jobService.On("GetByName", jobName, namespaceSpec).Return(jobSpec, nil)
-			jobService.On("ReplayDryRun", namespaceSpec, jobSpec, startDate, endDate).Return(dagNode, nil)
+			jobService.On("ReplayDryRun", replayWorkerRequest).Return(dagNode, nil)
 			defer jobService.AssertExpectations(t)
 
 			projectRepository := new(mock.ProjectRepository)
@@ -1514,7 +1520,7 @@ func TestRuntimeServiceServer(t *testing.T) {
 				nil,
 				nil,
 			)
-			replayRequest := pb.ReplayDryRunRequest{
+			replayRequest := pb.ReplayRequest{
 				ProjectName: projectName,
 				Namespace:   namespaceSpec.Name,
 				JobName:     jobName,