From 57532326f7b3526348b14e82bb61ecd41ac7d480 Mon Sep 17 00:00:00 2001 From: Frank Date: Sun, 25 Jan 2026 17:46:14 -0500 Subject: zen: handle subscription payment failure --- packages/console/app/src/routes/stripe/webhook.ts | 24 +++++++---------------- 1 file changed, 7 insertions(+), 17 deletions(-) (limited to 'packages/console/app') diff --git a/packages/console/app/src/routes/stripe/webhook.ts b/packages/console/app/src/routes/stripe/webhook.ts index c987158d3..828eb4c71 100644 --- a/packages/console/app/src/routes/stripe/webhook.ts +++ b/packages/console/app/src/routes/stripe/webhook.ts @@ -396,27 +396,17 @@ export async function POST(input: APIEvent) { } */ } - if (body.type === "customer.subscription.deleted") { + if (body.type === "customer.subscription.updated" && body.data.object.status === "incomplete_expired") { const subscriptionID = body.data.object.id if (!subscriptionID) throw new Error("Subscription ID not found") - const workspaceID = await Database.use((tx) => - tx - .select({ workspaceID: BillingTable.workspaceID }) - .from(BillingTable) - .where(eq(BillingTable.subscriptionID, subscriptionID)) - .then((rows) => rows[0]?.workspaceID), - ) - if (!workspaceID) throw new Error("Workspace ID not found for subscription") - - await Database.transaction(async (tx) => { - await tx - .update(BillingTable) - .set({ subscriptionID: null, subscription: null }) - .where(eq(BillingTable.workspaceID, workspaceID)) + await Billing.unsubscribe({ subscriptionID }) + } + if (body.type === "customer.subscription.deleted") { + const subscriptionID = body.data.object.id + if (!subscriptionID) throw new Error("Subscription ID not found") - await tx.delete(SubscriptionTable).where(eq(SubscriptionTable.workspaceID, workspaceID)) - }) + await Billing.unsubscribe({ subscriptionID }) } if (body.type === "invoice.payment_succeeded") { if ( -- cgit v1.2.3