working async create payments/plans/subscrptions

- need to handle edge cases

app/controllers/stripe.controller.js

@@ -6,92 +6,158 @@ const stripe = require('stripe')('sk_test_n8NCvCFjD1xFhGiEq6SI8CXj');
 const { Donor, Organization, Charge, PaymentPlan } = db;
 
 // Subscribe user to plan or one time charge
-exports.grantCharge = (req, res, next) => {
+exports.grantCharge = async (req, res, next) => {
 	const { stripeToken, grant_id, amount, monthly } = req.body;
 	const user = req.user;
 
-	Donor.findAll({ where: { id: user.id } })
+	// Donor.findAll({ where: { id: user.id } })
-		.then(donors => {
+	// 	.then(donors => {
-			var { stripe_id, subscription_id } = donors[0];
+	// 		var { stripe_id, subscription_id } = donors[0];
-			req.subscription_id = subscription_id;
+	// 		req.subscription_id = subscription_id;
+	// 		if (!stripe_id) {
+	// 			stripe_id = stripe.customers
+	// 				.create({
+	// 					source: stripeToken,
+	// 					email: user.email
+	// 				})
+	// 				.then(customer => customer.id)
+	// 				.catch(error =>
+	// 					next(errorMaker(500, "Couldn't create customer with source"))
+	// 				);
+	// 		}
+
+	// 		return [stripe_id, subscription_id];
+	// 	})
+	// 	.then(([stripe_id, subscription_id]) => {
+	// 		console.log(stripe_id, subscription_id);
+	// 		if (!monthly) {
+	// 			stripe.charges
+	// 				.create({
+	// 					amount,
+	// 					currency: 'usd',
+	// 					customer: stripe_id,
+	// 					description: 'One time payment for grant',
+	// 					statement_descriptor: 'One time payment for grant'
+	// 				})
+	// 				.then(chargeResponse => res.status(200).json(chargeResponse))
+	// 				.catch(error => next(error));
+	// 		} else {
+	// 			stripe.plans
+	// 				.create({
+	// 					id: grant_id,
+	// 					nickname: `Grant for user: ${user.id}`,
+	// 					product: 'prod_ER3jOog6QMX1GP',
+	// 					currency: 'usd',
+	// 					interval: 'month',
+	// 					amount
+	// 				})
+	// 				.then(plan => {
+	// 					if (!req.subscription_id) {
+	// 						stripe.subscriptions
+	// 							.create({
+	// 								customer: stripe_id,
+	// 								items: [{ plan: plan.id }]
+	// 							})
+	// 							.then(sub =>
+	// 								stripe.subscriptionItems
+	// 									.create({
+	// 										subscription: sub.id,
+	// 										plan: plan.id
+	// 									})
+	// 									.catch(error => next(error))
+	// 							)
+	// 							.catch(error => next(error));
+	// 					} else {
+	// 						stripe.subscriptionItems
+	// 							.create({
+	// 								subscription: req.subscription_id,
+	// 								plan: plan.id
+	// 							})
+	// 							.catch(error => next(error));
+	// 					}
+
+	// 					PaymentPlan.create({
+	// 						plan_id: plan.id,
+	// 						amount,
+	// 						grant_id: grant_id
+	// 					}).catch(error => next(error));
+	// 				});
+	// 		}
+	// 	})
+	// 	.catch(error => next(error));
+	try {
+		const donors = await Donor.findAll({ where: { id: user.id } });
+
+		// check if already a stripe customer
+		let { stripe_id, subscription_id } = donors[0];
+
 		if (!stripe_id) {
-				stripe_id = stripe.customers
+			const customer = await stripe.customers.create({
-					.create({
 				source: stripeToken,
 				email: user.email
-					})
+			});
-					.then(customer => customer.id)
+			stripe_id = customer.id;
-					.catch(error =>
+
-						next(errorMaker(500, "Couldn't create customer with source"))
+			await Donor.update({ stripe_id }, { where: { id: user.id } });
-					);
 		}
 
-			return [stripe_id, subscription_id];
+		var result;
-		})
+
-		.then(([stripe_id, subscription_id]) => {
+		// charge if not monthly, plan if it is
-			console.log(stripe_id, subscription_id);
 		if (!monthly) {
-				stripe.charges
+			let charge = await stripe.charges.create({
-					.create({
 				amount,
 				currency: 'usd',
 				customer: stripe_id,
 				description: 'One time payment for grant',
-						statement_descriptor: 'One time payment for grant'
+				statement_descriptor: 'one-time-grant'
-					})
+			});
-					.then(chargeResponse => res.status(200).json(chargeResponse))
+
-					.catch(error => next(error));
+			await Charge.create({
+				id: charge.id,
+				amount,
+				description: 'One time payment for grant'
+			});
+
+			result = charge;
 		} else {
-				stripe.plans
+			const plan = await stripe.plans.create({
-					.create({
 				id: grant_id,
-						nickname: `Grant for user: ${user.id}`,
+				nickname: `Grant for grant: ${grant_id}`,
 				product: 'prod_ER3jOog6QMX1GP',
 				currency: 'usd',
 				interval: 'month',
 				amount
-					})
+			});
-					.then(plan => {
+
-						if (!req.subscription_id) {
+			// either create new sub with new plan, or append plan to existing sub
-							stripe.subscriptions
+			if (!subscription_id) {
-								.create({
+				let subscription = await stripe.subscriptions.create({
 					customer: stripe_id,
 					items: [{ plan: plan.id }]
-								})
+				});
-								.then(sub =>
-									stripe.subscriptionItems
-										.create({
-											subscription: sub.id,
-											plan: plan.id
-										})
-										.catch(error => next(error))
-								)
-								.catch(error => next(error));
-						} else {
-							stripe.subscriptionItems
-								.create({
-									subscription: req.subscription_id,
-									plan: plan.id
-								})
-								.catch(error => next(error));
-						}
 
-						PaymentPlan.create({
+				await Donor.update(
+					{ subscription_id: subscription.id },
+					{ where: { id: user.id } }
+				);
+			} else
+				await stripe.subscriptionItems.create({
+					subscription: subscription_id,
+					plan: plan.id
+				});
+
+			result = await PaymentPlan.create({
 				plan_id: plan.id,
 				amount,
 				grant_id: grant_id
-						}).catch(error => next(error));
 			});
 		}
-		})
-		.catch(error => next(error));
-	// try {
-	// 	const donors = await Donor.findAll({ where: { id: user.id } });
 
-	// 	// check if already a stripe customer and have subscription
+		res.status(200).json({
-	// 	let customer_id = await (donors[0].stripe_id
+			message: 'Successfully charged or subscribed',
-	// 		? donors[0].stripe_id
+			result
-	// 		: .id);
+		});
 
 		// let subscription_id = await (donors[0].subscription_id
 		// 	? donors[0].subscription_id
@@ -143,7 +209,7 @@ exports.grantCharge = (req, res, next) => {
 		// res.status(200).json({
 		// 	message: 'Successfully charged or subscribed'
 		// });
-	// } catch (error) {
+	} catch (error) {
-	// 	next(error);
+		next(error);
-	// }
+	}
 };

app/models/paymentplan.model.js

@@ -7,6 +7,7 @@ module.exports = (sequelize, DataTypes) => {
 			autoIncrement: true
 		},
 		plan_id: {
+			unique: true,
 			type: DataTypes.UUID,
 			allowNull: false
 		},