Function checkAndBillOverageThreshold

apps/sim/lib/billing/threshold-billing.ts:43–246

(userId: string)

}

export async function checkAndBillOverageThreshold(userId: string): Promise<void> {
  try {
    const threshold = OVERAGE_THRESHOLD

    const userSubscription = await getHighestPrioritySubscription(userId)
    const billingStatus = await getEffectiveBillingStatus(userId)

    if (
      !userSubscription ||
      !hasUsableSubscriptionAccess(userSubscription.status, billingStatus.billingBlocked)
    ) {
      logger.debug('No active subscription for threshold billing', { userId })
      return
    }

    if (isFree(userSubscription.plan) || isEnterprise(userSubscription.plan)) {
      return
    }

    // Org-scoped subs are billed at the org level regardless of plan name.
    if (isOrgScopedSubscription(userSubscription, userId)) {
      logger.debug('Org-scoped subscription detected - triggering org-level threshold billing', {
        userId,
        organizationId: userSubscription.referenceId,
        plan: userSubscription.plan,
      })
      await checkAndBillOrganizationOverageThreshold(userSubscription.referenceId)
      return
    }

    const usageSnapshot = await getPersonalUsageSnapshot(userId)
    if (!usageSnapshot) {
      logger.warn('User stats not found for threshold billing', { userId })
      return
    }

    const currentOverage = await calculateSubscriptionOverage({
      id: userSubscription.id,
      plan: userSubscription.plan,
      referenceId: userSubscription.referenceId,
      seats: userSubscription.seats,
      periodStart: userSubscription.periodStart,
      periodEnd: userSubscription.periodEnd,
    })

    if (currentOverage < threshold) {
      logger.debug('Threshold billing check below threshold before locking user stats', {
        userId,
        plan: userSubscription.plan,
        currentOverage,
        threshold,
      })
      return
    }

    const stripeSubscriptionId = userSubscription.stripeSubscriptionId
    if (!stripeSubscriptionId) {
      logger.error('No Stripe subscription ID found', { userId })