Function parseAllConversationsAsync

src/conversations/parser.ts:275–298

()

}

export async function parseAllConversationsAsync(): Promise<ConversationItem[]> {
	const metas = collectMeta();
	const conversations: ConversationItem[] = [];
	const BATCH_SIZE = 20;

	metas.sort((a, b) => b.fileSize - a.fileSize);

	for (let i = 0; i < metas.length; i += BATCH_SIZE) {
		const batch = metas.slice(i, i + BATCH_SIZE);
		const results = await Promise.all(
			batch.map((meta) =>
				meta.fileSize > MAX_FILE_SIZE
					? parseFileAsync(meta)
					: Promise.resolve(parseFileSync(meta))
			)
		);
		for (const r of results) {
			if (r) conversations.push(r);
		}
	}

	conversations.sort((a, b) => (b.lastTimestamp || "").localeCompare(a.lastTimestamp || ""));
	return conversations;
}