Function GET

web/src/app/api/orgs/[orgId]/usage/export/route.ts:17–103

(
  request: NextRequest,
  { params }: RouteParams,
)

}

export async function GET(
  request: NextRequest,
  { params }: RouteParams,
): Promise<NextResponse> {
  try {
    const session = await getServerSession(authOptions)
    if (!session?.user?.id) {
      return NextResponse.json({ error: 'Unauthorized' }, { status: 401 })
    }

    const { orgId } = await params

    // 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, orgId),
          eq(schema.orgMember.user_id, session.user.id),
        ),
      )
      .limit(1)

    if (membership.length === 0) {
      return NextResponse.json(
        { error: 'Organization not found' },
        { status: 404 },
      )
    }

    // Sync organization billing cycle with Stripe and get current cycle start
    const quotaResetDate = await syncOrganizationBillingCycle({
      organizationId: orgId,
      logger,
    })

    // Get all usage data for this cycle
    const usageData = await db
      .select({
        date: schema.message.finished_at,
        user_name: schema.user.name,
        repository_url: schema.message.repo_url,
        credits_used: schema.message.credits,
        message_id: schema.message.id,
      })
      .from(schema.message)
      .innerJoin(schema.user, eq(schema.message.user_id, schema.user.id))
      .where(
        and(
          eq(schema.message.org_id, orgId),
          gte(schema.message.finished_at, quotaResetDate),
        ),
      )
      .orderBy(desc(schema.message.finished_at))

    // Convert to CSV
    const csvHeaders = 'Date,User,Repository,Credits Used,Message ID\n'