# 不监听的目录
# .idea   忽略.idea目录及其所有子目录的监听
exceptDirs:
    - .idea
    - .git
    - .vscode

# 监听文件的格式，此类文件更改会执行 command 中的命令
# .go   后缀为 .go 的文件更改，会执行 command 中的命令
# .*    所有的文件更改都会执行 command 中的命令
types:
     - .*

# 监听的事件类型，发生此类事件才执行 command 中的命令
# 没有该配置默认监听所有事件
# write   写入文件事件
# rename  重命名文件事件
# remove  移除文件事件
# create  创建文件事件
# chmod   更新文件权限事件(类unix)
events:
    - write
    - rename
    - remove
    - create

# 文件变更后命令在xx毫秒后才会执行，单位为毫秒
# 一个变更事件(A)如果在定义的延迟时间(t)内, 又有新的文件变更事件(B), 那么A会取消执行。
# B及以后的事件均依次类推，直到事件Z在t内没有新事件产生，Z 会执行
# 合理设置延迟时间，将有效减少冗余和重复任务的执行
# 如果不需要该特性，设置为 0
delayMillSecond: 1000

#- should-finish
#- exec-when-start
- ignore-warn

package main

import (
	"fmt"
	"os"
	"path/filepath"

	"github.com/fsnotify/fsnotify"
)

type NotifyFile struct {
	watch *fsnotify.Watcher
}

func NewNotifyFile() *NotifyFile {
	w := new(NotifyFile)
	w.watch, _ = fsnotify.NewWatcher()
	return w
}

//监控目录
func (this *NotifyFile) WatchDir(dir string) {
	//通过Walk来遍历目录下的所有子目录
	filepath.Walk(dir, func(path string, info os.FileInfo, err error) error {
		//判断是否为目录，监控目录,目录下文件也在监控范围内，不需要加
		if info.IsDir() {
			path, err := filepath.Abs(path)
			if err != nil {
				return err
			}
			err = this.watch.Add(path)
			if err != nil {
				return err
			}
			fmt.Println("监控 : ", path)
		}
		return nil
	})

	go this.WatchEvent() //协程
}

func (this *NotifyFile) WatchEvent() {
	for {
		select {
		case ev := <-this.watch.Events:
			{
				if ev.Op&fsnotify.Create == fsnotify.Create {
					fmt.Println("创建文件 : ", ev.Name)
					//获取新创建文件的信息，如果是目录，则加入监控中
					file, err := os.Stat(ev.Name)
					if err == nil && file.IsDir() {
						this.watch.Add(ev.Name)
						fmt.Println("添加监控 : ", ev.Name)
					}
				}

				if ev.Op&fsnotify.Write == fsnotify.Write {
					//fmt.Println("写入文件 : ", ev.Name)
				}

				if ev.Op&fsnotify.Remove == fsnotify.Remove {
					fmt.Println("删除文件 : ", ev.Name)
					//如果删除文件是目录，则移除监控
					fi, err := os.Stat(ev.Name)
					fmt.Println("dir:", fi)

					if err == nil && fi.IsDir() {
						this.watch.Remove(ev.Name)
						fmt.Println("删除监控 : ", ev.Name)
					}
				}

				if ev.Op&fsnotify.Rename == fsnotify.Rename {
					//如果重命名文件是目录，则移除监控 ,注意这里无法使用os.Stat来判断是否是目录了
					//因为重命名后，go已经无法找到原文件来获取信息了,所以简单粗爆直接remove
					fmt.Println("重命名文件 : ", ev.Name)
					this.watch.Remove(ev.Name)
				}
				if ev.Op&fsnotify.Chmod == fsnotify.Chmod {
					fmt.Println("修改权限 : ", ev.Name)
				}
			}
		case err := <-this.watch.Errors:
			{
				fmt.Println("error : ", err)
				return
			}
		}
	}
}

func main() {
	watch := NewNotifyFile()
	watch.WatchDir("/Users/hpd/ceshi")
	select {}
	return
}