Add -c param and exclusion

This commit is contained in:
trading_peter 2022-02-01 17:15:14 +01:00
parent 311339685c
commit 12de91324e
2 changed files with 54 additions and 23 deletions

74
main.go
View File

@ -2,6 +2,7 @@ package main
import ( import (
"encoding/json" "encoding/json"
"errors"
"fmt" "fmt"
"os" "os"
"os/signal" "os/signal"
@ -21,7 +22,8 @@ var triggerReload = make(chan struct{})
type options struct { type options struct {
ESBuild api.BuildOptions ESBuild api.BuildOptions
Watch struct { Watch struct {
Path string Path string
Exclude []string
} }
Copy []struct { Copy []struct {
Src string Src string
@ -30,26 +32,34 @@ type options struct {
} }
func main() { func main() {
opts := options{}
cfgContent, err := os.ReadFile("./.gowebbuild.json")
if err != nil {
fmt.Printf("%+v\n", err)
os.Exit(1)
}
err = json.Unmarshal(cfgContent, &opts)
if err != nil {
fmt.Printf("%+v\n", err)
os.Exit(1)
}
flow := &goyek.Flow{} flow := &goyek.Flow{}
opts := options{}
flow.Register(goyek.Task{ cfgPathParam := flow.RegisterStringParam(goyek.StringParam{
Name: "watch-frontend", Name: "c",
Usage: "", Usage: "Path to config file config file.",
Default: "./.gowebbuild.json",
})
watchFrontend := goyek.Task{
Name: "watch-frontend",
Usage: "",
Params: goyek.Params{cfgPathParam},
Action: func(tf *goyek.TF) { Action: func(tf *goyek.TF) {
cfgPath := cfgPathParam.Get(tf)
cfgContent, err := os.ReadFile(cfgPath)
if err != nil {
fmt.Printf("%+v\n", err)
os.Exit(1)
}
err = json.Unmarshal(cfgContent, &opts)
if err != nil {
fmt.Printf("%+v\n", err)
os.Exit(1)
}
c := make(chan os.Signal, 1) c := make(chan os.Signal, 1)
signal.Notify(c, os.Interrupt, syscall.SIGTERM) signal.Notify(c, os.Interrupt, syscall.SIGTERM)
@ -59,6 +69,11 @@ func main() {
w := watcher.New() w := watcher.New()
w.SetMaxEvents(1) w.SetMaxEvents(1)
w.FilterOps(watcher.Write, watcher.Rename, watcher.Move, watcher.Create, watcher.Remove) w.FilterOps(watcher.Write, watcher.Rename, watcher.Move, watcher.Create, watcher.Remove)
if len(opts.Watch.Exclude) > 0 {
w.Ignore(opts.Watch.Exclude...)
}
if err := w.AddRecursive(opts.Watch.Path); err != nil { if err := w.AddRecursive(opts.Watch.Path); err != nil {
fmt.Println(err.Error()) fmt.Println(err.Error())
os.Exit(1) os.Exit(1)
@ -81,6 +96,9 @@ func main() {
fmt.Printf("Watching %d elements in %s\n", len(w.WatchedFiles()), opts.Watch.Path) fmt.Printf("Watching %d elements in %s\n", len(w.WatchedFiles()), opts.Watch.Path)
cp(opts)
build(opts)
if err := w.Start(time.Millisecond * 100); err != nil { if err := w.Start(time.Millisecond * 100); err != nil {
fmt.Println(err.Error()) fmt.Println(err.Error())
} }
@ -107,8 +125,9 @@ func main() {
fmt.Println("\nExit") fmt.Println("\nExit")
os.Exit(0) os.Exit(0)
}, },
}) }
flow.DefaultTask = flow.Register(watchFrontend)
flow.Main() flow.Main()
} }
@ -143,13 +162,24 @@ func cp(opts options) {
} }
func isFile(path string) bool { func isFile(path string) bool {
stat, _ := os.Stat(path) stat, err := os.Stat(path)
if errors.Is(err, os.ErrNotExist) {
return false
}
return !stat.IsDir() return !stat.IsDir()
} }
func isDir(path string) bool { func isDir(path string) bool {
stat, _ := os.Stat(path) stat, err := os.Stat(path)
return stat.IsDir()
if errors.Is(err, os.ErrNotExist) {
os.MkdirAll(path, 0755)
return true
}
return err == nil && stat.IsDir()
} }
func build(opts options) { func build(opts options) {

View File

@ -1,6 +1,7 @@
{ {
"Watch": { "Watch": {
"Path": "./frontend/src" "Path": "./frontend/src",
"Exclude": [ "./dist" ]
}, },
"Copy": [ "Copy": [
{ {