Function initCodeGraph

bin/mcp_bridge.js:99–158

(version)

}

async function initCodeGraph(version) {
  const child = startCodeGraphMCP();
  if (!child) return false;

  // Use actual package version if not provided
  let resolvedVersion = version;
  if (!resolvedVersion) {
    try {
      const pkg = require('../package.json');
      resolvedVersion = pkg.version;
    } catch {}
    if (!resolvedVersion) resolvedVersion = '0.9.2';
  }

  const initResult = await mcpCall('initialize', {
    protocolVersion: '2024-11-05',
    capabilities: {},
    clientInfo: { name: 'smallcode', version: resolvedVersion },
  });

  if (!initResult) {
    mcpProcess = null;
    return false;
  }

  const listResult = await mcpCall('tools/call', { name: 'list_repos', arguments: {} });
  let alreadyIndexed = 0;
  if (listResult && listResult.content) {
    try {
      const data = JSON.parse(listResult.content[0]?.text || '{}');
      alreadyIndexed = data.total || 0;
    } catch {}
  }

  if (alreadyIndexed > 0) return true;

  const cwd = process.cwd();
  const subProjects = [];
  try {
    const entries = fs.readdirSync(cwd, { withFileTypes: true });
    for (const entry of entries) {
      if (!entry.isDirectory()) continue;
      if (entry.name.startsWith('.') || entry.name === 'node_modules' || entry.name === 'venv') continue;
      const subPath = path.join(cwd, entry.name);
      const markers = ['package.json', 'Cargo.toml', 'go.mod', 'pyproject.toml', 'src'];
      const hasMarker = markers.some(m => fs.existsSync(path.join(subPath, m)));
      if (hasMarker) subProjects.push({ path: subPath, name: entry.name });
    }
  } catch {}

  if (subProjects.length > 0) {
    for (const proj of subProjects.slice(0, 8)) {
      await mcpCall('tools/call', { name: 'index_repo', arguments: { path: proj.path, name: proj.name } });
    }
  } else {
    await mcpCall('tools/call', { name: 'index_repo', arguments: { path: cwd, name: path.basename(cwd) } });
  }