Merge pull request #116 from Kondeo/stripeAutoRenew

Stripe auto renew

backend/config/constants.json

@@ -1,6 +1,6 @@
 {
   "VERSION": {
-    "NUMBER": "0.1.8",
+    "NUMBER": "0.1.9",
     "DEPRICATED": "0.1.7",
     "LAST_COMPATIBLE": "0.1.7"
   },

backend/models/users.js

@@ -32,6 +32,10 @@ var User = new mongoose.Schema({
     stripeId: {
         type: String
     },
+    stripeInit: {
+        type: Boolean,
+        default: false
+    },
     memberPrice: {
         type: Boolean,
         default: false

backend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "backend",
-  "version": "0.0.0",
+  "version": "0.1.9",
   "private": true,
   "scripts": {
     "start": "node ./bin/www"

backend/routes/stripeHooks.js

@@ -1,6 +1,7 @@
 var express = require('express'),
     router = express.Router(),
     mongoose = require('mongoose'),
+    moment = require('moment'),
     StripeService = require('../services/stripe.js'),
     CONST = require('../config/constants.json'),
     User = mongoose.model('User');
@@ -12,6 +13,10 @@ router.post('/', function(req, res, next) {
       if(req.body.type == "customer.subscription.deleted"){
           console.log("User unsubscribe event")
           cancelUser(req.body.data.object.customer, req.body.data.object.id);
+      } else if(req.body.type == "invoice.payment_succeeded"){
+        console.log(req.body);
+          console.log("User paid event")
+          renewUser(req.body.data.object.customer, req.body.data.object.subscription);
       }
 
       res.status(200).send("ok");
@@ -22,6 +27,46 @@ router.post('/', function(req, res, next) {
   });
 });
 
+function renewUser(stripeId, subscriptionId){
+  User.findOne({
+      stripeId: stripeId,
+      subscriptionId: subscriptionId
+  })
+  .select('subscription subscriptionId stripeId stripeInit')
+  .exec(function(err, user) {
+      if (err) {
+          console.log("ALERT! Database error!")
+          console.log(err);
+      } else if (!user) {
+          console.log("User not subscribed. Autosubscription error, fragmented database.");
+          StripeService.unsubscribe(subscriptionId, function(confirmation){
+              console.log("Unsubscribed user to fix fragmentation")
+          }, function(err){
+              console.log("Stripe has no record of a subscription it just sent a webhook for. This is bad.")
+          });
+      } else {
+        if(user.stripeInit){
+          var origSub = moment(user.subscription);
+          var today = moment();
+
+          var newSub = moment.max(origSub, today).add(1, 'month');
+
+          user.subscription = newSub.toDate();
+          user.save(function(err){
+            if(err) console.log("User subscription update error (database)! " + err);
+            else console.log("Customer subscription autoextended.");
+          });
+        } else {
+          user.stripeInit = true;
+          user.save(function(err){
+            if(err) console.log("Stripe initialization error! " + err);
+            else console.log("Customer initialized.");
+          });
+        }
+      }
+  });
+}
+
 function cancelUser(stripeId, subscriptionId){
     User.findOne({
         stripeId: stripeId,

bower.json

@@ -1,6 +1,6 @@
 {
   "name": "CCRAECompendium",
-  "version": "0.1.8",
+  "version": "0.1.9",
   "dependencies": {
     "angular-animate": "1.5.3",
     "angular-hotkeys": "chieffancypants/angular-hotkeys#~1.6.0",

config.xml

@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
-<widget id="com.Kondeo.CCRAECompendium" version="0.1.8" xmlns="http://www.w3.org/ns/widgets" xmlns:cdv="http://cordova.apache.org/ns/1.0">
+<widget id="com.Kondeo.CCRAECompendium" version="0.1.9" xmlns="http://www.w3.org/ns/widgets" xmlns:cdv="http://cordova.apache.org/ns/1.0">
   <name>Compendium</name>
   <description>
         CCRA ECompendium

package.json

@@ -1,6 +1,6 @@
 {
   "name": "CCRAECompendium",
-  "version": "0.1.8",
+  "version": "0.1.9",
   "private": true,
   "dependencies": {
     "moment": "^2.11.1"