mirror of
https://github.com/overleaf/overleaf.git
synced 2024-09-16 02:52:31 -04:00
94 lines
4 KiB
CoffeeScript
94 lines
4 KiB
CoffeeScript
async = require("async")
|
|
RecurlyWrapper = require("./RecurlyWrapper")
|
|
Settings = require "settings-sharelatex"
|
|
User = require('../../models/User').User
|
|
logger = require('logger-sharelatex')
|
|
SubscriptionUpdater = require("./SubscriptionUpdater")
|
|
LimitationsManager = require('./LimitationsManager')
|
|
EmailHandler = require("../Email/EmailHandler")
|
|
Events = require "../../infrastructure/Events"
|
|
Analytics = require("../Analytics/AnalyticsManager")
|
|
|
|
|
|
module.exports =
|
|
validateNoSubscriptionInRecurly: (user_id, callback = (error, valid) ->) ->
|
|
RecurlyWrapper.listAccountActiveSubscriptions user_id, (error, subscriptions = []) ->
|
|
return callback(error) if error?
|
|
if subscriptions.length > 0
|
|
SubscriptionUpdater.syncSubscription subscriptions[0], user_id, (error) ->
|
|
return callback(error) if error?
|
|
return callback(null, false)
|
|
else
|
|
return callback(null, true)
|
|
|
|
createSubscription: (user, subscriptionDetails, recurly_token_id, callback)->
|
|
self = @
|
|
clientTokenId = ""
|
|
@validateNoSubscriptionInRecurly user._id, (error, valid) ->
|
|
return callback(error) if error?
|
|
if !valid
|
|
return callback(new Error("user already has subscription in recurly"))
|
|
RecurlyWrapper.createSubscription user, subscriptionDetails, recurly_token_id, (error, recurlySubscription)->
|
|
return callback(error) if error?
|
|
SubscriptionUpdater.syncSubscription recurlySubscription, user._id, (error) ->
|
|
return callback(error) if error?
|
|
callback()
|
|
|
|
updateSubscription: (user, plan_code, coupon_code, callback)->
|
|
logger.log user:user, plan_code:plan_code, coupon_code:coupon_code, "updating subscription"
|
|
LimitationsManager.userHasSubscription user, (err, hasSubscription, subscription)->
|
|
if !hasSubscription
|
|
return callback()
|
|
else
|
|
async.series [
|
|
(cb)->
|
|
return cb() if !coupon_code?
|
|
logger.log user_id:user._id, plan_code:plan_code, coupon_code:coupon_code, "updating subscription with coupon code applied first"
|
|
RecurlyWrapper.getSubscription subscription.recurlySubscription_id, includeAccount: true, (err, usersSubscription)->
|
|
return callback(err) if err?
|
|
account_code = usersSubscription.account.account_code
|
|
RecurlyWrapper.redeemCoupon account_code, coupon_code, cb
|
|
(cb)->
|
|
RecurlyWrapper.updateSubscription subscription.recurlySubscription_id, {plan_code: plan_code, timeframe: "now"}, (error, recurlySubscription) ->
|
|
return callback(error) if error?
|
|
SubscriptionUpdater.syncSubscription recurlySubscription, user._id, cb
|
|
], callback
|
|
|
|
|
|
cancelSubscription: (user, callback) ->
|
|
LimitationsManager.userHasSubscription user, (err, hasSubscription, subscription)->
|
|
if hasSubscription
|
|
RecurlyWrapper.cancelSubscription subscription.recurlySubscription_id, (error) ->
|
|
return callback(error) if error?
|
|
emailOpts =
|
|
to: user.email
|
|
first_name: user.first_name
|
|
ONE_HOUR_IN_MS = 1000 * 60 * 60
|
|
setTimeout (-> EmailHandler.sendEmail "canceledSubscription", emailOpts
|
|
), ONE_HOUR_IN_MS
|
|
Events.emit "cancelSubscription", user._id
|
|
Analytics.recordEvent user._id, "subscription-canceled"
|
|
callback()
|
|
else
|
|
callback()
|
|
|
|
reactivateSubscription: (user, callback) ->
|
|
LimitationsManager.userHasSubscription user, (err, hasSubscription, subscription)->
|
|
if hasSubscription
|
|
RecurlyWrapper.reactivateSubscription subscription.recurlySubscription_id, (error) ->
|
|
return callback(error) if error?
|
|
callback()
|
|
else
|
|
callback()
|
|
|
|
recurlyCallback: (recurlySubscription, callback) ->
|
|
RecurlyWrapper.getSubscription recurlySubscription.uuid, includeAccount: true, (error, recurlySubscription) ->
|
|
return callback(error) if error?
|
|
User.findById recurlySubscription.account.account_code, (error, user) ->
|
|
return callback(error) if error?
|
|
if !user?
|
|
return callback("no user found")
|
|
SubscriptionUpdater.syncSubscription recurlySubscription, user?._id, callback
|
|
|
|
extendTrial: (subscription, daysToExend, callback)->
|
|
RecurlyWrapper.extendTrial subscription.recurlySubscription_id, daysToExend, callback
|