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
|
// // where should this live?
// app.get('/subscribe/webhook', views.subscription.webhook);
/* 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();
// fs.readFile('./foo.xml', function(err, data) {
// parser.parseString(data, function (err, result) {
// console.log(inspect(result, { colors: true, depth: Infinity }));
// });
// });
/*
app.use(express.basicAuth(function(user, pass, callback) {
var result = (user === 'testUser' && pass === 'testPass');
callback(null, result);
}));
*/
var subscription = module.exports = {
callbacks: {
// accounts
new_account_notification: function(data){
},
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){
},
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){
},
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])
}
}
});
},
}
|
