94 lines
1.6 KiB
Go
94 lines
1.6 KiB
Go
package realize
|
|
|
|
import (
|
|
"github.com/fsnotify/fsnotify"
|
|
"fmt"
|
|
"path/filepath"
|
|
"os"
|
|
"log"
|
|
"strings"
|
|
"sync"
|
|
)
|
|
|
|
func InArray(str string, list []string) bool{
|
|
for _, v := range list {
|
|
if v == str {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|
|
|
|
func Ignore(str string, list []string) bool{
|
|
for _, v := range list {
|
|
if strings.Contains(str, v) {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (h *Config) Watch() error{
|
|
|
|
var current Watcher
|
|
|
|
var wg sync.WaitGroup
|
|
|
|
var watcher *fsnotify.Watcher
|
|
|
|
walk := func(path string, info os.FileInfo, err error) error{
|
|
if !Ignore(path,current.Ignore) {
|
|
if info.IsDir() && len(filepath.Ext(path)) == 0 && !strings.Contains(path, "/.") {
|
|
if err = watcher.Add(path); err != nil {
|
|
return filepath.SkipDir
|
|
}
|
|
} else if InArray(filepath.Ext(path), current.Exts) {
|
|
if err = watcher.Add(path); err != nil {
|
|
return filepath.SkipDir
|
|
}
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
watch := func(val Project){
|
|
watcher, _ = fsnotify.NewWatcher()
|
|
for _, dir := range val.Watcher.Paths {
|
|
path, _ := os.Getwd()
|
|
current = val.Watcher
|
|
if err := filepath.Walk(path + dir, walk); err != nil {
|
|
fmt.Println(err)
|
|
}
|
|
}
|
|
|
|
for {
|
|
select {
|
|
case event := <-watcher.Events:
|
|
if event.Op&fsnotify.Chmod == fsnotify.Chmod {
|
|
continue
|
|
}
|
|
log.Println("event:", event)
|
|
case err := <-watcher.Errors:
|
|
log.Println("error:", err)
|
|
}
|
|
}
|
|
|
|
wg.Done()
|
|
watcher.Close()
|
|
}
|
|
|
|
// add to watcher
|
|
if err := h.Read(); err == nil {
|
|
|
|
// loop projects
|
|
wg.Add(len(h.Projects))
|
|
for _, val := range h.Projects {
|
|
go watch(val)
|
|
}
|
|
wg.Wait()
|
|
|
|
return nil
|
|
}else{
|
|
return err
|
|
}
|
|
} |