
* downgrade func * fix security hole lol * fix query conditions * - set to trial not free - auto create stripe customer if missing - fix production check * Extracts downgrade logic to script, fixes ts-node conflicts with prisma * Adds trialEndsAt field to users * Updates trial/downgrade logic * Typo * Legibility fixes * Update team-billing.ts * Legibility improvements * Updates illegal logic * WIP * WIP migrating stripe to package * Update website * Import fixes * Import fixes * Fixes to downgrade script * Check for premium usernames before downgrading * Fixed formatting * Delete deploy-env.sh * Locks dayjs to 1.10.6 * Type fixes * Seems like we're stuck with dayjs 1.10.4 * Script fixes * Adds first name to dump * Loop fix Co-authored-by: Jamie <ijamespine@me.com> Co-authored-by: Peer Richelsen <peeroke@gmail.com> Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com>
83 lines
2.2 KiB
TypeScript
83 lines
2.2 KiB
TypeScript
import { Prisma } from "@prisma/client";
|
|
|
|
import { HttpError as HttpCode } from "@calcom/lib/http-error";
|
|
import prisma from "@calcom/prisma";
|
|
import stripe from "@calcom/stripe/server";
|
|
|
|
export async function getStripeCustomerIdFromUserId(userId: number) {
|
|
// Get user
|
|
const user = await prisma.user.findUnique({
|
|
where: {
|
|
id: userId,
|
|
},
|
|
select: {
|
|
email: true,
|
|
name: true,
|
|
metadata: true,
|
|
},
|
|
});
|
|
|
|
if (!user?.email) throw new HttpCode({ statusCode: 404, message: "User email not found" });
|
|
|
|
const customerId = await getStripeCustomerId(user);
|
|
|
|
return customerId;
|
|
}
|
|
|
|
const userType = Prisma.validator<Prisma.UserArgs>()({
|
|
select: {
|
|
email: true,
|
|
metadata: true,
|
|
},
|
|
});
|
|
|
|
type UserType = Prisma.UserGetPayload<typeof userType>;
|
|
/** This will retrieve the customer ID from Stripe or create it if it doesn't exists yet. */
|
|
export async function getStripeCustomerId(user: UserType): Promise<string> {
|
|
let customerId: string | null = null;
|
|
|
|
if (user?.metadata && typeof user.metadata === "object" && "stripeCustomerId" in user.metadata) {
|
|
customerId = (user?.metadata as Prisma.JsonObject).stripeCustomerId as string;
|
|
} else {
|
|
/* We fallback to finding the customer by email (which is not optimal) */
|
|
const customersResponse = await stripe.customers.list({
|
|
email: user.email,
|
|
limit: 1,
|
|
});
|
|
if (customersResponse.data[0]?.id) {
|
|
customerId = customersResponse.data[0].id;
|
|
} else {
|
|
/* Creating customer on Stripe and saving it on prisma */
|
|
const customer = await stripe.customers.create({ email: user.email });
|
|
customerId = customer.id;
|
|
}
|
|
|
|
await prisma.user.update({
|
|
where: {
|
|
email: user.email,
|
|
},
|
|
data: {
|
|
metadata: {
|
|
...(user.metadata as Prisma.JsonObject),
|
|
stripeCustomerId: customerId,
|
|
},
|
|
},
|
|
});
|
|
}
|
|
|
|
return customerId;
|
|
}
|
|
|
|
export async function deleteStripeCustomer(user: UserType): Promise<string | null> {
|
|
const customerId = await getStripeCustomerId(user);
|
|
|
|
if (!customerId) {
|
|
console.warn("No stripe customer found for user:" + user.email);
|
|
return null;
|
|
}
|
|
|
|
//delete stripe customer
|
|
const deletedCustomer = await stripe.customers.del(customerId);
|
|
|
|
return deletedCustomer.id;
|
|
}
|