SubscriptionGroupHandler.coffee 2.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. async = require("async")
  2. _ = require("underscore")
  3. SubscriptionUpdater = require("./SubscriptionUpdater")
  4. SubscriptionLocator = require("./SubscriptionLocator")
  5. UserGetter = require("../User/UserGetter")
  6. Subscription = require("../../models/Subscription").Subscription
  7. LimitationsManager = require("./LimitationsManager")
  8. logger = require("logger-sharelatex")
  9. OneTimeTokenHandler = require("../Security/OneTimeTokenHandler")
  10. EmailHandler = require("../Email/EmailHandler")
  11. settings = require("settings-sharelatex")
  12. NotificationsBuilder = require("../Notifications/NotificationsBuilder")
  13. UserMembershipViewModel = require("../UserMembership/UserMembershipViewModel")
  14. module.exports = SubscriptionGroupHandler =
  15. removeUserFromGroup: (subscriptionId, userToRemove_id, callback)->
  16. SubscriptionUpdater.removeUserFromGroup subscriptionId, userToRemove_id, callback
  17. replaceUserReferencesInGroups: (oldId, newId, callback) ->
  18. logger.log old_id: oldId, new_id: newId, "replacing user reference in groups"
  19. Subscription.update {admin_id: oldId}, {admin_id: newId}, (error) ->
  20. return callback(error) if error?
  21. replaceInArray Subscription, "manager_ids", oldId, newId, (error) ->
  22. return callback(error) if error?
  23. replaceInArray Subscription, "member_ids", oldId, newId, callback
  24. isUserPartOfGroup: (user_id, subscription_id, callback=(err, partOfGroup)->)->
  25. SubscriptionLocator.getSubscriptionByMemberIdAndId user_id, subscription_id, (err, subscription)->
  26. if subscription?
  27. partOfGroup = true
  28. else
  29. partOfGroup = false
  30. logger.log user_id:user_id, subscription_id:subscription_id, partOfGroup:partOfGroup, "checking if user is part of a group"
  31. callback(err, partOfGroup)
  32. getTotalConfirmedUsersInGroup: (subscription_id, callback=(err, totalUsers)->)->
  33. SubscriptionLocator.getSubscription subscription_id, (err, subscription)->
  34. callback(err, subscription?.member_ids?.length)
  35. replaceInArray = (model, property, oldValue, newValue, callback) ->
  36. logger.log "Replacing #{oldValue} with #{newValue} in #{property} of #{model}"
  37. # Mongo won't let us pull and addToSet in the same query, so do it in
  38. # two. Note we need to add first, since the query is based on the old user.
  39. query = {}
  40. query[property] = oldValue
  41. setNewValue = {}
  42. setNewValue[property] = newValue
  43. setOldValue = {}
  44. setOldValue[property] = oldValue
  45. model.update query, { $addToSet: setNewValue }, { multi: true }, (error) ->
  46. return callback(error) if error?
  47. model.update query, { $pull: setOldValue }, { multi: true }, callback