// // 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]) } } }); }, }