Compare commits
7 Commits
b0d76dff3e
...
621c720767
Author | SHA1 | Date |
---|---|---|
Evan Chen | 621c720767 | |
Evan Chen | 733dada3fe | |
Evan Chen | 556f673b3e | |
Evan | f039033077 | |
Evan Chen | 2ecac19807 | |
Evan Chen | 56841cc8be | |
Evan Chen | 31c141b6f9 |
43
app.go
43
app.go
|
@ -27,6 +27,7 @@ type Page struct {
|
||||||
BaseUrl string
|
BaseUrl string
|
||||||
Actions []Action
|
Actions []Action
|
||||||
Integrations []*Integration
|
Integrations []*Integration
|
||||||
|
Onitachi map[string]*Oni
|
||||||
Version string
|
Version string
|
||||||
Build string
|
Build string
|
||||||
Files []ActiveFile
|
Files []ActiveFile
|
||||||
|
@ -79,6 +80,7 @@ func (cui *ConfigUI) App(w http.ResponseWriter, r *http.Request) {
|
||||||
},
|
},
|
||||||
Actions: cui.Actions,
|
Actions: cui.Actions,
|
||||||
Integrations: cui.Integrations,
|
Integrations: cui.Integrations,
|
||||||
|
Onitachi: cui.Onitachi,
|
||||||
Static: cui.NoReconfig,
|
Static: cui.NoReconfig,
|
||||||
HideConfig: cui.HideConfig,
|
HideConfig: cui.HideConfig,
|
||||||
ResultBellow: cui.ResultBellow,
|
ResultBellow: cui.ResultBellow,
|
||||||
|
@ -127,3 +129,44 @@ func (cui *ConfigUI) App(w http.ResponseWriter, r *http.Request) {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (cui *ConfigUI) Program(w http.ResponseWriter, r *http.Request) {
|
||||||
|
Files := []ActiveFile{}
|
||||||
|
for _, i := range cui.fileIndex {
|
||||||
|
Files = append(Files, ActiveFile{
|
||||||
|
Name: cui.Files[i].Name,
|
||||||
|
Path: cui.Files[i].Path,
|
||||||
|
Order: cui.Files[i].Order,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
sort.Slice(Files, func(i, j int) bool {
|
||||||
|
if Files[i].Order == Files[j].Order {
|
||||||
|
return Files[i].Name < Files[j].Name
|
||||||
|
}
|
||||||
|
return Files[i].Order < Files[j].Order
|
||||||
|
})
|
||||||
|
plat := "unix"
|
||||||
|
if runtime.GOOS == "windows" {
|
||||||
|
plat = "windows"
|
||||||
|
}
|
||||||
|
data := Page{
|
||||||
|
AppName: cui.AppName,
|
||||||
|
BaseUrl: cui.BaseUrl,
|
||||||
|
File: ActiveFile{},
|
||||||
|
Files: Files,
|
||||||
|
Editor: Editor{
|
||||||
|
Platform: plat,
|
||||||
|
},
|
||||||
|
Actions: cui.Actions,
|
||||||
|
Integrations: cui.Integrations,
|
||||||
|
Onitachi: cui.Onitachi,
|
||||||
|
Static: cui.NoReconfig,
|
||||||
|
HideConfig: cui.HideConfig,
|
||||||
|
Version: version,
|
||||||
|
}
|
||||||
|
|
||||||
|
err := cui.tmpl.ExecuteTemplate(w, "muzan", data)
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
|
@ -36,7 +36,7 @@ func init() {
|
||||||
flag.StringVar(&flagAction, "c", "", "cmd to apply")
|
flag.StringVar(&flagAction, "c", "", "cmd to apply")
|
||||||
flag.StringVar(&flagLogFile, "log", "", "log to file")
|
flag.StringVar(&flagLogFile, "log", "", "log to file")
|
||||||
flag.StringVar(&flagAllow, "allow", "", "IPs to allow, blank to allow all")
|
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(&flagNoReconfig, "static", false, "disable config api")
|
||||||
flag.BoolVar(&flagVer, "v", false, "show version")
|
flag.BoolVar(&flagVer, "v", false, "show version")
|
||||||
flag.Usage = func() {
|
flag.Usage = func() {
|
||||||
|
|
89
configui.go
89
configui.go
|
@ -7,6 +7,7 @@ import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"html/template"
|
"html/template"
|
||||||
"os"
|
"os"
|
||||||
|
"path/filepath"
|
||||||
"runtime"
|
"runtime"
|
||||||
"strings"
|
"strings"
|
||||||
"sync"
|
"sync"
|
||||||
|
@ -39,9 +40,9 @@ type Action struct {
|
||||||
Name string `json:"name"`
|
Name string `json:"name"`
|
||||||
Cmd string `json:"cmd"`
|
Cmd string `json:"cmd"`
|
||||||
Dir string `json:"dir"`
|
Dir string `json:"dir"`
|
||||||
Env []string `json"env,omitempty"`
|
|
||||||
run chan struct{} `json:"-"`
|
run chan struct{} `json:"-"`
|
||||||
pid int `json:"-"`
|
pid int
|
||||||
}
|
}
|
||||||
|
|
||||||
type Integration struct {
|
type Integration struct {
|
||||||
|
@ -75,6 +76,9 @@ type ConfigUI struct {
|
||||||
LogPath string `json:"log_path"`
|
LogPath string `json:"log_path"`
|
||||||
LogLevel klog.Llevel `json:"log_level"`
|
LogLevel klog.Llevel `json:"log_level"`
|
||||||
|
|
||||||
|
// Running commands
|
||||||
|
Onitachi map[string]*Oni `json:"onitachi"`
|
||||||
|
|
||||||
TmplFS embed.FS `json:"-"`
|
TmplFS embed.FS `json:"-"`
|
||||||
tmpl *engine.Engine
|
tmpl *engine.Engine
|
||||||
PublicFS embed.FS `json:"-"`
|
PublicFS embed.FS `json:"-"`
|
||||||
|
@ -96,6 +100,30 @@ func New() *ConfigUI {
|
||||||
"normal": func(name string) string {
|
"normal": func(name string) string {
|
||||||
return strings.ReplaceAll(name, " ", "-")
|
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"))
|
}).ParseFS(tmplFS, "templates/*.tmpl", "templates/**/*.tmpl"))
|
||||||
sh := ""
|
sh := ""
|
||||||
switch runtime.GOOS {
|
switch runtime.GOOS {
|
||||||
|
@ -120,6 +148,7 @@ func New() *ConfigUI {
|
||||||
cmdTimeout: time.Second * 10,
|
cmdTimeout: time.Second * 10,
|
||||||
LogLevel: klog.Lerror | klog.Linfo,
|
LogLevel: klog.Lerror | klog.Linfo,
|
||||||
log: klog.Sub("ConfigUI"),
|
log: klog.Sub("ConfigUI"),
|
||||||
|
Onitachi: make(map[string]*Oni),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -140,6 +169,8 @@ func (cui *ConfigUI) File(file_name string) (*File, error) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cui *ConfigUI) LoadConfig(confstr string) error {
|
func (cui *ConfigUI) LoadConfig(confstr string) error {
|
||||||
|
cui.configLock.Lock()
|
||||||
|
defer cui.configLock.Unlock()
|
||||||
tmpConf := &ConfigUI{}
|
tmpConf := &ConfigUI{}
|
||||||
err := json.Unmarshal([]byte(confstr), tmpConf)
|
err := json.Unmarshal([]byte(confstr), tmpConf)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -162,9 +193,15 @@ func (cui *ConfigUI) LoadConfig(confstr string) error {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// del oni dry run
|
||||||
|
for k, v := range cui.Onitachi {
|
||||||
|
_, ok := tmpConf.Onitachi[k]
|
||||||
|
if !ok && v.State == STARTED {
|
||||||
|
return ErrorNoDeleteRunning.New(k)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// copy
|
// copy
|
||||||
cui.configLock.Lock()
|
|
||||||
defer cui.configLock.Unlock()
|
|
||||||
cui.fileIndex = tmpIndex
|
cui.fileIndex = tmpIndex
|
||||||
cui.Files = tmpConf.Files
|
cui.Files = tmpConf.Files
|
||||||
cui.AllowIP = tmpConf.AllowIP
|
cui.AllowIP = tmpConf.AllowIP
|
||||||
|
@ -174,6 +211,40 @@ func (cui *ConfigUI) LoadConfig(confstr string) error {
|
||||||
cui.HideConfig = tmpConf.HideConfig
|
cui.HideConfig = tmpConf.HideConfig
|
||||||
cui.NoReconfig = tmpConf.NoReconfig
|
cui.NoReconfig = tmpConf.NoReconfig
|
||||||
cui.ResultBellow = tmpConf.ResultBellow
|
cui.ResultBellow = tmpConf.ResultBellow
|
||||||
|
cui.SHELL = tmpConf.SHELL
|
||||||
|
|
||||||
|
cui.log = klog.Sub(cui.AppName)
|
||||||
|
cui.LogLevel = tmpConf.LogLevel
|
||||||
|
if cui.LogLevel == 0 {
|
||||||
|
cui.LogLevel = klog.Lerror | klog.Linfo
|
||||||
|
}
|
||||||
|
klog.LEVEL = cui.LogLevel
|
||||||
|
cui.LogPath = tmpConf.LogPath
|
||||||
|
cui.setLog()
|
||||||
|
|
||||||
|
// construct oni - update existing, del
|
||||||
|
for k, v := range cui.Onitachi {
|
||||||
|
n, ok := tmpConf.Onitachi[k]
|
||||||
|
if !ok {
|
||||||
|
delete(cui.Onitachi, k)
|
||||||
|
} else {
|
||||||
|
v.Name = k
|
||||||
|
v.Cmd = n.Cmd
|
||||||
|
v.Args = n.Args
|
||||||
|
v.Envs = n.Envs
|
||||||
|
v.Dir = n.Dir
|
||||||
|
v.Policy = n.Policy
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// construct oni - append new
|
||||||
|
for k, v := range tmpConf.Onitachi {
|
||||||
|
_, ok := cui.Onitachi[k]
|
||||||
|
if !ok {
|
||||||
|
v.Name = k
|
||||||
|
v.Init(cui)
|
||||||
|
cui.Onitachi[k] = v
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
cui.Actions = tmpConf.Actions
|
cui.Actions = tmpConf.Actions
|
||||||
for i := range cui.Actions {
|
for i := range cui.Actions {
|
||||||
|
@ -201,15 +272,6 @@ func (cui *ConfigUI) LoadConfig(confstr string) error {
|
||||||
cui.cmdTimeout = ct
|
cui.cmdTimeout = ct
|
||||||
}
|
}
|
||||||
|
|
||||||
cui.log = klog.Sub(cui.AppName)
|
|
||||||
|
|
||||||
cui.LogLevel = tmpConf.LogLevel
|
|
||||||
if cui.LogLevel == 0 {
|
|
||||||
cui.LogLevel = klog.Lerror | klog.Linfo
|
|
||||||
}
|
|
||||||
klog.LEVEL = cui.LogLevel
|
|
||||||
cui.LogPath = tmpConf.LogPath
|
|
||||||
cui.setLog()
|
|
||||||
// fmt.Printf("%+v", cui)
|
// fmt.Printf("%+v", cui)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
@ -220,6 +282,7 @@ func (cui *ConfigUI) setLog() {
|
||||||
cui.f.Close()
|
cui.f.Close()
|
||||||
}
|
}
|
||||||
if cui.LogPath != "" {
|
if cui.LogPath != "" {
|
||||||
|
mkdir(filepath.Dir(cui.LogPath))
|
||||||
cui.f, err = os.OpenFile(cui.LogPath, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666)
|
cui.f, err = os.OpenFile(cui.LogPath, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
cui.log.Error(err)
|
cui.log.Error(err)
|
||||||
|
|
42
errors.go
42
errors.go
|
@ -11,3 +11,45 @@ var ErrorServerReloading = ksrv.Error{
|
||||||
ID: "ErrorServerReloading",
|
ID: "ErrorServerReloading",
|
||||||
Message: "server is reloading",
|
Message: "server is reloading",
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var ErrorOniHasNoPID = ksrv.Error{
|
||||||
|
Code: http.StatusBadRequest,
|
||||||
|
ID: "ErrorOniHasNoPID",
|
||||||
|
Message: "oni has no pid",
|
||||||
|
}
|
||||||
|
|
||||||
|
var ErrorOniNotStarted = ksrv.Error{
|
||||||
|
Code: http.StatusConflict,
|
||||||
|
ID: "ErrorOniNotStarted",
|
||||||
|
Tmpl: "%s hasn't start",
|
||||||
|
}
|
||||||
|
|
||||||
|
var ErrorOniHasStarted = ksrv.Error{
|
||||||
|
Code: http.StatusConflict,
|
||||||
|
ID: "ErrorOniHasStarted",
|
||||||
|
Tmpl: "%s has started",
|
||||||
|
}
|
||||||
|
|
||||||
|
var ErrorOniNotFound = ksrv.Error{
|
||||||
|
Code: http.StatusNotFound,
|
||||||
|
ID: "ErrorOniNotFound",
|
||||||
|
Tmpl: "%s not found",
|
||||||
|
}
|
||||||
|
|
||||||
|
var ErrorOniNotValid = ksrv.Error{
|
||||||
|
Code: http.StatusBadRequest,
|
||||||
|
ID: "ErrorOniNotValid",
|
||||||
|
Message: "oni no name or cmd",
|
||||||
|
}
|
||||||
|
|
||||||
|
var ErrorNoDeleteRunning = ksrv.Error{
|
||||||
|
Code: http.StatusBadRequest,
|
||||||
|
ID: "ErrorNoDeleteRunning",
|
||||||
|
Tmpl: "cannot delete running: %s",
|
||||||
|
}
|
||||||
|
|
||||||
|
var ErrorOniNoLog = ksrv.Error{
|
||||||
|
Code: http.StatusNotFound,
|
||||||
|
ID: "ErrorOniNoLog",
|
||||||
|
Tmpl: "%s has no logs",
|
||||||
|
}
|
||||||
|
|
97
handler.go
97
handler.go
|
@ -154,6 +154,7 @@ func (cui *ConfigUI) DoAction(w http.ResponseWriter, r *http.Request) {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
w.Write([]byte(result))
|
w.Write([]byte(result))
|
||||||
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -258,3 +259,99 @@ func (cui *ConfigUI) GetConfig(w http.ResponseWriter, r *http.Request) {
|
||||||
}
|
}
|
||||||
w.Write(data)
|
w.Write(data)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (cui *ConfigUI) GetOni(w http.ResponseWriter, r *http.Request) {
|
||||||
|
name := r.URL.Query().Get("name")
|
||||||
|
if name == "" {
|
||||||
|
ksrv.JSON(w, cui.Onitachi)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
oni, ok := cui.Onitachi[name]
|
||||||
|
if !ok {
|
||||||
|
panic(ErrorOniNotFound.New(name))
|
||||||
|
}
|
||||||
|
ksrv.JSON(w, oni)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (cui *ConfigUI) OniStart(w http.ResponseWriter, r *http.Request) {
|
||||||
|
name := r.URL.Query().Get("name")
|
||||||
|
oni, ok := cui.Onitachi[name]
|
||||||
|
if !ok {
|
||||||
|
panic(ErrorOniNotFound.New(name))
|
||||||
|
}
|
||||||
|
switch oni.State {
|
||||||
|
case "":
|
||||||
|
oni.Init(cui)
|
||||||
|
case STARTED:
|
||||||
|
panic(ErrorOniHasStarted.New(name))
|
||||||
|
}
|
||||||
|
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")
|
||||||
|
oni, ok := cui.Onitachi[name]
|
||||||
|
if !ok {
|
||||||
|
panic(ErrorOniNotFound.New(name))
|
||||||
|
}
|
||||||
|
switch oni.State {
|
||||||
|
case STARTED:
|
||||||
|
err := oni.Stop()
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
default:
|
||||||
|
panic(ErrorOniNotStarted.New(name))
|
||||||
|
}
|
||||||
|
w.Write([]byte("ok"))
|
||||||
|
}
|
||||||
|
|
||||||
|
func (cui *ConfigUI) OniLog(w http.ResponseWriter, r *http.Request) {
|
||||||
|
name := r.URL.Query().Get("name")
|
||||||
|
oni, ok := cui.Onitachi[name]
|
||||||
|
if !ok {
|
||||||
|
panic(ErrorOniNotFound.New(name))
|
||||||
|
}
|
||||||
|
if oni.LogFile == "" {
|
||||||
|
panic(ErrorOniNoLog.New(name))
|
||||||
|
}
|
||||||
|
stat, err := os.Stat(oni.LogFile)
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
data, err := os.ReadFile(oni.LogFile)
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
ksrv.JSON(w, map[string]string{
|
||||||
|
"name": name,
|
||||||
|
"data": string(data),
|
||||||
|
"delta": strconv.Itoa(int(stat.Size())),
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
func (cui *ConfigUI) OniKill(w http.ResponseWriter, r *http.Request) {
|
||||||
|
name := r.URL.Query().Get("name")
|
||||||
|
oni, ok := cui.Onitachi[name]
|
||||||
|
if !ok {
|
||||||
|
panic(ErrorOniNotFound.New(name))
|
||||||
|
}
|
||||||
|
switch oni.State {
|
||||||
|
case STARTED:
|
||||||
|
err := oni.Kill()
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
default:
|
||||||
|
panic(ErrorOniNotStarted.New(name))
|
||||||
|
}
|
||||||
|
w.Write([]byte("ok"))
|
||||||
|
}
|
||||||
|
|
||||||
|
func (cui *ConfigUI) OniAttach(w http.ResponseWriter, r *http.Request) {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
|
@ -0,0 +1,172 @@
|
||||||
|
package configui
|
||||||
|
|
||||||
|
import (
|
||||||
|
"bufio"
|
||||||
|
"bytes"
|
||||||
|
"fmt"
|
||||||
|
"io"
|
||||||
|
"os"
|
||||||
|
"os/exec"
|
||||||
|
"path/filepath"
|
||||||
|
"syscall"
|
||||||
|
)
|
||||||
|
|
||||||
|
type State string
|
||||||
|
|
||||||
|
const (
|
||||||
|
READY State = "ready"
|
||||||
|
ERROR State = "error"
|
||||||
|
STARTED State = "started"
|
||||||
|
ENDED State = "ended"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Policy string
|
||||||
|
|
||||||
|
const (
|
||||||
|
NO Policy = "no"
|
||||||
|
ONFAIL Policy = "on-failure"
|
||||||
|
ALWAYS Policy = "always"
|
||||||
|
UNLESSSTOP Policy = "unless-stopped"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Oni struct {
|
||||||
|
Name string `json:"-"`
|
||||||
|
Cmd string `json:"cmd"`
|
||||||
|
Dir string `json:"dir"`
|
||||||
|
Args []string `json:"args"`
|
||||||
|
Envs []string `json:"envs"`
|
||||||
|
Policy Policy `json:"policy"`
|
||||||
|
|
||||||
|
PID int `json:"pid"`
|
||||||
|
LogFile string `json:"log_file"`
|
||||||
|
State State `json:"state"`
|
||||||
|
Error string `json:"error"`
|
||||||
|
ManStop bool `json:"manual_stop"`
|
||||||
|
|
||||||
|
parent *ConfigUI
|
||||||
|
cmd *exec.Cmd
|
||||||
|
running chan struct{}
|
||||||
|
buff bytes.Buffer
|
||||||
|
log io.Writer
|
||||||
|
|
||||||
|
listeners []io.Writer
|
||||||
|
}
|
||||||
|
|
||||||
|
func (oni *Oni) Init(cui *ConfigUI) {
|
||||||
|
oni.parent = cui
|
||||||
|
oni.running = make(chan struct{}, 1)
|
||||||
|
oni.listeners = make([]io.Writer, 0)
|
||||||
|
oni.StateChange(READY)
|
||||||
|
oni.SetLog()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (oni *Oni) Start() error {
|
||||||
|
if oni.Cmd == "" {
|
||||||
|
return ErrorOniNotValid
|
||||||
|
}
|
||||||
|
select {
|
||||||
|
case oni.running <- struct{}{}:
|
||||||
|
defer func() {
|
||||||
|
err := recover()
|
||||||
|
if err != nil {
|
||||||
|
oni.end(err)
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
default:
|
||||||
|
return ErrorOniHasStarted
|
||||||
|
}
|
||||||
|
var err error
|
||||||
|
cmd := exec.Command(oni.Cmd, oni.Args...)
|
||||||
|
setgpid(cmd)
|
||||||
|
cmd.Env = oni.Envs
|
||||||
|
cmd.Dir = oni.Dir
|
||||||
|
var out io.Writer
|
||||||
|
if oni.LogFile != "" {
|
||||||
|
out = io.MultiWriter(oni.log, &oni.buff)
|
||||||
|
} else {
|
||||||
|
out = &oni.buff
|
||||||
|
}
|
||||||
|
cmd.Stderr = out
|
||||||
|
cmd.Stdout = out
|
||||||
|
oni.cmd = cmd
|
||||||
|
err = oni.cmd.Start()
|
||||||
|
if err != nil {
|
||||||
|
oni.end(err)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
go oni.read()
|
||||||
|
oni.PID = cmd.Process.Pid
|
||||||
|
oni.StateChange(STARTED)
|
||||||
|
go func() {
|
||||||
|
oni.end(cmd.Wait())
|
||||||
|
}()
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (oni *Oni) Stop() error {
|
||||||
|
if oni.cmd == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
return oni.cmd.Process.Signal(syscall.SIGTERM)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (oni *Oni) end(v interface{}) {
|
||||||
|
if v == nil {
|
||||||
|
oni.StateChange(ENDED)
|
||||||
|
} else {
|
||||||
|
oni.Error = fmt.Sprint(v)
|
||||||
|
oni.StateChange(ERROR)
|
||||||
|
}
|
||||||
|
if oni.log != nil {
|
||||||
|
file, ok := oni.log.(*os.File)
|
||||||
|
if ok {
|
||||||
|
file.Close()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if len(oni.running) == 1 {
|
||||||
|
<-oni.running
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (oni *Oni) read() {
|
||||||
|
go func() {
|
||||||
|
scanner := bufio.NewScanner(&oni.buff)
|
||||||
|
for scanner.Scan() {
|
||||||
|
if len(oni.listeners) == 0 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
w := io.MultiWriter(oni.listeners...)
|
||||||
|
w.Write([]byte(scanner.Text()))
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
}
|
||||||
|
|
||||||
|
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
|
||||||
|
// }
|
||||||
|
// }
|
||||||
|
}
|
||||||
|
|
||||||
|
func (oni *Oni) SetLog() error {
|
||||||
|
var err error
|
||||||
|
if oni.log != nil {
|
||||||
|
file, ok := oni.log.(*os.File)
|
||||||
|
if ok {
|
||||||
|
file.Close()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if oni.parent.LogPath != "" {
|
||||||
|
logpath := filepath.Join(filepath.Dir(oni.parent.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 {
|
||||||
|
oni.end(err)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return err
|
||||||
|
}
|
|
@ -0,0 +1,24 @@
|
||||||
|
//go:build !windows
|
||||||
|
// +build !windows
|
||||||
|
|
||||||
|
package configui
|
||||||
|
|
||||||
|
import (
|
||||||
|
"os/exec"
|
||||||
|
"syscall"
|
||||||
|
)
|
||||||
|
|
||||||
|
func setgpid(cmd *exec.Cmd) {
|
||||||
|
cmd.SysProcAttr = &syscall.SysProcAttr{Setpgid: true}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (oni *Oni) Kill() error {
|
||||||
|
if oni.cmd == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
pgid, err := syscall.Getpgid(oni.cmd.Process.Pid)
|
||||||
|
if err == nil {
|
||||||
|
return syscall.Kill(-pgid, 15) // note the minus sign
|
||||||
|
}
|
||||||
|
return oni.cmd.Process.Kill()
|
||||||
|
}
|
|
@ -0,0 +1,13 @@
|
||||||
|
package configui
|
||||||
|
|
||||||
|
import "os/exec"
|
||||||
|
|
||||||
|
func setgpid(cmd *exec.Cmd) {
|
||||||
|
}
|
||||||
|
|
||||||
|
func (oni *Oni) Kill() error {
|
||||||
|
if oni.cmd == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
return oni.cmd.Process.Kill()
|
||||||
|
}
|
60
server.go
60
server.go
|
@ -31,6 +31,9 @@ func (cui *ConfigUI) middleware(next http.Handler) http.Handler {
|
||||||
panic("permission denied")
|
panic("permission denied")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if MutexLocked(&cui.configLock) {
|
||||||
|
panic(ErrorServerReloading)
|
||||||
|
}
|
||||||
next.ServeHTTP(rw, r)
|
next.ServeHTTP(rw, r)
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
|
@ -39,13 +42,6 @@ func (cui *ConfigUI) middleware(next http.Handler) http.Handler {
|
||||||
|
|
||||||
func (cui *ConfigUI) mux() *http.ServeMux {
|
func (cui *ConfigUI) mux() *http.ServeMux {
|
||||||
cuiR := http.NewServeMux()
|
cuiR := http.NewServeMux()
|
||||||
cuiR.HandleFunc("/api/profile", func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
if r.Method == "GET" {
|
|
||||||
ksrv.JSON(w, stat.GetProfile())
|
|
||||||
} else {
|
|
||||||
w.WriteHeader(404)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
cuiR.HandleFunc("/api/conf", func(w http.ResponseWriter, r *http.Request) {
|
cuiR.HandleFunc("/api/conf", func(w http.ResponseWriter, r *http.Request) {
|
||||||
if r.Method == "GET" {
|
if r.Method == "GET" {
|
||||||
cui.GetConfig(w, r)
|
cui.GetConfig(w, r)
|
||||||
|
@ -106,7 +102,57 @@ func (cui *ConfigUI) mux() *http.ServeMux {
|
||||||
w.WriteHeader(404)
|
w.WriteHeader(404)
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
cuiR.HandleFunc("/api/profile", func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if r.Method == "GET" {
|
||||||
|
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.OniStop(w, r)
|
||||||
|
} else {
|
||||||
|
w.WriteHeader(404)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
cuiR.HandleFunc("/api/oni/kill", func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if r.Method == "POST" {
|
||||||
|
cui.OniKill(w, r)
|
||||||
|
} else {
|
||||||
|
w.WriteHeader(404)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
cuiR.HandleFunc("/api/oni/log", func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if r.Method == http.MethodGet {
|
||||||
|
cui.OniLog(w, r)
|
||||||
|
} else {
|
||||||
|
w.WriteHeader(404)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
cuiR.HandleFunc("/api/oni/attach", func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if r.Method == http.MethodGet {
|
||||||
|
cui.OniAttach(w, r)
|
||||||
|
} else {
|
||||||
|
w.WriteHeader(404)
|
||||||
|
}
|
||||||
|
})
|
||||||
cuiR.Handle("/public/", http.StripPrefix("/public/", http.FileServer(http.FS(cui.PublicFS))))
|
cuiR.Handle("/public/", http.StripPrefix("/public/", http.FileServer(http.FS(cui.PublicFS))))
|
||||||
|
cuiR.HandleFunc("/program", cui.Program)
|
||||||
cuiR.HandleFunc("/", cui.App)
|
cuiR.HandleFunc("/", cui.App)
|
||||||
return cuiR
|
return cuiR
|
||||||
}
|
}
|
||||||
|
|
|
@ -3,6 +3,7 @@
|
||||||
|
|
||||||
$modal-content-width: 90vw;
|
$modal-content-width: 90vw;
|
||||||
$footer-padding: 0.5rem 1.5rem 0.5rem;
|
$footer-padding: 0.5rem 1.5rem 0.5rem;
|
||||||
|
// $navbar-z: 0;
|
||||||
|
|
||||||
@import "../node_modules/bulma/bulma.sass";
|
@import "../node_modules/bulma/bulma.sass";
|
||||||
@import "../node_modules/@creativebulma/bulma-tooltip/src/sass/index.sass";
|
@import "../node_modules/@creativebulma/bulma-tooltip/src/sass/index.sass";
|
||||||
|
|
|
@ -6,11 +6,6 @@
|
||||||
</p>
|
</p>
|
||||||
</div>
|
</div>
|
||||||
</footer>
|
</footer>
|
||||||
<script src="{{.BaseUrl}}public/ace/js/ace.js" type="text/javascript" charset="utf-8"></script>
|
|
||||||
<script src="{{.BaseUrl}}public/ace/js/ext-beautify.js" type="text/javascript" charset="utf-8"></script>
|
|
||||||
<script src="{{.BaseUrl}}public/ace/js/ext-searchbox.js" type="text/javascript" charset="utf-8"></script>
|
|
||||||
{{template "base/script" .}}
|
|
||||||
<!-- <script src="/public/js/main.js"></script> -->
|
|
||||||
</body>
|
</body>
|
||||||
</html>
|
</html>
|
||||||
{{end}}
|
{{end}}
|
|
@ -8,4 +8,6 @@
|
||||||
<link rel="stylesheet" href="{{.BaseUrl}}public/css/main.css">
|
<link rel="stylesheet" href="{{.BaseUrl}}public/css/main.css">
|
||||||
</head>
|
</head>
|
||||||
<body>
|
<body>
|
||||||
|
|
||||||
|
{{template "base/nav" .}}
|
||||||
{{end}}
|
{{end}}
|
|
@ -0,0 +1,76 @@
|
||||||
|
|
||||||
|
{{define "base/nav"}}
|
||||||
|
<nav class="navbar" role="navigation" aria-label="main navigation">
|
||||||
|
<div class="navbar-brand">
|
||||||
|
<a class="navbar-item" href="{{.BaseUrl}}">
|
||||||
|
<p><strong>{{.AppName}}</strong></p>
|
||||||
|
</a>
|
||||||
|
|
||||||
|
<a role="button" class="navbar-burger" aria-label="menu" aria-expanded="false" data-target="navbarBasicExample">
|
||||||
|
<span aria-hidden="true"></span>
|
||||||
|
<span aria-hidden="true"></span>
|
||||||
|
<span aria-hidden="true"></span>
|
||||||
|
</a>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div id="navbarBasicExample" class="navbar-menu">
|
||||||
|
{{/*
|
||||||
|
<div class="navbar-start">
|
||||||
|
{{if .Actions}}
|
||||||
|
<a class="navbar-item">
|
||||||
|
Actions
|
||||||
|
</a>
|
||||||
|
{{end}}
|
||||||
|
{{if .Integrations}}
|
||||||
|
<a class="navbar-item">
|
||||||
|
Integrations
|
||||||
|
</a>
|
||||||
|
{{end}}
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="navbar-end">
|
||||||
|
<div class="navbar-item">
|
||||||
|
<div class="buttons">
|
||||||
|
<a class="button is-primary">
|
||||||
|
<strong>Sign up</strong>
|
||||||
|
</a>
|
||||||
|
<a class="button is-light">
|
||||||
|
Log in
|
||||||
|
</a>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
*/}}
|
||||||
|
</div>
|
||||||
|
</nav>
|
||||||
|
|
||||||
|
{{/* not having pages
|
||||||
|
<script>
|
||||||
|
document.addEventListener('DOMContentLoaded', () => {
|
||||||
|
|
||||||
|
// Get all "navbar-burger" elements
|
||||||
|
const $navbarBurgers = Array.prototype.slice.call(document.querySelectorAll('.navbar-burger'), 0);
|
||||||
|
|
||||||
|
// Check if there are any navbar burgers
|
||||||
|
if ($navbarBurgers.length > 0) {
|
||||||
|
|
||||||
|
// Add a click event on each of them
|
||||||
|
$navbarBurgers.forEach( el => {
|
||||||
|
el.addEventListener('click', () => {
|
||||||
|
|
||||||
|
// Get the target from the "data-target" attribute
|
||||||
|
const target = el.dataset.target;
|
||||||
|
const $target = document.getElementById(target);
|
||||||
|
|
||||||
|
// Toggle the "is-active" class on both the "navbar-burger" and the "navbar-menu"
|
||||||
|
el.classList.toggle('is-active');
|
||||||
|
$target.classList.toggle('is-active');
|
||||||
|
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
});
|
||||||
|
*/}}
|
||||||
|
</script>
|
||||||
|
{{end}}
|
|
@ -1,4 +1,8 @@
|
||||||
{{define "base/script"}}
|
{{define "base/script"}}
|
||||||
|
|
||||||
|
<script src="{{.BaseUrl}}public/ace/js/ace.js" type="text/javascript" charset="utf-8"></script>
|
||||||
|
<script src="{{.BaseUrl}}public/ace/js/ext-beautify.js" type="text/javascript" charset="utf-8"></script>
|
||||||
|
<script src="{{.BaseUrl}}public/ace/js/ext-searchbox.js" type="text/javascript" charset="utf-8"></script>
|
||||||
<script>
|
<script>
|
||||||
window.ToolIsFollow = false;
|
window.ToolIsFollow = false;
|
||||||
window.LastDelta = 0;
|
window.LastDelta = 0;
|
||||||
|
|
|
@ -14,6 +14,26 @@
|
||||||
</li>
|
</li>
|
||||||
{{ end }}
|
{{ end }}
|
||||||
</ul>
|
</ul>
|
||||||
|
{{if .Onitachi}}
|
||||||
|
<p class="menu-label">
|
||||||
|
Programs
|
||||||
|
</p>
|
||||||
|
<ul class="menu-list">
|
||||||
|
{{- range $key, $value := .Onitachi -}}
|
||||||
|
<li>
|
||||||
|
<a class="has-tooltip-arrow" data-tooltip="{{$value.Cmd}}" href="{{$.BaseUrl}}program?name={{.Name}}">
|
||||||
|
<div class="level">
|
||||||
|
<span>{{$key}}</span>
|
||||||
|
<div class="tags has-addons">
|
||||||
|
<span class="tag">State</span>
|
||||||
|
<span class="tag {{$value.State|state_class}}">{{$value.State}}</span>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</a>
|
||||||
|
</li>
|
||||||
|
{{- end -}}
|
||||||
|
</ul>
|
||||||
|
{{end}}
|
||||||
{{if not .HideConfig}}
|
{{if not .HideConfig}}
|
||||||
<p class="menu-label">
|
<p class="menu-label">
|
||||||
System
|
System
|
||||||
|
|
|
@ -5,16 +5,6 @@
|
||||||
var Active = "{{.File.Name}}";
|
var Active = "{{.File.Name}}";
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
<nav class="level">
|
|
||||||
<div class="level-left">
|
|
||||||
<div class="level-item">
|
|
||||||
<a class="title is-size-4 ml-2 mt-1" href="{{.BaseUrl}}">
|
|
||||||
{{.AppName}}
|
|
||||||
</a>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</nav>
|
|
||||||
|
|
||||||
<div class="columns">
|
<div class="columns">
|
||||||
<div class="column is-one-quarter">
|
<div class="column is-one-quarter">
|
||||||
<div class="box">
|
<div class="box">
|
||||||
|
@ -90,5 +80,6 @@ async function toolDoIntegration(name){
|
||||||
{{if not .ResultBellow}}
|
{{if not .ResultBellow}}
|
||||||
{{template "components/result" .}}
|
{{template "components/result" .}}
|
||||||
{{end}}
|
{{end}}
|
||||||
|
{{template "base/script" .}}
|
||||||
{{template "base/footer" .}}
|
{{template "base/footer" .}}
|
||||||
{{end}}
|
{{end}}
|
|
@ -0,0 +1,73 @@
|
||||||
|
{{define "muzan"}}
|
||||||
|
{{template "base/header" .}}
|
||||||
|
{{template "components/error" .}}
|
||||||
|
<script>
|
||||||
|
var Active = "{{.File.Name}}";
|
||||||
|
</script>
|
||||||
|
|
||||||
|
<div class="columns">
|
||||||
|
<div class="column is-one-quarter">
|
||||||
|
<div class="box">
|
||||||
|
{{template "components/menu" .}}
|
||||||
|
</div>
|
||||||
|
{{if .Actions}}
|
||||||
|
<div class="box">
|
||||||
|
<p class="menu-label has-text-left">Actions</p>
|
||||||
|
<div class="buttons are-small">
|
||||||
|
{{- range .Actions -}}
|
||||||
|
<button class="button has-tooltip-arrow" id="actbtn-{{.Name|normal}}"
|
||||||
|
data-tooltip="{{.Cmd}}" onclick="toolDoAction('{{.Name}}')">
|
||||||
|
<span>{{- .Name -}}</span>
|
||||||
|
</button>
|
||||||
|
{{- end -}}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
{{end}}
|
||||||
|
{{if .Integrations}}
|
||||||
|
<div class="box">
|
||||||
|
<p class="menu-label has-text-left">Integrations</p>
|
||||||
|
<div class="buttons are-small">
|
||||||
|
{{- range .Integrations -}}
|
||||||
|
<button class="button has-tooltip-arrow" id="itgbtn-{{.Name|normal}}"
|
||||||
|
data-tooltip="{{.Description}}" onclick="toolDoIntegration('{{.Name}}')">
|
||||||
|
<span>{{- .Name -}}</span>
|
||||||
|
</button>
|
||||||
|
{{- end -}}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
{{end}}
|
||||||
|
<div class="box has-text-centered">
|
||||||
|
<a href="{{.BaseUrl}}api/export" class="button is-small">Export Files</a>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<div class="column">
|
||||||
|
<div class="box">
|
||||||
|
Home
|
||||||
|
{{/* {{template "components/editor" .}} */}}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<script>
|
||||||
|
async function toolDoAction(name){
|
||||||
|
let el = document.getElementById('actbtn-'+name.replaceAll(" ","-"));
|
||||||
|
el.classList.add("is-loading")
|
||||||
|
el.classList.remove("has-tooltip-arrow")
|
||||||
|
await DoAction('action',name)
|
||||||
|
el.classList.remove("is-loading")
|
||||||
|
el.classList.add("has-tooltip-arrow")
|
||||||
|
{{if not .ResultBellow}}ResultViewTog(){{end}}
|
||||||
|
}
|
||||||
|
|
||||||
|
async function toolDoIntegration(name){
|
||||||
|
let el = document.getElementById('itgbtn-'+name.replaceAll(" ","-"));
|
||||||
|
el.classList.add("is-loading")
|
||||||
|
el.classList.remove("has-tooltip-arrow")
|
||||||
|
await DoAction('integration',name)
|
||||||
|
el.classList.remove("is-loading")
|
||||||
|
el.classList.add("has-tooltip-arrow")
|
||||||
|
{{if not .ResultBellow}}ResultViewTog(){{end}}
|
||||||
|
}
|
||||||
|
</script>
|
||||||
|
{{template "base/footer" .}}
|
||||||
|
{{end}}
|
Loading…
Reference in New Issue