更新依赖
This commit is contained in:
@@ -214,7 +214,7 @@ export const connect = (urlInfo: LX.Sync.Client.UrlInfo, keyInfo: LX.Sync.Client
|
||||
client?.close(SYNC_CLOSE_CODE.failed)
|
||||
return
|
||||
}
|
||||
message2read.onMessage(syncData)
|
||||
message2read.message(syncData)
|
||||
}).catch((error) => {
|
||||
log.error('decrypt msg error: ', error)
|
||||
client?.close(SYNC_CLOSE_CODE.failed)
|
||||
@@ -253,7 +253,7 @@ export const connect = (urlInfo: LX.Sync.Client.UrlInfo, keyInfo: LX.Sync.Client
|
||||
}
|
||||
closeEvents = []
|
||||
disconnected = true
|
||||
message2read.onDestroy()
|
||||
message2read.destroy()
|
||||
switch (code) {
|
||||
case SYNC_CLOSE_CODE.normal:
|
||||
// case SYNC_CLOSE_CODE.failed:
|
||||
|
||||
@@ -210,7 +210,7 @@ const handleStartServer = async(port = 9527, ip = '0.0.0.0') => await new Promis
|
||||
socket.close(SYNC_CLOSE_CODE.failed)
|
||||
return
|
||||
}
|
||||
msg2call.onMessage(syncData)
|
||||
msg2call.message(syncData)
|
||||
}).catch(err => {
|
||||
log.error('decrypt message error:', err)
|
||||
log.error(err.message)
|
||||
@@ -226,7 +226,7 @@ const handleStartServer = async(port = 9527, ip = '0.0.0.0') => await new Promis
|
||||
}
|
||||
closeEvents = []
|
||||
disconnected = true
|
||||
msg2call.onDestroy()
|
||||
msg2call.destroy()
|
||||
if (socket.isReady) {
|
||||
log.info('deconnection', socket.userInfo.name, socket.keyInfo.deviceName)
|
||||
// events = {}
|
||||
|
||||
Reference in New Issue
Block a user