cal.pub0.org/ee/pages/api/integrations/stripepayment/webhook.ts

138 lines
3.4 KiB
TypeScript

import { buffer } from "micro";
import type { NextApiRequest, NextApiResponse } from "next";
import { getErrorFromUnknown } from "pages/_error";
import Stripe from "stripe";
import stripe from "@ee/lib/stripe/server";
import { CalendarEvent } from "@lib/calendarClient";
import EventManager from "@lib/events/EventManager";
import prisma from "@lib/prisma";
const webhookSecret = process.env.STRIPE_WEBHOOK_SECRET;
export const config = {
api: {
bodyParser: false,
},
};
async function handlePaymentSuccess(event: Stripe.Event) {
const paymentIntent = event.data.object as Stripe.PaymentIntent;
const payment = await prisma.payment.update({
where: {
externalId: paymentIntent.id,
},
data: {
success: true,
booking: {
update: {
paid: true,
},
},
},
select: {
bookingId: true,
booking: {
select: {
title: true,
description: true,
startTime: true,
endTime: true,
confirmed: true,
attendees: true,
location: true,
userId: true,
id: true,
uid: true,
paid: true,
user: {
select: {
id: true,
credentials: true,
timeZone: true,
email: true,
name: true,
},
},
},
},
},
});
if (!payment) throw new Error("No payment found");
const { booking } = payment;
if (!booking) throw new Error("No booking found");
const { user } = booking;
if (!user) throw new Error("No user found");
const evt: CalendarEvent = {
type: booking.title,
title: booking.title,
description: booking.description || undefined,
startTime: booking.startTime.toISOString(),
endTime: booking.endTime.toISOString(),
organizer: { email: user.email!, name: user.name!, timeZone: user.timeZone },
attendees: booking.attendees,
};
if (booking.location) evt.location = booking.location;
if (booking.confirmed) {
const eventManager = new EventManager(user.credentials);
const scheduleResult = await eventManager.create(evt, booking.uid);
await prisma.booking.update({
where: {
id: payment.bookingId,
},
data: {
references: {
create: scheduleResult.referencesToCreate,
},
},
});
}
}
export default async function handler(req: NextApiRequest, res: NextApiResponse) {
const requestBuffer = await buffer(req);
const sig = req.headers["stripe-signature"];
let event;
if (!sig) {
res.status(400).send(`Webhook Error: missing Stripe signature`);
return;
}
if (!webhookSecret) {
res.status(400).send(`Webhook Error: missing Stripe webhookSecret`);
return;
}
try {
event = stripe.webhooks.constructEvent(requestBuffer.toString(), sig, webhookSecret);
// Handle the event
if (event.type === "payment_intent.succeeded") {
await handlePaymentSuccess(event);
} else {
console.error(`Unhandled event type ${event.type}`);
}
} catch (_err) {
const err = getErrorFromUnknown(_err);
console.error(`Webhook Error: ${err.message}`);
res.status(err.statusCode ?? 500).send({
message: err.message,
stack: process.env.NODE_ENV === "production" ? undefined : err.stack,
});
return;
}
// Return a response to acknowledge receipt of the event
res.json({ received: true });
}