Function getWorkspaceTableLimits

apps/sim/lib/table/billing.ts:110–149

(workspaceId: string)

 * @returns Table limits based on the workspace's billing plan
 */
export async function getWorkspaceTableLimits(workspaceId: string): Promise<TablePlanLimits> {
  const cached = limitsCache.get(workspaceId)
  if (cached) {
    if (cached.expiresAt > Date.now()) return cached.limits
    limitsCache.delete(workspaceId)
  }

  const planLimits = getTablePlanLimits()

  try {
    const billedAccountUserId = await getWorkspaceBilledAccountUserId(workspaceId)

    if (!billedAccountUserId) {
      logger.warn('No billed account found for workspace, using free tier limits', { workspaceId })
      cacheLimits(workspaceId, planLimits.free)
      return planLimits.free
    }

    const subscription = await getHighestPrioritySubscription(billedAccountUserId)
    const planName = getPlanTypeForLimits(subscription?.plan) as PlanName

    const limits = planLimits[planName] ?? planLimits.free

    logger.info('Retrieved workspace table limits', {
      workspaceId,
      billedAccountUserId,
      planName,
      limits,
    })

    cacheLimits(workspaceId, limits)
    return limits
  } catch (error) {
    logger.error('Error getting workspace table limits, falling back to free tier', {
      workspaceId,
      error,
    })
    return planLimits.free
  }
}

function cacheLimits(workspaceId: string, limits: TablePlanLimits): void {
  // Keep the Map bounded for a new key: sweep expired entries, then (if a burst of