mirror of
https://github.com/overleaf/overleaf.git
synced 2024-12-04 04:57:36 -05:00
50 lines
1.3 KiB
CoffeeScript
50 lines
1.3 KiB
CoffeeScript
|
_ = 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
|
||
|
|
|
||
|
|
|