Dokploy/dokploy
1
0
Fork 0
mirror of https://github.com/Dokploy/dokploy synced 2025-06-26 18:27:59 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

refactor: clean stripe customer if the customer is deleted

Browse Source
This commit is contained in:
Mauricio Siu
2024-10-21 13:01:08 -06:00
parent c0afcaf3f6
commit 9bace8e58b
1 changed files with 20 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
apps/dokploy/server/api/routers/stripe.ts
View File

@@ -1,5 +1,10 @@
import { WEBSITE_URL, getStripeItems } from "@/server/utils/stripe"; import { WEBSITE_URL, getStripeItems } from "@/server/utils/stripe";
import { IS_CLOUD, findAdminById, findServersByAdminId } from "@dokploy/server"; import {
IS_CLOUD,
findAdminById,
findServersByAdminId,
updateAdmin,
} from "@dokploy/server";
import { TRPCError } from "@trpc/server"; import { TRPCError } from "@trpc/server";
import Stripe from "stripe"; import Stripe from "stripe";
import { z } from "zod"; import { z } from "zod";
@@ -49,14 +54,22 @@ export const stripeRouter = createTRPCRouter({
const stripe = new Stripe(process.env.STRIPE_SECRET_KEY || "", { const stripe = new Stripe(process.env.STRIPE_SECRET_KEY || "", {
apiVersion: "2024-09-30.acacia", apiVersion: "2024-09-30.acacia",
}); });
// await updateAdmin(ctx.user.authId, {
// stripeCustomerId: null,
// stripeSubscriptionId: null,
// serversQuantity: 0,
// });
const items = getStripeItems(input.serverQuantity, input.isAnnual); const items = getStripeItems(input.serverQuantity, input.isAnnual);
const admin = await findAdminById(ctx.user.adminId); const admin = await findAdminById(ctx.user.adminId);
const stripeCustomerId = admin.stripeCustomerId;
let stripeCustomerId = admin.stripeCustomerId;
if (stripeCustomerId) {
const customer = await stripe.customers.retrieve(stripeCustomerId);
if (customer.deleted) {
await updateAdmin(admin.authId, {
stripeCustomerId: null,
});
stripeCustomerId = null;
}
}
const session = await stripe.checkout.sessions.create({ const session = await stripe.checkout.sessions.create({
mode: "subscription", mode: "subscription",