rename all base.xxx to basend-xxx

This commit is contained in:
陆柯 2022-06-04 10:51:45 +08:00
parent ab4dfb2db4
commit c1acfe53fb
3 changed files with 10 additions and 10 deletions

View File

@ -1 +1 @@
# base.websocket.server web服务端套接口 # basend-websocket-server web 服务端套接口

View File

@ -1,5 +1,5 @@
const ws = require('ws') const ws = require('ws')
const webtoken = require('base.webtoken') const webtoken = require('basend-webtoken')
const my = { const my = {
wssServer: undefined, wssServer: undefined,
@ -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.')
@ -30,7 +30,7 @@ module.exports = {
} }
if (dataObj.skevent === 'SOCKET_OWNER') { if (dataObj.skevent === 'SOCKET_OWNER') {
dataObj._passtokenSource = webtoken.verifyToken(dataObj._passtoken) // todo: 为防止前端欺骗应当用和login里类似的方法来检查来检查 dataObj._passtokenSource = webtoken.verifyToken(dataObj._passtoken) // todo: 为防止前端欺骗应当用和login里类似的方法来检查来检查
if (typeof(dataObj._passtokenSource?.uuid)==='string') { if (typeof dataObj._passtokenSource?.uuid === 'string') {
my.socketPool[dataObj._passtokenSource.uuid] = socket my.socketPool[dataObj._passtokenSource.uuid] = socket
console.log('收到Login 成功的消息绑定socket', Object.keys(my.socketPool)) console.log('收到Login 成功的消息绑定socket', Object.keys(my.socketPool))
} }
@ -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)

View File

@ -1,10 +1,10 @@
{ {
"name": "base.websocket.server", "name": "basend-websocket-server",
"version": "0.1.0", "version": "0.1.0",
"main": "basesocket.js", "main": "basesocket.js",
"private": true, "private": true,
"dependencies": { "dependencies": {
"base.webtoken": "git+https://git.faronear.org/npm/base.webtoken", "basend-webtoken": "git+https://git.faronear.org/npm/basend-webtoken",
"ws": "^7.2.1" "ws": "^7.2.1"
}, },
"devDependencies": {}, "devDependencies": {},