1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
|
/* jshint node: true */
var _ = require('lodash'),
util = require('../util'),
upload = require('../upload'),
config = require('../../../config.json'),
User = require('../schemas/User'),
Project = require('../schemas/Project'),
Layout = require('../schemas/Layout'),
Plan = require('../schemas/Plan');
Subscription = require('../schemas/Subscription'),
Recurly = require('node-recurly'),
recurly = new Recurly(require('../webhook/recurly-config'));
var plan_levels = {
free: 0,
basic: 1,
pro: 2,
}
var subscription = module.exports = {
middleware: {
ensureSubscription: function(req, res, next){
Subscription.findOne({ user_id: req.user._id }, function(err, data){
if (err) { return next() }
req.subscription = data
next()
})
},
ensurePlans: function(req, res, next){
Plan.find({}).sort({ 'level': -1 }).exec(function (err, plans) {
res.locals.plans = (plans || [])
next()
})
},
},
// synchronise an account with recurly..
// useful when testing locally (where webhooks cannot be received)
// parses the XML from the subscription API into something usable
sync: function(req, res){
var subscriber = req.subscription || new Subscription ()
var user = req.user
recurly.subscriptions.listByAccount(req.user._id, function(recurlyRes){
var data = recurlyRes.data
if (recurlyRes.description !== 200) {
res.json({ error: "no account" })
return
}
if (! data.subscriptions.subscription) {
res.json({ error: "account error" })
return
}
if (subscriber.state != "active") {
user.plan_type = "free"
user.plan_level = plan_levels["free"]
return subscriber.remove(function(){
user.save(function(){
res.json({ error: "account cancelled" })
})
})
}
else {
var plan = data.subscriptions.subscription.plan.plan_code.split("-")
var plan_type = plan[0]
var plan_period = plan[1]
user.plan_type = plan_type
user.plan_level = plan_levels[plan_type]
subscriber.uuid = data.subscriptions.subscription.uuid
subscriber.user_id = user._id
subscriber.plan_type = plan_type
subscriber.plan_period = plan_period
subscriber.plan_level = plan_levels[plan_type]
var add_ons = data.subscriptions.subscription.subscription_add_ons.subscription_add_on
if (add_ons) {
if (add_ons.add_on_code) {
add_ons = [ add_ons ]
}
// TODO: handle multiple add-ons.. presumably this will work
add_ons.forEach(function(add_on){
var add_on_type = add_on.add_on_code.split("-")[1]
if (add_on_type == "basic") {
subscriber.basic_layouts = parseInt( add_on.quantity._ )
}
if (add_on_type == "pro") {
subscriber.pro_layouts = parseInt( add_on.quantity._ )
}
})
}
else {
subscriber.basic_layouts = 0
subscriber.pro_layouts = 0
}
}
subscriber.save(function(){
user.save(function(){
res.json({
subscription: subscriber,
plans: res.locals.plans
})
})
})
})
},
show: function(req, res){
if (req.subscription) {
res.json({
subscription: req.subscription,
plans: res.locals.plans
})
}
else {
res.json({
error: "no subscription",
plans: res.locals.plans,
})
}
},
update: function(req, res){
if (! req.subscription ) {
return res.json({ error: "no subscription" })
}
if (! (req.body.plan_type in plan_levels)) {
return res.json({ error: "bad input" })
}
var subscriber = req.subscription
// change..
// data.plan_code
// data.subscription_add_ons = []
// add_on.add_on_code
// add_on.quantity
var basic_layouts = max(0, parseInt(req.body.basic_layouts))
var pro_layouts = max(0, parseInt(req.body.pro_layouts))
var data = {}
data.plan_code = req.body.plan_type + "_monthly"
data.subscription_add_ons = []
if (plan_levels[req.body.plan_type]) {
data.subscription_add_ons.push({ add_on_code: "extra-basic-layout", quantity: basic_layouts })
}
if (req.body.plan_type == "pro") {
data.subscription_add_ons.push({ add_on_code: "extra-pro-layout", quantity: pro_layouts })
}
recurly.subscriptions.update(subscriber.uuid, data, function(){
return res.json(subscriber)
})
},
destroy: function(req, res){
if (! req.subscription ) {
return res.json({ error: "no subscription" })
}
var subscriber = req.subscription
recurly.subscriptions.terminate(subscriber.uuid, "partial", function(){
subscriber.remove(function(){
req.user.plan_code = 0
req.user.plan_type = "free"
req.user.save(function(){
res.json({ status: "OK" })
})
})
})
},
};
|
