Function maybeNotifyLimit

apps/sim/lib/billing/core/limit-notifications.ts:274–327

(params: {
  category: LimitCategory
  billedUserId: string
  workspaceId: string
  currentUsage: number
  limit: number
  usageLabel: string
  limitLabel: string
  /** Re-arm only, never send — for usage-decrease callers. See {@link maybeSendLimitThresholdEmail}. */
  rearmOnly?: boolean
  subscription?: HighestPrioritySubscription | null
})

 *   the `getHighestPrioritySubscription` lookup on hot paths; omit to fetch here.
 */
export async function maybeNotifyLimit(params: {
  category: LimitCategory
  billedUserId: string
  workspaceId: string
  currentUsage: number
  limit: number
  usageLabel: string
  limitLabel: string
  /** Re-arm only, never send — for usage-decrease callers. See {@link maybeSendLimitThresholdEmail}. */
  rearmOnly?: boolean
  subscription?: HighestPrioritySubscription | null
}): Promise<void> {
  try {
    const sub =
      params.subscription === undefined
        ? await getHighestPrioritySubscription(params.billedUserId)
        : params.subscription
    const isOrg = Boolean(sub && isOrgScopedSubscription(sub, params.billedUserId))

    const percent = params.limit > 0 ? (params.currentUsage / params.limit) * 100 : 0
    let userEmail: string | undefined
    let userName: string | undefined
    if (!isOrg && !params.rearmOnly && percent >= WARN_THRESHOLD) {
      const [row] = await db
        .select({ email: user.email, name: user.name })
        .from(user)
        .where(eq(user.id, params.billedUserId))
        .limit(1)
      userEmail = row?.email
      userName = row?.name || undefined
    }

    await maybeSendLimitThresholdEmail({
      category: params.category,
      scope: isOrg ? 'organization' : 'user',
      workspaceId: params.workspaceId,
      currentUsage: params.currentUsage,
      limit: params.limit,
      usageLabel: params.usageLabel,
      limitLabel: params.limitLabel,
      rearmOnly: params.rearmOnly,
      userId: params.billedUserId,
      userEmail,
      userName,
      organizationId: isOrg ? sub?.referenceId : undefined,
    })
  } catch (error) {
    logger.error('Failed to resolve scope for usage-limit notification', {
      category: params.category,
      billedUserId: params.billedUserId,
      error,
    })
  }
}