fix: join stream checks now if stream ended

lyve-app · Jun 16, 2024 · 39aad5c · 39aad5c
1 parent 9ac7d08
commit 39aad5c
Showing 1 changed file with 16 additions and 1 deletion.
diff --git a/apps/api/src/app.ts b/apps/api/src/app.ts
@@ -242,7 +242,8 @@ io.on("connection", (socket) => {
       select: {
         id: true,
         streamerId: true,
-        created_at: true
+        created_at: true,
+        ended_at: true
       }
     });
 
@@ -260,6 +261,20 @@ io.on("connection", (socket) => {
       });
     }
 
+    if (checkStream.ended_at) {
+      return callback({
+        success: false,
+        data: null,
+        error: [
+          {
+            name: "Stream Ended",
+            code: -1,
+            msg: "This stream has already ended."
+          }
+        ]
+      });
+    }
+
     if (!streams.get(streamId)) {
       // create stream
       streams.set(streamId, {