Function processAutoTopupPayment

packages/billing/src/auto-topup.ts:142–208

(params: {
  userId: string
  amountToTopUp: number
  stripeCustomerId: string
  paymentMethod: Stripe.PaymentMethod
  logger: Logger
})

}

async function processAutoTopupPayment(params: {
  userId: string
  amountToTopUp: number
  stripeCustomerId: string
  paymentMethod: Stripe.PaymentMethod
  logger: Logger
}): Promise<void> {
  const { userId, amountToTopUp, stripeCustomerId, paymentMethod, logger } =
    params
  const logContext = { userId, amountToTopUp }

  // Generate a deterministic operation ID based on userId and current time to minute precision
  const timestamp = generateOperationIdTimestamp(new Date())
  const idempotencyKey = `auto-topup-${userId}-${timestamp}`
  const operationId = idempotencyKey // Use same ID for both Stripe and our DB

  const centsPerCredit = 1
  const amountInCents = convertCreditsToUsdCents(amountToTopUp, centsPerCredit)

  if (amountInCents <= 0) {
    throw new AutoTopupPaymentError('Invalid payment amount calculated')
  }

  const paymentIntent = await stripeServer.paymentIntents.create(
    {
      amount: amountInCents,
      currency: 'usd',
      customer: stripeCustomerId,
      payment_method: paymentMethod.id,
      off_session: true,
      confirm: true,
      description: `Auto top-up: ${amountToTopUp.toLocaleString()} credits`,
      metadata: {
        userId,
        credits: amountToTopUp.toString(),
        operationId,
        grantType: 'purchase',
        type: 'auto-topup',
      },
    },
    {
      idempotencyKey, // Add Stripe idempotency key
    },
  )

  if (paymentIntent.status !== 'succeeded') {
    throw new AutoTopupPaymentError('Payment failed or requires action')
  }

  await processAndGrantCredit({
    ...params,
    amount: amountToTopUp,
    type: 'purchase',
    description: `Auto top-up of ${amountToTopUp.toLocaleString()} credits`,
    expiresAt: null,
    operationId,
  })