From 946f6122f9ff033e525ee2db844d9650de8e1ff6 Mon Sep 17 00:00:00 2001 From: linjin Date: Tue, 21 Mar 2023 11:05:03 +0800 Subject: [PATCH 1/2] Support for obtaining the current online client --- bin/server.js | 1 + 1 file changed, 1 insertion(+) diff --git a/bin/server.js b/bin/server.js index e0a295f..861313f 100755 --- a/bin/server.js +++ b/bin/server.js @@ -109,6 +109,7 @@ const onconnection = conn => { if (message.topic) { const receivers = topics.get(message.topic) if (receivers) { + message.number = receivers.size receivers.forEach(receiver => send(receiver, message) ) From 9d399e3525bec111808705d8476c12fe2621a0b3 Mon Sep 17 00:00:00 2001 From: linjin Date: Tue, 21 Mar 2023 16:45:16 +0800 Subject: [PATCH 2/2] rename message.number to message.clients --- bin/server.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/bin/server.js b/bin/server.js index 861313f..485f2ca 100755 --- a/bin/server.js +++ b/bin/server.js @@ -109,7 +109,7 @@ const onconnection = conn => { if (message.topic) { const receivers = topics.get(message.topic) if (receivers) { - message.number = receivers.size + message.clients = receivers.size receivers.forEach(receiver => send(receiver, message) )