webstudio/server/src/features/realtime/usecases/run_instance_pipeline_usecase.ts

import { App } from "../../../core/controllers/app";
import { Result } from "../../../core/helper/result";
import { EXEC_TYPE } from "../../../core/model/exec_error_model";
import { ReadByIdDataBaseModelUseCase } from "../../../core/usecases/read_by_id_database_model_usecase";
import { IProjectModel, ProjectDBModel } from "../../projects/projects_model";
import {
  RealTimeValidationModel,
  pipelineRealTimeService,
} from "../realtime_presentation";

export class RunInstancePipelineUseCase {
  async call(model: RealTimeValidationModel): Promise<Result<Error, any>> {
    const id = model.id;
    const readByIdDataBaseModelUseCase =
      await new ReadByIdDataBaseModelUseCase<IProjectModel>(
        ProjectDBModel
      ).call(id);
    if (readByIdDataBaseModelUseCase.isFailure()) {
      return readByIdDataBaseModelUseCase.forward();
    }

    const projectModel = readByIdDataBaseModelUseCase.value;
    projectModel.pipelines.map((el) => {
      el.process.type = EXEC_TYPE.EXEC;
    });
    
    pipelineRealTimeService.runPipeline(
      projectModel.pipelines,
      App.staticFilesStoreDir() + projectModel.rootDir + "/",
      projectModel._id
    );

    return Result.ok({ status: "ok" });
  }
}

// /Users/idontsudo/Desktop/testdeck-mocha-seed/server/build/public/ce4e7710-73dc-47fc-87ee-d448ea2412ce
// new ObjectId("6554c22d2ef337587505a494")