fix: fixed leave stream when host leaves and users cant

lyve-app · Jul 4, 2024 · 08a69d6 · 08a69d6
1 parent c9c8556
commit 08a69d6
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/apps/api/src/app.ts b/apps/api/src/app.ts
@@ -615,7 +615,10 @@ io.on("connection", (socket) => {
 
       io.in(streamId).socketsLeave(streamId);
 
-      streams.delete(streamId);
+      if (stream.viewerCount === 0) {
+        streams.delete(streamId);
+      }
+
       delete socket.data.streamId;
     } else {
       const checkIfPresent = stream.viewers.find(
@@ -673,6 +676,10 @@ io.on("connection", (socket) => {
 
       delete socket.data.streamId;
 
+      if (stream.viewerCount === 0) {
+        streams.delete(streamId);
+      }
+
       logger.info(
         `User ${socket.data.user.username} leaved stream: ${streamId}`
       );