mirror of
https://github.com/overleaf/overleaf.git
synced 2024-09-23 02:55:13 -04:00
89ee728514
This reverts commit 4ac63921b030a01ed79bc0da1666d3c9f9545248. GitOrigin-RevId: c8814e7fd85776feb37bf8fad95038349b36cd9a
55 lines
2.3 KiB
CoffeeScript
55 lines
2.3 KiB
CoffeeScript
Errors = require "../Errors/Errors"
|
|
User = require("../../models/User").User
|
|
UserUpdater = require "./UserUpdater"
|
|
_ = require "lodash"
|
|
|
|
module.exports = ThirdPartyIdentityManager =
|
|
login: (providerId, externalUserId, externalData, callback) ->
|
|
return callback(new Error "invalid arguments") unless providerId? and externalUserId?
|
|
externalUserId = externalUserId.toString()
|
|
providerId = providerId.toString()
|
|
query =
|
|
"thirdPartyIdentifiers.externalUserId": externalUserId
|
|
"thirdPartyIdentifiers.providerId": providerId
|
|
User.findOne query, (err, user) ->
|
|
return callback err if err?
|
|
return callback(new Errors.ThirdPartyUserNotFoundError()) unless user
|
|
# skip updating data unless passed
|
|
return callback(null, user) unless externalData
|
|
# get third party identifier object from array
|
|
thirdPartyIdentifier = user.thirdPartyIdentifiers.find (tpi) ->
|
|
tpi.externalUserId == externalUserId and tpi.providerId == providerId
|
|
# do recursive merge of new data over existing data
|
|
_.merge(thirdPartyIdentifier.externalData, externalData)
|
|
# update user
|
|
update = "thirdPartyIdentifiers.$": thirdPartyIdentifier
|
|
User.findOneAndUpdate query, update, {new: true}, callback
|
|
|
|
# register: () ->
|
|
# this should be implemented once we move to having v2 as the master
|
|
# but for now we need to register with v1 then call link once that
|
|
# is complete
|
|
|
|
link: (user_id, providerId, externalUserId, externalData, callback, retry) ->
|
|
query =
|
|
_id: user_id
|
|
"thirdPartyIdentifiers.providerId": $ne: providerId
|
|
update = $push: thirdPartyIdentifiers:
|
|
externalUserId: externalUserId
|
|
externalData: externalData
|
|
providerId: providerId
|
|
# add new tpi only if an entry for the provider does not exist
|
|
UserUpdater.updateUser query, update, (err, res) ->
|
|
return callback err if err?
|
|
return callback null, res if res.nModified == 1
|
|
# if already retried then throw error
|
|
return callback(new Error "update failed") if retry
|
|
# attempt to clear existing entry then retry
|
|
ThirdPartyIdentityManager.unlink user_id, providerId, (err) ->
|
|
return callback err if err?
|
|
ThirdPartyIdentityManager.link user_id, providerId, externalUserId, externalData, callback, true
|
|
|
|
unlink: (user_id, providerId, callback) ->
|
|
update = $pull: thirdPartyIdentifiers:
|
|
providerId: providerId
|
|
UserUpdater.updateUser user_id, update, callback
|