package cli import ( "contexts/ctx" "io/ioutil" "syscall" "toolkit" "fmt" "os" "os/exec" "regexp" "runtime" "strconv" "strings" "time" ) type Frame struct { key string run bool pos int index int list []string } type CLI struct { alias map[string][]string label map[string]string target *ctx.Context stack []*Frame *ctx.Context } func (cli *CLI) Spawn(m *ctx.Message, c *ctx.Context, arg ...string) ctx.Server { c.Caches = map[string]*ctx.Cache{ "level": &ctx.Cache{Name: "level", Value: "0", Help: "嵌套层级"}, "parse": &ctx.Cache{Name: "parse(true/false)", Value: "true", Help: "命令解析"}, "last_msg": &ctx.Cache{Name: "last_msg", Value: "0", Help: "前一条消息"}, "ps_count": &ctx.Cache{Name: "ps_count", Value: "0", Help: "命令计数"}, "ps_target": &ctx.Cache{Name: "ps_target", Value: c.Name, Help: "当前模块", Hand: func(m *ctx.Message, x *ctx.Cache, arg ...string) string { if len(arg) > 0 { if cli, ok := m.Target().Server.(*CLI); ok { if msg := m.Find(arg[0]); msg != nil { cli.target = msg.Target() return arg[0] } } } return x.Value }}, } c.Configs = map[string]*ctx.Config{ "ps_time": &ctx.Config{Name: "ps_time", Value: "[15:04:05]", Help: "当前时间", Hand: func(m *ctx.Message, x *ctx.Config, arg ...string) string { if len(arg) > 0 { return arg[0] } return time.Now().Format(x.Value.(string)) }}, "ps_end": &ctx.Config{Name: "ps_end", Value: "> ", Help: "命令行提示符结尾"}, "prompt": &ctx.Config{Name: "prompt(ps_count/ps_time/ps_target/ps_end/...)", Value: "ps_count ps_time ps_target ps_end", Help: "命令行提示符, 以空格分隔, 依次显示缓存或配置信息", Hand: func(m *ctx.Message, x *ctx.Config, arg ...string) string { if len(arg) > 0 { return arg[0] } ps := make([]string, 0, 3) for _, v := range strings.Split(x.Value.(string), " ") { if m.Conf(v) != "" { ps = append(ps, m.Conf(v)) } else { ps = append(ps, m.Cap(v)) } } return strings.Join(ps, "") }}, } s := new(CLI) s.Context = c s.target = c s.alias = map[string][]string{ "~": []string{"context"}, "!": []string{"message"}, ":": []string{"command"}, "::": []string{"command", "list"}, "@": []string{"config"}, "$": []string{"cache"}, } return s } func (cli *CLI) Begin(m *ctx.Message, arg ...string) ctx.Server { return cli } func (cli *CLI) Start(m *ctx.Message, arg ...string) bool { m.Optionv("ps_target", cli.target) m.Option("prompt", m.Conf("prompt")) m.Cap("stream", m.Spawn(m.Sess("yac", false).Target()).Call(func(cmd *ctx.Message) *ctx.Message { if !m.Caps("parse") { switch cmd.Detail(0) { case "if": cmd.Set("detail", "if", "false") case "else": case "end": case "for": default: cmd.Hand = true return nil } } if m.Option("prompt", cmd.Cmd().Conf("prompt")); cmd.Has("return") { m.Result(0, cmd.Meta["return"]) m.Options("scan_end", true) m.Target().Close(m) } m.Optionv("ps_target", cli.target) return nil }, "scan", arg[1]).Target().Name) return false } func (cli *CLI) Close(m *ctx.Message, arg ...string) bool { switch cli.Context { case m.Target(): case m.Source(): } return true } var Index = &ctx.Context{Name: "cli", Help: "管理中心", Caches: map[string]*ctx.Cache{ "nshell": &ctx.Cache{Name: "nshell", Value: "0", Help: "终端数量"}, }, Configs: map[string]*ctx.Config{ "init.shy": &ctx.Config{Name: "init.shy", Value: "etc/init.shy", Help: "启动脚本"}, "exit.shy": &ctx.Config{Name: "exit.shy", Value: "etc/exit.shy", Help: "启动脚本"}, "time_format": &ctx.Config{Name: "time_format", Value: "2006-01-02 15:04:05", Help: "时间格式"}, "time_unit": &ctx.Config{Name: "time_unit", Value: "1000", Help: "时间倍数"}, "time_close": &ctx.Config{Name: "time_close(open/close)", Value: "open", Help: "时间区间"}, "cmd_script": &ctx.Config{Name: "cmd_script", Value: map[string]interface{}{ "sh": "bash", "py": "python", "shy": "source", }, Help: "系统命令超时"}, "cmd_timeout": &ctx.Config{Name: "cmd_timeout", Value: "60s", Help: "系统命令超时"}, "cmd_combine": &ctx.Config{Name: "cmd_combine", Value: map[string]interface{}{ "vi": map[string]interface{}{"active": true}, "top": map[string]interface{}{"active": true}, "ls": map[string]interface{}{"arg": []interface{}{"-l"}}, }, Help: "系统命令配置, active: 交互方式, cmd: 命令映射, arg: 命令参数, args: 子命令参数, path: 命令目录, env: 环境变量, dir: 工作目录"}, }, Commands: map[string]*ctx.Command{ "alias": &ctx.Command{Name: "alias [short [long...]]|[delete short]|[import module [command [alias]]]", Help: "查看、定义或删除命令别名, short: 命令别名, long: 命令原名, delete: 删除别名, import导入模块所有命令", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if cli, ok := m.Target().Server.(*CLI); m.Assert(ok) { switch len(arg) { case 0: for k, v := range cli.alias { m.Echo("%s: %v\n", k, v) } case 1: m.Echo("%s: %v\n", arg[0], cli.alias[arg[0]]) default: switch arg[0] { case "delete": m.Echo("delete: %s %v\n", arg[1], cli.alias[arg[1]]) delete(cli.alias, arg[1]) case "import": msg := m.Find(arg[1], false) if msg == nil { msg = m.Find(arg[1], true) } if msg == nil { m.Echo("%s not exist", arg[1]) return } m.Log("info", "import %s", arg[1]) module := msg.Cap("module") for k, _ := range msg.Target().Commands { if len(arg) == 2 { cli.alias[k] = []string{module + "." + k} continue } if key := k; k == arg[2] { if len(arg) > 3 { key = arg[3] } cli.alias[key] = []string{module + "." + k} break } } default: cli.alias[arg[0]] = arg[1:] m.Echo("%s: %v\n", arg[0], cli.alias[arg[0]]) m.Log("info", "%s: %v", arg[0], cli.alias[arg[0]]) } } } }}, "cmd": &ctx.Command{Name: "cmd word", Help: "", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if cli, ok := m.Target().Server.(*CLI); m.Assert(ok) { detail := []string{} if a, ok := cli.alias[arg[0]]; ok { detail = append(detail, a...) detail = append(detail, arg[1:]...) } else { detail = append(detail, arg...) } if detail[0] != "context" { target := m.Cap("ps_target") defer func() { m.Cap("ps_target", target) }() } msg := m for k, v := range m.Confv("cmd_script").(map[string]interface{}) { if strings.HasSuffix(detail[0], "."+k) { detail = append([]string{v.(string)}, detail...) msg = m.Spawn(cli.target) break } } if msg == m { if routes := strings.Split(detail[0], "."); len(routes) > 1 { route := strings.Join(routes[:len(routes)-1], ".") if msg = m.Find(route, false); msg == nil { msg = m.Find(route, true) } if msg == nil { m.Echo("%s not exist", route) return } detail[0] = routes[len(routes)-1] } else { msg = m.Spawn(cli.target) } } msg.Copy(m, "append") msg.Copy(m, "option") args := []string{} rest := []string{} exec := true execexec := false exports := []map[string]string{} for i := 0; i < len(detail); i++ { switch detail[i] { case "?": if !ctx.Right(detail[i+1]) { return } i++ case "??": exec = false execexec = execexec || ctx.Right(detail[i+1]) i++ case "<": pipe := m.Spawn().Cmd("import", detail[i+1]) msg.Copy(pipe, "append") i++ case ">": exports = append(exports, map[string]string{"file": detail[i+1]}) i++ case ">$": if i == len(detail)-2 { exports = append(exports, map[string]string{"cache": detail[i+1], "index": "result"}) i += 1 break } exports = append(exports, map[string]string{"cache": detail[i+1], "index": detail[i+2]}) i += 2 case ">@": if i == len(detail)-2 { exports = append(exports, map[string]string{"config": detail[i+1], "index": "result"}) i += 1 break } exports = append(exports, map[string]string{"config": detail[i+1], "index": detail[i+2]}) i += 2 case "|": detail, rest = detail[:i], detail[i+1:] case "%": rest = append(rest, "select") detail, rest = detail[:i], append(rest, detail[i+1:]...) default: args = append(args, detail[i]) } } if !exec && !execexec { return } detail = args if msg.Cmd(detail); msg.Hand { m.Cap("ps_target", msg.Cap("module")) } else { msg.Copy(m, "target").Detail(-1, "system") msg.Cmd() } for _, v := range exports { m.Log("info", "export %v", v) if v["file"] != "" { m.Sess("nfs").Copy(msg, "option").Copy(msg, "append").Copy(msg, "result").Cmd("export", v["file"]) } if v["cache"] != "" { if v["index"] == "result" { m.Cap(v["cache"], strings.Join(msg.Meta["result"], "")) } else { m.Cap(v["cache"], msg.Append(v["index"])) } } if v["config"] != "" { if v["index"] == "result" { m.Conf(v["config"], strings.Join(msg.Meta["result"], "")) } else { m.Conf(v["config"], msg.Append(v["index"])) } } } if len(rest) > 0 { pipe := m.Spawn().Copy(msg, "option").Copy(msg, "append").Cmd("cmd", rest) msg.Set("result").Set("append") m.Log("fuck", "what %v", msg.Meta) msg.Copy(pipe, "result").Copy(pipe, "append") m.Log("fuck", "what %v", msg.Meta) } m.Target().Message().Set("result").Set("append").Copy(msg, "result").Copy(msg, "append") m.Copy(msg, "result").Copy(msg, "append") m.Capi("last_msg", 0, msg.Code()) m.Capi("ps_count", 1) } }}, "str": &ctx.Command{Name: "str word", Help: "解析字符串", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { m.Echo(arg[0][1 : len(arg[0])-1]) }}, "exe": &ctx.Command{Name: "exe $ ( cmd )", Help: "解析嵌套命令", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if cli, ok := m.Target().Server.(*CLI); m.Assert(ok) { switch len(arg) { case 1: m.Echo(arg[0]) case 2: msg := m.Spawn(cli.target) switch arg[0] { case "$": m.Echo(msg.Cap(arg[1])) case "@": value := msg.Option(arg[1]) if value == "" { value = msg.Conf(arg[1]) } m.Echo(value) default: m.Echo(arg[0]).Echo(arg[1]) } default: switch arg[0] { case "$", "@": m.Result(0, arg[2:len(arg)-1]) } } } //}}} }}, "val": &ctx.Command{Name: "val exp", Help: "表达式运算", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { result := "false" switch len(arg) { case 0: result = "" case 1: result = arg[0] case 2: switch arg[0] { case "-z": if arg[1] == "" { result = "true" } case "-n": if arg[1] != "" { result = "true" } case "-e": if _, e := os.Stat(arg[1]); e == nil { result = "true" } case "-f": if info, e := os.Stat(arg[1]); e == nil && !info.IsDir() { result = "true" } case "-d": if info, e := os.Stat(arg[1]); e == nil && info.IsDir() { result = "true" } case "+": result = arg[1] case "-": result = arg[1] if i, e := strconv.Atoi(arg[1]); e == nil { result = fmt.Sprintf("%d", -i) } } case 3: v1, e1 := strconv.Atoi(arg[0]) v2, e2 := strconv.Atoi(arg[2]) switch arg[1] { case ":=": if !m.Target().Has(arg[0]) { result = m.Cap(arg[0], arg[0], arg[2], "临时变量") } case "=": result = m.Cap(arg[0], arg[2]) case "+=": if i, e := strconv.Atoi(m.Cap(arg[0])); e == nil && e2 == nil { result = m.Cap(arg[0], fmt.Sprintf("%d", v2+i)) } else { result = m.Cap(arg[0], m.Cap(arg[0])+arg[2]) } case "+": if e1 == nil && e2 == nil { result = fmt.Sprintf("%d", v1+v2) } else { result = arg[0] + arg[2] } case "-": if e1 == nil && e2 == nil { result = fmt.Sprintf("%d", v1-v2) } else { result = strings.Replace(arg[0], arg[1], "", -1) } case "*": result = arg[0] if e1 == nil && e2 == nil { result = fmt.Sprintf("%d", v1*v2) } case "/": result = arg[0] if e1 == nil && e2 == nil { result = fmt.Sprintf("%d", v1/v2) } case "%": result = arg[0] if e1 == nil && e2 == nil { result = fmt.Sprintf("%d", v1%v2) } case "<": if e1 == nil && e2 == nil { result = fmt.Sprintf("%t", v1 < v2) } else { result = fmt.Sprintf("%t", arg[0] < arg[2]) } case "<=": if e1 == nil && e2 == nil { result = fmt.Sprintf("%t", v1 <= v2) } else { result = fmt.Sprintf("%t", arg[0] <= arg[2]) } case ">": if e1 == nil && e2 == nil { result = fmt.Sprintf("%t", v1 > v2) } else { result = fmt.Sprintf("%t", arg[0] > arg[2]) } case ">=": if e1 == nil && e2 == nil { result = fmt.Sprintf("%t", v1 >= v2) } else { result = fmt.Sprintf("%t", arg[0] >= arg[2]) } case "==": if e1 == nil && e2 == nil { result = fmt.Sprintf("%t", v1 == v2) } else { result = fmt.Sprintf("%t", arg[0] == arg[2]) } case "!=": if e1 == nil && e2 == nil { result = fmt.Sprintf("%t", v1 != v2) } else { result = fmt.Sprintf("%t", arg[0] != arg[2]) } case "~": if m, e := regexp.MatchString(arg[2], arg[0]); m && e == nil { result = "true" } case "!~": if m, e := regexp.MatchString(arg[2], arg[0]); !m || e != nil { result = "true" } } } m.Echo(result) }}, "exp": &ctx.Command{Name: "exp word", Help: "表达式运算", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if len(arg) > 0 && arg[0] == "{" { msg := m.Spawn() for i := 1; i < len(arg); i++ { key := arg[i] for i += 3; i < len(arg); i++ { if arg[i] == "]" { break } msg.Add("append", key, arg[i]) } } m.Echo("%d", msg.Code()) return } pre := map[string]int{ "=": 1, "+": 2, "-": 2, "*": 3, "/": 3, "%": 3, } num := []string{arg[0]} op := []string{} for i := 1; i < len(arg); i += 2 { if len(op) > 0 && pre[op[len(op)-1]] >= pre[arg[i]] { num[len(op)-1] = m.Spawn().Cmd("val", num[len(op)-1], op[len(op)-1], num[len(op)]).Get("result") num = num[:len(num)-1] op = op[:len(op)-1] } num = append(num, arg[i+1]) op = append(op, arg[i]) } for i := len(op) - 1; i >= 0; i-- { num[i] = m.Spawn().Cmd("val", num[i], op[i], num[i+1]).Get("result") } m.Echo("%s", num[0]) }}, "let": &ctx.Command{Name: "let a = exp", Help: "设置变量, a: 变量名, exp: 表达式(a {+|-|*|/|%} b)", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { switch arg[2] { case "=": m.Cap(arg[1], arg[3]) case "<-": m.Cap(arg[1], m.Cap("last_msg")) } m.Echo(m.Cap(arg[1])) }}, "var": &ctx.Command{Name: "var a [= exp]", Help: "定义变量, a: 变量名, exp: 表达式", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if m.Cap(arg[1], arg[1], "", "临时变量"); len(arg) > 1 { switch arg[2] { case "=": m.Cap(arg[1], arg[3]) case "<-": m.Cap(arg[1], m.Cap("last_msg")) } } m.Echo(m.Cap(arg[1])) }}, "echo": &ctx.Command{Name: "echo arg...", Help: "输出表达式", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { m.Echo("%s", strings.Join(arg[1:], "")) }}, "return": &ctx.Command{Name: "return result...", Help: "结束脚本, result: 返回值", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { m.Add("append", "return", arg[1:]) }}, "source": &ctx.Command{Name: "source [stdio [init.shy [exit.shy]]]|[filename [async]]|string", Help: "解析脚本, filename: 文件名, async: 异步执行", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { yac := m.Sess("yac") if yac.Cap("status") != "start" { yac.Target().Start(yac) yac.Cmd("train", "void", "void", "[\t ]+") yac.Cmd("train", "key", "key", "[A-Za-z_][A-Za-z_0-9]*") yac.Cmd("train", "num", "num", "mul{", "0", "-?[1-9][0-9]*", "0[0-9]+", "0x[0-9]+", "}") yac.Cmd("train", "str", "str", "mul{", "\"[^\"]*\"", "'[^']*'", "}") yac.Cmd("train", "exe", "exe", "mul{", "$", "@", "}", "key") yac.Cmd("train", "op1", "op1", "mul{", "-z", "-n", "}") yac.Cmd("train", "op1", "op1", "mul{", "-e", "-f", "-d", "}") yac.Cmd("train", "op1", "op1", "mul{", "-", "+", "}") yac.Cmd("train", "op2", "op2", "mul{", ":=", "=", "+=", "}") yac.Cmd("train", "op2", "op2", "mul{", "+", "-", "*", "/", "%", "}") yac.Cmd("train", "op2", "op2", "mul{", "<", "<=", ">", ">=", "==", "!=", "}") yac.Cmd("train", "op2", "op2", "mul{", "~", "!~", "}") yac.Cmd("train", "val", "val", "opt{", "op1", "}", "mul{", "num", "key", "str", "exe", "}") yac.Cmd("train", "exp", "exp", "val", "rep{", "op2", "val", "}") yac.Cmd("train", "map", "map", "key", ":", "\\[", "rep{", "key", "}", "\\]") yac.Cmd("train", "exp", "exp", "\\{", "rep{", "map", "}", "\\}") yac.Cmd("train", "val", "val", "opt{", "op1", "}", "(", "exp", ")") yac.Cmd("train", "stm", "var", "var", "key", "opt{", "=", "exp", "}") yac.Cmd("train", "stm", "let", "let", "key", "opt{", "=", "exp", "}") yac.Cmd("train", "stm", "var", "var", "key", "<-") yac.Cmd("train", "stm", "var", "var", "key", "<-", "opt{", "exe", "}") yac.Cmd("train", "stm", "let", "let", "key", "<-", "opt{", "exe", "}") yac.Cmd("train", "stm", "if", "if", "exp") yac.Cmd("train", "stm", "else", "else") yac.Cmd("train", "stm", "end", "end") yac.Cmd("train", "stm", "for", "for", "opt{", "exp", ";", "}", "exp") yac.Cmd("train", "stm", "for", "for", "index", "exp", "opt{", "exp", "}", "exp") yac.Cmd("train", "stm", "label", "label", "exp") yac.Cmd("train", "stm", "goto", "goto", "exp", "opt{", "exp", "}", "exp") yac.Cmd("train", "stm", "echo", "echo", "rep{", "exp", "}") yac.Cmd("train", "stm", "return", "return", "rep{", "exp", "}") yac.Cmd("train", "word", "word", "mul{", "~", "!", "=", "\\?\\?", "\\?", "<", ">$", ">@", ">", "\\|", "%", "exe", "str", "[a-zA-Z0-9_/\\-.:]+", "}") yac.Cmd("train", "cmd", "cmd", "rep{", "word", "}") yac.Cmd("train", "exe", "exe", "$", "(", "cmd", ")") yac.Cmd("train", "line", "line", "opt{", "mul{", "stm", "cmd", "}", "}", "mul{", ";", "\n", "#[^\n]*\n", "}") } if arg[0] != "stdio" { if !m.Sess("nfs").Cmd("path", arg[0]).Results(0) { m.Sess("yac").Call(func(msg *ctx.Message) *ctx.Message { switch msg.Cmd().Detail(0) { case "cmd": m.Set("append").Copy(msg, "append").Set("result").Copy(msg, "result") } return nil }, "parse", "line", "void", arg) return } } if _, ok := m.Source().Server.(*CLI); ok { msg := m.Spawn(c) m.Copy(msg, "target") } name := fmt.Sprintf("shell%d", m.Capi("nshell", 1)) if arg[0] == "stdio" { name = "shy" } m.Start(name, "shell", key, arg[0]) if arg[0] == "stdio" { if m.Sess("nfs").Cmd("path", m.Confx("init.shy", arg, 1)).Results(0) { m.Spawn().Add("option", "scan_end", "false").Cmd("source", m.Conf("init.shy")) } m.Option("prompt", m.Conf("prompt")) m.Find("nfs.file1").Cmd("prompt") } if len(arg) < 2 || arg[1] != "async" { if arg[0] == "stdio" && len(arg) > 1 { fmt.Printf(m.Spawn().Cmd("source", arg[1]).Result(0)) } else { m.Wait() } if arg[0] == "stdio" { if m.Sess("nfs").Cmd("path", m.Confx("exit.shy", arg, 2)).Results(0) { m.Spawn().Add("option", "scan_end", "false").Cmd("source", m.Conf("exit.shy")) } } m.Target().Close(m) } }}, "sleep": &ctx.Command{Name: "sleep time", Help: "睡眠, time(ns/us/ms/s/m/h): 时间值(纳秒/微秒/毫秒/秒/分钟/小时)", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if d, e := time.ParseDuration(arg[0]); m.Assert(e) { m.Log("info", "sleep %v", d) time.Sleep(d) m.Log("info", "sleep %v done", d) } }}, "time": &ctx.Command{Name: "time when [begin|end|yestoday|tommorow|monday|sunday|first|last|origin|last]", Help: "查看时间, when: 输入的时间戳, 剩余参数是时间偏移", Form: map[string]int{"time_format": 1, "time_close": 1}, Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { t, stamp := time.Now(), true if len(arg) > 0 { if i, e := strconv.ParseInt(arg[0], 10, 64); e == nil { t = time.Unix(int64(i/int64(m.Confi("time_unit"))), 0) arg = arg[1:] stamp = false } else if n, e := time.ParseInLocation(m.Confx("time_format"), arg[0], time.Local); e == nil { arg = arg[1:] t = n } } if len(arg) > 0 { switch arg[0] { case "begin": d, e := time.ParseDuration(fmt.Sprintf("%dh%dm%ds", t.Hour(), t.Minute(), t.Second())) m.Assert(e) t = t.Add(-d) case "end": d, e := time.ParseDuration(fmt.Sprintf("%dh%dm%ds%dns", t.Hour(), t.Minute(), t.Second(), t.Nanosecond())) m.Assert(e) t = t.Add(time.Duration(24*time.Hour) - d) if m.Confx("time_close") == "close" { t = t.Add(-time.Second) } case "yestoday": t = t.Add(-time.Duration(24 * time.Hour)) case "tomorrow": t = t.Add(time.Duration(24 * time.Hour)) case "monday": d, e := time.ParseDuration(fmt.Sprintf("%dh%dm%ds", int((t.Weekday()-time.Monday+7)%7)*24+t.Hour(), t.Minute(), t.Second())) m.Assert(e) t = t.Add(-d) case "sunday": d, e := time.ParseDuration(fmt.Sprintf("%dh%dm%ds", int((t.Weekday()-time.Monday+7)%7)*24+t.Hour(), t.Minute(), t.Second())) m.Assert(e) t = t.Add(time.Duration(7*24*time.Hour) - d) if m.Confx("time_close") == "close" { t = t.Add(-time.Second) } case "first": t = time.Date(t.Year(), t.Month(), 1, 0, 0, 0, 0, time.Local) case "last": month, year := t.Month()+1, t.Year() if month >= 13 { month, year = 1, year+1 } t = time.Date(year, month, 1, 0, 0, 0, 0, time.Local) if m.Confx("time_close") == "close" { t = t.Add(-time.Second) } case "origin": t = time.Date(t.Year(), 1, 1, 0, 0, 0, 0, time.Local) case "final": t = time.Date(t.Year()+1, 1, 1, 0, 0, 0, 0, time.Local) if m.Confx("time_close") == "close" { t = t.Add(-time.Second) } } } if stamp { m.Echo("%d", t.Unix()*int64(m.Confi("time_unit"))) } else { m.Echo(t.Format(m.Confx("time_format"))) } }}, "tmux": &ctx.Command{Name: "tmux buffer", Help: "终端管理, buffer: 查看复制", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { switch arg[0] { case "buffer": bufs := strings.Split(m.Spawn().Cmd("system", "tmux", "list-buffers").Result(0), "\n") n := 3 if m.Option("limit") != "" { n = m.Optioni("limit") } for i, b := range bufs { if i >= n { break } bs := strings.SplitN(b, ": ", 3) if len(bs) > 1 { m.Add("append", "buffer", bs[0][:len(bs[0])]) m.Add("append", "length", bs[1][:len(bs[1])-6]) m.Add("append", "strings", bs[2][1:len(bs[2])-1]) } } if m.Option("index") == "" { m.Echo(m.Spawn().Cmd("system", "tmux", "show-buffer").Result(0)) } else { m.Echo(m.Spawn().Cmd("system", "tmux", "show-buffer", "-b", m.Option("index")).Result(0)) } } }}, "system": &ctx.Command{Name: "system word...", Help: []string{"调用系统命令, word: 命令", "cmd_active(true/false): 是否交互", "cmd_timeout: 命令超时", "cmd_env: 环境变量", "cmd_dir: 工作目录"}, Form: map[string]int{"cmd_active": 1, "cmd_timeout": 1, "cmd_env": 2, "cmd_dir": 1}, Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { conf := map[string]interface{}{} if m.Confv("cmd_combine", arg[0]) != nil { conf = m.Confv("cmd_combine", arg[0]).(map[string]interface{}) } if conf["cmd"] != nil { arg[0] = m.Parse(conf["cmd"]) } args := []string{} if conf["arg"] != nil { for _, v := range conf["arg"].([]interface{}) { args = append(args, m.Parse(v)) } } args = append(args, arg[1:]...) if conf["args"] != nil { for _, v := range conf["args"].([]interface{}) { args = append(args, m.Parse(v)) } } cmd := exec.Command(arg[0], args...) if conf["path"] != nil { cmd.Path = m.Parse(conf["path"]) } if conf["env"] != nil { for k, v := range conf["env"].(map[string]interface{}) { cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%s", k, m.Parse(v))) } } for i := 0; i < len(m.Meta["cmd_env"])-1; i += 2 { cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%s", m.Meta["cmd_env"][i], m.Parse(m.Meta["cmd_env"][i+1]))) } if conf["dir"] != nil { cmd.Dir = m.Parse(conf["dir"]) } if m.Options("cmd_dir") { cmd.Dir = m.Option("cmd_dir") } if m.Options("cmd_active") || ctx.Right(conf["active"]) { cmd.Stdin, cmd.Stdout, cmd.Stderr = os.Stdin, os.Stdout, os.Stderr if e := cmd.Start(); e != nil { m.Echo("error: ").Echo("%s\n", e) } else if e := cmd.Wait(); e != nil { m.Echo("error: ").Echo("%s\n", e) } } else { wait := make(chan bool, 1) go func() { if out, e := cmd.CombinedOutput(); e != nil { m.Echo("error: ").Echo("%s\n", e) m.Echo("%s\n", string(out)) } else { m.Echo(string(out)) } wait <- true }() timeout := m.Conf("cmd_timeout") if conf["timeout"] != nil { timeout = conf["timeout"].(string) } if m.Option("timeout") != "" { timeout = m.Option("timeout") } d, e := time.ParseDuration(timeout) m.Assert(e) select { case <-time.After(d): cmd.Process.Kill() m.Echo("%s: %s timeout", arg[0], m.Conf("cmd_timeout")) case <-wait: } } }}, "sysinfo": &ctx.Command{Name: "sysinfo", Help: "sysinfo", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { sys := &syscall.Sysinfo_t{} syscall.Sysinfo(sys) d, e := time.ParseDuration(fmt.Sprintf("%ds", sys.Uptime)) m.Assert(e) m.Append("NumCPU", runtime.NumCPU()) m.Append("uptime", d) m.Append("procs", sys.Procs) m.Append("total", kit.FmtSize(sys.Totalram)) m.Append("free", kit.FmtSize(sys.Freeram)) m.Append("mper", fmt.Sprintf("%d%%", sys.Freeram*100/sys.Totalram)) fs := &syscall.Statfs_t{} syscall.Statfs("./", fs) m.Append("blocks", kit.FmtSize(fs.Blocks*uint64(fs.Bsize))) m.Append("bavail", kit.FmtSize(fs.Bavail*uint64(fs.Bsize))) m.Append("bper", fmt.Sprintf("%d%%", fs.Bavail*100/fs.Blocks)) m.Append("files", fs.Files) m.Append("ffree", fs.Ffree) m.Append("fper", fmt.Sprintf("%d%%", fs.Ffree*100/fs.Files)) m.Table() }}, "runtime": &ctx.Command{Name: "runtime", Help: "runtime", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { mem := &runtime.MemStats{} runtime.ReadMemStats(mem) m.Append("NumGoroutine", runtime.NumGoroutine()) m.Append("NumGC", mem.NumGC) m.Append("other", kit.FmtSize(mem.OtherSys)) m.Append("stack", kit.FmtSize(mem.StackSys)) m.Append("heapsys", kit.FmtSize(mem.HeapSys)) m.Append("heapinuse", kit.FmtSize(mem.HeapInuse)) m.Append("heapidle", kit.FmtSize(mem.HeapIdle)) m.Append("heapalloc", kit.FmtSize(mem.HeapAlloc)) m.Append("lookups", mem.Lookups) m.Append("objects", mem.HeapObjects) m.Table() }}, "develop": &ctx.Command{Name: "develop", Help: "develop", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { m.Append("nclient", strings.Count(m.Spawn().Cmd("system", "tmux", "list-clients").Result(0), "\n")) m.Append("nsesion", strings.Count(m.Spawn().Cmd("system", "tmux", "list-sessions").Result(0), "\n")) m.Append("nwindow", strings.Count(m.Spawn().Cmd("system", "tmux", "list-windows", "-a").Result(0), "\n")) m.Append("npane", strings.Count(m.Spawn().Cmd("system", "tmux", "list-panes", "-a").Result(0), "\n")) m.Append("ncommand", strings.Count(m.Spawn().Cmd("system", "tmux", "list-commands").Result(0), "\n")) m.Append("nkey", strings.Count(m.Spawn().Cmd("system", "tmux", "list-keys").Result(0), "\n")) m.Append("nbuffer", strings.Count(m.Spawn().Cmd("system", "tmux", "list-buffers").Result(0), "\n")) nw, _ := ioutil.ReadFile("var/.nwrite") m.Append("nwrite", string(nw)) nr, _ := ioutil.ReadFile("var/.nread") m.Append("nread", string(nr)) m.Table() }}, "label": &ctx.Command{Name: "label name", Help: "记录当前脚本的位置, name: 位置名", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if cli, ok := m.Target().Server.(*CLI); m.Assert(ok) { if cli.label == nil { cli.label = map[string]string{} } cli.label[arg[1]] = m.Option("file_pos") } }}, "goto": &ctx.Command{Name: "goto label [exp] condition", Help: "向上跳转到指定位置, label: 跳转位置, condition: 跳转条件", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if cli, ok := m.Target().Server.(*CLI); m.Assert(ok) { if pos, ok := cli.label[arg[1]]; ok { if !ctx.Right(arg[len(arg)-1]) { return } m.Append("file_pos0", pos) } } }}, "if": &ctx.Command{Name: "if exp", Help: "条件语句, exp: 表达式", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if cli, ok := m.Target().Server.(*CLI); m.Assert(ok) { run := m.Caps("parse") && ctx.Right(arg[1]) cli.stack = append(cli.stack, &Frame{pos: m.Optioni("file_pos"), key: key, run: run}) m.Capi("level", 1) m.Caps("parse", run) } }}, "else": &ctx.Command{Name: "else", Help: "条件语句", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if cli, ok := m.Target().Server.(*CLI); m.Assert(ok) { if !m.Caps("parse") { m.Caps("parse", true) } else { if len(cli.stack) == 1 { m.Caps("parse", false) } else { frame := cli.stack[len(cli.stack)-2] m.Caps("parse", !frame.run) } } } }}, "end": &ctx.Command{Name: "end", Help: "结束语句", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if cli, ok := m.Target().Server.(*CLI); m.Assert(ok) { if frame := cli.stack[len(cli.stack)-1]; frame.key == "for" && frame.run { m.Append("file_pos0", frame.pos) return } if cli.stack = cli.stack[:len(cli.stack)-1]; m.Capi("level", -1) > 0 { m.Caps("parse", cli.stack[len(cli.stack)-1].run) } else { m.Caps("parse", true) } } }}, "for": &ctx.Command{Name: "for [[express ;] condition]|[index message meta value]", Help: "循环语句, express: 每次循环运行的表达式, condition: 循环条件, index: 索引消息, message: 消息编号, meta: value: ", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if cli, ok := m.Target().Server.(*CLI); m.Assert(ok) { run := m.Caps("parse") defer func() { m.Caps("parse", run) }() msg := m if run { if arg[1] == "index" { if code, e := strconv.Atoi(arg[2]); m.Assert(e) { msg = m.Target().Message().Tree(code) run = run && msg != nil && msg.Meta != nil switch len(arg) { case 4: run = run && len(msg.Meta) > 0 case 5: run = run && len(msg.Meta[arg[3]]) > 0 } } } else { run = run && ctx.Right(arg[len(arg)-1]) } if len(cli.stack) > 0 { if frame := cli.stack[len(cli.stack)-1]; frame.key == "for" && frame.pos == m.Optioni("file_pos") { if arg[1] == "index" { frame.index++ if run = run && len(frame.list) > frame.index; run { if len(arg) == 5 { arg[3] = arg[4] } m.Cap(arg[3], frame.list[frame.index]) } } frame.run = run return } } } cli.stack = append(cli.stack, &Frame{pos: m.Optioni("file_pos"), key: key, run: run, index: 0}) if m.Capi("level", 1); run && arg[1] == "index" { frame := cli.stack[len(cli.stack)-1] switch len(arg) { case 4: frame.list = []string{} for k, _ := range msg.Meta { frame.list = append(frame.list, k) } case 5: frame.list = msg.Meta[arg[3]] arg[3] = arg[4] } m.Cap(arg[3], arg[3], frame.list[0], "临时变量") } } }}, }, } func init() { cli := &CLI{} cli.Context = Index ctx.Index.Register(Index, cli) }