From f103d84aba78d74c32f6c9425da6b0c2362a9206 Mon Sep 17 00:00:00 2001 From: karishmas6 Date: Tue, 8 Oct 2024 23:34:53 +0530 Subject: [PATCH] feat: recording id for shceduled robot --- server/src/workflow-management/scheduler/index.ts | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/server/src/workflow-management/scheduler/index.ts b/server/src/workflow-management/scheduler/index.ts index 4ddbebc3..c1e94bde 100644 --- a/server/src/workflow-management/scheduler/index.ts +++ b/server/src/workflow-management/scheduler/index.ts @@ -7,12 +7,23 @@ import { createRemoteBrowserForRun, destroyRemoteBrowser } from '../../browser-m import logger from '../../logger'; import { browserPool } from "../../server"; import { googleSheetUpdateTasks, processGoogleSheetUpdates } from "../integrations/gsheet"; +import { getRecordingByFileName } from "../../routes/storage"; async function runWorkflow(fileName: string, runId: string) { if (!runId) { runId = uuid(); } + const recording = await getRecordingByFileName(fileName); + + if (!recording || !recording.recording_meta || !recording.recording_meta.id) { + logger.log('info', `Recording with name: ${fileName} not found`); + return { + success: false, + error: `Recording with name: ${fileName} not found`, + }; + } + try { const browserId = createRemoteBrowserForRun({ browser: chromium, @@ -21,6 +32,7 @@ async function runWorkflow(fileName: string, runId: string) { const run_meta = { status: 'Scheduled', name: fileName, + recordingId: recording.recording_meta.id, startedAt: new Date().toLocaleString(), finishedAt: '', browserId: browserId,