Function persistSymbolGraph

src/services/code-graph.ts:250–356

Persist the symbol graph: per-file payloads + sharded indices + meta.

(
  projectId: string,
  resolvedPath: string,
  symbolsByFile: Map<string, SymbolNode[]>,
  outgoingCallsByFile: Map<string, SymbolEdge[]>,
)

/** Persist the symbol graph: per-file payloads + sharded indices + meta. */
async function persistSymbolGraph(
  projectId: string,
  resolvedPath: string,
  symbolsByFile: Map<string, SymbolNode[]>,
  outgoingCallsByFile: Map<string, SymbolEdge[]>,
): Promise<void> {
  await ensureSymbolGraphCollections(projectId);

  // Build per-file payloads (need source bytes for contentHash).
  const payloads: SymbolGraphFilePayload[] = [];
  let totalSymbols = 0;
  let totalEdges = 0;
  for (const [relPath, symbols] of symbolsByFile.entries()) {
    const outgoingCalls = outgoingCallsByFile.get(relPath) ?? [];
    let language = "plaintext";
    const firstNonModule = symbols.find((s) => s.name !== "<module>");
    if (firstNonModule) language = firstNonModule.language;
    else language = symbols[0]?.language ?? language;

    let contentHash = "";
    try {
      const src = await fs.readFile(path.join(resolvedPath, relPath), "utf-8");
      contentHash = contentHashOf(src);
    } catch {
      // ignore
    }
    payloads.push({
      file: relPath, language, contentHash, symbols, outgoingCalls,
    });
    totalSymbols += symbols.filter((s) => s.name !== "<module>").length;
    totalEdges += outgoingCalls.length;
  }

  // Build sharded indices
  const nameShards = new Map<string, Record<string, SymbolRef[]>>();
  for (const key of allNameShardKeys()) nameShards.set(key, {});
  for (const [file, symbols] of symbolsByFile.entries()) {
    for (const sym of symbols) {
      if (sym.name === "<module>") continue;
      const shardKey = nameShardKey(sym.name);
      const shard = nameShards.get(shardKey);
      if (!shard) continue;
      const ref: SymbolRef = { file, id: sym.id };
      // Use hasOwn — `shard[sym.name]` would return Object.prototype.constructor
      // (a function) for symbol names like "constructor" / "toString" / "hasOwnProperty".
      const existing = Object.hasOwn(shard, sym.name) ? shard[sym.name] : undefined;
      if (existing) existing.push(ref);
      else shard[sym.name] = [ref];
    }
  }

  const reverseShards = new Map<number, Record<string, string[]>>();
  for (const [callerFile, edges] of outgoingCallsByFile.entries()) {
    for (const e of edges) {
      for (const calleeId of e.calleeCandidates) {
        const calleeFile = calleeId.split("::")[0];
        if (!calleeFile || calleeFile === callerFile) continue;
        const bucket = reverseShardKey(calleeFile);