Function parseCodexMessagesFromLines

apps/web/lib/server/queries.ts:888–927

(lines: string[])

}

function parseCodexMessagesFromLines(lines: string[]): WebCodexThreadMessage[] {
  const messages: WebCodexThreadMessage[] = [];
  for (const line of lines) {
    const trimmed = line.trim();
    if (!trimmed) {
      continue;
    }
    try {
      const parsed = JSON.parse(trimmed) as {
        timestamp?: string;
        type?: string;
        payload?: {
          type?: string;
          role?: string;
          content?: Array<{ type?: string; text?: string; content?: Array<{ text?: string }> }>;
        };
      };
      if (parsed.type !== 'response_item' || parsed.payload?.type !== 'message') {
        continue;
      }
      if (parsed.payload.role !== 'user' && parsed.payload.role !== 'assistant') {
        continue;
      }
      const text = extractMessageText(parsed.payload.content);
      if (!text || isInternalCodexUserMessage(parsed.payload.role, text)) {
        continue;
      }
      messages.push({
        id: `${parsed.timestamp ?? 'msg'}:${messages.length}`,
        role: parsed.payload.role,
        source: 'history',
        text,
        timestamp: parsed.timestamp ?? null,
      });
    } catch {
      continue;
    }
  }
  return messages;
}

function readFileTail(filePath: string, maxBytes = 1024 * 1024): string {
  const stat = fs.statSync(filePath);