highperfocused/open-saas
1
0
Fork 0
mirror of https://github.com/wasp-lang/open-saas.git synced 2025-03-29 11:12:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

improve stripe checkout flow

Browse Source
This commit is contained in:
vincanger 2023-04-13 12:30:36 +02:00
parent 7b0b684754
commit 48b2443a05
2 changed files with 32 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/client/CheckoutPage.tsx
View File

@ -11,7 +11,7 @@ export default function CheckoutPage({ user }: { user: User }) {
function delayedRedirect() {
return setTimeout(() => {
history.push('/profile');
history.push('/account');
}, 4000);
}
@ -24,7 +24,7 @@ export default function CheckoutPage({ user }: { user: User }) {
} else if (success) {
setHasPaid('paid');
} else {
history.push('/profile');
history.push('/account');
}
delayedRedirect();
return () => {
@ -43,7 +43,7 @@ export default function CheckoutPage({ user }: { user: User }) {
</h1>
{hasPaid !== 'loading' && (
<span className='text-center'>
You are being redirected to your profile page... <br />
You are being redirected to your account page... <br />
</span>
)}
</>

47
src/server/webhooks.ts
View File

@ -42,12 +42,18 @@ export const stripeWebhook: StripeWebhook = async (request, response, context) =
try {
event = request.body;
if (event.type === 'invoice.paid') {
const charge = event.data.object as Stripe.Invoice;
userStripeId = charge.customer as string;
if (event.type === 'checkout.session.completed') {
const session = event.data.object as Stripe.Checkout.Session;
userStripeId = session.customer as string;
if (charge.amount_paid === 999) {
console.log('Subscription purchased: ', charge.amount_paid);
const { line_items } = await stripe.checkout.sessions.retrieve(session.id, {
expand: ['line_items'],
});
console.log('line_items: ', line_items);
if (line_items?.data[0]?.price?.id === process.env.SUBSCRIPTION_PRICE_ID) {
console.log('Subscription purchased ');
await context.entities.User.updateMany({
where: {
stripeId: userStripeId,
@ -58,19 +64,24 @@ export const stripeWebhook: StripeWebhook = async (request, response, context) =
});
}
if (charge.amount_paid === 295) {
console.log('Credits purchased: ', charge.amount_paid);
await context.entities.User.updateMany({
where: {
stripeId: userStripeId,
},
data: {
credits: {
increment: 10,
},
},
});
}
/**
* and here is an example of handling a different type of product
* make sure to configure it in the Stripe dashboard first!
*/
// if (line_items?.data[0]?.price?.id === process.env.CREDITS_PRICE_ID) {
// console.log('Credits purchased: ');
// await context.entities.User.updateMany({
// where: {
// stripeId: userStripeId,
// },
// data: {
// credits: {
// increment: 10,
// },
// },
// });
// }
} else if (event.type === 'customer.subscription.updated') {
const subscription = event.data.object as Stripe.Subscription;
userStripeId = subscription.customer as string;