diff --git a/server/src/routes/storage.ts b/server/src/routes/storage.ts index f74635a5..8e88e3dc 100644 --- a/server/src/routes/storage.ts +++ b/server/src/routes/storage.ts @@ -11,7 +11,7 @@ import cron from 'node-cron'; import { googleSheetUpdateTasks, processGoogleSheetUpdates } from '../workflow-management/integrations/gsheet'; import { getDecryptedProxyConfig } from './proxy'; import { requireSignIn } from '../middlewares/auth'; -import { workflowQueue } from '../worker'; +// import { workflowQueue } from '../worker'; // todo: move from here const getRecordingByFileName = async (fileName: string): Promise => { @@ -96,7 +96,8 @@ router.delete('/runs/:fileName', requireSignIn, async (req, res) => { router.put('/runs/:fileName', requireSignIn, async (req, res) => { try { const recording = await getRecordingByFileName(req.params.fileName); - if (!recording || !recording.recordingId) { + + if (!recording || !recording.recording_meta || !recording.recording_meta.id) { return res.status(404).send({ error: 'Recording not found' }); } @@ -126,7 +127,7 @@ router.put('/runs/:fileName', requireSignIn, async (req, res) => { const run_meta = { status: 'RUNNING', name: req.params.fileName, - recordingId: recording.id, + recordingId: recording.recording_meta.id, startedAt: new Date().toLocaleString(), finishedAt: '', browserId: id, @@ -281,16 +282,16 @@ router.put('/schedule/:fileName/', requireSignIn, async (req, res) => { const runId = uuid(); - await workflowQueue.add( - 'run workflow', - { fileName, runId }, - { - repeat: { - pattern: cronExpression, - tz: timezone - } - } - ); + // await workflowQueue.add( + // 'run workflow', + // { fileName, runId }, + // { + // repeat: { + // pattern: cronExpression, + // tz: timezone + // } + // } + // ); res.status(200).json({ message: 'success',