61 lines
2.0 KiB
TypeScript
61 lines
2.0 KiB
TypeScript
import { ACCOUNT_ACCESS } from '~~/prisma/account-access-enum';
|
|
import Stripe from 'stripe';
|
|
import { AccountService } from '~~/lib/services/account.service';
|
|
import { AccountWithMembers } from '~~/lib/services/service.types';
|
|
|
|
const config = useRuntimeConfig();
|
|
const stripe = new Stripe(config.stripeSecretKey, { apiVersion: '2022-11-15' });
|
|
|
|
export default defineEventHandler(async event => {
|
|
const body = await readBody(event);
|
|
let { price_id, account_id } = body;
|
|
account_id = +account_id;
|
|
console.log(
|
|
`session.post.ts recieved price_id:${price_id}, account_id:${account_id}`
|
|
);
|
|
|
|
const account: AccountWithMembers = await AccountService.getAccountById(
|
|
account_id
|
|
);
|
|
let customer_id: string;
|
|
if (!account.stripe_customer_id) {
|
|
// need to pre-emptively create a Stripe user for this account so we know who they are when the webhook comes back
|
|
const owner = account.members.find(
|
|
member => member.access == ACCOUNT_ACCESS.OWNER
|
|
);
|
|
console.log(
|
|
`Creating account with name ${account.name} and email ${owner?.user.email}`
|
|
);
|
|
const customer = await stripe.customers.create({
|
|
name: account.name,
|
|
email: owner?.user.email
|
|
});
|
|
customer_id = customer.id;
|
|
AccountService.updateAccountStipeCustomerId(account_id, customer.id);
|
|
} else {
|
|
customer_id = account.stripe_customer_id;
|
|
}
|
|
|
|
const session = await stripe.checkout.sessions.create({
|
|
mode: 'subscription',
|
|
line_items: [
|
|
{
|
|
price: price_id,
|
|
quantity: 1
|
|
}
|
|
],
|
|
// {CHECKOUT_SESSION_ID} is a string literal; do not change it!
|
|
// the actual Session ID is returned in the query parameter when your customer
|
|
// is redirected to the success page.
|
|
success_url: `${config.public.siteRootUrl}/success?session_id={CHECKOUT_SESSION_ID}`,
|
|
cancel_url: `${config.public.siteRootUrl}/cancel`,
|
|
customer: customer_id
|
|
});
|
|
|
|
if (session?.url) {
|
|
return sendRedirect(event, session.url, 303);
|
|
} else {
|
|
return sendRedirect(event, `${config.public.siteRootUrl}/fail`, 303);
|
|
}
|
|
});
|