Function startConfigWatcher

src/utils/config-watcher.ts:23–127

(options: ConfigWatcherOptions)

 * HTTP transport creates a fresh server per request, so tool changes take effect immediately.
 */
export function startConfigWatcher(options: ConfigWatcherOptions): (() => void) | null {
  const { connectorManager, initialTools } = options;
  const configPath = resolveTomlConfigPath();
  if (!configPath) {
    return null;
  }

  let debounceTimer: NodeJS.Timeout | null = null;
  let isReloading = false;
  let reloadPending = false;

  // Track last known-good config for rollback (sources + tools)
  let lastGoodSources: SourceConfig[] = connectorManager.getAllSourceConfigs();
  let lastGoodTools: ToolConfig[] | undefined = initialTools;

  const scheduleReload = () => {
    if (debounceTimer) {
      clearTimeout(debounceTimer);
    }
    debounceTimer = setTimeout(reload, DEBOUNCE_MS);
  };

  const reload = async () => {
    if (isReloading) {
      reloadPending = true;
      return;
    }
    isReloading = true;
    reloadPending = false;

    try {
      console.error(`\nDetected change in ${configPath}, reloading configuration...`);

      // Parse and validate new config — if this throws, keep existing connections
      const newConfig = loadTomlConfig();
      if (!newConfig) {
        console.error("Config reload: failed to load TOML config, keeping existing connections.");
        return;
      }

      // Save current config for rollback
      const oldSources = lastGoodSources;
      const oldTools = lastGoodTools;

      // Disconnect all existing sources
      await connectorManager.disconnect();

      try {
        // Reconnect with new sources
        await connectorManager.connectWithSources(newConfig.sources);

        // Re-initialize tool registry with new config
        initializeToolRegistry({
          sources: newConfig.sources,
          tools: newConfig.tools,
        });

        // Update last known-good config