114 lines
3.2 KiB
Go
114 lines
3.2 KiB
Go
package watch
|
|
|
|
import (
|
|
"gomark/logging"
|
|
|
|
"github.com/fsnotify/fsnotify"
|
|
)
|
|
|
|
var log = logging.GetLogger("WATCH")
|
|
|
|
// Used as input to WatcherThread
|
|
// It does not have to be a browser as long is the interface is implemented
|
|
type Watchable interface {
|
|
HasReducer() bool // Does the watchable has a reducer
|
|
SetupFileWatcher(...*Watch) // Starts watching bookmarks and runs Load on change
|
|
Watch() bool // starts watching linked watcher
|
|
GetWatcher() *Watcher // returns linked watcher
|
|
ResetWatcher() // resets a new watcher
|
|
GetBookmarksPath() string // returns watched path
|
|
GetDir() string // returns watched dir
|
|
Run() // Callbaks to run on event
|
|
EventsChan() chan fsnotify.Event
|
|
}
|
|
|
|
// Wrapper around fsnotify watcher
|
|
type Watcher struct {
|
|
W *fsnotify.Watcher // underlying fsnotify watcher
|
|
Watched map[string]*Watch // watched paths
|
|
Watches []*Watch // helper var
|
|
}
|
|
|
|
// Details about the object being watched
|
|
type Watch struct {
|
|
Path string // Path to watch for events
|
|
EventTypes []fsnotify.Op // events to watch for
|
|
EventNames []string // event names to watch for (file/dir names)
|
|
ResetWatch bool // Reset the watcher when the event happens (useful for create events)
|
|
}
|
|
|
|
// Main thread for watching file changes
|
|
func WatcherThread(w Watchable) {
|
|
|
|
log.Infof("<%s> Started watcher", w)
|
|
for {
|
|
// Keep watcher here as it is reset from within
|
|
// the select block
|
|
watcher := w.GetWatcher()
|
|
resetWatch := false
|
|
|
|
select {
|
|
case event := <-watcher.W.Events:
|
|
// Very verbose
|
|
//log.Debugf("event: %v | eventName: %v", event.Op, event.Name)
|
|
|
|
// On Chrome like browsers the bookmarks file is created
|
|
// at every change.
|
|
|
|
/*
|
|
* When a file inside a watched directory is renamed/created,
|
|
* fsnotify does not seem to resume watching the newly created file, we
|
|
* need to destroy and create a new watcher. The ResetWatcher() and
|
|
* `break` statement ensure we get out of the `select` block and catch
|
|
* the newly created watcher to catch events even after rename/create
|
|
*/
|
|
|
|
for _, watched := range watcher.Watches {
|
|
for _, watchedEv := range watched.EventTypes {
|
|
for _, watchedName := range watched.EventNames {
|
|
if event.Op&watchedEv == watchedEv &&
|
|
event.Name == watchedName {
|
|
|
|
// For watchers who need a reducer
|
|
// to avoid spammy events
|
|
if w.HasReducer() {
|
|
ch := w.EventsChan()
|
|
ch <- event
|
|
} else {
|
|
w.Run()
|
|
}
|
|
|
|
//log.Warning("event: %v | eventName: %v", event.Op, event.Name)
|
|
|
|
if watched.ResetWatch {
|
|
log.Debugf("resetting watchers")
|
|
w.ResetWatcher()
|
|
resetWatch = true // needed to break out of big loop
|
|
}
|
|
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if resetWatch {
|
|
break
|
|
}
|
|
|
|
// Firefox keeps the file open and makes changes on it
|
|
// It needs a debouncer
|
|
//if event.Name == bookmarkPath {
|
|
//log.Debugf("event: %v | eventName: %v", event.Op, event.Name)
|
|
////go debounce(1000*time.Millisecond, spammyEventsChannel, w)
|
|
//ch := w.EventsChan()
|
|
//ch <- event
|
|
////w.Run()
|
|
//}
|
|
case err := <-watcher.W.Errors:
|
|
if err != nil {
|
|
log.Error(err)
|
|
}
|
|
}
|
|
}
|
|
}
|