Function getSubscriptionLimits

packages/billing/src/subscription.ts:152–189

(params: {
  userId: string
  logger: Logger
  conn?: DbConn
  tier?: number | null
})

 * Checks `limit_override` first, then falls back to the default tier constants.
 */
export async function getSubscriptionLimits(params: {
  userId: string
  logger: Logger
  conn?: DbConn
  tier?: number | null
}): Promise<SubscriptionLimits> {
  const { userId, logger, conn = db, tier } = params

  const overrides = await conn
    .select()
    .from(schema.limitOverride)
    .where(eq(schema.limitOverride.user_id, userId))
    .limit(1)

  if (overrides.length > 0) {
    const o = overrides[0]
    logger.debug(
      { userId, creditsPerBlock: o.credits_per_block },
      'Using limit override for user',
    )
    return {
      creditsPerBlock: o.credits_per_block,
      blockDurationHours: o.block_duration_hours,
      weeklyCreditsLimit: o.weekly_credit_limit,
    }
  }

  const tierConfig =
    tier != null && tier in SUBSCRIPTION_TIERS
      ? SUBSCRIPTION_TIERS[tier as SubscriptionTierPrice]
      : DEFAULT_TIER

  return {
    creditsPerBlock: tierConfig.creditsPerBlock,
    blockDurationHours: tierConfig.blockDurationHours,
    weeklyCreditsLimit: tierConfig.weeklyCreditsLimit,
  }
}

// ---------------------------------------------------------------------------
// Weekly usage tracking