mirror of https://github.com/status-im/codimd.git
50 lines
1.3 KiB
JavaScript
50 lines
1.3 KiB
JavaScript
'use strict'
|
|
|
|
const async = require('async')
|
|
const config = require('./config')
|
|
const logger = require('./logger')
|
|
|
|
/**
|
|
* clean when user not in any rooms or user not in connected list
|
|
*/
|
|
class CleanDanglingUserJob {
|
|
constructor (realtime) {
|
|
this.realtime = realtime
|
|
}
|
|
|
|
start () {
|
|
if (this.timer) return
|
|
this.timer = setInterval(this.cleanDanglingUser.bind(this), 60000)
|
|
}
|
|
|
|
stop () {
|
|
if (!this.timer) return
|
|
clearInterval(this.timer)
|
|
this.timer = undefined
|
|
}
|
|
|
|
cleanDanglingUser () {
|
|
const users = this.realtime.getUserPool()
|
|
async.each(Object.keys(users), (key, callback) => {
|
|
const socket = this.realtime.io.sockets.connected[key]
|
|
if ((!socket && users[key]) ||
|
|
(socket && (!socket.rooms || socket.rooms.length <= 0))) {
|
|
if (config.debug) {
|
|
logger.info('cleaner found redundant user: ' + key)
|
|
}
|
|
if (!socket) {
|
|
return callback(null, null)
|
|
}
|
|
if (!this.realtime.disconnectProcessQueue.checkTaskIsInQueue(socket.id)) {
|
|
this.realtime.queueForDisconnect(socket)
|
|
}
|
|
}
|
|
return callback(null, null)
|
|
}, function (err) {
|
|
if (err) return logger.error('cleaner error', err)
|
|
})
|
|
}
|
|
}
|
|
|
|
exports.CleanDanglingUserJob = CleanDanglingUserJob
|