diff --git a/unisocket.js b/unisocket.js index b075a5e..9d6eb80 100644 --- a/unisocket.js +++ b/unisocket.js @@ -5,7 +5,7 @@ const my = { listeners: {}, heartbeatInterval: 20000, reconnectInterval: 5000, - messageQueue: [] + messageQueue: [], } // uni.onSocket* 和 sendSocketMessage/closeSocket 方法,是全局唯一的 api,不需要保存 socket 对象。 @@ -28,10 +28,10 @@ export default { if (my.messageQueue.length) { console.log('WebSocket_onOpen: sending messageQueue') - my.messageQueue.forEach(dataObj => { + my.messageQueue.forEach((dataObj) => { this.sendObject(dataObj) }) - my.messageQueue = [] + my.messageQueue = [] } clearInterval(my.reconnecting) @@ -110,8 +110,12 @@ export default { } return 0 }, - sendObject (dataObj) { + sendObject (dataObj = {}) { console.log('sendObject! socket.readyState =', my.socket.readyState) + // 把 sendObject({_passtoken}) 从其他零散地方迁移到这里来 + if (!dataObj._passtoken) { + dataObj._passtoken = uni.getStorageSync('_passtoken') || undefined + } if (my.socket && my.socket.readyState === my.socket.OPEN) { my.socket.send({ data: typeof dataObj !== 'string' ? JSON.stringify(dataObj) : dataObj,