SubscriptionGroupHandler.coffee 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. async = require("async")
  2. _ = require("underscore")
  3. SubscriptionUpdater = require("./SubscriptionUpdater")
  4. SubscriptionLocator = require("./SubscriptionLocator")
  5. UserGetter = require("../User/UserGetter")
  6. LimitationsManager = require("./LimitationsManager")
  7. logger = require("logger-sharelatex")
  8. OneTimeTokenHandler = require("../Security/OneTimeTokenHandler")
  9. TeamInvitesHandler = require("./TeamInvitesHandler")
  10. EmailHandler = require("../Email/EmailHandler")
  11. settings = require("settings-sharelatex")
  12. NotificationsBuilder = require("../Notifications/NotificationsBuilder")
  13. module.exports = SubscriptionGroupHandler =
  14. addUserToGroup: (adminUserId, newEmail, callback)->
  15. logger.log adminUserId:adminUserId, newEmail:newEmail, "adding user to group"
  16. LimitationsManager.hasGroupMembersLimitReached adminUserId, (err, limitReached, subscription)->
  17. if err?
  18. logger.err err:err, adminUserId:adminUserId, newEmail:newEmail, "error checking if limit reached for group plan"
  19. return callback(err)
  20. if limitReached
  21. logger.err adminUserId:adminUserId, newEmail:newEmail, "group subscription limit reached not adding user to group"
  22. return callback(limitReached:limitReached)
  23. UserGetter.getUserByMainEmail newEmail, (err, user)->
  24. return callback(err) if err?
  25. if user?
  26. SubscriptionUpdater.addUserToGroup adminUserId, user._id, (err)->
  27. if err?
  28. logger.err err:err, "error adding user to group"
  29. return callback(err)
  30. NotificationsBuilder.groupPlan(user, {subscription_id:subscription._id}).read()
  31. userViewModel = buildUserViewModel(user)
  32. callback(err, userViewModel)
  33. else
  34. TeamInvitesHandler.createManagerInvite adminUserId, newEmail, (err) ->
  35. return callback(err) if err?
  36. userViewModel = buildEmailInviteViewModel(newEmail)
  37. callback(err, userViewModel)
  38. removeUserFromGroup: (adminUser_id, userToRemove_id, callback)->
  39. SubscriptionUpdater.removeUserFromGroup adminUser_id, userToRemove_id, callback
  40. getPopulatedListOfMembers: (adminUser_id, callback)->
  41. SubscriptionLocator.getUsersSubscription adminUser_id, (err, subscription)->
  42. return callback(err) if err?
  43. users = []
  44. for teamInvite in subscription.teamInvites or []
  45. users.push buildEmailInviteViewModel(teamInvite.email)
  46. jobs = _.map subscription.member_ids, (user_id)->
  47. return (cb)->
  48. UserGetter.getUser user_id, (err, user)->
  49. if err? or !user?
  50. users.push _id:user_id
  51. return cb()
  52. userViewModel = buildUserViewModel(user)
  53. users.push(userViewModel)
  54. cb()
  55. async.series jobs, (err)->
  56. callback(err, users)
  57. isUserPartOfGroup: (user_id, subscription_id, callback=(err, partOfGroup)->)->
  58. SubscriptionLocator.getSubscriptionByMemberIdAndId user_id, subscription_id, (err, subscription)->
  59. if subscription?
  60. partOfGroup = true
  61. else
  62. partOfGroup = false
  63. logger.log user_id:user_id, subscription_id:subscription_id, partOfGroup:partOfGroup, "checking if user is part of a group"
  64. callback(err, partOfGroup)
  65. buildUserViewModel = (user)->
  66. u =
  67. email: user.email
  68. first_name: user.first_name
  69. last_name: user.last_name
  70. holdingAccount: user.holdingAccount
  71. _id: user._id
  72. return u
  73. buildEmailInviteViewModel = (email) ->
  74. return {
  75. email: email
  76. holdingAccount: true
  77. }