liubin/icebergs
1
0
Fork 0
forked from x/icebergs
Code Pull Requests Activity

add some

Browse Source
This commit is contained in:
IT 老营长 @云轩领航-创始人 2024-04-02 21:49:19 +08:00
parent b63cdf740c
commit 5735299596
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
misc/ssh/relay/relay.go
View File

@ -65,6 +65,7 @@ type relay struct {
tools string `data:"ssh.trans,ssh.auth,aaa.cert"` tools string `data:"ssh.trans,ssh.auth,aaa.cert"`
field string `data:"time,icons,machine,username,host,port,portal,dream,module,version,commitTime,compileTime,bootTime,go,git,package,shell,kernel,arch,vcpu,ncpu,mhz,mem,disk,network,listen,socket,proc,vendor"` field string `data:"time,icons,machine,username,host,port,portal,dream,module,version,commitTime,compileTime,bootTime,go,git,package,shell,kernel,arch,vcpu,ncpu,mhz,mem,disk,network,listen,socket,proc,vendor"`
create string `name:"create host* port=22 username machine icons"` create string `name:"create host* port=22 username machine icons"`
upgrade string `name:"upgrade machine"`
stats string `name:"stats machine" help:"采集" icon:"bi bi-card-list"` stats string `name:"stats machine" help:"采集" icon:"bi bi-card-list"`
publish string `name:"publish" help:"发布" icon:"bi bi-send-check"` publish string `name:"publish" help:"发布" icon:"bi bi-send-check"`
forEach string `name:"forEach machine cmd*:textarea=pwd"` forEach string `name:"forEach machine cmd*:textarea=pwd"`
@ -343,14 +344,16 @@ func (s relay) shell(m *ice.Message, init string, arg ...string) {
), mdb.TEXT, strings.ReplaceAll(init, lex.NL, "; ")}, arg...) ), mdb.TEXT, strings.ReplaceAll(init, lex.NL, "; ")}, arg...)
} }
func (s relay) foreachScript(m *ice.Message, script string, arg ...string) { func (s relay) foreachScript(m *ice.Message, script string, arg ...string) {
m.Options(web.DREAM, path.Base(m.DreamPath(m.Option(web.DREAM))))
m.Option(ice.MSG_TITLE, kit.Keys(m.Option(ice.MSG_USERPOD), m.CommandKey(), m.ActionKey())) m.Option(ice.MSG_TITLE, kit.Keys(m.Option(ice.MSG_USERPOD), m.CommandKey(), m.ActionKey()))
if len(arg) == 0 && (m.Option(MACHINE) == "" || strings.Contains(m.Option(MACHINE), ",")) { if !kit.HasPrefixList(arg, ctx.RUN) && (m.Option(MACHINE) == "" || strings.Contains(m.Option(MACHINE), ",")) {
s.foreach(m, func(msg *ice.Message, cmd []string) { s.foreach(m, func(msg *ice.Message, cmd []string) {
if msg.Option(cli.GO) == "" { if msg.Option(cli.GO) == "" {
return return
} }
msg.Option(web.LINK, web.HostPort(m.Message, msg.Option(tcp.HOST), msg.Option(web.PORTAL))) m.Debug("what %v", msg.Option(web.DREAM))
msg.Option(web.DREAM, path.Base(m.DreamPath(msg.Option(web.DREAM))))
m.Debug("what %v", msg.Option(web.DREAM))
msg.Option(web.LINK, m.HostPort(msg.Option(tcp.HOST), msg.Option(web.PORTAL)))
ssh.PushShell(msg.Message, strings.Split(msg.Template(script), lex.NL), func(res string) { ssh.PushShell(msg.Message, strings.Split(msg.Template(script), lex.NL), func(res string) {
web.PushNoticeGrow(m.Options(ctx.DISPLAY, html.PLUGIN_XTERM, ice.MSG_COUNT, "0", ice.MSG_DEBUG, ice.FALSE, ice.LOG_DISABLE, ice.TRUE).Message, res) web.PushNoticeGrow(m.Options(ctx.DISPLAY, html.PLUGIN_XTERM, ice.MSG_COUNT, "0", ice.MSG_DEBUG, ice.FALSE, ice.LOG_DISABLE, ice.TRUE).Message, res)
}) })