From a3e811e00d8a7fe0f37d85557d7db60087967171 Mon Sep 17 00:00:00 2001
From: Robin Jarry <robin@jarry.cc>
Date: Thu, 29 Jun 2023 16:53:38 +0200
Subject: watchers: move filesystem monitoring stuff in lib

No functional change. This will allow reuse in other parts of aerc.

Signed-off-by: Robin Jarry <robin@jarry.cc>
Tested-by: Koni Marti <koni.marti@gmail.com>
---
 worker/lib/watchers/fsevents.go | 84 -----------------------------------------
 1 file changed, 84 deletions(-)
 delete mode 100644 worker/lib/watchers/fsevents.go

(limited to 'worker/lib/watchers/fsevents.go')

diff --git a/worker/lib/watchers/fsevents.go b/worker/lib/watchers/fsevents.go
deleted file mode 100644
index 7b657999..00000000
--- a/worker/lib/watchers/fsevents.go
+++ /dev/null
@@ -1,84 +0,0 @@
-//go:build darwin
-// +build darwin
-
-package watchers
-
-import (
-	"time"
-
-	"git.sr.ht/~rjarry/aerc/log"
-	"git.sr.ht/~rjarry/aerc/worker/handlers"
-	"git.sr.ht/~rjarry/aerc/worker/types"
-	"github.com/fsnotify/fsevents"
-)
-
-func init() {
-	handlers.RegisterWatcherFactory(newDarwinWatcher)
-}
-
-type darwinWatcher struct {
-	ch        chan *types.FSEvent
-	w         *fsevents.EventStream
-	watcherCh chan []fsevents.Event
-}
-
-func newDarwinWatcher() (types.FSWatcher, error) {
-	watcher := &darwinWatcher{
-		watcherCh: make(chan []fsevents.Event),
-		ch:        make(chan *types.FSEvent),
-		w: &fsevents.EventStream{
-			Flags:   fsevents.FileEvents | fsevents.WatchRoot,
-			Latency: 500 * time.Millisecond,
-		},
-	}
-	return watcher, nil
-}
-
-func (w *darwinWatcher) watch() {
-	defer log.PanicHandler()
-	for events := range w.w.Events {
-		for _, ev := range events {
-			switch {
-			case ev.Flags&fsevents.ItemCreated > 0:
-				w.ch <- &types.FSEvent{
-					Operation: types.FSCreate,
-					Path:      ev.Path,
-				}
-			case ev.Flags&fsevents.ItemRenamed > 0:
-				w.ch <- &types.FSEvent{
-					Operation: types.FSRename,
-					Path:      ev.Path,
-				}
-			case ev.Flags&fsevents.ItemRemoved > 0:
-				w.ch <- &types.FSEvent{
-					Operation: types.FSRemove,
-					Path:      ev.Path,
-				}
-			}
-		}
-	}
-}
-
-func (w *darwinWatcher) Configure(root string) error {
-	dev, err := fsevents.DeviceForPath(root)
-	if err != nil {
-		return err
-	}
-	w.w.Device = dev
-	w.w.Paths = []string{root}
-	w.w.Start()
-	go w.watch()
-	return nil
-}
-
-func (w *darwinWatcher) Events() chan *types.FSEvent {
-	return w.ch
-}
-
-func (w *darwinWatcher) Add(p string) error {
-	return nil
-}
-
-func (w *darwinWatcher) Remove(p string) error {
-	return nil
-}
-- 
cgit