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

u

Browse Source
This commit is contained in:
陆柯 2023-08-14 11:38:50 +08:00
parent a3a1d09f3c
commit 7fd8868290
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
basesocket.js
View File

@ -28,11 +28,17 @@ module.exports = {
console.log(new Date().toJSON(), 'Unable to parse socket message: ', data) console.log(new Date().toJSON(), 'Unable to parse socket message: ', data)
return return
} }
if (dataObj.skevent === 'SOCKET_OWNER') { if (['SOCKET_OWNER', 'SOCKET_OWNER_RECONNECT'].includes(dataObj.skevent)) {
dataObj._passtokenSource = webtoken.verifyToken(dataObj._passtoken) // todo: 为防止前端欺骗，应当用和login里类似的方法来检查来检查 dataObj._passtokenSource = webtoken.verifyToken(dataObj._passtoken)
if (typeof dataObj._passtokenSource?.usid === 'string') { if (typeof dataObj._passtokenSource?.usid === 'string') {
my.socketPool[dataObj._passtokenSource.usid] = socket my.socketPool[dataObj._passtokenSource.usid] = socket
console.log('收到 Login 成功的消息，绑定socket', Object.keys(my.socketPool)) console.log(
dataObj.skevent === 'SOCKET_OWNER' ? 'Login 成功' : 'Reconnect 成功',
'绑定 socket 到',
dataObj._passtokenSource.usid,
'socketPool.length =',
Object.keys(my.socketPool)?.length
)
} }
} }