| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849 |
- _ = 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
|
