mirror of
https://github.com/overleaf/overleaf.git
synced 2024-11-21 20:47:08 -05:00
Address Henry's comments about robustness
This commit is contained in:
parent
73443f5a65
commit
e1af76f652
1 changed files with 16 additions and 16 deletions
|
@ -24,7 +24,7 @@ module.exports = HoldingAccountMigration =
|
||||||
jobs = projects.map (project) ->
|
jobs = projects.map (project) ->
|
||||||
(cb) ->
|
(cb) ->
|
||||||
console.log "[Removing user from project]", user_id, JSON.stringify(project)
|
console.log "[Removing user from project]", user_id, JSON.stringify(project)
|
||||||
if !project._id?
|
if !project?._id?
|
||||||
throw new Error("no project id")
|
throw new Error("no project id")
|
||||||
|
|
||||||
if !HoldingAccountMigration.DRY_RUN
|
if !HoldingAccountMigration.DRY_RUN
|
||||||
|
@ -48,31 +48,31 @@ module.exports = HoldingAccountMigration =
|
||||||
deleteUser: (user_id, callback = (error) ->) ->
|
deleteUser: (user_id, callback = (error) ->) ->
|
||||||
if !user_id?
|
if !user_id?
|
||||||
throw new Error("must have user_id")
|
throw new Error("must have user_id")
|
||||||
db.users.find {_id: user_id}, (error, user) ->
|
|
||||||
return callback(error) if error?
|
|
||||||
if !user?
|
|
||||||
throw new Error("expected user")
|
|
||||||
console.log "[Removing user]", user_id, JSON.stringify(user)
|
|
||||||
if !HoldingAccountMigration.DRY_RUN
|
if !HoldingAccountMigration.DRY_RUN
|
||||||
db.users.remove {_id: user_id}, (error, result) ->
|
db.users.remove {_id: user_id, holdingAccount: true}, (error, result) ->
|
||||||
|
return callback(error) if error?
|
||||||
console.log "[Removed user]", user_id, result
|
console.log "[Removed user]", user_id, result
|
||||||
callback(error)
|
if result.n != 1
|
||||||
|
return callback(new Error("failed to remove user as expected"))
|
||||||
|
callback()
|
||||||
else
|
else
|
||||||
console.log "[Would have removed user]", user_id
|
console.log "[Would have removed user]", user_id
|
||||||
callback()
|
callback()
|
||||||
|
|
||||||
run: (done) ->
|
run: (done = () ->) ->
|
||||||
HoldingAccountMigration.findHoldingAccounts (error, users) ->
|
HoldingAccountMigration.findHoldingAccounts (error, users) ->
|
||||||
throw error if error?
|
throw error if error?
|
||||||
console.log "[Got list of holding accounts]", users.map (u) -> u._id
|
console.log "[Got list of holding accounts]", users.map (u) -> u._id
|
||||||
jobs = users.map (u) ->
|
jobs = users.map (u) ->
|
||||||
(cb) ->
|
(cb) ->
|
||||||
|
HoldingAccountMigration.deleteUser u._id, (error) ->
|
||||||
|
return cb(error) if error?
|
||||||
HoldingAccountMigration.deleteUserProjects u._id, (error) ->
|
HoldingAccountMigration.deleteUserProjects u._id, (error) ->
|
||||||
return cb(error) if error?
|
return cb(error) if error?
|
||||||
HoldingAccountMigration.deleteUser u._id, cb
|
setTimeout cb, 200 # Small delay to not hammer DB
|
||||||
async.series jobs, (error) ->
|
async.series jobs, (error) ->
|
||||||
throw error if error?
|
throw error if error?
|
||||||
console.log "[Removed holding accounts]"
|
console.log "[FINISHED]"
|
||||||
done()
|
done()
|
||||||
|
|
||||||
migrate: (client, done=()->) ->
|
migrate: (client, done=()->) ->
|
||||||
|
|
Loading…
Reference in a new issue