cal.pub0.org/packages/app-store/stripepayment/api/paymentCallback.ts

77 lines
2.4 KiB
TypeScript

import { NextApiRequest, NextApiResponse } from "next";
import z from "zod";
import { getCustomerAndCheckoutSession } from "@calcom/app-store/stripepayment/lib/getCustomerAndCheckoutSession";
import { WEBAPP_URL } from "@calcom/lib/constants";
import { defaultHandler, defaultResponder } from "@calcom/lib/server";
import { prisma } from "@calcom/prisma";
import { Prisma } from "@calcom/prisma/client";
const querySchema = z.object({
callbackUrl: z.string().transform((url) => {
if (url.search(/^https?:\/\//) === -1) {
url = `${WEBAPP_URL}${url}`;
}
return new URL(url);
}),
checkoutSessionId: z.string(),
});
// It handles premium user payment success/failure
async function getHandler(req: NextApiRequest, res: NextApiResponse) {
const { callbackUrl, checkoutSessionId } = querySchema.parse(req.query);
const { stripeCustomer, checkoutSession } = await getCustomerAndCheckoutSession(checkoutSessionId);
if (!stripeCustomer) return { message: "Stripe customer not found or deleted" };
// first let's try to find user by metadata stripeCustomerId
let user = await prisma.user.findFirst({
where: {
metadata: {
path: ["stripeCustomerId"],
equals: stripeCustomer.id,
},
},
});
if (!user && stripeCustomer.email) {
// if user not found, let's try to find user by email
user = await prisma.user.findFirst({
where: {
email: stripeCustomer.email,
},
});
}
if (checkoutSession.payment_status === "paid" && stripeCustomer.metadata.username) {
try {
if (!user) return { message: "User not found" };
await prisma.user.update({
data: {
username: stripeCustomer.metadata.username,
metadata: {
...(user.metadata as Prisma.JsonObject),
isPremium: true,
},
},
where: {
id: user.id,
},
});
} catch (error) {
console.error(error);
return {
message:
"We have received your payment. Your premium username could still not be reserved. Please contact support@cal.com and mention your premium username",
};
}
}
callbackUrl.searchParams.set("paymentStatus", checkoutSession.payment_status);
return res.redirect(callbackUrl.toString()).end();
}
export default defaultHandler({
GET: Promise.resolve({ default: defaultResponder(getHandler) }),
});