Function checkCreditsAndCharge

web/src/app/api/v1/_helpers.ts:143–244

(params: {
  userId: string
  creditsToCharge: number
  repoUrl?: string
  context: string
  operationName?: string
  logger: Logger
  trackEvent: TrackEventFn
  insufficientCreditsEvent: AnalyticsEvent
  getUserUsageData: GetUserUsageDataFn
  consumeCreditsWithFallback: ConsumeCreditsWithFallbackFn
  ensureSubscriberBlockGrant?: (params: {
    userId: string
    logger: Logger
  }) => Promise<unknown>
})

}

export const checkCreditsAndCharge = async (params: {
  userId: string
  creditsToCharge: number
  repoUrl?: string
  context: string
  operationName?: string
  logger: Logger
  trackEvent: TrackEventFn
  insufficientCreditsEvent: AnalyticsEvent
  getUserUsageData: GetUserUsageDataFn
  consumeCreditsWithFallback: ConsumeCreditsWithFallbackFn
  ensureSubscriberBlockGrant?: (params: {
    userId: string
    logger: Logger
  }) => Promise<unknown>
}): Promise<HandlerResult<{ creditsUsed: number }>> => {
  const {
    userId,
    creditsToCharge,
    repoUrl,
    context,
    operationName,
    logger,
    trackEvent,
    insufficientCreditsEvent,
    getUserUsageData,
    consumeCreditsWithFallback,
    ensureSubscriberBlockGrant,
  } = params

  if (creditsToCharge <= 0) {
    return { ok: true, data: { creditsUsed: 0 } }
  }

  // Ensure subscription block grant exists before checking credits.
  // This creates the grant (if eligible) so its credits appear in the balance below.
  // When the function is provided, always include subscription credits in the balance:
  // error/null results mean subscription grants have 0 balance, so including them is harmless.
  const includeSubscriptionCredits = !!ensureSubscriberBlockGrant
  if (ensureSubscriberBlockGrant) {
    try {
      await ensureSubscriberBlockGrant({ userId, logger })
    } catch (error) {
      logger.error(
        { error, userId },
        'Error ensuring subscription block grant in credit check',
      )
      // Fail open: proceed with subscription credits included in balance check
    }
  }

  const {
    balance: { totalRemaining },
    nextQuotaReset,
  } = await getUserUsageData({ userId, logger, includeSubscriptionCredits })

  if (totalRemaining <= 0 || totalRemaining < creditsToCharge) {
    trackEvent({