async = require("async") _ = require("underscore") SubscriptionUpdater = require("./SubscriptionUpdater") SubscriptionLocator = require("./SubscriptionLocator") UserLocator = require("../User/UserLocator") LimitationsManager = require("./LimitationsManager") logger = require("logger-sharelatex") OneTimeTokenHandler = require("../Security/OneTimeTokenHandler") EmailHandler = require("../Email/EmailHandler") settings = require("settings-sharelatex") NotificationsBuilder = require("../Notifications/NotificationsBuilder") module.exports = SubscriptionGroupHandler = addUserToGroup: (adminUserId, newEmail, callback)-> logger.log adminUserId:adminUserId, newEmail:newEmail, "adding user to group" LimitationsManager.hasGroupMembersLimitReached adminUserId, (err, limitReached, subscription)-> if err? logger.err err:err, adminUserId:adminUserId, newEmail:newEmail, "error checking if limit reached for group plan" return callback(err) if limitReached logger.err adminUserId:adminUserId, newEmail:newEmail, "group subscription limit reached not adding user to group" return callback(limitReached:limitReached) UserLocator.findByEmail newEmail, (err, user)-> return callback(err) if err? if user? SubscriptionUpdater.addUserToGroup adminUserId, user._id, (err)-> if err? logger.err err:err, "error adding user to group" return callback(err) NotificationsBuilder.groupPlan(user, {subscription_id:subscription._id}).read() userViewModel = buildUserViewModel(user) callback(err, userViewModel) else SubscriptionUpdater.addEmailInviteToGroup adminUserId, newEmail, (err) -> return callback(err) if err? userViewModel = buildEmailInviteViewModel(newEmail) callback(err, userViewModel) removeUserFromGroup: (adminUser_id, userToRemove_id, callback)-> SubscriptionUpdater.removeUserFromGroup adminUser_id, userToRemove_id, callback removeEmailInviteFromGroup: (adminUser_id, email, callback) -> SubscriptionUpdater.removeEmailInviteFromGroup adminUser_id, email, callback getPopulatedListOfMembers: (adminUser_id, callback)-> SubscriptionLocator.getUsersSubscription adminUser_id, (err, subscription)-> users = [] for email in subscription.invited_emails or [] users.push buildEmailInviteViewModel(email) jobs = _.map subscription.member_ids, (user_id)-> return (cb)-> UserLocator.findById user_id, (err, user)-> if err? or !user? users.push _id:user_id return cb() userViewModel = buildUserViewModel(user) users.push(userViewModel) cb() async.series jobs, (err)-> callback(err, users) isUserPartOfGroup: (user_id, subscription_id, callback=(err, partOfGroup)->)-> SubscriptionLocator.getSubscriptionByMemberIdAndId user_id, subscription_id, (err, subscription)-> if subscription? partOfGroup = true else partOfGroup = false logger.log user_id:user_id, subscription_id:subscription_id, partOfGroup:partOfGroup, "checking if user is part of a group" callback(err, partOfGroup) sendVerificationEmail: (subscription_id, licenceName, email, callback)-> ONE_DAY_IN_S = 1000 * 60 * 60 * 24 OneTimeTokenHandler.getNewToken subscription_id, {expiresIn:ONE_DAY_IN_S}, (err, token)-> opts = to : email group_name: licenceName completeJoinUrl: "#{settings.siteUrl}/user/subscription/#{subscription_id}/group/complete-join?token=#{token}" EmailHandler.sendEmail "completeJoinGroupAccount", opts, callback processGroupVerification: (userEmail, subscription_id, token, callback)-> logger.log userEmail:userEmail, subscription_id:subscription_id, "processing group verification for user" OneTimeTokenHandler.getValueFromTokenAndExpire token, (err, token_subscription_id)-> if err? or subscription_id != token_subscription_id logger.err userEmail:userEmail, token:token, "token value not found for processing group verification" return callback("token_not_found") SubscriptionLocator.getSubscription subscription_id, (err, subscription)-> if err? logger.err err:err, subscription:subscription, userEmail:userEmail, subscription_id:subscription_id, "error getting subscription" return callback(err) if !subscription? logger.warn subscription_id:subscription_id, userEmail:userEmail, "no subscription found" return callback() SubscriptionGroupHandler.addUserToGroup subscription?.admin_id, userEmail, callback convertEmailInvitesToMemberships: (email, user_id, callback = (err) ->) -> SubscriptionLocator.getGroupsWithEmailInvite email, (err, groups = []) -> return callback(err) if err? logger.log {email, user_id, groups}, "found groups to convert from email invite to member" jobs = [] for group in groups do (group) -> jobs.push (cb) -> SubscriptionUpdater.removeEmailInviteFromGroup group.admin_id, email, (err) -> return cb(err) if err? SubscriptionUpdater.addUserToGroup group.admin_id, user_id, (err) -> return cb(err) if err? logger.log {group_id: group._id, user_id, email}, "converted email invite to group membership" return cb() async.series jobs, callback buildUserViewModel = (user)-> u = email: user.email first_name: user.first_name last_name: user.last_name holdingAccount: user.holdingAccount _id: user._id return u buildEmailInviteViewModel = (email) -> return { email: email holdingAccount: true }