From 5482de258d5de5dd29d690193f9108c3a7ffe8e1 Mon Sep 17 00:00:00 2001
From: karishmas6 <carishmashukla28@gmail.com>
Date: Thu, 12 Sep 2024 21:08:36 +0530
Subject: [PATCH] feat: logging

---
 server/src/workflow-management/scheduler/index.ts | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/server/src/workflow-management/scheduler/index.ts b/server/src/workflow-management/scheduler/index.ts
index f8043a70..267ae609 100644
--- a/server/src/workflow-management/scheduler/index.ts
+++ b/server/src/workflow-management/scheduler/index.ts
@@ -33,25 +33,25 @@ export const worker = new Worker('workflow', async job => {
     const result = await handleRunRecording(fileName, runId);
     return result;
   } catch (error) {
-    console.error('Error running workflow:', error);
+    logger.error('Error running workflow:', error);
     throw error;
   }
 }, { connection });
 
 worker.on('completed', async (job: any) => {
-  console.log(`Job ${job.id} completed for ${job.data.fileName}_${job.data.runId}`);
+  logger.log(`info`,`Job ${job.id} completed for ${job.data.fileName}_${job.data.runId}`);
 
   await worker.close();
   await workflowQueue.close();
-  console.log('Worker and queue have been closed.');
+  logger.log(`info`,`Worker and queue have been closed.`);
 });
 
 worker.on('failed', async (job: any, err) => {
-  console.error(`Job ${job.id} failed for ${job.data.fileName}_${job.data.runId}:`, err);
+  logger.log(`error`, `Job ${job.id} failed for ${job.data.fileName}_${job.data.runId}:`, err);
 
   await worker.close();
   await workflowQueue.close();
-  console.log('Worker and queue have been closed after failure.');
+  logger.log(`info`, `Worker and queue have been closed after failure.`);
 });
 
 const existingJobs = workflowQueue.getRepeatableJobs();
@@ -184,7 +184,7 @@ async function readyForRunHandler(browserId: string, fileName: string, runId: st
     resetRecordingState(browserId, fileName, runId);
 
   } catch (error: any) {
-    console.error(`Error during readyForRunHandler: ${error.message}`);
+    logger.error(`Error during readyForRunHandler: ${error.message}`);
     await destroyRemoteBrowser(browserId);
   }
 }
@@ -219,7 +219,7 @@ async function handleRunRecording(fileName: string, runId: string) {
     });
 
   } catch (error: any) {
-    console.error('Error running recording:', error);
+    logger.error('Error running recording:', error);
   }
 }