From a3f15b13e4ff4b3a1fe26a16fa6dfd3ff3e3dbc5 Mon Sep 17 00:00:00 2001
From: Rohit <rohit.rajan031101@gmail.com>
Date: Wed, 12 Mar 2025 20:47:39 +0530
Subject: [PATCH] feat: emit socket event for notif

---
 server/src/pgboss-worker.ts | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/server/src/pgboss-worker.ts b/server/src/pgboss-worker.ts
index a05b7959..633d5efa 100644
--- a/server/src/pgboss-worker.ts
+++ b/server/src/pgboss-worker.ts
@@ -20,6 +20,7 @@ import { capture } from './utils/analytics';
 import { googleSheetUpdateTasks, processGoogleSheetUpdates } from './workflow-management/integrations/gsheet';
 import { airtableUpdateTasks, processAirtableUpdates } from './workflow-management/integrations/airtable';
 import { RemoteBrowser } from './browser-management/classes/RemoteBrowser';
+import { io as serverIo } from "./server";
 
 const pgBossConnectionString = `postgres://${process.env.DB_USER}:${process.env.DB_PASSWORD}@${process.env.DB_HOST}:${process.env.DB_PORT}/${process.env.DB_NAME}`;
 
@@ -298,6 +299,14 @@ async function processRunExecution(job: Job<ExecuteRunData>) {
       } catch (err: any) {
         logger.log('error', `Failed to update Google Sheet for run: ${plainRun.runId}: ${err.message}`);
       }
+
+      serverIo.of(plainRun.browserId).emit('run-completed', {
+        runId: data.runId,
+        robotMetaId: plainRun.robotMetaId,
+        robotName: recording.recording_meta.name,
+        status: 'success',
+        finishedAt: new Date().toLocaleString()
+      });;
       
       // Check for and process queued runs before destroying the browser
       const queuedRunProcessed = await checkAndProcessQueuedRun(data.userId, plainRun.browserId);