Function parseTranscript

src/web/transcript-parser.ts:64–220

(jsonlContent: string)

}

export function parseTranscript(jsonlContent: string): LogEntry[] {
  const entries: LogEntry[] = [];
  const lines = jsonlContent.split('\n').filter((l) => l.trim());

  for (const line of lines) {
    let obj: TranscriptLine;
    try {
      obj = JSON.parse(line);
    } catch {
      continue;
    }

    const time = formatTime(obj.timestamp);

    // System messages
    if (obj.type === 'system') {
      if (obj.subtype === 'init') {
        entries.push({
          time,
          type: 'system',
          content: `Session initialized: ${obj.session_id || ''}`,
        });
      } else if (obj.subtype === 'task_started') {
        entries.push({ time, type: 'system', content: `Task started` });
      } else if (obj.subtype === 'task_notification') {
        const tn = obj as unknown as {
          task_id: string;
          status: string;
          summary: string;
        };
        entries.push({
          time,
          type: 'system',
          content: `Task ${tn.task_id}: ${tn.status} - ${tn.summary}`,
        });
      } else {
        entries.push({
          time,
          type: 'system',
          content: `${obj.subtype || 'system event'}`,
        });
      }
      continue;
    }

    // Queue operations
    if (obj.type === 'queue-operation') {
      continue; // Skip internal queue ops
    }

    // Rate limit events
    if (obj.type === 'rate_limit_event') {
      entries.push({
        time,
        type: 'system',
        content: 'Rate limit hit, waiting...',
      });
      continue;