Improve directory rename handling

wtetsu · Nov 6, 2022 · a5582f2 · a5582f2
1 parent 4d1fd37
commit a5582f2
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/pkg/notify/notify.go b/pkg/notify/notify.go
@@ -249,8 +249,17 @@ func (n *Notify) wait() {
 
 			logger.Debug("fs.IsDir: %s", fs.IsDir(normalizedName))
 			if event.Op == fsnotify.Create && shouldWatch(normalizedName, n.candidates) {
+				err := n.watcher.Remove(normalizedName)
+				if err != nil {
+					if !strings.HasPrefix(err.Error(), "can't remove non-existent watch for:") {
+						logger.Error("watcher.Remove: %s", err)
+					}
+				}
 				logger.Info("gazing at: %s", normalizedName)
-				n.watcher.Add(normalizedName)
+				err = n.watcher.Add(normalizedName)
+				if err != nil {
+					logger.Error("watcher.Add: %s", err)
+				}
 			}
 
 			if !ok {