Function doRebuildGraph

src/services/code-graph.ts:182–247

Internal: performs the actual graph rebuild with progress tracking

(
  resolvedPath: string,
  opts: RebuildGraphOptions,
)

/** Internal: performs the actual graph rebuild with progress tracking */
async function doRebuildGraph(
  resolvedPath: string,
  opts: RebuildGraphOptions,
): Promise<CodeGraph> {
  const progress: GraphBuildProgress = {
    startedAt: Date.now(),
    filesTotal: 0,
    filesProcessed: 0,
    phase: "scanning files",
  };
  graphBuildInProgress.set(resolvedPath, progress);

  try {
    graphCache.delete(resolvedPath);
    const built = await buildCodeGraph(resolvedPath, opts.extraExtensions, progress);
    const graph: CodeGraph = { nodes: built.nodes, edges: built.edges };
    graphCache.set(resolvedPath, graph);

    // Persist file-import graph to Qdrant
    progress.phase = "persisting";
    const projectId = projectIdFromPath(resolvedPath);
    const graphCollName = graphCollectionName(projectId);
    await saveGraphData(graphCollName, resolvedPath, graph);

    // Build & persist symbol graph (resolution + sharded persistence) — unless
    // the caller asked to skip it (Phase F watcher path).
    if (!opts.skipSymbolGraph) {
      try {
        progress.phase = "resolving symbols";
        resolveCallSites(graph, built.symbolsByFile, built.outgoingCallsByFile);

        progress.phase = "persisting symbols";
        await persistSymbolGraph(projectId, resolvedPath, built.symbolsByFile, built.outgoingCallsByFile);
      } catch (err) {
        logger.warn("Symbol graph build failed (file-import graph saved)", {
          projectPath: resolvedPath,
          error: err instanceof Error ? err.message : String(err),
        });
      }
    }

    lastGraphBuildCompleted.set(resolvedPath, {
      completedAt: Date.now(),
      durationMs: Date.now() - progress.startedAt,
      filesProcessed: progress.filesProcessed,
      nodesCreated: graph.nodes.length,
      edgesCreated: graph.edges.length,
    });

    return graph;
  } catch (err) {
    const message = err instanceof Error ? err.message : String(err);
    progress.error = message;
    lastGraphBuildCompleted.set(resolvedPath, {
      completedAt: Date.now(),
      durationMs: Date.now() - progress.startedAt,
      filesProcessed: progress.filesProcessed,
      nodesCreated: 0,