Spaces:
Sleeping
Sleeping
File size: 3,076 Bytes
b6ecafa | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 | import { NextRequest, NextResponse } from 'next/server'
import { requireRole } from '@/lib/auth'
import { config } from '@/lib/config'
import { getAllGatewaySessions } from '@/lib/sessions'
import { parseJsonlTranscript, readSessionJsonl, type TranscriptMessage, type MessageContentPart } from '@/lib/transcript-parser'
export interface AggregateEvent {
id: string
ts: number
sessionKey: string
agentName: string
role: string
type: string
content: string
metadata?: Record<string, any>
}
/**
* GET /api/sessions/transcript/aggregate?limit=100&since=<unix-ms>
*
* Fan out to all active session JSONL files on disk, parse, merge into
* a single chronological event stream for the agent-feed panel.
*/
export async function GET(request: NextRequest) {
const auth = requireRole(request, 'viewer')
if ('error' in auth) return NextResponse.json({ error: auth.error }, { status: auth.status })
const { searchParams } = new URL(request.url)
const limit = Math.min(Math.max(parseInt(searchParams.get('limit') || '100', 10), 1), 500)
const since = parseInt(searchParams.get('since') || '0', 10) || 0
const stateDir = config.openclawStateDir
if (!stateDir) {
return NextResponse.json({ events: [], sessionCount: 0 })
}
const sessions = getAllGatewaySessions()
const allEvents: AggregateEvent[] = []
for (const session of sessions) {
if (!session.sessionId) continue
const raw = readSessionJsonl(stateDir, session.agent, session.sessionId)
if (!raw) continue
const messages = parseJsonlTranscript(raw, 500)
let lineIndex = 0
for (const msg of messages) {
const ts = msg.timestamp ? new Date(msg.timestamp).getTime() : session.updatedAt
if (since && ts <= since) { lineIndex++; continue }
for (const part of msg.parts) {
allEvents.push(partToEvent(part, msg.role, ts, session.key, session.agent, lineIndex))
lineIndex++
}
}
}
// Sort chronologically (newest last), take the last `limit` entries
allEvents.sort((a, b) => a.ts - b.ts)
const trimmed = allEvents.slice(-limit)
return NextResponse.json({
events: trimmed,
sessionCount: sessions.length,
})
}
function partToEvent(
part: MessageContentPart,
role: string,
ts: number,
sessionKey: string,
agentName: string,
lineIndex: number,
): AggregateEvent {
const id = `tx-${sessionKey}-${lineIndex}`
switch (part.type) {
case 'text':
return { id, ts, sessionKey, agentName, role, type: 'text', content: part.text.slice(0, 500) }
case 'thinking':
return { id, ts, sessionKey, agentName, role, type: 'thinking', content: part.thinking.slice(0, 300) }
case 'tool_use':
return { id, ts, sessionKey, agentName, role, type: 'tool_use', content: part.name, metadata: { toolId: part.id, input: part.input } }
case 'tool_result':
return { id, ts, sessionKey, agentName, role, type: 'tool_result', content: part.content.slice(0, 500), metadata: { toolUseId: part.toolUseId, isError: part.isError } }
}
}
export const dynamic = 'force-dynamic'
|