npm/wo-base-websocket-server
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

优化格式

Browse Source
This commit is contained in:
陆柯 2022-04-01 20:51:10 +08:00
parent a6d35705e9
commit a5882242cc
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
index.js
View File

@ -8,7 +8,7 @@ const my = {
} }
module.exports = { module.exports = {
initSocket: (webServer) => { initSocket(webServer) {
my.wssServer = new ws.Server({ server: webServer }) my.wssServer = new ws.Server({ server: webServer })
console.info('App Socket Server attached to web server.') console.info('App Socket Server attached to web server.')
@ -46,11 +46,11 @@ module.exports = {
return this return this
}, },
removeUserSocket: (uuid) => { removeUserSocket(uuid) {
delete my.socketPool[uuid] delete my.socketPool[uuid]
}, },
addListener: (skevent, listener) => { addListener(skevent, listener) {
if (Array.isArray(my.listeners[skevent]) && typeof listener === 'function') { if (Array.isArray(my.listeners[skevent]) && typeof listener === 'function') {
my.listeners[skevent].push(listener) my.listeners[skevent].push(listener)
} else { } else {
@ -59,7 +59,7 @@ module.exports = {
return this return this
}, },
sendToAll: (dataObj) => { sendToAll(dataObj) {
my.wssServer.clients.forEach((socket) => { my.wssServer.clients.forEach((socket) => {
if (socket.readyState === socket.OPEN) { if (socket.readyState === socket.OPEN) {
socket.send(typeof dataObj !== 'string' ? JSON.stringify(dataObj) : dataObj) socket.send(typeof dataObj !== 'string' ? JSON.stringify(dataObj) : dataObj)
@ -69,7 +69,7 @@ module.exports = {
}) })
}, },
sendToOne: (dataObj, uuid) => { sendToOne(dataObj, uuid) {
const socket = my.socketPool[uuid] const socket = my.socketPool[uuid]
if (socket && socket.readyState === socket.OPEN) { if (socket && socket.readyState === socket.OPEN) {
socket.send(typeof dataObj !== 'string' ? JSON.stringify(dataObj) : dataObj) socket.send(typeof dataObj !== 'string' ? JSON.stringify(dataObj) : dataObj)