package main import ( "errors" "fmt" "os" "time" "github.com/fatih/color" "github.com/tockins/interact" "github.com/tockins/realize/server" "github.com/tockins/realize/settings" "github.com/tockins/realize/style" "github.com/tockins/realize/watcher" cli "gopkg.in/urfave/cli.v2" ) const ( version = "1.4.1" config = "realize.yaml" directory = ".realize" outputs = "outputs.log" errs = "errors.log" logs = "logs.log" host = "localhost" port = 3001 interval = 200 ) // Realize struct contains the general app informations type realize struct { settings.Settings `yaml:"settings,omitempty"` Sync chan string `yaml:"-"` Blueprint watcher.Blueprint `yaml:"-"` Server server.Server `yaml:"-"` Projects *[]watcher.Project `yaml:"projects" json:"projects"` } // New realize instance var r realize // Cli commands func main() { app := &cli.App{ Name: "Realize", Version: version, Authors: []*cli.Author{ { Name: "Alessio Pracchia", Email: "pracchia@hastega.it", }, { Name: "Daniele Conventi", Email: "conventi@hastega.it", }, }, Description: "A Go build system with file watchers, output streams and live reload. Run, build and watch file changes with custom paths", Commands: []*cli.Command{ { Name: "run", Aliases: []string{"r"}, Description: "Run a toolchain on a project or a list of projects. If not exist a config file it creates a new one", Flags: []cli.Flag{ &cli.StringFlag{Name: "path", Aliases: []string{"p"}, Value: "", Usage: "Project base path."}, &cli.StringFlag{Name: "name", Aliases: []string{"n"}, Value: "", Usage: "Run a project by its name."}, &cli.BoolFlag{Name: "test", Aliases: []string{"t"}, Value: false, Usage: "Enable go test."}, &cli.BoolFlag{Name: "generate", Aliases: []string{"g"}, Value: false, Usage: "Enable go generate."}, &cli.BoolFlag{Name: "build", Aliases: []string{"b"}, Value: false, Usage: "Enable go build."}, &cli.BoolFlag{Name: "legacy", Aliases: []string{"l"}, Value: false, Usage: "Watch by polling instead of Watch by fsnotify."}, &cli.BoolFlag{Name: "server", Aliases: []string{"s"}, Value: false, Usage: "Enable server and open into the default browser."}, &cli.BoolFlag{Name: "open", Aliases: []string{"o"}, Value: false, Usage: "Open server directly in the default browser."}, &cli.BoolFlag{Name: "no-run", Aliases: []string{"nr"}, Value: false, Usage: "Disable go run"}, &cli.BoolFlag{Name: "no-install", Aliases: []string{"ni"}, Value: false, Usage: "Disable go install"}, &cli.BoolFlag{Name: "no-config", Aliases: []string{"nc"}, Value: false, Usage: "Ignore existing configurations."}, }, Action: func(p *cli.Context) error { polling(p, &r.Config.Legacy) noconf(p, &r.Settings.Config) if err := insert(p, &r.Blueprint); err != nil { return err } if err := r.Server.Start(p); err != nil { return err } if err := r.Blueprint.Run(p); err != nil { return err } if r.Config.Create { if err := r.Record(r); err != nil { return err } } return nil }, Before: before, }, { Name: "add", Category: "Configuration", Aliases: []string{"a"}, Description: "Add a project to an existing config file or create a new one.", Flags: []cli.Flag{ &cli.StringFlag{Name: "path", Aliases: []string{"p"}, Value: "", Usage: "Project base path."}, &cli.BoolFlag{Name: "test", Aliases: []string{"t"}, Value: false, Usage: "Enable go test."}, &cli.BoolFlag{Name: "generate", Aliases: []string{"g"}, Value: false, Usage: "Enable go generate."}, &cli.BoolFlag{Name: "build", Aliases: []string{"b"}, Value: false, Usage: "Enable go build."}, &cli.BoolFlag{Name: "legacy", Aliases: []string{"l"}, Value: false, Usage: "Watch by polling instead of Watch by fsnotify."}, &cli.BoolFlag{Name: "server", Aliases: []string{"s"}, Value: false, Usage: "Enable server and open into the default browser."}, &cli.BoolFlag{Name: "no-run", Aliases: []string{"nr"}, Value: false, Usage: "Disable go run"}, &cli.BoolFlag{Name: "no-fmt", Aliases: []string{"nf"}, Value: false, Usage: "Disable go fmt."}, &cli.BoolFlag{Name: "no-install", Aliases: []string{"ni"}, Value: false, Usage: "Disable go install"}, &cli.BoolFlag{Name: "no-config", Aliases: []string{"nc"}, Value: false, Usage: "Ignore existing configurations."}, }, Action: func(p *cli.Context) error { if err := r.Blueprint.Add(p); err != nil { return err } if err := r.Record(r); err != nil { return err } fmt.Fprintln(style.Output, prefix(style.Green.Bold("Your project was successfully added."))) return nil }, Before: before, }, { Name: "init", Category: "Configuration", Aliases: []string{"a"}, Description: "Define a new config file with all options step by step", Action: func(p *cli.Context) (actErr error) { interact.Run(&interact.Interact{ Before: func(context interact.Context) error { context.SetErr(style.Red.Bold("INVALID INPUT")) context.SetPrfx(color.Output, style.Yellow.Bold("[")+"REALIZE"+style.Yellow.Bold("]")) return nil }, Questions: []*interact.Question{ { Before: func(d interact.Context) error { if _, err := os.Stat(directory + "/" + config); err != nil { d.Skip() } d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Would you want to overwrite the existing " + style.Magenta.Bold("Realize") + " config?", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } else if val { r.Settings = settings.Settings{ Config: settings.Config{ Create: true, }, Resources: settings.Resources{ Config: config, }, Server: settings.Server{ Status: false, Open: false, Host: host, Port: port, }, } r.Blueprint.Projects = r.Blueprint.Projects[len(r.Blueprint.Projects):] } return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Would you want to customize the " + ("settings") + "?", Resolve: func(d interact.Context) bool { val, _ := d.Ans().Bool() return val }, }, Subs: []*interact.Question{ { Before: func(d interact.Context) error { d.SetDef(0, style.Green.Regular("(os default)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[int]"), Msg: "Max number of open files (root required)", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Int() if err != nil { return d.Err() } r.Config.Flimit = val return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Enable legacy watch by polling", Resolve: func(d interact.Context) bool { val, _ := d.Ans().Bool() return val }, }, Subs: []*interact.Question{ { Before: func(d interact.Context) error { d.SetDef(1, style.Green.Regular("(1s)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[seconds]"), Msg: "Set polling interval in seconds", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Int() if err != nil { return d.Err() } r.Config.Legacy.Interval = time.Duration(val * 1000000000) return nil }, }, }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } r.Config.Legacy.Status = val return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Enable web server", Resolve: func(d interact.Context) bool { val, _ := d.Ans().Bool() return val }, }, Subs: []*interact.Question{ { Before: func(d interact.Context) error { d.SetDef(5001, style.Green.Regular("(5001)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[int]"), Msg: "Server port", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Int() if err != nil { return d.Err() } r.Server.Port = int(val) return nil }, }, { Before: func(d interact.Context) error { d.SetDef("localhost", style.Green.Regular("(localhost)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[string]"), Msg: "Server host", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().String() if err != nil { return d.Err() } r.Server.Host = val return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Open in the current browser", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } r.Server.Open = val return nil }, }, }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } r.Server.Status = val return nil }, }, }, Action: func(d interact.Context) interface{} { _, err := d.Ans().Bool() if err != nil { return d.Err() } return nil }, }, { Before: func(d interact.Context) error { d.SetDef(true, style.Green.Regular("(y)")) d.SetEnd("!") return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Would you want to " + style.Magenta.Regular("add a new project") + "? (insert '!' to stop)", Resolve: func(d interact.Context) bool { val, _ := d.Ans().Bool() if val { r.Blueprint.Add(p) } return val }, }, Subs: []*interact.Question{ { Before: func(d interact.Context) error { d.SetDef(r.Settings.Wdir(), style.Green.Regular("("+r.Settings.Wdir()+")")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[string]"), Msg: "Project name", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().String() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Name = val return nil }, }, { Before: func(d interact.Context) error { dir, _ := os.Getwd() d.SetDef(dir, style.Green.Regular("("+dir+")")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[string]"), Msg: "Project path", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().String() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Path = r.Settings.Path(val) return nil }, }, { Before: func(d interact.Context) error { d.SetDef(true, style.Green.Regular("(y)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Enable go fmt", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Cmds.Fmt = val return nil }, }, { Before: func(d interact.Context) error { d.SetDef(true, style.Green.Regular("(y)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Enable go vet", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Cmds.Vet = val return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Enable go test", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Cmds.Test = val return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Enable go generate", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Cmds.Generate = val return nil }, }, { Before: func(d interact.Context) error { d.SetDef(true, style.Green.Regular("(y)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Enable go install", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Cmds.Bin.Status = val return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Enable go build", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Cmds.Build.Status = val return nil }, }, { Before: func(d interact.Context) error { d.SetDef(true, style.Green.Regular("(y)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Enable go run", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Cmds.Run = val return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Customize watched paths", Resolve: func(d interact.Context) bool { val, _ := d.Ans().Bool() if val { r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Paths = r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Paths[:len(r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Paths)-1] } return val }, }, Subs: []*interact.Question{ { Before: func(d interact.Context) error { d.SetEnd("!") return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[string]"), Msg: "Insert a path to watch (insert '!' to stop)", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().String() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Paths = append(r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Paths, val) d.Reload() return nil }, }, }, Action: func(d interact.Context) interface{} { _, err := d.Ans().Bool() if err != nil { return d.Err() } return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Customize ignored paths", Resolve: func(d interact.Context) bool { val, _ := d.Ans().Bool() if val { r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Ignore = r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Ignore[:len(r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Ignore)-1] } return val }, }, Subs: []*interact.Question{ { Before: func(d interact.Context) error { d.SetEnd("!") return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[string]"), Msg: "Insert a path to ignore (insert '!' to stop)", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().String() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Ignore = append(r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Ignore, val) d.Reload() return nil }, }, }, Action: func(d interact.Context) interface{} { _, err := d.Ans().Bool() if err != nil { return d.Err() } return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Add additionals arguments", Resolve: func(d interact.Context) bool { val, _ := d.Ans().Bool() return val }, }, Subs: []*interact.Question{ { Before: func(d interact.Context) error { d.SetEnd("!") return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[string]"), Msg: "Insert an argument (insert '!' to stop)", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().String() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Args = append(r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Args, val) d.Reload() return nil }, }, }, Action: func(d interact.Context) interface{} { _, err := d.Ans().Bool() if err != nil { return d.Err() } return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Add 'before' custom commands", Resolve: func(d interact.Context) bool { val, _ := d.Ans().Bool() return val }, }, Subs: []*interact.Question{ { Before: func(d interact.Context) error { d.SetEnd("!") return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[string]"), Msg: "Insert a command (insert '!' to stop)", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().String() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Scripts = append(r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Scripts, watcher.Command{Type: "before", Command: val}) d.Reload() return nil }, }, }, Action: func(d interact.Context) interface{} { _, err := d.Ans().Bool() if err != nil { return d.Err() } return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Add 'after' custom commands", Resolve: func(d interact.Context) bool { val, _ := d.Ans().Bool() return val }, }, Subs: []*interact.Question{ { Before: func(d interact.Context) error { d.SetEnd("!") return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[string]"), Msg: "Insert a command (insert '!' to stop)", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().String() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Scripts = append(r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Scripts, watcher.Command{Type: "after", Command: val}) d.Reload() return nil }, }, }, Action: func(d interact.Context) interface{} { _, err := d.Ans().Bool() if err != nil { return d.Err() } return nil }, }, { Before: func(d interact.Context) error { d.SetDef(false, style.Green.Regular("(n)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[y/n]"), Msg: "Enable watcher files preview", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().Bool() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].Watcher.Preview = val return nil }, }, { Before: func(d interact.Context) error { d.SetDef("", style.Green.Regular("(none)")) return nil }, Quest: interact.Quest{ Options: style.Yellow.Regular("[string]"), Msg: "Set an error output pattern", }, Action: func(d interact.Context) interface{} { val, err := d.Ans().String() if err != nil { return d.Err() } r.Blueprint.Projects[len(r.Blueprint.Projects)-1].ErrorOutputPattern = val return nil }, }, }, Action: func(d interact.Context) interface{} { if val, err := d.Ans().Bool(); err != nil { return d.Err() } else if val { d.Reload() } return nil }, }, }, After: func(d interact.Context) error { if val, _ := d.Qns().Get(0).Ans().Bool(); val { actErr = r.Settings.Remove(directory) if actErr != nil { return actErr } } return nil }, }) if err := r.Record(r); err != nil { return err } fmt.Fprintln(style.Output, prefix(style.Green.Bold("Your configuration was successful."))) return nil }, Before: before, }, { Name: "remove", Category: "Configuration", Aliases: []string{"r"}, Description: "Remove a project from a realize configuration.", Flags: []cli.Flag{ &cli.StringFlag{Name: "name", Aliases: []string{"n"}, Value: ""}, }, Action: func(p *cli.Context) error { if err := r.Blueprint.Remove(p); err != nil { return err } if err := r.Record(r); err != nil { return err } fmt.Fprintln(style.Output, prefix(style.Green.Bold("Your project was successfully removed."))) return nil }, Before: before, }, { Name: "list", Category: "Configuration", Aliases: []string{"l"}, Description: "Print projects list.", Action: func(p *cli.Context) error { return r.Blueprint.List() }, Before: before, }, { Name: "clean", Category: "Configuration", Aliases: []string{"c"}, Description: "Remove realize folder.", Action: func(p *cli.Context) error { if err := r.Settings.Remove(directory); err != nil { return err } fmt.Fprintln(style.Output, prefix(style.Green.Bold("Realize folder successfully removed."))) return nil }, Before: before, }, }, } if err := app.Run(os.Args); err != nil { print(style.Red.Bold(err)) os.Exit(1) } } // Prefix a given string func prefix(s string) string { if s != "" { return fmt.Sprint(style.Yellow.Bold("[")+"REALIZE"+style.Yellow.Bold("]"), s) } return "" } // Before is launched before each command func before(*cli.Context) error { // Before of every exec of a cli method gopath := os.Getenv("GOPATH") if gopath == "" { return errors.New("$GOPATH isn't set properly") } r = realize{ Sync: make(chan string), Settings: settings.Settings{ Config: settings.Config{ Create: true, }, Resources: settings.Resources{ Config: config, }, Server: settings.Server{ Status: false, Open: false, Host: host, Port: port, }, }, } r.Blueprint = watcher.Blueprint{ Settings: &r.Settings, Sync: r.Sync, } r.Server = server.Server{ Blueprint: &r.Blueprint, Settings: &r.Settings, Sync: r.Sync, } r.Projects = &r.Blueprint.Projects // read if exist r.Read(&r) // increase the file limit if r.Config.Flimit != 0 { if err := r.Flimit(); err != nil { return err } } return nil } // Check for the noconf option func noconf(c *cli.Context, s *settings.Config) { if c.Bool("no-config") { s.Create = false } } // Check for polling option func polling(c *cli.Context, s *settings.Legacy) { if c.Bool("legacy") { s.Status = c.Bool("legacy") s.Interval = interval } } // Insert a project if there isn't already one func insert(c *cli.Context, b *watcher.Blueprint) error { if len(b.Projects) <= 0 { if err := b.Add(c); err != nil { return err } } return nil }