Function buildFlowGraph

tools/debug-console/lib/build-flow-graph.ts:311–629

(
  msg: UIMessage | null | undefined,
  userQuery?: string | null,
  locale: Locale = DEFAULT_LOCALE,
)

}

export function buildFlowGraph(
  msg: UIMessage | null | undefined,
  userQuery?: string | null,
  locale: Locale = DEFAULT_LOCALE,
): BuildResult {
  if (!msg && !userQuery) return { nodes: [], edges: [] };

  const nodeMap = new Map<string, FlowNodeData>();
  const orderedKeys: string[] = [];
  const callsByKey = new Map<string, ToolCallVizData[]>();
  const edges: GraphEdge[] = [];
  let edgeSeq = 0;
  let prevKey: string | null = null;
  let toolOrder = 0;

  const pushNode = (key: string, data: FlowNodeData) => {
    nodeMap.set(key, data);
    orderedKeys.push(key);
  };

  // 起始 Query
  const QUERY_KEY = "__query__";
  if (userQuery && userQuery.trim()) {
    const trimmed = userQuery.trim();
    pushNode(QUERY_KEY, {
      key: QUERY_KEY,
      kind: "query",
      fileType: "unknown",
      title: i18nT("flow.node_question", locale),
      subtitle: trimmed.length > 80 ? trimmed.slice(0, 80) + "…" : trimmed,
      body: trimmed,
      hitCount: 1,
      status: "ok",
      order: 0,
      toolCallIds: [],
    });
    prevKey = QUERY_KEY;
  }

  if (!msg) {
    return finalize(orderedKeys, nodeMap, edges);
  }

  // Pass 1：收集实际被 tool 调到的 path（用于 ghost 判断）
  const toolCalledPaths = new Set<string>();
  for (const part of msg.parts) {
    if (part.kind !== "tool-call") continue;
    const cls = classifyCall(part.call.name, part.call.args);
    if (cls.path) toolCalledPaths.add(cls.path);
  }

  // Pass 2：建图
  let thoughtCounter = 0;
  let ghostCounter = 0;
  const ghostKeyByPath = new Map<string, string>(); // path → ghost node key（去重）

  /**
   * 并行检测：两个 tool-call 之间没有任何 text part（或 text 只是空白）