Function GET

web/src/app/api/orgs/[orgId]/alerts/route.ts:17–68

(
  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 },
      )
    }

    // Get alerts using centralized billing logic
    const alerts = await getOrganizationAlerts({
      organizationId: orgId,
      logger,
    })

    // Convert Date objects to ISO strings for JSON serialization
    const serializedAlerts = alerts.map((alert) => ({
      ...alert,
      timestamp: alert.timestamp.toISOString(),
    }))

    return NextResponse.json({ alerts: serializedAlerts })
  } catch (error) {
    console.error('Error fetching billing alerts:', error)
    return NextResponse.json(
      { error: 'Internal server error' },
      { status: 500 },
    )
  }
}