From d2782503eb07c1b5621f8f7c398a6ffc965cb125 Mon Sep 17 00:00:00 2001
From: karishmas6 <carishmashukla28@gmail.com>
Date: Thu, 10 Oct 2024 03:23:29 +0530
Subject: [PATCH] feat: accept userId

---
 server/src/routes/storage.ts | 23 ++++++++++++-----------
 1 file changed, 12 insertions(+), 11 deletions(-)

diff --git a/server/src/routes/storage.ts b/server/src/routes/storage.ts
index 66ffbdbc..fa21a1b3 100644
--- a/server/src/routes/storage.ts
+++ b/server/src/routes/storage.ts
@@ -13,7 +13,7 @@ import { getDecryptedProxyConfig } from './proxy';
 import { requireSignIn } from '../middlewares/auth';
 import Robot from '../models/Robot';
 import Run from '../models/Run';
-// import { workflowQueue } from '../worker';
+import { workflowQueue } from '../worker';
 
 // todo: move from here
 export const getRecordingByFileName = async (fileName: string): Promise<any | null> => {
@@ -315,17 +315,18 @@ router.put('/schedule/:id/', requireSignIn, async (req, res) => {
     }
 
     const runId = uuid();
+    const userId = req.user.id;
 
-    // await workflowQueue.add(
-    //   'run workflow',
-    //   { id, runId, req.user.id },
-    //   {
-    //     repeat: {
-    //       pattern: cronExpression,
-    //       tz: timezone
-    //     }
-    //   }
-    // );
+     await workflowQueue.add(
+       'run workflow',
+       { id, runId, userId },
+       {
+         repeat: {
+           pattern: cronExpression,
+          tz: timezone
+     }
+       }
+     );
 
     res.status(200).json({
       message: 'success',