getting webhooks in order.. didnt need as many as i thought

1 files changed, 118 insertions, 0 deletions

diff --git a/server/lib/webhook/webhook.js b/server/lib/webhook/webhook.js
new file mode 100644
index 0000000..067af30
--- /dev/null
+++ b/server/lib/webhook/webhook.js
@@ -0,0 +1,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])
+			  }
+			}
+		});
+	},
+}