Function getEffectiveCurrentPeriodCost

apps/sim/lib/billing/core/usage.ts:688–769

(
  userId: string,
  executor: DbClient = db
)

 * all org members; personally-scoped subs return this user's own cost.
 */
export async function getEffectiveCurrentPeriodCost(
  userId: string,
  executor: DbClient = db
): Promise<number> {
  const subscription = await getHighestPrioritySubscription(userId, { executor })
  const orgScoped = isOrgScopedSubscription(subscription, userId)

  let rawCost: number
  let refreshUserIds: string[] = [userId]

  if (orgScoped && subscription) {
    const pooled = await getPooledOrgCurrentPeriodCost(subscription.referenceId, executor)
    if (pooled.memberIds.length === 0) return 0
    refreshUserIds = pooled.memberIds
    const billingPeriod =
      subscription.periodStart && subscription.periodEnd
        ? { start: subscription.periodStart, end: subscription.periodEnd }
        : defaultBillingPeriod()
    rawCost =
      pooled.currentPeriodCost +
      (await getBillingPeriodUsageCost(
        { type: 'organization', id: subscription.referenceId },
        billingPeriod,
        undefined,
        executor
      ))
  } else {
    const rows = await executor
      .select({ current: userStats.currentPeriodCost })
      .from(userStats)
      .where(eq(userStats.userId, userId))
      .limit(1)

    if (rows.length === 0) return 0
    const billingPeriod =
      subscription?.periodStart && subscription.periodEnd
        ? { start: subscription.periodStart, end: subscription.periodEnd }
        : defaultBillingPeriod()
    rawCost =
      toNumber(toDecimal(rows[0].current)) +
      (await getBillingPeriodUsageCost(
        { type: 'user', id: userId },
        billingPeriod,
        undefined,
        executor
      ))
  }

  if (!subscription || !isPaid(subscription.plan) || !subscription.periodStart) {
    return rawCost
  }

  const planDollars = getPlanTierDollars(subscription.plan)
  if (planDollars <= 0) return rawCost

  const userBounds =
    orgScoped && subscription.periodStart
      ? await getOrgMemberRefreshBounds(