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
|
// // where should this live?
// app.get('/subscribe/webhook', views.subscription.webhook);
/*
app.use(express.basicAuth(function(user, pass, callback) {
var result = (user === 'testUser' && pass === 'testPass');
callback(null, result);
}));
*/
/* jshint node: true */
var User = require('../schemas/User'),
Subscription = require('../schemas/Subscription'),
config = require('../../../config'),
middleware = require('../middleware'),
util = require('../util'),
_ = require('lodash'),
moment = require('moment'),
xml2js = require('xml2js'),
Recurly = require('node-recurly'),
recurly = new Recurly(require('./config'));
var parser = new xml2js.Parser();
var subscription = module.exports = {
plan_level: {
free: 0,
basic: 1,
pro: 2,
},
callbacks: {
// accounts
new_account_notification: function(data){
// fires on successful signup
// use the account_code to find the user,
},
canceled_account_notification: function(data){
},
billing_info_updated_notification: function(data){
},
reactivated_account_notification: function(data){
},
// invoices
new_invoice_notification: function(data){
},
closed_invoice_notification: function(data){
},
past_due_invoice_notification: function(data){
},
// subscriptions
new_subscription_notification: function(data){
var account = data.account
User.findOne({ _id: account.account_code }, function(err, user){
if (err) return;
var subscription = data.subscription
var plan = subscription.plan.plan_code.split("_")
var plan_type = plan[0]
var plan_period = plan[1]
user.plan_type = plan_type
user.plan_level = subscription.plan_level[plan_type]
// subscription.uuid
// subscription.subscription_add_ons[]
// subscription.subscription_add_ons[0].quantity
user.save(function(){
})
})
},
updated_subscription_notification: function(data){
},
canceled_subscription_notification: function(data){
},
expired_subscription_notification: function(data){
},
renewed_subscription_notification: function(data){
},
// payments
successful_payment_notification: function(data){
var account = data.account
User.findOne({ _id: account.account_code }, function(err, user){
if (err) return;
user.last_charged = new Date(data.transaction.date)
user.save(function(){
})
})
},
failed_payment_notification: function(data){
},
successful_refund_notification: function(data){
},
void_payment_notification: function(data){
},
},
// need a route for the webhook,
// then calls to get appropriate info from the recurly api
webhook: function(req, res){
res.status(200).end()
parser.parseString(data, function (err, result) {
console.log(inspect(result, { colors: true, depth: Infinity }));
for (var i in data) {
if (subscription.callbacks[i]) {
subscription.callbacks[i](data[i])
}
}
});
},
}
|
