Function GET

web/src/app/api/admin/traces/[clientRequestId]/timeline/route.ts:36–99

(req: NextRequest, { params }: RouteParams)

}

export async function GET(req: NextRequest, { params }: RouteParams) {
  // Check admin authentication
  const authResult = await checkAdminAuth()
  if (authResult instanceof NextResponse) {
    return authResult
  }

  const { clientRequestId } = await params

  if (!clientRequestId) {
    return NextResponse.json(
      { error: 'Missing required parameter: clientRequestId' },
      { status: 400 },
    )
  }

  try {
    // First, get the main request message to find the client_id
    const mainMessage = await db
      .select()
      .from(schema.message)
      .where(eq(schema.message.client_request_id, clientRequestId))
      .limit(1)

    if (mainMessage.length === 0) {
      return NextResponse.json(
        { error: 'No messages found for this client request ID' },
        { status: 404 },
      )
    }

    const clientId = mainMessage[0].client_id

    // Query all messages with the same client_id to include spawned agents
    const allMessages = await db
      .select()
      .from(schema.message)
      .where(eq(schema.message.client_id, clientId ?? 'NULL'))
      .orderBy(schema.message.finished_at)

    // Build timeline events from messages using utility function
    const timelineEvents = buildTimelineFromMessages(
      allMessages,
      clientRequestId,
    )

    logger.info(
      {
        adminId: authResult.id,
        clientRequestId,
        eventCount: timelineEvents.length,
      },
      'Admin fetched timeline events',
    )

    return NextResponse.json({ events: timelineEvents })
  } catch (error) {
    logger.error({ error, clientRequestId }, 'Error building timeline')