ceos/opencode
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(console): deduct partial refund amount from Zen balance

Browse source
This commit is contained in:
Jack 2026-07-05 15:12:21 +00:00
commit e1edb2b8f7
1 changed files with 15 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

19
packages/console/app/src/routes/stripe/webhook.ts
View file

@ -1,7 +1,7 @@
import type { Stripe } from "stripe" import type { Stripe } from "stripe"
import { Billing } from "@opencode-ai/console-core/billing.js" import { Billing } from "@opencode-ai/console-core/billing.js"
import type { APIEvent } from "@solidjs/start/server" import type { APIEvent } from "@solidjs/start/server"
import { and, Database, eq, sql } from "@opencode-ai/console-core/drizzle/index.js" import { and, Database, eq, isNull, sql } from "@opencode-ai/console-core/drizzle/index.js"
import { BillingTable, LiteTable, PaymentTable } from "@opencode-ai/console-core/schema/billing.sql.js" import { BillingTable, LiteTable, PaymentTable } from "@opencode-ai/console-core/schema/billing.sql.js"
import { Identifier } from "@opencode-ai/console-core/identifier.js" import { Identifier } from "@opencode-ai/console-core/identifier.js"
import { centsToMicroCents } from "@opencode-ai/console-core/util/price.js" import { centsToMicroCents } from "@opencode-ai/console-core/util/price.js"
@ -350,21 +350,32 @@ export async function POST(input: APIEvent) {
.then((rows) => rows[0]), .then((rows) => rows[0]),
) )
if (!payment) throw new Error("Payment not found") if (!payment) throw new Error("Payment not found")
const amountRefunded = Math.min(centsToMicroCents(body.data.object.amount_refunded), payment.amount)
if (!amountRefunded) throw new Error("Refund amount not found")
await Database.transaction(async (tx) => { await Database.transaction(async (tx) => {
await tx // Payment rows record one refund transition. Claim it atomically so Stripe webhook retries
// cannot deduct the refunded credits more than once.
const claimed = await tx
.update(PaymentTable) .update(PaymentTable)
.set({ .set({
timeRefunded: new Date(body.created * 1000), timeRefunded: new Date(body.created * 1000),
}) })
.where(and(eq(PaymentTable.paymentID, paymentIntentID), eq(PaymentTable.workspaceID, workspaceID))) .where(
and(
eq(PaymentTable.paymentID, paymentIntentID),
eq(PaymentTable.workspaceID, workspaceID),
isNull(PaymentTable.timeRefunded),
),
)
if (claimed.rowsAffected === 0) return
// deduct balance only for top up // deduct balance only for top up
if (!payment.enrichment?.type) { if (!payment.enrichment?.type) {
await tx await tx
.update(BillingTable) .update(BillingTable)
.set({ .set({
balance: sql`${BillingTable.balance} - ${payment.amount}`, balance: sql`GREATEST(0, ${BillingTable.balance} - ${amountRefunded})`,
}) })
.where(eq(BillingTable.workspaceID, workspaceID)) .where(eq(BillingTable.workspaceID, workspaceID))
} }