Function newConfigWatcher

agent/x/agentmcp/configwatcher.go:57–88

newConfigWatcher creates a configWatcher and starts its event loop. Sync registers the actual paths to watch. The watcher does nothing until Sync is called.

(
	logger slog.Logger,
	clock quartz.Clock,
	debounce time.Duration,
	onChange func(),
)

// loop. Sync registers the actual paths to watch. The watcher does
// nothing until Sync is called.
func newConfigWatcher(
	logger slog.Logger,
	clock quartz.Clock,
	debounce time.Duration,
	onChange func(),
) (*configWatcher, error) {
	if onChange == nil {
		return nil, xerrors.New("onChange callback is required")
	}
	if debounce <= 0 {
		debounce = defaultWatchDebounce
	}

	w, err := fsnotify.NewWatcher()
	if err != nil {
		return nil, xerrors.Errorf("create fsnotify watcher: %w", err)
	}

	cw := &configWatcher{
		logger:    logger,
		clock:     clock,
		debounce:  debounce,
		onChange:  onChange,
		watcher:   w,
		files:     make(map[string]string),
		dirs:      make(map[string]int),
		closedCh:  make(chan struct{}),
		runDoneCh: make(chan struct{}),
	}
	go cw.run()
	return cw, nil
}

// Sync replaces the watched set with paths. Files no longer in the
// list are removed; new files are added. Symlinks are resolved