precacheForDirectory() — mcp Function Reference

Source Code

src/cache/graph-cache.ts lines 644–705

export async function precacheForDirectory(
  client: ClientContext,
  directory: string,
  cacheDir: string | undefined
): Promise<void> {
  // Already cached?
  if (detectRepo(directory, _repoMap)) {
    logger.debug('Graph already cached for', directory);
    return;
  }

  logger.info('Pre-computing graph for', directory, '(first run for this repo; subsequent runs will be instant)...');

  const idempotencyKey = generateIdempotencyKey(directory);
  const repoName = detectRepoName(directory);

  const zipResult = await zipRepository(directory);
  let progressInterval: NodeJS.Timeout | null = null;
  let elapsed = 0;
  progressInterval = setInterval(() => {
    elapsed += 15;
    logger.info(`Analysis in progress... (${elapsed}s elapsed)`);
  }, 15000);

  try {
    const fileBuffer = await fs.readFile(zipResult.path);
    const fileBlob = new Blob([fileBuffer], { type: 'application/zip' });

    const response = await client.graphs.generateSupermodelGraph(
      fileBlob as any,
      { idempotencyKey }
    );

    const graph = buildIndexes(response, `precache:${repoName}`);

    // Update in-memory caches
    graphCache.set(idempotencyKey, graph);
    _repoMap.set(repoName.toLowerCase(), graph);
    const parts = repoName.toLowerCase().split(/[_\-\/]/);
    for (const part of parts) {
      if (part && part.length > 2 && !_repoMap.has(part)) {
        _repoMap.set(part, graph);
      }
    }

    // Persist to disk for cross-container reuse
    if (cacheDir) {
      try {
        const savedPath = await saveCacheToDisk(cacheDir, repoName, response);
        logger.info('Saved graph to:', savedPath);
      } catch (err: any) {
        // Non-fatal: cache dir might be read-only or full
        logger.warn('Failed to persist graph to disk:', err.message);
      }
    }

    logger.info(`Pre-compute complete: ${graph.summary.nodeCount} nodes, ${graph.summary.relationshipCount} relationships`);
  } finally {
    if (progressInterval) clearInterval(progressInterval);
    await zipResult.cleanup();
  }
}