Method parseAndDedup

agent/x/agentmcp/manager.go:543–581

parseAndDedup reads all config files and returns a deduplicated list of server configs. Missing files are silently skipped; parse errors are logged and skipped.

(ctx context.Context, mcpConfigFiles []string)

// list of server configs. Missing files are silently skipped;
// parse errors are logged and skipped.
func (m *Manager) parseAndDedup(ctx context.Context, mcpConfigFiles []string) ([]ServerConfig, map[string]fileSnapshot) {
	logger := m.logger.With(agentchat.Fields(ctx)...)

	// Stat before reading so the snapshot is conservatively old.
	// If a file changes between stat and read, the snapshot
	// records the old mtime, SnapshotChanged detects a mismatch
	// on the next check, and triggers a re-read. False positives
	// (extra reload) are safe; false negatives (missed change)
	// are not.
	snap := captureSnapshot(mcpConfigFiles)

	var allConfigs []ServerConfig
	for _, configPath := range mcpConfigFiles {
		configs, err := ParseConfig(configPath)
		if err != nil {
			if errors.Is(err, fs.ErrNotExist) {
				continue
			}
			logger.Warn(ctx, "failed to parse MCP config",
				slog.F("path", configPath),
				slog.Error(err),
			)
			continue
		}
		allConfigs = append(allConfigs, configs...)
	}

	// Deduplicate by server name; first occurrence wins.
	seen := make(map[string]struct{})
	deduped := make([]ServerConfig, 0, len(allConfigs))
	for _, cfg := range allConfigs {
		if _, ok := seen[cfg.Name]; ok {
			continue
		}
		seen[cfg.Name] = struct{}{}
		deduped = append(deduped, cfg)
	}
	return deduped, snap
}

// classifyServers compares wanted configs against the current
// server map and returns a diff describing what changed.