highperfocused/open-saas
1
0
Fork 0
mirror of https://github.com/wasp-lang/open-saas.git synced 2025-06-25 16:23:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

Drop redundant validation

Browse Source
This commit is contained in:
Mihovil Ilakovac 2025-02-20 11:25:32 +01:00
parent a969544793
commit 77ad7a4969
1 changed files with 4 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
template/app/src/payment/stripe/webhook.ts
View File

@ -118,7 +118,7 @@ export async function handleCheckoutSessionCompleted(
// This is called when a subscription is purchased or renewed and payment succeeds. // This is called when a subscription is purchased or renewed and payment succeeds.
// Invoices are not created for one-time payments, so we handle them in the payment_intent.succeeded webhook. // Invoices are not created for one-time payments, so we handle them in the payment_intent.succeeded webhook.
export async function handleInvoicePaid(invoice: InvoicePaidData, prismaUserDelegate: PrismaClient['user']) { export async function handleInvoicePaid(invoice: InvoicePaidData, prismaUserDelegate: PrismaClient['user']) {
const userStripeId = validateUserStripeIdOrThrow(invoice.customer); const userStripeId = invoice.customer;
const datePaid = new Date(invoice.period_start * 1000); const datePaid = new Date(invoice.period_start * 1000);
return updateUserStripePaymentDetails({ userStripeId, datePaid }, prismaUserDelegate); return updateUserStripePaymentDetails({ userStripeId, datePaid }, prismaUserDelegate);
} }
@ -133,7 +133,7 @@ export async function handlePaymentIntentSucceeded(
return; return;
} }
const userStripeId = validateUserStripeIdOrThrow(paymentIntent.customer); const userStripeId = paymentIntent.customer;
const datePaid = new Date(paymentIntent.created * 1000); const datePaid = new Date(paymentIntent.created * 1000);
// We capture the price id from the payment intent metadata // We capture the price id from the payment intent metadata
@ -162,7 +162,7 @@ export async function handleCustomerSubscriptionUpdated(
subscription: SubscriptionUpdatedData, subscription: SubscriptionUpdatedData,
prismaUserDelegate: PrismaClient['user'] prismaUserDelegate: PrismaClient['user']
) { ) {
const userStripeId = validateUserStripeIdOrThrow(subscription.customer); const userStripeId = subscription.customer;
let subscriptionStatus: SubscriptionStatus | undefined; let subscriptionStatus: SubscriptionStatus | undefined;
const priceId = extractPriceId(subscription.items); const priceId = extractPriceId(subscription.items);
@ -198,16 +198,10 @@ export async function handleCustomerSubscriptionDeleted(
subscription: SubscriptionDeletedData, subscription: SubscriptionDeletedData,
prismaUserDelegate: PrismaClient['user'] prismaUserDelegate: PrismaClient['user']
) { ) {
const userStripeId = validateUserStripeIdOrThrow(subscription.customer); const userStripeId = subscription.customer;
return updateUserStripePaymentDetails({ userStripeId, subscriptionStatus: 'deleted' }, prismaUserDelegate); return updateUserStripePaymentDetails({ userStripeId, subscriptionStatus: 'deleted' }, prismaUserDelegate);
} }
function validateUserStripeIdOrThrow(userStripeId: Stripe.Checkout.Session['customer']): string {
if (!userStripeId) throw new HttpError(400, 'No customer id');
if (typeof userStripeId !== 'string') throw new HttpError(400, 'Customer id is not a string');
return userStripeId;
}
type SubscsriptionItems = z.infer<typeof subscriptionItemsSchema>; type SubscsriptionItems = z.infer<typeof subscriptionItemsSchema>;
const subscriptionItemsSchema = z.object({ const subscriptionItemsSchema = z.object({