| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768 |
- Settings = require('settings-sharelatex')
- redis = require('redis-sharelatex')
- rclient = redis.createClient(Settings.redis.web)
- logger = require("logger-sharelatex")
- module.exports = UserSessionsManager =
- _sessionSetKey: (user) ->
- return "UserSessions:#{user._id}"
- # mimic the key used by the express sessions
- _sessionKey: (sessionId) ->
- return "sess:#{sessionId}"
- trackSession: (user, sessionId, callback=(err)-> ) ->
- logger.log {user_id: user._id, sessionId}, "onLogin handler"
- sessionSetKey = UserSessionsManager._sessionSetKey(user)
- value = UserSessionsManager._sessionKey sessionId
- rclient.multi()
- .sadd(sessionSetKey, value)
- .expire(sessionSetKey, "#{Settings.cookieSessionLength}")
- .exec (err, response) ->
- if err
- logger.err {err, user_id: user._id, sessionSetKey}, "error while adding session key to UserSessions set"
- return callback(err)
- callback()
- untrackSession: (user, sessionId, callback=(err)-> ) ->
- logger.log {user_id: user._id, sessionId}, "onLogout handler"
- if !user
- logger.log {sessionId}, "no user, for some reason"
- return callback()
- sessionSetKey = UserSessionsManager._sessionSetKey(user)
- value = UserSessionsManager._sessionKey sessionId
- rclient.multi()
- .srem(sessionSetKey, value)
- .expire(sessionSetKey, "#{Settings.cookieSessionLength}")
- .exec (err, response) ->
- if err
- logger.err {err, user_id: user._id, sessionSetKey}, "error while removing session key from UserSessions set"
- return callback(err)
- callback()
- revokeAllUserSessions: (user, callback=(err)->) ->
- logger.log {user_id: user._id}, "revoking all existing sessions for user"
- sessionSetKey = UserSessionsManager._sessionSetKey(user)
- rclient.smembers sessionSetKey, (err, sessionKeys) ->
- if err
- logger.err {err, user_id: user._id, sessionSetKey}, "error getting contents of UserSessions set"
- return callback(err)
- logger.log {user_id: user._id, count: sessionKeys.length}, "deleting sessions for user"
- rclient.multi()
- .del(sessionKeys)
- .srem(sessionSetKey, sessionKeys)
- .exec (err, result) ->
- if err
- logger.err {err, user_id: user._id, sessionSetKey}, "error revoking all sessions for user"
- return callback(err)
- callback(null)
- touch: (user, callback=(err)->) ->
- if !user
- return callback(null)
- sessionSetKey = UserSessionsManager._sessionSetKey(user)
- rclient.expire sessionSetKey, "#{Settings.cookieSessionLength}", (err, response) ->
- if err
- logger.err {err, user_id: user._id}, "error while updating ttl on UserSessions set"
- return callback(err)
|