修正新增目录可能监听失败

fengqi · May 27, 2023 · 0a5af4e · 0a5af4e
1 parent 2861fc7
commit 0a5af4e
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/music_videos/collector.go b/music_videos/collector.go
@@ -74,6 +74,11 @@ func (c *Collector) runWatcher() {
 
 			//  新增目录
 			if fileInfo.IsDir() {
+				err = c.watcher.Add(event.Name)
+				if err != nil {
+					utils.Logger.WarningF("add music video dir: %s to watcher err: %v", event.Name, err)
+				}
+
 				videos, err := c.scanDir(event.Name)
 				if err != nil || len(videos) == 0 {
 					utils.Logger.WarningF("new dir %s scan err: %v", event.Name, err)
@@ -84,11 +89,6 @@ func (c *Collector) runWatcher() {
 					c.channel <- video
 				}
 
-				err = c.watcher.Add(event.Name)
-				if err != nil {
-					utils.Logger.FatalF("add music video dir: %s to watcher err: %v", event.Name, err)
-				}
-
 				continue
 			}