Function getPooledOrgCurrentPeriodCost

apps/sim/lib/billing/core/usage.ts:62–90

(
  organizationId: string,
  executor: DbClient = db
)

 * downstream refresh / bounds computations.
 */
export async function getPooledOrgCurrentPeriodCost(
  organizationId: string,
  executor: DbClient = db
): Promise<{ memberIds: string[]; currentPeriodCost: number; lastPeriodCost: number }> {
  const rows = await executor
    .select({
      userId: member.userId,
      currentPeriodCost: userStats.currentPeriodCost,
      lastPeriodCost: userStats.lastPeriodCost,
    })
    .from(member)
    .leftJoin(userStats, eq(member.userId, userStats.userId))
    .where(eq(member.organizationId, organizationId))

  let pooled = new Decimal(0)
  let lastPeriodCost = new Decimal(0)
  const memberIds: string[] = []
  for (const row of rows) {
    memberIds.push(row.userId)
    pooled = pooled.plus(toDecimal(row.currentPeriodCost))
    lastPeriodCost = lastPeriodCost.plus(toDecimal(row.lastPeriodCost))
  }

  return {
    memberIds,
    currentPeriodCost: toNumber(pooled),
    lastPeriodCost: toNumber(lastPeriodCost),
  }
}

/**
 * Calculates the effective usage limit for an organization-scoped plan.