review app

server/src/features/realtime/domain/run_instance_pipeline_usecase.ts

@@ -0,0 +1,41 @@
+import { App } from "../../../core/controllers/app";
+import { Result } from "../../../core/helper/result";
+import { ReadByIdDataBaseModelUseCase } from "../../../core/usecases/read_by_id_database_model_usecase";
+import { UpdateDataBaseModelUseCase } from "../../../core/usecases/update_database_model_usecase";
+import {
+  IProjectInstanceModel,
+  ProjectInstanceDbModel,
+} from "../../project_instance/models/project_instance_database_model";
+import { RealTimeValidationModel, pipelineRealTimeService } from "../realtime_presentation";
+
+export class RunInstancePipelineUseCase {
+  async call(model: RealTimeValidationModel): Promise<Result<Error, any>> {
+    const { id } = model;
+    const readByIdDataBaseModelUseCase = await new ReadByIdDataBaseModelUseCase<IProjectInstanceModel>(
+      ProjectInstanceDbModel
+    ).call(id);
+
+    if (readByIdDataBaseModelUseCase.isFailure()) {
+      return readByIdDataBaseModelUseCase.forward();
+    }
+
+    const projectModel = readByIdDataBaseModelUseCase.value;
+    projectModel.isActive = true;
+
+    const updateDataBaseModelUseCase = await new UpdateDataBaseModelUseCase<IProjectInstanceModel, any>(
+      ProjectInstanceDbModel
+    ).call(projectModel);
+
+    if (updateDataBaseModelUseCase.isFailure()) {
+      return updateDataBaseModelUseCase.forward();
+    }
+    pipelineRealTimeService.setPipelineDependency(
+      projectModel.project.pipelines,
+      App.staticFilesStoreDir() + projectModel.rootDir + "/",
+      projectModel._id
+    );
+    pipelineRealTimeService.runPipeline();
+
+    return Result.ok({ status: "ok" });
+  }
+}