Function applyOrgRefresh

apps/sim/lib/billing/calculations/usage-monitor.ts:176–210

(
  organizationId: string,
  sub: {
    plan: string | null
    seats: number | null
    periodStart: Date | null
    periodEnd: Date | null
  },
  currentUsage: number,
  preloadedMemberIds?: string[]
)

}

async function applyOrgRefresh(
  organizationId: string,
  sub: {
    plan: string | null
    seats: number | null
    periodStart: Date | null
    periodEnd: Date | null
  },
  currentUsage: number,
  preloadedMemberIds?: string[]
): Promise<number> {
  if (!isPaid(sub.plan) || !sub.periodStart) {
    return currentUsage
  }

  const memberIds =
    preloadedMemberIds ?? (await getPooledOrgCurrentPeriodCost(organizationId)).memberIds
  if (memberIds.length === 0) return currentUsage

  const planDollars = getPlanTierDollars(sub.plan)
  if (planDollars <= 0) return currentUsage

  const userBounds = await getOrgMemberRefreshBounds(organizationId, sub.periodStart)
  const refresh = await computeDailyRefreshConsumed({
    userIds: memberIds,
    periodStart: sub.periodStart,
    periodEnd: sub.periodEnd ?? null,
    planDollars,
    seats: sub.seats || 1,
    userBounds: Object.keys(userBounds).length > 0 ? userBounds : undefined,
    billingEntity: { type: 'organization', id: organizationId },
  })

  return Math.max(0, currentUsage - refresh)
}

function buildUsageData(params: {
  currentUsage: number