tmp

cmd/configui/main.go

@@ -36,7 +36,7 @@ func init() {
 	flag.StringVar(&flagAction, "c", "", "cmd to apply")
 	flag.StringVar(&flagLogFile, "log", "", "log to file")
 	flag.StringVar(&flagAllow, "allow", "", "IPs to allow, blank to allow all")
-	flag.StringVar(&flagBind, "bind", "0.0.0.0:8000", "address to bind")
+	flag.StringVar(&flagBind, "bind", "127.0.0.1:8000", "address to bind")
 	flag.BoolVar(&flagNoReconfig, "static", false, "disable config api")
 	flag.BoolVar(&flagVer, "v", false, "show version")
 	flag.Usage = func() {

configui.go

@@ -8,6 +8,7 @@ import (
 	"html/template"
 	"os"
 	"path/filepath"
+	"runtime"
 	"strings"
 	"sync"
 	"time"
@@ -17,8 +18,9 @@ import (
 	"kumoly.io/tools/configui/public"
 )
 
-var UNIX_SHELL = "/usr/bin/sh"
-var WIN_SHELL = "C:\\Windows\\System32\\cmd"
+const UNIX_SHELL = "/usr/bin/sh"
+const WIN_SHELL = "C:\\Windows\\System32\\cmd"
+const DARWIN_SHELL = "/bin/bash"
 
 const version = "v0.1.12"
 
@@ -38,10 +40,9 @@ type Action struct {
 	Name string `json:"name"`
 	Cmd  string `json:"cmd"`
 	Dir  string `json:"dir"`
-	Args []string `json:"args"`
-	Envs []string `json:"envs"`
 
 	run chan struct{} `json:"-"`
+	pid int
 }
 
 type Integration struct {
@@ -56,6 +57,7 @@ type ConfigUI struct {
 	Prod       bool   `json:"production"`
 	BaseUrl    string `json:"base_url"`
 	ConfigPath string `json:"config_path"`
+	SHELL      string `json:"shell"`
 
 	NoReconfig bool   `json:"no_reconfig"`
 	AllowIP    string `json:"allow_ip"`
@@ -75,7 +77,8 @@ type ConfigUI struct {
 	LogLevel klog.Llevel `json:"log_level"`
 
 	// Running commands
-	Onitachi map[string]*Oni `json:"-"`
+	Onitachi []*Oni         `json:"onitachi"`
+	oniIndex map[string]int `json:"-"`
 
 	TmplFS     embed.FS `json:"-"`
 	tmpl       *engine.Engine
@@ -98,9 +101,43 @@ func New() *ConfigUI {
 		"normal": func(name string) string {
 			return strings.ReplaceAll(name, " ", "-")
 		},
+		"state_class": func(state State) string {
+			switch state {
+			case STARTED:
+				return "is-success"
+			case ERROR:
+				return "is-danger"
+			case ENDED:
+				return "has-background-grey-light"
+			default:
+				return ""
+			}
+		},
+		"state_icon": func(state State) string {
+			switch state {
+			case STARTED:
+				return "play_arrow"
+			case ERROR:
+				return "error"
+			case ENDED:
+				return "stop"
+			default:
+				return "pending"
+			}
+		},
 	}).ParseFS(tmplFS, "templates/*.tmpl", "templates/**/*.tmpl"))
+	sh := ""
+	switch runtime.GOOS {
+	case "darwin":
+		sh = DARWIN_SHELL
+	case "windows":
+		sh = WIN_SHELL
+	default:
+		sh = UNIX_SHELL
+	}
 	return &ConfigUI{
 		fileIndex:  map[string]int{},
+		SHELL:      sh,
 		Prod:       true,
 		AppName:    "ConfigUI",
 		BaseUrl:    "/",
@@ -112,7 +149,7 @@ func New() *ConfigUI {
 		cmdTimeout: time.Second * 10,
 		LogLevel:   klog.Lerror | klog.Linfo,
 		log:        klog.Sub("ConfigUI"),
-		Onitachi:   make(map[string]*Oni),
+		oniIndex:   make(map[string]int),
 	}
 }
 
@@ -155,6 +192,28 @@ func (cui *ConfigUI) LoadConfig(confstr string) error {
 		}
 	}
 
+	// construct oni
+	for _, o := range tmpConf.Onitachi {
+		if o.Cmd == "" {
+			continue
+		}
+		if o.Name == "" {
+			o.Name = o.Cmd
+		}
+		// update if exist
+		j, ok := cui.oniIndex[o.Name]
+		if ok {
+			cui.Onitachi[j].Cmd = o.Cmd
+			cui.Onitachi[j].Args = o.Args
+			cui.Onitachi[j].Envs = o.Envs
+			cui.Onitachi[j].Dir = o.Dir
+			cui.Onitachi[j].Policy = o.Policy
+		} else {
+			cui.oniIndex[o.Name] = len(cui.Onitachi)
+			cui.Onitachi = append(cui.Onitachi, o)
+		}
+	}
+
 	// copy
 	cui.configLock.Lock()
 	defer cui.configLock.Unlock()
@@ -167,6 +226,7 @@ func (cui *ConfigUI) LoadConfig(confstr string) error {
 	cui.HideConfig = tmpConf.HideConfig
 	cui.NoReconfig = tmpConf.NoReconfig
 	cui.ResultBellow = tmpConf.ResultBellow
+	cui.SHELL = tmpConf.SHELL
 
 	cui.Actions = tmpConf.Actions
 	for i := range cui.Actions {

errors.go

@@ -15,7 +15,7 @@ var ErrorOniHasNoPID = ksrv.Error{
 var ErrorOniNotStarted = ksrv.Error{
 	Code: http.StatusConflict,
 	ID:   "ErrorOniNotStarted",
-	Message: "oni hasn't start",
+	Tmpl: "%s hasn't start",
 }
 
 var ErrorOniHasStarted = ksrv.Error{
@@ -27,7 +27,7 @@ var ErrorOniHasStarted = ksrv.Error{
 var ErrorOniNotFound = ksrv.Error{
 	Code: http.StatusNotFound,
 	ID:   "ErrorOniNotFound",
-	Message: "oni not found",
+	Tmpl: "%s not found",
 }
 
 var ErrorOniNotValid = ksrv.Error{

file.go

@@ -58,7 +58,7 @@ func (f *File) Write(data []byte) error {
 	return os.WriteFile(f.Path, data, info.Mode())
 }
 
-func (f *File) Do(CmdTimeout time.Duration) (string, error) {
+func (f *File) Do(CmdTimeout time.Duration, report chan int) (string, error) {
 	if f.Cmd == "" {
 		return "", nil
 	}
@@ -80,9 +80,9 @@ func (f *File) Do(CmdTimeout time.Duration) (string, error) {
 	// prepare cmd
 	cmd := &exec.Cmd{}
 	if runtime.GOOS == "windows" {
-		cmd = exec.Command(WIN_SHELL, "/c", f.Cmd)
+		cmd = exec.Command(f.owner.SHELL, "/c", f.Cmd)
 	} else {
-		cmd = exec.Command(UNIX_SHELL, "-c", f.Cmd)
+		cmd = exec.Command(f.owner.SHELL, "-c", f.Cmd)
 	}
 	f.owner.log.Info("DO: ", f.Cmd)
 	done := make(chan string, 1)
@@ -96,6 +96,7 @@ func (f *File) Do(CmdTimeout time.Duration) (string, error) {
 	}
 	go func() {
 		f.pid = cmd.Process.Pid
+		report <- cmd.Process.Pid
 		cmd.Wait()
 		done <- b.String()
 	}()

go.mod

@@ -10,4 +10,5 @@ require (
 require (
 	github.com/mattn/go-isatty v0.0.14 // indirect
 	golang.org/x/sys v0.0.0-20211103235746-7861aae1554b // indirect
+	kumoly.io/lib/stat v0.0.1 // indirect
 )

go.sum

@@ -10,3 +10,5 @@ kumoly.io/lib/ksrv v0.0.1 h1:JfWwJ9GeiTtDfGoeG7YxJwsckralbhsLKEPLQb20Uzo=
 kumoly.io/lib/ksrv v0.0.1/go.mod h1:ykHXeAPjNvA5jEZo5rp32edzkugLf0e+2pspct3FOFQ=
 kumoly.io/lib/ksrv v0.0.2-0.20211112060911-0d61b343a298 h1:0raqoIXmNpD6s1SrJbieAyIIkDyhe+aqfaXvx8wenrI=
 kumoly.io/lib/ksrv v0.0.2-0.20211112060911-0d61b343a298/go.mod h1:pwd+NspxnoxPJAETRY2V4i2qZc+orKLxvWzGUBiqBW8=
+kumoly.io/lib/stat v0.0.1 h1:Ck596El7Ixk7GZyzQq/86F1YCl7iYffHmzEdFx1sSRM=
+kumoly.io/lib/stat v0.0.1/go.mod h1:zqMV9q4TC94VGbpDn/mGBTwRNWBVWlVg1taLlCBAWc8=

handler.go

@@ -121,7 +121,7 @@ func (cui *ConfigUI) Apply(w http.ResponseWriter, r *http.Request) {
 		ksrv.Response(w, 404, []byte("file not found"))
 		return
 	}
-	result, err := file.Do(cui.cmdTimeout)
+	result, err := file.Do(cui.cmdTimeout, make(chan int))
 	if err != nil {
 		panic(err)
 	}
@@ -141,23 +141,20 @@ func (cui *ConfigUI) DoAction(w http.ResponseWriter, r *http.Request) {
 			case cui.Actions[i].run <- struct{}{}:
 				defer func() { <-cui.Actions[i].run }()
 			default:
-				panic(fmt.Errorf("another task of %s is running with", name))
+				panic(fmt.Errorf("another task of %s is running with pid: %d", name, v.pid))
 			}
 
-			oni, ok := cui.Onitachi[name]
-			if !ok {
-				oni = NewOni(name, cui)
-				oni.Cmd = cui.Actions[i].Cmd
-				oni.Args = cui.Actions[i].Args
-				oni.Envs = cui.Actions[i].Envs
-				oni.Dir = cui.Actions[i].Dir
-				cui.Onitachi[name] = oni
-			}
-			err := oni.Start()
+			file := &File{Name: name, Cmd: v.Cmd, owner: cui}
+			pid := make(chan int)
+			go func() {
+				cui.Actions[i].pid = <-pid
+			}()
+			result, err := file.Do(cui.cmdTimeout, pid)
 			if err != nil {
 				panic(err)
 			}
-			w.Write([]byte("ok"))
+			w.Write([]byte(result))
+
 			return
 		}
 	}
@@ -199,8 +196,8 @@ func (cui *ConfigUI) Download(w http.ResponseWriter, r *http.Request) {
 				panic(err)
 			}
 			w.Header().Set(
-				"Content-Disposition", `
-				attachment; filename="`+cui.AppName+`.json"`,
+				"Content-Disposition",
+				`attachment; filename="`+cui.AppName+`.json"`,
 			)
 			w.Write(data)
 			return
@@ -263,6 +260,53 @@ func (cui *ConfigUI) GetConfig(w http.ResponseWriter, r *http.Request) {
 	w.Write(data)
 }
 
-func (cui *ConfigUI) GetRunning(w http.ResponseWriter, r *http.Request) {
+func (cui *ConfigUI) GetOni(w http.ResponseWriter, r *http.Request) {
+	name := r.URL.Query().Get("name")
+	if name == "" {
 		ksrv.JSON(w, cui.Onitachi)
+		return
+	}
+	i, ok := cui.oniIndex[name]
+	if !ok {
+		panic(ErrorOniNotFound.New(name))
+	}
+	oni := cui.Onitachi[i]
+	ksrv.JSON(w, oni)
+}
+
+func (cui *ConfigUI) OniStart(w http.ResponseWriter, r *http.Request) {
+	name := r.URL.Query().Get("name")
+	i, ok := cui.oniIndex[name]
+	if !ok {
+		panic(ErrorOniNotFound.New(name))
+	}
+	oni := cui.Onitachi[i]
+	switch oni.State {
+	case "":
+		oni.Init(cui)
+	case STARTED:
+		panic(ErrorOniHasStarted)
+	}
+	err := oni.Start()
+	if err != nil {
+		panic(err)
+	}
+	w.Write([]byte("ok"))
+}
+
+func (cui *ConfigUI) OniStop(w http.ResponseWriter, r *http.Request) {
+	name := r.URL.Query().Get("name")
+	i, ok := cui.oniIndex[name]
+	if !ok {
+		panic(ErrorOniNotFound.New(name))
+	}
+	oni := cui.Onitachi[i]
+	switch oni.State {
+	case STARTED:
+		oni.Stop()
+	default:
+		panic(ErrorOniNotStarted.New(name))
+	}
+	oni.Start()
+	w.Write([]byte("ok"))
 }

muzan.go

@@ -44,31 +44,28 @@ type Oni struct {
 
 	parent  *ConfigUI
 	cmd     *exec.Cmd
-	start  chan struct{}
+	running chan struct{}
 	buff    bytes.Buffer
 	log     io.Writer
 
 	listeners []io.Writer
 }
 
-func NewOni(name string, cui *ConfigUI) *Oni {
+func (oni *Oni) Init(cui *ConfigUI) error {
 	var err error
-	oni := &Oni{
-		Policy:    NO,
-		State:     READY,
-		parent:    cui,
-		start:     make(chan struct{}, 1),
-		listeners: make([]io.Writer, 0),
-	}
+	oni.parent = cui
+	oni.running = make(chan struct{}, 1)
+	oni.listeners = make([]io.Writer, 0)
+	oni.StateChange(READY)
 	if cui.LogPath != "" {
-		logpath := filepath.Join(filepath.Dir(cui.LogPath), name+".log")
+		logpath := filepath.Join(filepath.Dir(cui.LogPath), oni.Name+".log")
 		oni.LogFile = logpath
 		oni.log, err = os.OpenFile(logpath, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666)
 		if err != nil {
-			panic(err)
+			return err
 		}
 	}
-	return oni
+	return err
 }
 
 func (oni *Oni) Start() error {
@@ -76,7 +73,7 @@ func (oni *Oni) Start() error {
 		return ErrorOniNotValid
 	}
 	select {
-	case oni.start <- struct{}{}:
+	case oni.running <- struct{}{}:
 		defer func() {
 			err := recover()
 			if err != nil {
@@ -105,7 +102,7 @@ func (oni *Oni) Start() error {
 	}
 	go oni.read()
 	oni.PID = cmd.Process.Pid
-	oni.State = STARTED
+	oni.StateChange(STARTED)
 	go func() {
 		oni.end(cmd.Wait())
 	}()
@@ -122,13 +119,13 @@ func (oni *Oni) Stop() error {
 
 func (oni *Oni) end(v interface{}) {
 	if v == nil {
-		oni.State = ENDED
+		oni.StateChange(ENDED)
 	} else {
 		oni.Error = fmt.Sprint(v)
-		oni.State = ERROR
+		oni.StateChange(ERROR)
 	}
-	if len(oni.start) == 1 {
-		<-oni.start
+	if len(oni.running) == 1 {
+		<-oni.running
 	}
 }
 
@@ -144,3 +141,12 @@ func (oni *Oni) read() {
 		}
 	}()
 }
+
+func (oni *Oni) StateChange(state State) {
+	oni.State = state
+	// for i := range oni.parent.Actions {
+	// 	if oni.parent.Actions[i].Name == oni.Name {
+	// 		oni.parent.Actions[i].State = state
+	// 	}
+	// }
+}

package.json

@@ -17,10 +17,6 @@
   "dependencies": {
     "@creativebulma/bulma-tooltip": "^1.2.0",
     "bulma": "^0.9.3",
-    "prismjs": "^1.25.0",
     "sass": "^1.43.2"
-  },
-  "devDependencies": {
-    "parcel": "^2.0.0"
   }
 }

server.go

@@ -5,6 +5,7 @@ import (
 	"strings"
 
 	"kumoly.io/lib/ksrv"
+	"kumoly.io/lib/stat"
 )
 
 func (cui *ConfigUI) ServeHTTP(w http.ResponseWriter, r *http.Request) {
@@ -98,9 +99,30 @@ func (cui *ConfigUI) mux() *http.ServeMux {
 			w.WriteHeader(404)
 		}
 	})
-	cuiR.HandleFunc("/api/running", func(w http.ResponseWriter, r *http.Request) {
+	cuiR.HandleFunc("/api/profile", func(w http.ResponseWriter, r *http.Request) {
 		if r.Method == "GET" {
-			cui.GetRunning(w, r)
+			ksrv.JSON(w, stat.GetProfile())
+		} else {
+			w.WriteHeader(404)
+		}
+	})
+	cuiR.HandleFunc("/api/oni", func(w http.ResponseWriter, r *http.Request) {
+		if r.Method == "GET" {
+			cui.GetOni(w, r)
+		} else {
+			w.WriteHeader(404)
+		}
+	})
+	cuiR.HandleFunc("/api/oni/start", func(w http.ResponseWriter, r *http.Request) {
+		if r.Method == "POST" {
+			cui.OniStart(w, r)
+		} else {
+			w.WriteHeader(404)
+		}
+	})
+	cuiR.HandleFunc("/api/oni/stop", func(w http.ResponseWriter, r *http.Request) {
+		if r.Method == "POST" {
+			cui.OniStart(w, r)
 		} else {
 			w.WriteHeader(404)
 		}

templates/action.tmpl

@@ -0,0 +1,7 @@
+{{define "action"}}
+{{template "base/header" .}}
+{{template "components/error" .}}
+
+
+{{template "base/footer" .}}
+{{end}}

templates/base/nav.tmpl

@@ -14,6 +14,7 @@
   </div>
 
   <div id="navbarBasicExample" class="navbar-menu">
+    {{/*
     <div class="navbar-start">
       {{if .Actions}}
       <a class="navbar-item">
@@ -27,7 +28,6 @@
       {{end}}
     </div>
 
-    {{/*
     <div class="navbar-end">
       <div class="navbar-item">
         <div class="buttons">
@@ -44,6 +44,7 @@
   </div>
 </nav>
 
+{{/* not having pages
 <script>
 document.addEventListener('DOMContentLoaded', () => {
 
@@ -70,5 +71,6 @@ document.addEventListener('DOMContentLoaded', () => {
   }
 
 });
+*/}}
 </script>
 {{end}}

templates/components/menu.tmpl

@@ -14,6 +14,24 @@
       </li>
       {{ end }}
     </ul>
+    {{/* {{if .Actions}}
+    <p class="menu-label">
+      Actions
+    </p>
+    <ul class="menu-list">
+      {{- range .Actions -}}
+      <li>
+        <a class="button has-tooltip-arrow {{.State|state_class}}" id="actbtn-{{.Name|normal}}"
+          data-tooltip="{{.Cmd}}" onclick="toolDoAction('{{.Name}}')">
+          <span>{{- .Name -}}</span>
+          <span class="icon is-small"><span class="material-icons">
+            {{.State|state_icon}}
+          </span></span>
+        </a>
+      </li>
+      {{- end -}}
+    </ul>
+    {{end}} */}}
     {{if not .HideConfig}}
     <p class="menu-label">
       System