fix: leave_stream

lyve-app · Jul 5, 2024 · b8c3731 · b8c3731
1 parent 4ce19e3
commit b8c3731
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/apps/api/src/app.ts b/apps/api/src/app.ts
@@ -629,7 +629,9 @@ io.on("connection", (socket) => {
 
       io.in(streamId).socketsLeave(streamId);
 
-      if (stream.viewerCount === 0) {
+      const socketCount = await io.in(streamId).fetchSockets();
+
+      if (stream.viewerCount === 0 && socketCount.length === 0) {
         streams.delete(streamId);
       }
 
@@ -690,7 +692,9 @@ io.on("connection", (socket) => {
 
       delete socket.data.streamId;
 
-      if (stream.viewerCount === 0) {
+      const socketCount = await io.in(streamId).fetchSockets();
+
+      if (stream.viewerCount === 0 && socketCount.length === 0) {
         streams.delete(streamId);
       }