overleaf/services/web/app/coffee/Features/User/UserGetter.coffee

83 lines
2.6 KiB
CoffeeScript
Raw Normal View History

2014-02-12 05:23:40 -05:00
mongojs = require("../../infrastructure/mongojs")
metrics = require('metrics-sharelatex')
2017-03-16 06:59:18 -04:00
logger = require('logger-sharelatex')
2014-02-12 05:23:40 -05:00
db = mongojs.db
ObjectId = mongojs.ObjectId
module.exports = UserGetter =
getUser: (query, projection, callback = (error, user) ->) ->
if query?.email?
return callback(new Error("Don't use getUser to find user by email"), null)
2014-02-12 05:23:40 -05:00
if arguments.length == 2
callback = projection
projection = {}
if typeof query == "string"
2014-11-09 18:08:23 -05:00
try
query = _id: ObjectId(query)
catch e
return callback(null, null)
2014-02-12 05:23:40 -05:00
else if query instanceof ObjectId
query = _id: query
db.users.findOne query, projection, callback
2018-05-25 07:04:09 -04:00
getUserEmail: (userId, callback = (error, email) ->) ->
@getUser userId, { email: 1 }, (error, user) ->
callback(error, user?.email)
getUserByMainEmail: (email, projection, callback = (error, user) ->) ->
email = email.trim()
if arguments.length == 2
callback = projection
projection = {}
db.users.findOne email: email, projection, callback
2018-05-25 07:04:09 -04:00
getUserByAnyEmail: (email, projection, callback = (error, user) ->) ->
email = email.trim()
if arguments.length == 2
callback = projection
projection = {}
2018-06-06 09:46:41 -04:00
# $exists: true MUST be set to use the partial index
query = emails: { $exists: true }, 'emails.email': email
db.users.findOne query, projection, (error, user) =>
2018-05-25 07:04:09 -04:00
return callback(error, user) if error? or user?
# While multiple emails are being rolled out, check for the main email as
# well
@getUserByMainEmail email, projection, callback
getUsers: (user_ids, projection, callback = (error, users) ->) ->
try
user_ids = user_ids.map (u) -> ObjectId(u.toString())
catch error
return callback error
2017-03-16 06:59:18 -04:00
db.users.find { _id: { $in: user_ids} }, projection, callback
getUserOrUserStubById: (user_id, projection, callback = (error, user) ->) ->
try
query = _id: ObjectId(user_id.toString())
catch e
return callback(new Error(e))
db.users.findOne query, projection, (error, user) ->
return callback(error) if error?
return callback(null, user) if user?
db.userstubs.findOne query, projection, callback
2017-03-17 10:55:41 -04:00
2018-05-28 10:08:37 -04:00
# check for duplicate email address. This is also enforced at the DB level
ensureUniqueEmailAddress: (newEmail, callback) ->
@getUserByAnyEmail newEmail, (error, user) ->
return callback(message: 'alread_exists') if user?
callback(error)
2017-03-17 10:55:41 -04:00
[
'getUser',
2018-05-25 07:04:09 -04:00
'getUserEmail',
'getUserByMainEmail',
2018-05-25 07:04:09 -04:00
'getUserByAnyEmail',
'getUsers',
2018-05-28 10:08:37 -04:00
'getUserOrUserStubById',
'ensureUniqueEmailAddress',
2017-03-17 10:55:41 -04:00
].map (method) ->
metrics.timeAsyncMethod UserGetter, method, 'mongo.UserGetter', logger