forked from x/icebergs
91 lines
3.8 KiB
Go
91 lines
3.8 KiB
Go
package relay
|
|
|
|
import (
|
|
"path"
|
|
|
|
"shylinux.com/x/ice"
|
|
"shylinux.com/x/icebergs/base/cli"
|
|
"shylinux.com/x/icebergs/base/ctx"
|
|
"shylinux.com/x/icebergs/base/mdb"
|
|
"shylinux.com/x/icebergs/base/nfs"
|
|
"shylinux.com/x/icebergs/base/tcp"
|
|
"shylinux.com/x/icebergs/base/web"
|
|
"shylinux.com/x/icebergs/base/web/html"
|
|
kit "shylinux.com/x/toolkits"
|
|
)
|
|
|
|
type matrix struct {
|
|
status string `name:"status" help:"源码" icon:"bi bi-git"`
|
|
list string `name:"list refresh" help:"矩阵"`
|
|
}
|
|
|
|
func (s matrix) List(m *ice.Message, arg ...string) {
|
|
m.Cmdy(SSH_RELAY, web.DREAM).Table(func(value ice.Maps) {
|
|
if value[web.SPACE] == ice.CONTEXTS {
|
|
m.PushButton(s.Portal, s.Desktop, s.Dream, s.Admin, s.Open, s.Word, s.Status, s.Vimer, s.Compile, s.Runtime, s.Xterm)
|
|
} else if value[mdb.STATUS] == cli.STOP {
|
|
m.PushButton()
|
|
} else if value[MACHINE] == tcp.LOCALHOST {
|
|
m.PushButton(s.Portal, s.Word, s.Status, s.Vimer, s.Compile, s.Runtime, s.Xterm, s.Desktop, s.Admin, s.Open)
|
|
} else {
|
|
m.PushButton(s.Portal, s.Desktop, s.Admin, s.Open, s.Vimer, s.Runtime, s.Xterm)
|
|
}
|
|
}).Action(html.FILTER).Display("").Sort("type,status,space,machine", []string{web.SERVER, web.WORKER, ""}, []string{cli.START, cli.STOP, ""}, "str_r", "str")
|
|
}
|
|
func (s matrix) Portal(m *ice.Message, arg ...string) { s.iframe(m, arg...) }
|
|
func (s matrix) Desktop(m *ice.Message, arg ...string) { s.plug(m, arg...) }
|
|
func (s matrix) Dream(m *ice.Message, arg ...string) { s.plug(m, arg...) }
|
|
func (s matrix) Admin(m *ice.Message, arg ...string) { s.open(m, arg...) }
|
|
func (s matrix) Open(m *ice.Message, arg ...string) { s.open(m, arg...) }
|
|
func (s matrix) Word(m *ice.Message, arg ...string) { s.plug(m, arg...) }
|
|
func (s matrix) Status(m *ice.Message, arg ...string) { s.plug(m, arg...) }
|
|
func (s matrix) Vimer(m *ice.Message, arg ...string) { s.plug(m, arg...) }
|
|
func (s matrix) Compile(m *ice.Message, arg ...string) { s.plug(m, arg...) }
|
|
func (s matrix) Runtime(m *ice.Message, arg ...string) { s.plug(m, arg...) }
|
|
func (s matrix) Xterm(m *ice.Message, arg ...string) { s.xterm(m, arg...) }
|
|
|
|
func init() { ice.Cmd("ssh.matrix", matrix{}) }
|
|
|
|
func (s matrix) plug(m *ice.Message, arg ...string) {
|
|
if !kit.HasPrefixList(arg, ctx.RUN) {
|
|
defer m.Push(web.TITLE, s.title(m))
|
|
}
|
|
m.ProcessPodCmd(kit.Keys(kit.Select("", ice.OPS, ice.Info.NodeType == web.WORKER), m.Option(MACHINE), m.Option(web.SPACE)), m.ActionKey(), arg, arg...)
|
|
}
|
|
func (s matrix) xterm(m *ice.Message, arg ...string) {
|
|
m.ProcessXterm("", func() []string {
|
|
cmd, dir := cli.SH, ice.CONTEXTS
|
|
if m.Option(MACHINE) == "" {
|
|
cmd = cli.Shell(m.Message)
|
|
} else {
|
|
cmd, dir = m.Option(MACHINE), kit.Select(dir, m.Cmd(SSH_RELAY, m.Option(MACHINE)).Append(web.DREAM))
|
|
}
|
|
kit.If(m.Option(web.SPACE), func() { dir = path.Join(dir, nfs.USR_LOCAL_WORK+m.Option(web.SPACE)) })
|
|
return []string{cmd, "", kit.Format("cd ~/%s", dir)}
|
|
}, arg...)
|
|
kit.If(!kit.HasPrefixList(arg, ctx.RUN), func() { m.Push(web.STYLE, html.FLOAT).Push(web.TITLE, s.title(m)) })
|
|
}
|
|
func (s matrix) iframe(m *ice.Message, arg ...string) {
|
|
m.ProcessIframe(s.title(m), s.link(m), arg...)
|
|
}
|
|
func (s matrix) open(m *ice.Message, arg ...string) {
|
|
if m.ActionKey() == web.OPEN {
|
|
m.ProcessOpen(s.link(m))
|
|
return
|
|
}
|
|
if kit.HasPrefixList(arg, ctx.RUN) || m.Option(MACHINE) == "" {
|
|
m.ProcessIframe(s.title(m), s.link(m), arg...)
|
|
} else {
|
|
m.ProcessOpen(s.link(m))
|
|
}
|
|
}
|
|
func (s matrix) link(m *ice.Message, arg ...string) (res string) {
|
|
kit.If(m.Option(MACHINE), func(p string) { res = m.Cmd(SSH_RELAY, p).Append(mdb.LINK) })
|
|
kit.If(m.Option(web.SPACE), func(p string) { res += web.S(p) })
|
|
kit.If(m.ActionKey() != web.OPEN, func() { res += web.C(m.ActionKey()) })
|
|
return kit.Select(nfs.PS, res)
|
|
}
|
|
func (s matrix) title(m *ice.Message) string {
|
|
return kit.Select(ice.CONTEXTS, kit.Keys(m.Option(MACHINE), m.Option(web.SPACE), kit.Select("", m.ActionKey(), m.ActionKey() != web.OPEN)))
|
|
}
|