📖 update readme

2021-06-13 18:21:36 +08:00
parent 018d252e5d
commit 1e81e68bd7
3 changed files with 27 additions and 10 deletions
@@ -1,8 +1,9 @@
+const WebSocket = require('ws');
 const { tokenStore } = require('./token');

 async function pushClientMessage(userPrefix, message) {
  let user = tokenStore.get(userPrefix);
-  if (!user || !user.ws) {
+  if (!user || !user.ws || user.ws.readyState !== WebSocket.OPEN) {
    return {
      success: false,
      message: `客户端未连接`,
@@ -12,11 +13,10 @@ async function pushClientMessage(userPrefix, message) {
    title: message.title,
    description: message.description,
  };
-  console.log(JSON.stringify(data));
  user.ws.send(JSON.stringify(data));
  return {
    success: true,
-    message: '消息已发送给 WebSocket 客户端',
+    message: '消息已发送至客户端',
  };
 }