Function checkAndTriggerOrgAutoTopup

packages/billing/src/auto-topup.ts:520–594

(params: {
  organizationId: string
  userId: string
  logger: Logger
})

}

export async function checkAndTriggerOrgAutoTopup(params: {
  organizationId: string
  userId: string
  logger: Logger
}): Promise<void> {
  const { organizationId, userId, logger } = params
  const logContext: any = { organizationId, userId }

  try {
    const org = await getOrganizationSettings(organizationId)

    if (!org.auto_topup_enabled || !org.stripe_customer_id) {
      return
    }

    const { balance } = await calculateOrganizationUsageAndBalance({
      ...params,
      quotaResetDate: getNextQuotaReset(null),
    })

    if (balance.netBalance > (org.auto_topup_threshold || 0)) {
      logger.info(
        {
          ...logContext,
          currentBalance: balance.netBalance,
          threshold: org.auto_topup_threshold,
        },
        `Organization auto top-up not needed. Balance ${balance.netBalance} is above threshold ${org.auto_topup_threshold}.`,
      )
      return
    }

    const amountToTopUp = org.auto_topup_amount || 0

    if (amountToTopUp < MINIMUM_PURCHASE_CREDITS) {
      logger.warn(
        logContext,
        `Organization auto-top-up triggered but amount ${amountToTopUp} is less than minimum ${MINIMUM_PURCHASE_CREDITS}. Skipping top-up. Check organization settings.`,
      )
      return
    }

    logger.info(
      {
        ...logContext,
        currentBalance: balance.netBalance,
        threshold: org.auto_topup_threshold,
        amountToTopUp,
      },
      `Organization auto-top-up needed. Will attempt to purchase ${amountToTopUp} credits.`,
    )

    try {
      await processOrgAutoTopupPayment({
        ...params,
        amountToTopUp,
        stripeCustomerId: org.stripe_customer_id,
      })