Kai/habitica
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(subscriptions): move all payments stuff to it's own controller

Browse Source
This commit is contained in:
Tyler Renelle
2014-03-24 20:41:50 -06:00
parent 0f430e102e
commit 440a2e2884
6 changed files with 236 additions and 214 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/controllers/user.js
+1 -201
View File
@@ -268,18 +268,12 @@ api['delete'] = function(req, res, next) {
/*
------------------------------------------------------------------------
Unlock Preferences
Gems
------------------------------------------------------------------------
*/
// api.unlock // see Shared.ops
/*
------------------------------------------------------------------------
Buy Gems
------------------------------------------------------------------------
*/
api.addTenGems = function(req, res, next) {
var user = res.locals.user;
user.balance += 2.5;
@@ -289,200 +283,6 @@ api.addTenGems = function(req, res, next) {
})
}
// TODO delete plan
function revealMysteryItems(user) {
_.each(shared.content.gear.flat, function(item) {
if (
item.klass === 'mystery' &&
moment().isAfter(item.mystery.start) &&
moment().isBefore(item.mystery.end) &&
!user.items.gear.owned[item.key] &&
!~user.purchased.plan.mysteryItems.indexOf(item.key)
) {
user.purchased.plan.mysteryItems.push(item.key);
}
});
}
function createSubscription(user, data) {
if (!user.purchased.plan) user.purchased.plan = {};
_(user.purchased.plan)
.merge({ // override with these values
planId:'basic_earned',
customerId: data.customerId,
dateUpdated: new Date,
gemsBought: 0,
paymentMethod: data.paymentMethod
})
.defaults({ // allow non-override if a plan was previously used
dateCreated: new Date,
mysteryItems: []
});
revealMysteryItems(user);
user.purchased.txnCount++;
ga.event('subscribe', data.paymentMethod).send()
ga.transaction(data.customerId, 5).item(5, 1, data.paymentMethod.toLowerCase() + '-subscription', data.paymentMethod + " > Stripe").send();
}
function cancelSubscription(user, data){
_.merge(user.purchased.plan, {planId:null, customerId:null, paymentMethod:null});
user.markModified('purchased.plan');
ga.event('unsubscribe', 'Stripe').send();
}
function buyGems(user, data) {
user.balance += 5;
user.purchased.txnCount++;
ga.event('checkout', data.paymentMethod).send();
ga.transaction(data.customerId, 5).item(5, 1, data.paymentMethod.toLowerCase() + "-checkout", "Gems > " + data.paymentMethod).send();
}
/*
Setup Stripe response when posting payment
*/
api.stripeCheckout = function(req, res, next) {
var api_key = nconf.get('STRIPE_API_KEY');
var stripe = require("stripe")(api_key);
var token = req.body.id;
var user = res.locals.user;
async.waterfall([
function(cb){
if (req.query.plan) {
stripe.customers.create({
email: req.body.email,
metadata: {uuid: res.locals.user._id},
card: token,
plan: req.query.plan,
}, cb);
} else {
stripe.charges.create({
amount: "500", // $5
currency: "usd",
card: token
}, cb);
}
},
function(response, cb) {
if (req.query.plan) {
createSubscription(user, {customerId: response.id, paymentMethod: 'Stripe'});
} else {
buyGems(user, {customerId: response.id, paymentMethod: 'Stripe'});
}
user.save(cb);
}
], function(err, saved){
if (err) return res.send(500, err.toString()); // don't json this, let toString() handle errors
res.send(200);
});
};
api.stripeSubscribeCancel = function(req, res, next) {
var stripe = require("stripe")(nconf.get('STRIPE_API_KEY'));
var user = res.locals.user;
if (!user.purchased.plan.customerId)
return res.json(401, {err: "User does not have a plan subscription"});
async.waterfall([
function(cb) {
stripe.customers.del(user.purchased.plan.customerId, cb);
},
function(response, cb) {
cancelSubscription(user);
user.save(cb);
}
], function(err, saved){
if (err) return res.send(500, err.toString()); // don't json this, let toString() handle errors
res.redirect('/');
});
}
api.paypalSubscribe = function(req,res,next) {
var uuid = res.locals.user._id;
// Authenticate a future subscription of ~5 USD
paypalRecurring.authenticate({
RETURNURL: nconf.get('BASE_URL') + '/paypal/subscribe/success?uuid=' + uuid,
CANCELURL: nconf.get("BASE_URL"),
PAYMENTREQUEST_0_AMT: 5,
L_BILLINGAGREEMENTDESCRIPTION0: "HabitRPG Subscription"
}, function(err, data, url) {
// Redirect the user if everything went well with
// a HTTP 302 according to PayPal's guidelines
if (err) return next(err);
res.redirect(302, url);
});
}
api.paypalSubscribeSuccess = function(req,res,next) {
// Create a subscription of 10 USD every month
var uuid = req.query.uuid;
if (!uuid) return next("UUID required");
paypalRecurring.createSubscription(req.query.token, req.query.PayerID,{
AMT: 5,
DESC: "HabitRPG Subscription",
BILLINGPERIOD: "Month",
BILLINGFREQUENCY: 1,
}, function(err, data) {
if (err) return res.next(err);
User.findById(uuid, function(err,user){
if (err) return next(err);
createSubscription(user, {customerId: data.PROFILEID, paymentMethod: 'Paypal'});
user.save(function(err,saved){
res.redirect('/');
})
})
});
}
api.paypalSubscribeCancel = function(req, res, next) {
var user = res.locals.user;
if (!user.purchased.plan.customerId)
return res.json(401, {err: "User does not have a plan subscription"});
async.waterfall([
function(cb) {
paypalRecurring.modifySubscription(user.purchased.plan.customerId, 'cancel', cb);
},
function(response, cb) {
cancelSubscription(user);
user.save(cb);
}
], function(err, saved){
if (err) return next(err);
res.redirect('/');
});
}
api.paypalCheckout = function(req, res, next) {
var uuid = res.locals.user._id;
var opts = {RETURNURL:nconf.get('BASE_URL') + '/paypal/checkout/success?uuid=' + uuid};
paypalCheckout.pay(+new Date, 5, 'HabitRPG Gems', 'USD', opts, function(err, url) {
if (err) return next(err);
res.redirect(url);
});
}
api.paypalCheckoutSuccess = function(req,res,next) {
paypalCheckout.detail(req.query.token, req.query.PayerID, function(err, data, invoiceNumber, price) {
// see `data` vars at https://github.com/petersirka/node-paypal-express-checkout#paypal-account
//if (err) return next('PayPal Error: ' + msg);
if (err) return next(err);
if (data.ACK !== 'Success') return next('PayPal transaction failed, please try again');
var uuid = req.query.uuid; //, apiToken = query.apiToken;
User.findById(uuid , function(err, user) {
if (_.isEmpty(user)) err = "user not found with uuid " + uuid + " when completing paypal transaction";
if (err) return next(err);
buyGems(user, {customerId:req.query.PayerID, paymentMethod:'Paypal'});
user.save(function(){
if (err) return next(err);
res.redirect('/');
});
});
});
}
/*
------------------------------------------------------------------------
Tags