Function processOrgAutoTopupPayment

packages/billing/src/auto-topup.ts:450–518

(params: {
  organizationId: string
  userId: string
  amountToTopUp: number
  stripeCustomerId: string
  logger: Logger
})

}

async function processOrgAutoTopupPayment(params: {
  organizationId: string
  userId: string
  amountToTopUp: number
  stripeCustomerId: string
  logger: Logger
}): Promise<void> {
  const { organizationId, userId, amountToTopUp, stripeCustomerId, logger } =
    params
  const logContext = { organizationId, userId, amountToTopUp, stripeCustomerId }

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

  // Organizations use fixed pricing
  const amountInCents = amountToTopUp * CREDIT_PRICING.CENTS_PER_CREDIT

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

  // Get the payment method to use for this organization
  const paymentMethodToUse = await getOrganizationPaymentMethod(params)

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

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

  await grantOrganizationCredits({
    ...params,
    amount: amountToTopUp,
    operationId,
    description: `Organization auto top-up of ${amountToTopUp.toLocaleString()} credits`,
    expiresAt: null,
  })