Function getUserUsageData

packages/billing/src/usage-service.ts:53–114

(params: {
  userId: string
  logger: Logger
  includeSubscriptionCredits?: boolean
})

 * This consolidates logic from web/src/app/api/user/usage/route.ts
 */
export async function getUserUsageData(params: {
  userId: string
  logger: Logger
  includeSubscriptionCredits?: boolean
}): Promise<UserUsageData> {
  const { userId, logger, includeSubscriptionCredits } = params
  try {
    const now = new Date()

    // Check if we need to reset quota and grant new credits
    // This also returns autoTopupEnabled to avoid a separate query
    const { quotaResetDate, autoTopupEnabled } =
      await triggerMonthlyResetAndGrant(params)

    // Check if we need to trigger auto top-up
    let autoTopupTriggered = false
    try {
      const topupAmount = await checkAndTriggerAutoTopup(params)
      autoTopupTriggered = topupAmount !== undefined
    } catch (error) {
      logger.error(
        { error, userId },
        'Error during auto top-up check in getUserUsageData',
      )
      // Continue execution to return usage data even if auto top-up fails
    }

    // Use the canonical balance calculation function with the effective reset date
    // Pass isPersonalContext: true to exclude organization credits from personal usage
    const { usageThisCycle, balance } = await calculateUsageAndBalance({
      userId,
      logger,
      quotaResetDate,
      now,
      isPersonalContext: true,
      includeSubscriptionCredits: includeSubscriptionCredits ?? false,
    })

    // Check for active subscription
    let subscription: UserUsageData['subscription']
    const activeSub = await getActiveSubscription({ userId, logger })
    if (activeSub) {
      subscription = {
        status: activeSub.status,
        billingPeriodEnd: activeSub.billing_period_end.toISOString(),
        cancelAtPeriodEnd: activeSub.cancel_at_period_end,
      }
    }

    return {
      usageThisCycle,
      balance,
      nextQuotaReset: quotaResetDate.toISOString(),
      autoTopupTriggered,
      autoTopupEnabled,
      subscription,
    }
  } catch (error) {