49 lines
2.2 KiB
TypeScript
49 lines
2.2 KiB
TypeScript
import Stripe from 'stripe';
|
|
import UserAccountService from '~~/lib/services/user.account.service';
|
|
|
|
const config = useRuntimeConfig();
|
|
const stripe = new Stripe(config.stripeSecretKey, { apiVersion: '2022-11-15' });
|
|
|
|
export default defineEventHandler(async (event) => {
|
|
const stripeSignature = getRequestHeader(event, 'stripe-signature');
|
|
if(!stripeSignature){
|
|
throw createError({ statusCode: 400, statusMessage: 'Webhook Error: No stripe signature in header' });
|
|
}
|
|
|
|
const rawBody = await readRawBody(event)
|
|
if(!rawBody){
|
|
throw createError({ statusCode: 400, statusMessage: 'Webhook Error: No body' });
|
|
}
|
|
let stripeEvent: Stripe.Event;
|
|
|
|
try {
|
|
stripeEvent = stripe.webhooks.constructEvent(rawBody, stripeSignature, config.stripeEndpointSecret);
|
|
}
|
|
catch (err) {
|
|
console.log(err);
|
|
throw createError({ statusCode: 400, statusMessage: `Error validating Webhook Event` });
|
|
}
|
|
|
|
if(stripeEvent.type && stripeEvent.type.startsWith('customer.subscription')){
|
|
console.log(`****** Web Hook Recieved (${stripeEvent.type}) ******`);
|
|
|
|
let subscription = stripeEvent.data.object as Stripe.Subscription;
|
|
if(subscription.status == 'active'){
|
|
const sub_item = subscription.items.data.find(item => item?.object && item?.object == 'subscription_item')
|
|
|
|
const stripe_product_id = sub_item?.plan.product?.toString(); // TODO - is the product ever a product object and in that case should I check for deleted?
|
|
if(!stripe_product_id){
|
|
throw createError({ statusCode: 400, statusMessage: `Error validating Webhook Event` });
|
|
}
|
|
|
|
const userService = new UserAccountService();
|
|
|
|
let current_period_ends: Date = new Date(subscription.current_period_end * 1000);
|
|
current_period_ends.setDate(current_period_ends.getDate() + config.subscriptionGraceDays);
|
|
|
|
console.log(`updating stripe sub details subscription.current_period_end:${subscription.current_period_end}, subscription.id:${subscription.id}, stripe_product_id:${stripe_product_id}`);
|
|
userService.updateStripeSubscriptionDetailsForAccount(subscription.customer.toString(), subscription.id, current_period_ends, stripe_product_id);
|
|
}
|
|
}
|
|
return `handled ${stripeEvent.type}.`;
|
|
}); |