🐛 Fixed stream.idle webhook handling

Author: Mario-SO

packages/server/src/controllers/index.controller.ts

@@ -182,11 +182,21 @@ export class IndexController extends Controller {
           break;
 
         case LivepeerEvent.streamStarted:
+          console.log('🎥 Stream started event received:', {
+            streamId: payload.stream?.id,
+            status: payload.stream?.status,
+            isActive: payload.stream?.isActive,
+            isHealthy: payload.stream?.isHealthy
+          });
+          await this.stageService.findStreamAndUpdate(payload.stream.id);
+          break;
+          
         case LivepeerEvent.streamIdle:
-          console.log('🎥 Stream event received:', {
-            event: payload.event,
+          console.log('🎥 Stream idle event received:', {
             streamId: payload.stream?.id,
             status: payload.stream?.status,
+            isActive: payload.stream?.isActive,
+            isHealthy: payload.stream?.isHealthy,
           });
           await this.stageService.findStreamAndUpdate(payload.stream.id);
           break;

packages/server/src/services/stage.service.ts

@@ -140,14 +140,17 @@ export default class StageService {
     const stream = await getStreamInfo(id);
     let stage = await Stage.findOne({ 'streamSettings.streamId': id });
     if (!stage) throw new HttpException(400, 'stage not found');
-    // send message to redis
-    const queue = await stageTranscriptionsQueue();
-    await queue.add({
-      stageId: stage._id,
-    });
+
+    if (!stream.isActive) {
+      const queue = await stageTranscriptionsQueue();
+      await queue.add({
+        stageId: stage._id,
+      });
+    }
+
     await stage.updateOne(
       {
-        'stageSettings.transcripts.status': 'in-queue',
+        'stageSettings.transcripts.status': !stream.isActive ? 'in-queue' : undefined,
         'streamSettings.isActive': stream.isActive,
         'streamSettings.isHealthy': stream.isHealthy ?? false,
       },