peerNotFound stats

Author: snowinszu

.github/workflows/docker-build.yml

@@ -36,4 +36,4 @@ jobs:
                     push: true
                     platforms: linux/amd64
 #                    tags: cdnbye/cbsignal_uws:latest
-                    tags: cdnbye/cbsignal_uws:5.5.0
+                    tags: cdnbye/cbsignal_uws:5.5.1

lib/hub.js

@@ -14,6 +14,10 @@ class Hub {
         this.logger = logger;
         this.numClientAllWorkers = 0;
         this.numWorkers = 0;
+        this.stats = {
+            notFoundCount: 0,
+            total: 1,
+        };
         setInterval(() => {
             this.checkConns();
         }, CHECK_CLIENT_INTERVAL * 1000 + randomNum(0, 10000))
@@ -238,6 +242,7 @@ class Hub {
         if (data.candidate && !data.candidate.candidate) {
             return
         }
+        this.stats.total ++;
         if (target) {
             const success = this.sendJsonToClient(target, this._processJson(json, peerId, target.isCompact));
             if (!success) {
@@ -288,6 +293,7 @@ class Hub {
 
     async _handlePeerNotFound(client, toPeerId, peerId) {
         // this.logger.info(`_handlePeerNotFound ${client} ${toPeerId} ${peerId}`);
+        this.stats.notFoundCount ++;
         const msg = {
             action: 'signal',
             from_peer_id: toPeerId,
@@ -335,9 +341,13 @@ class Hub {
         // if (wsCountRemoved > 0 || httpCountRemoved > 0) {
         //     this.logger.warn(`check cmap finished, closed clients: ws ${wsCountRemoved} polling ${httpCountRemoved}`);
         // }
-        this.logger.warn(`current clients ws ${wsCount}, polling ${httpCount}, hit cache ${((redis.stats.curCount/redis.stats.totalCount)*100).toFixed(2)}%`);
+        this.logger.warn(`current clients ws ${wsCount}, polling ${httpCount}, hit cache ${((redis.stats.curCount/redis.stats.totalCount)*100).toFixed(2)}%, peerNotFound ${((this.stats.notFoundCount/this.stats.total)*100).toFixed(2)}%`);
         redis.stats.curCount = 0;
         redis.stats.totalCount = 1;
+        this.stats = {
+            notFoundCount: 0,
+            total: 1,
+        }
     }
 }
 

lib/server.js

@@ -349,7 +349,7 @@ class Server {
                 (this.access.denyDomains?.has(domain) ||
                     this.access.allowDomains?.has(domain) === false);
             if (shouldDeny) {
-                this.logger.warn(`denied domain ${domain}`);
+                // this.logger.warn(`denied domain ${domain}`);
                 ws.end(4000, 'domain is denied');
                 return
             }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "cbsignal_uws",
-  "version": "5.5.0",
+  "version": "5.5.1",
   "description": "SwarmCloud signaling server using uWebSockets.js",
   "main": "index.js",
   "bin": "index.js",