From 0395c79986a13c9d31ef6677b50b5337f5841e97 Mon Sep 17 00:00:00 2001
From: Taha Yassine Kraiem <tahayk2@gmail.com>
Date: Tue, 15 Feb 2022 21:52:22 +0100
Subject: [PATCH] feat(utilities): WS log stats

---
 utilities/servers/websocket.js | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)

diff --git a/utilities/servers/websocket.js b/utilities/servers/websocket.js
index ddc40ff0d..f2e16884a 100644
--- a/utilities/servers/websocket.js
+++ b/utilities/servers/websocket.js
@@ -244,6 +244,29 @@ module.exports = {
         });
         console.log("WS server started");
         debug ? console.log("Debugging enabled.") : console.log("Debugging disabled, set debug=\"1\" to enable debugging.");
+
+        setInterval((io) => {
+            try {
+                let count = 0;
+                console.log(` ====== Rooms: ${io.sockets.adapter.rooms.size} ====== `);
+                const arr = Array.from(io.sockets.adapter.rooms)
+                const filtered = arr.filter(room => !room[1].has(room[0]))
+                for (let i of filtered) {
+                    let {projectKey, sessionId} = extractPeerId(i[0]);
+                    if (projectKey !== null && sessionId !== null) {
+                        count++;
+                    }
+                }
+                console.log(` ====== Valid Rooms: ${count} ====== `);
+                if (debug) {
+                    for (let item of filtered) {
+                        console.log(`Room: ${item[0]} connected: ${item[1].size}`)
+                    }
+                }
+            } catch (e) {
+                console.error(e);
+            }
+        }, 20000, io);
     },
     handlers: {
         socketsList,