overleaf/services/web/app/coffee/Features/ConnectedUsers/ConnectedUsersManager.coffee

50 lines
1.3 KiB
CoffeeScript
Raw Normal View History

_ = require("underscore")
async = require("async")
Settings = require('settings-sharelatex')
redis = require('redis')
rclient = redis.createClient(Settings.redis.web.port, Settings.redis.web.host)
rclient.auth(Settings.redis.web.password)
ONE_HOUR_IN_S = 60 * 60
buildUserKey = (project_id, user_id)-> return "connected_user:#{project_id}:#{user_id}"
buildProjectSetKey = (project_id)-> return "connected_user:#{project_id}"
module.exports =
markUserAsConnected: (project_id, user_id, callback = (err)->)->
async.series [
(cb)->
rclient.sadd buildProjectSetKey(project_id), user_id, cb
(cb)->
rclient.setex buildUserKey(project_id, user_id), new Date(), ONE_HOUR_IN_S * 6, cb
], callback
_getConnectedUser: (project_id, user_id, callback)->
rclient.get buildUserKey(project_id, user_id), (err, result)->
if !result?
connected = false
else
connected = true
callback err, {connected:connected, user_id:user_id}
getConnectedUsers: (project_id, callback)->
self = @
rclient.get "connected_users_list:#{project_id}", (err, results)->
jobs = results.map (user_id)->
(cb)->
self._getConnectedUser(project_id, user_id, cb)
async.series jobs, (err, users)->
users = _.filter users, (user)->
user.connected
user_ids = _.map users, (user)->
user.user_id
callback err, user_ids