Function prepareThreadItems

src/utils/threadItems.explore.ts:379–431

(
  items: ConversationItem[],
  options?: PrepareThreadItemsOptions,
)

}

export function prepareThreadItems(
  items: ConversationItem[],
  options?: PrepareThreadItemsOptions,
) {
  const filtered: ConversationItem[] = [];
  for (const item of items) {
    const last = filtered[filtered.length - 1];
    if (
      item.kind === "message" &&
      item.role === "assistant" &&
      last?.kind === "review" &&
      last.state === "completed" &&
      item.text.trim() === last.text.trim()
    ) {
      continue;
    }
    filtered.push(item);
  }
  const normalized = filtered.map((item) => normalizeItem(item));
  const maxItemsPerThreadRaw = options?.maxItemsPerThread;
  const maxItemsPerThread =
    maxItemsPerThreadRaw === null
      ? null
      : typeof maxItemsPerThreadRaw === "number" &&
          Number.isFinite(maxItemsPerThreadRaw) &&
          maxItemsPerThreadRaw > 0
        ? Math.floor(maxItemsPerThreadRaw)
        : DEFAULT_MAX_ITEMS_PER_THREAD;
  const limited =
    maxItemsPerThread === null
      ? normalized
      : normalized.length > maxItemsPerThread
        ? normalized.slice(-maxItemsPerThread)
        : normalized;
  const summarized = summarizeExploration(limited);
  const cutoff = Math.max(0, summarized.length - TOOL_OUTPUT_RECENT_ITEMS);
  return summarized.map((item, index) => {
    if (index >= cutoff || item.kind !== "tool") {
      return item;
    }
    const output = item.output ? truncateText(item.output) : item.output;
    const changes = item.changes
      ? item.changes.map((change) => ({
          ...change,
          diff: change.diff ? truncateText(change.diff) : change.diff,
        }))
      : item.changes;
    if (output === item.output && changes === item.changes) {
      return item;
    }
    return { ...item, output, changes };
  });
}