Function aggregateOrgMemberStats

apps/sim/lib/billing/core/billing.ts:119–161

* Aggregate raw pooled stats for all members of an organization in a single * query. Used by org-scoped summary and overage calculations so we don't * call `getUserUsageData` per-member — that helper now returns the entire * pool for org-scoped subs, which would N-times-count the usage. * * The

(
  organizationId: string,
  executor: DbClient = db
)

 * current-period billing math.
 */
async function aggregateOrgMemberStats(
  organizationId: string,
  executor: DbClient = db
): Promise<{
  memberIds: string[]
  currentPeriodCost: number
  currentPeriodCopilotCost: number
  lastPeriodCopilotCost: number
}> {
  const rows = await executor
    .select({
      userId: member.userId,
      currentPeriodCost: userStats.currentPeriodCost,
      currentPeriodCopilotCost: userStats.currentPeriodCopilotCost,
      lastPeriodCopilotCost: userStats.lastPeriodCopilotCost,
    })
    .from(member)
    .leftJoin(userStats, eq(member.userId, userStats.userId))
    .where(eq(member.organizationId, organizationId))

  let currentPeriodCost = new Decimal(0)
  // Copilot baseline (copilot source). All copilot-family usage (incl. MCP) lives
  // in usage_log and is added via the copilot ledger by callers — not a baseline.
  let currentPeriodCopilotCost = new Decimal(0)
  let lastPeriodCopilotCost = new Decimal(0)
  const memberIds: string[] = []

  for (const row of rows) {
    memberIds.push(row.userId)
    currentPeriodCost = currentPeriodCost.plus(toDecimal(row.currentPeriodCost))
    currentPeriodCopilotCost = currentPeriodCopilotCost.plus(
      toDecimal(row.currentPeriodCopilotCost)
    )
    lastPeriodCopilotCost = lastPeriodCopilotCost.plus(toDecimal(row.lastPeriodCopilotCost))
  }

  return {
    memberIds,
    currentPeriodCost: toNumber(currentPeriodCost),
    currentPeriodCopilotCost: toNumber(currentPeriodCopilotCost),
    lastPeriodCopilotCost: toNumber(lastPeriodCopilotCost),
  }
}

/**
 * Compute an org's overage amount from already-fetched pool/departed