152 lines
3.7 KiB
JavaScript
152 lines
3.7 KiB
JavaScript
const db = require('../../models'),
|
|
errorMaker = require('../helpers/error.maker'),
|
|
requestPromise = require('request-promise');
|
|
|
|
const stripe = require('stripe')(process.env.STRIPE_KEY);
|
|
|
|
const { Donor, Organization, Charge, PaymentPlan } = db;
|
|
|
|
// Subscribe user to plan or one time charge
|
|
exports.grantCharge = async ({
|
|
grant,
|
|
stripeToken,
|
|
organizations,
|
|
monthly,
|
|
amount,
|
|
user
|
|
}) => {
|
|
const grant_id = await grant.id;
|
|
|
|
try {
|
|
const donors = await Donor.findAll({ where: { id: user.id } });
|
|
|
|
var result;
|
|
|
|
const stripeAmount = amount * 100;
|
|
|
|
// charge if yes or no monthly
|
|
let charge = await stripe.charges.create({
|
|
amount: stripeAmount,
|
|
currency: 'usd',
|
|
source: 'tok_visa',
|
|
description: `Charity Bundle Payment`,
|
|
statement_descriptor: `charity bundle ${grant.id}`,
|
|
receipt_email: '[email protected]'
|
|
});
|
|
|
|
let transfers = await organizations.map(async org => {
|
|
let stripeOrgAmount = Math.round(org.amount * 100);
|
|
const applicationStripeFee = stripeOrgAmount * 0.05;
|
|
|
|
let t = await stripe.transfers.create({
|
|
amount: stripeOrgAmount - applicationStripeFee,
|
|
currency: 'usd',
|
|
source_transaction: charge.id,
|
|
destination: 'acct_1EAxzUIVW1uo07uH'
|
|
});
|
|
return t;
|
|
});
|
|
|
|
await Charge.create({
|
|
id: charge.id,
|
|
amount,
|
|
description: 'One time payment for grant'
|
|
});
|
|
|
|
result = charge;
|
|
|
|
return null;
|
|
} catch (error) {
|
|
throw error;
|
|
}
|
|
};
|
|
|
|
// Delete grant's stripe plan under subscription
|
|
exports.deleteGrant = async (req, res, next) => {
|
|
const { grant_id } = req.body;
|
|
|
|
try {
|
|
const paymentPlans = await PaymentPlan.findAll({ where: { grant_id } });
|
|
|
|
// check if there are plans for that grant
|
|
if (!paymentPlans.length) {
|
|
return res.status(400).json({
|
|
message: 'Not a valid grant'
|
|
});
|
|
} else {
|
|
const plan = paymentPlans[0];
|
|
|
|
//delete the plan/grant under the subscription for the user
|
|
await stripe.subscriptionItems.del(plan.sub_item_id);
|
|
//delete the plan from the main product 'Grants'
|
|
await stripe.plans.del(plan.plan_id);
|
|
}
|
|
|
|
next();
|
|
} catch (error) {
|
|
next(error);
|
|
}
|
|
};
|
|
|
|
// allows the org to see their stripe account with their balance and payout to their bank
|
|
exports.getExpressUILink = async (req, res, next) => {
|
|
// get connected stripe account id from db
|
|
// createLoginLink with stripe function
|
|
// return to frontend
|
|
const org_id = req.user.id;
|
|
|
|
try {
|
|
const orgs = await db.sequelize.query(
|
|
`SELECT stripe_account_id
|
|
FROM organizations
|
|
WHERE id = :org_id
|
|
LIMIT 1`,
|
|
{ replacements: { org_id }, type: db.sequelize.QueryTypes.SELECT }
|
|
);
|
|
|
|
const stripeAccessRes = await stripe.accounts.createLoginLink(
|
|
orgs[0].stripe_account_id
|
|
);
|
|
|
|
return res.status(200).json({ url: stripeAccessRes.url });
|
|
} catch (error) {
|
|
next(error);
|
|
}
|
|
};
|
|
|
|
// verify the charity after they filled out basic info for express ui
|
|
exports.activateStripeAccount = async (req, res, next) => {
|
|
const { code, state } = req.query;
|
|
const org_id = state;
|
|
|
|
try {
|
|
var dataString = `client_secret=${
|
|
process.env.STRIPE_KEY
|
|
}&code=${code}&grant_type=authorization_code`;
|
|
|
|
var options = {
|
|
uri: 'https://connect.stripe.com/oauth/token',
|
|
method: 'POST',
|
|
body: {
|
|
client_secret: process.env.STRIPE_KEY,
|
|
code,
|
|
grant_type: 'authorization_code'
|
|
},
|
|
json: true
|
|
};
|
|
|
|
// store for current user, get user_id from the state param maybe?
|
|
const stripeAccRes = await requestPromise(options);
|
|
const { stripe_user_id } = stripeAccRes;
|
|
|
|
const updateRes = await db.sequelize.query(
|
|
'UPDATE organizations SET stripe_account_id = :stripe_user_id WHERE id = :org_id',
|
|
{ replacements: { stripe_user_id, org_id } }
|
|
);
|
|
|
|
return res.status(302).redirect('http://localhost:8081/org/main/banking');
|
|
} catch (error) {
|
|
next(error);
|
|
}
|
|
};
|