125 lines
3.7 KiB
TypeScript
125 lines
3.7 KiB
TypeScript
import appStore from "@calcom/app-store";
|
|
import dayjs from "@calcom/dayjs";
|
|
import { sendNoShowFeeChargedEmail } from "@calcom/emails";
|
|
import { getTranslation } from "@calcom/lib/server/i18n";
|
|
import type { PrismaClient } from "@calcom/prisma";
|
|
import type { CalendarEvent } from "@calcom/types/Calendar";
|
|
import type { IAbstractPaymentService, PaymentApp } from "@calcom/types/PaymentService";
|
|
|
|
import { TRPCError } from "@trpc/server";
|
|
|
|
import type { TrpcSessionUser } from "../../../trpc";
|
|
import type { TChargeCardInputSchema } from "./chargeCard.schema";
|
|
|
|
interface ChargeCardHandlerOptions {
|
|
ctx: { user: NonNullable<TrpcSessionUser>; prisma: PrismaClient };
|
|
input: TChargeCardInputSchema;
|
|
}
|
|
export const chargeCardHandler = async ({ ctx, input }: ChargeCardHandlerOptions) => {
|
|
const { prisma } = ctx;
|
|
|
|
const booking = await prisma.booking.findFirst({
|
|
where: {
|
|
id: input.bookingId,
|
|
},
|
|
include: {
|
|
payment: true,
|
|
user: true,
|
|
attendees: true,
|
|
eventType: true,
|
|
},
|
|
});
|
|
|
|
if (!booking) {
|
|
throw new Error("Booking not found");
|
|
}
|
|
|
|
if (booking.payment[0].success) {
|
|
throw new TRPCError({
|
|
code: "BAD_REQUEST",
|
|
message: `The no show fee for ${booking.id} has already been charged.`,
|
|
});
|
|
}
|
|
|
|
const tOrganizer = await getTranslation(booking.user?.locale ?? "en", "common");
|
|
|
|
const attendeesListPromises = [];
|
|
|
|
for (const attendee of booking.attendees) {
|
|
const attendeeObject = {
|
|
name: attendee.name,
|
|
email: attendee.email,
|
|
timeZone: attendee.timeZone,
|
|
language: {
|
|
translate: await getTranslation(attendee.locale ?? "en", "common"),
|
|
locale: attendee.locale ?? "en",
|
|
},
|
|
};
|
|
|
|
attendeesListPromises.push(attendeeObject);
|
|
}
|
|
|
|
const attendeesList = await Promise.all(attendeesListPromises);
|
|
|
|
const evt: CalendarEvent = {
|
|
type: (booking?.eventType?.title as string) || booking?.title,
|
|
title: booking.title,
|
|
startTime: dayjs(booking.startTime).format(),
|
|
endTime: dayjs(booking.endTime).format(),
|
|
organizer: {
|
|
email: booking.user?.email || "",
|
|
name: booking.user?.name || "Nameless",
|
|
timeZone: booking.user?.timeZone || "",
|
|
language: { translate: tOrganizer, locale: booking.user?.locale ?? "en" },
|
|
},
|
|
attendees: attendeesList,
|
|
paymentInfo: {
|
|
amount: booking.payment[0].amount,
|
|
currency: booking.payment[0].currency,
|
|
paymentOption: booking.payment[0].paymentOption,
|
|
},
|
|
};
|
|
|
|
const paymentCredential = await prisma.credential.findFirst({
|
|
where: {
|
|
userId: ctx.user.id,
|
|
appId: booking.payment[0].appId,
|
|
},
|
|
include: {
|
|
app: true,
|
|
},
|
|
});
|
|
|
|
if (!paymentCredential?.app) {
|
|
throw new TRPCError({ code: "BAD_REQUEST", message: "Invalid payment credential" });
|
|
}
|
|
|
|
const paymentApp = (await appStore[
|
|
paymentCredential?.app?.dirName as keyof typeof appStore
|
|
]()) as PaymentApp;
|
|
|
|
if (!paymentApp?.lib?.PaymentService) {
|
|
throw new TRPCError({ code: "BAD_REQUEST", message: "Payment service not found" });
|
|
}
|
|
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
|
const PaymentService = paymentApp.lib.PaymentService as any;
|
|
const paymentInstance = new PaymentService(paymentCredential) as IAbstractPaymentService;
|
|
|
|
try {
|
|
const paymentData = await paymentInstance.chargeCard(booking.payment[0]);
|
|
|
|
if (!paymentData) {
|
|
throw new TRPCError({ code: "NOT_FOUND", message: `Could not generate payment data` });
|
|
}
|
|
|
|
await sendNoShowFeeChargedEmail(attendeesListPromises[0], evt);
|
|
|
|
return paymentData;
|
|
} catch (err) {
|
|
throw new TRPCError({
|
|
code: "INTERNAL_SERVER_ERROR",
|
|
message: `Error processing payment with error ${err}`,
|
|
});
|
|
}
|
|
};
|