Function parseFileAsync

src/conversations/parser.ts:185–258

(meta: ConversationMeta)

}

async function parseFileAsync(meta: ConversationMeta): Promise<ConversationItem | null> {
	return new Promise((resolve) => {
		const messages: ConversationMessage[] = [];
		let firstTimestamp = "";
		let lastTimestamp = "";
		let lineCount = 0;

		const rl = createInterface({
			input: createReadStream(meta.filePath, { encoding: "utf-8" }),
			crlfDelay: Number.POSITIVE_INFINITY,
		});

		rl.on("line", (line) => {
			if (!line.trim()) return;
			lineCount++;
			if (lineCount > MAX_LINES_PER_FILE) { rl.close(); return; }

			try {
				const entry = JSON.parse(line) as Record<string, unknown>;
				const ts = typeof entry.timestamp === "string" ? entry.timestamp : undefined;
				if (ts) {
					if (!firstTimestamp) firstTimestamp = ts;
					lastTimestamp = ts;
				}

				if (entry.type === "user") {
					const msg = entry.message as { content?: unknown } | undefined;
					if (!msg) return;
					const text = extractText(msg.content);
					if (text) messages.push({ role: "human", text, timestamp: ts || "" });
				}

				if (entry.type === "assistant") {
					const msg = entry.message as { content?: unknown } | undefined;
					if (!msg) return;
					const text = extractText(msg.content);
					const toolCalls = extractToolCalls(msg.content);
					if (text) {
						messages.push({
							role: "assistant", text, timestamp: ts || "",
							toolCalls: toolCalls.length > 0 ? toolCalls : undefined,
						});
					}
				}
			} catch { /* skip */ }
		});

		rl.on("close", () => {
			if (messages.length === 0) { resolve(null); return; }
			const firstHuman = messages.find((m) => m.role === "human");
			const title = firstHuman
				? firstHuman.text.slice(0, 120).replace(/\n/g, " ")
				: "(empty conversation)";

			resolve({
				id: meta.uuid,
				uuid: meta.uuid,
				project: meta.project,