From 2f6a9258fca577bdad07a584e0c0087575bfe516 Mon Sep 17 00:00:00 2001
From: Taha Yassine Kraiem <tahayk2@gmail.com>
Date: Mon, 14 Feb 2022 20:26:20 +0100
Subject: [PATCH] feat(utilities): WS reduce maxHttpBufferSize feat(utilities):
 WS log status each 30s

---
 utilities/build.sh             |  8 ++++----
 utilities/servers/websocket.js | 22 +++++++++++++++++++++-
 2 files changed, 25 insertions(+), 5 deletions(-)

diff --git a/utilities/build.sh b/utilities/build.sh
index 99be144fe..9855d1b26 100644
--- a/utilities/build.sh
+++ b/utilities/build.sh
@@ -20,11 +20,11 @@ function build_api(){
     [[ $1 == "ee" ]] && {
         cp -rf ../ee/utilities/* ./
     }
-    docker build -f ./Dockerfile -t ${DOCKER_REPO:-'local'}/utilities:${git_sha1} .
+    docker build -f ./Dockerfile -t ${DOCKER_REPO:-'local'}/utilities:1.5.0 .
     [[ $PUSH_IMAGE -eq 1 ]] && {
-        docker push ${DOCKER_REPO:-'local'}/utilities:${git_sha1}
-        docker tag ${DOCKER_REPO:-'local'}/utilities:${git_sha1} ${DOCKER_REPO:-'local'}/utilities:latest
-        docker push ${DOCKER_REPO:-'local'}/utilities:latest
+        docker push ${DOCKER_REPO:-'local'}/utilities:1.5.0
+        docker build -f ./Dockerfile -t ${DOCKER_REPO:-'local'}/utilities:1.5.0-ee .
+        docker push ${DOCKER_REPO:-'local'}/utilities:1.5.0-ee
     }
 }
 
diff --git a/utilities/servers/websocket.js b/utilities/servers/websocket.js
index 96364f4a8..f96674b4e 100644
--- a/utilities/servers/websocket.js
+++ b/utilities/servers/websocket.js
@@ -161,7 +161,7 @@ module.exports = {
     wsRouter,
     start: (server) => {
         io = _io(server, {
-            maxHttpBufferSize: 7e6,
+            maxHttpBufferSize: 1e6,
             cors: {
                 origin: "*",
                 methods: ["GET", "POST", "PUT"]
@@ -252,5 +252,25 @@ module.exports = {
 
         });
         console.log("WS server started")
+        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} ====== `);
+                for (let item of filtered) {
+                    console.log(`Room: ${item[0]} connected: ${item[1].size}`)
+                }
+            } catch (e) {
+                console.error(e);
+            }
+        }, 30000, io);
     }
 };
\ No newline at end of file