Function getOrganizationUsageData

packages/billing/src/usage-service.ts:120–245

(params: {
  organizationId: string
  userId: string
  logger: Logger
})

 * This consolidates logic from backend/src/api/usage.ts and web/src/app/api/orgs/[orgId]/usage/route.ts
 */
export async function getOrganizationUsageData(params: {
  organizationId: string
  userId: string
  logger: Logger
}): Promise<OrganizationUsageData> {
  const { organizationId, userId, logger } = params

  try {
    // Check if user is a member of this organization
    const membership = await db
      .select({ role: schema.orgMember.role })
      .from(schema.orgMember)
      .where(
        and(
          eq(schema.orgMember.org_id, organizationId),
          eq(schema.orgMember.user_id, userId),
        ),
      )
      .limit(1)

    if (membership.length === 0) {
      throw new Error('User is not a member of this organization')
    }

    // Sync organization billing cycle with Stripe and get current cycle start
    const startOfCurrentCycle = await syncOrganizationBillingCycle(params)

    // Get the organization to fetch the current period end date
    const organization = await db.query.org.findFirst({
      where: eq(schema.org.id, organizationId),
      columns: {
        current_period_start: true,
        current_period_end: true,
      },
    })

    // Use the synced dates or fallback to reasonable defaults
    const cycleStartDate =
      organization?.current_period_start || startOfCurrentCycle
    const cycleEndDate =
      organization?.current_period_end ||
      new Date(Date.now() + 30 * 24 * 60 * 60 * 1000) // 30 days from now

    let currentBalance = 0
    let usageThisCycle = 0

    try {
      const now = new Date()
      const { balance, usageThisCycle: usage } =
        await calculateOrganizationUsageAndBalance({
          ...params,
          quotaResetDate: startOfCurrentCycle,
          now,
        })
      currentBalance = balance.netBalance
      usageThisCycle = usage
    } catch (error) {
      // If no credits exist yet, that's fine