Function updateGrantBalance

packages/billing/src/balance-calculator.ts:167–200

(params: {
  userId: string
  grant: typeof schema.creditLedger.$inferSelect
  consumed: number
  newBalance: number
  tx: DbConn
  logger: Logger
})

 * Updates a single grant's balance and logs the change.
 */
export async function updateGrantBalance(params: {
  userId: string
  grant: typeof schema.creditLedger.$inferSelect
  consumed: number
  newBalance: number
  tx: DbConn
  logger: Logger
}) {
  const {
    userId: _userId,
    grant,
    consumed: _consumed,
    newBalance,
    tx,
    logger: _logger,
  } = params
  await tx
    .update(schema.creditLedger)
    .set({ balance: newBalance })
    .where(eq(schema.creditLedger.operation_id, grant.operation_id))

  // Note (James): This log was too noisy. Reenable it as you need to test something.
  // logger.debug(
  //   {
  //     userId,
  //     grantId: grant.operation_id,
  //     grantType: grant.type,
  //     consumed,
  //     remaining: newBalance,
  //     expiresAt: grant.expires_at,
  //   },
  //   'Updated grant remaining amount after consumption',
  // )
}

/**
 * Consumes credits from a list of ordered grants.