satori/kana
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

用户会话结束时移除订阅

Browse Source
This commit is contained in:
satori 2021-12-15 03:14:55 +08:00
parent 8afd1acd15
commit 88eddf4a58
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
fmhub.js
View File

@ -30,6 +30,9 @@ export default class {
if (user.size < 1) { if (user.size < 1) {
console.log(`由于用户 ${uid} 已经没有会话, 直接移除此用户记录`) console.log(`由于用户 ${uid} 已经没有会话, 直接移除此用户记录`)
this.users.delete(uid) this.users.delete(uid)
this.channels.forEach((channel, fm) => {
channel.delete(uid)
})
} }
} }
发送消息(fm, uid, data) { 发送消息(fm, uid, data) {
@ -38,7 +41,7 @@ export default class {
let channel = this.channels.get(fm) || new Map() let channel = this.channels.get(fm) || new Map()
if (!channel.size) this.channels.set(fm, channel) if (!channel.size) this.channels.set(fm, channel)
channel.forEach((value, userid) => { channel.forEach((value, userid) => {
console.log(userid, value) //console.log(userid, value)
let user = this.users.get(userid) || new Map() let user = this.users.get(userid) || new Map()
if (!user.size) { if (!user.size) {
console.log(user) console.log(user)