Method Start

apps/cli/internal/watcher/watcher.go:36–86

Start begins watching. It blocks until Stop is called or an error occurs. nolint:gocognit // TODO: refactor to reduce complexity

()

//
//nolint:gocognit // TODO: refactor to reduce complexity
func (w *Watcher) Start() error {
	fsw, err := fsnotify.NewWatcher()
	if err != nil {
		return err
	}
	w.mu.Lock()
	w.watcher = fsw
	w.mu.Unlock()

	defer fsw.Close()

	if err := w.addRecursive(fsw, w.dir); err != nil {
		return err
	}

	var timer *time.Timer
	for {
		select {
		case event, ok := <-fsw.Events:
			if !ok {
				return nil
			}
			if !isMarkdown(event.Name) {
				// Watch new directories for recursive support
				if event.Op&fsnotify.Create != 0 {
					if info, err := os.Stat(event.Name); err == nil && info.IsDir() {
						_ = w.addRecursive(fsw, event.Name)
					}
				}
				continue
			}
			if event.Op&(fsnotify.Write|fsnotify.Create|fsnotify.Remove|fsnotify.Rename) == 0 {
				continue
			}
			// Debounce
			if timer != nil {
				timer.Stop()
			}
			timer = time.AfterFunc(w.debounce, w.onChange)

		case err, ok := <-fsw.Errors:
			if !ok {
				return nil
			}
			_ = err // log in verbose mode if needed

		case <-w.done:
			return nil
		}
	}
}

// Stop signals the watcher to stop.
func (w *Watcher) Stop() {