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

Merge branch '0.2.0'

Browse Source
This commit is contained in:
shaoying 2018-01-05 00:26:05 +08:00
commit dc77397fe9
7 changed files with 248 additions and 134 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
README.md
View File

@ -1,15 +1,15 @@
# context # context
context: 通过提供自由的模块，简洁的接口，动态的结构，让编程变得更简单，让世界变得更美好。 context: 通过提供自由的模块，简洁的接口，动态的结构，让编程变得更简单，让世界变得更美好。
## 设计理念 ## 数据结构
* 让用户轻松学会编程 * ARM: 寻址与指令
* 让系统轻松学会编程 * Linux: 文件与进程
* 让自己轻松学会编程 * HTTP: 表示与会话
## 设计规范 ## 开发流程
* 协议与流程 * 设计: 协议与流程
* 框架与接口 * 编程: 接口与框架
* 语句与表达式 * 测试: 语句与表达式
## 接口设计CCC(command, config, cache) ## 接口设计CCC(command, config, cache)
* 服务管理server * 服务管理server
@ -19,27 +19,38 @@ context: 通过提供自由的模块，简洁的接口，动态的结构，让
* 配置管理config * 配置管理config
* 缓存管理cache * 缓存管理cache
### Context
* Cap() Conf() Cmd() * Cap() Conf() Cmd()
* Spawn() Begin() Start() Close() * Spawn() Begin() Start() Close()
### Message
* Request[] History[] Session[] * Request[] History[] Session[]
* detail[] option[] result[] append[] * detail[] option[] result[] append[]
### Conbine
* Context Master Owner * Context Master Owner
* Search() Choice() Assert() Figure() * Search() Choice() Assert() Figure()
## 结构设计 ## 模块设计
* 功能树 * ctx cli aaa web
* 权限树 * nfs tcp mdb ssh
* 消息树 * lex yac log gdb
## 分支管理 ### Core
* 0.1 ctx cli aaa ssh * ctx: 模块中心
* 0.2 nfs tcp mdb web * cli: 管理中心
* 0.3 lex yac log gdb * aaa: 认证中心
* web: 应用中心
## 终端管理 ### Base
* 寻址 指令 事件 函数 资源 * nfs: 存储中心
* 文件 进程 配置 框架 模块 * tcp: 网络中心
* 表示 会话 认证 搜索 交互 * mdb: 数据中心
* ssh: 集群中心
### Draw
* lex: 词法解析
* yac: 语法解析
* log: 日志中心
* gdb: 调试中心

33
etc/init.sh
View File

@ -2,26 +2,27 @@
~cli ~cli
@lex lex @lex lex
~aaa login root root ~aaa login root root
~web serve ~ssh dial chat.shylinux.com:9090 true
return sleep 1
~ssh dial chat.shylinux.com:9090 true
sleep 1
~host1 ~host1
~aaa login root root
~web serve
~nfs load usr/sess.txt ~nfs load usr/sess.txt
var a = $result var sessid = $result
return if -n $sessid
$a = $result ~host1 remote context mpa register $sessid
if $a != "" else
remote context mpa register $a ~host1 remote context mpa register terminal shhylinux term term term 1
let sessid $result
end end
if $a == "" ~host1 cache sessid $sessid
remote context mpa register terminal shhylinux term term term 1 ~host1 remote cache sessid $sessid
$sessid $result ~nfs save usr/sess.txt $sessid
remote cache sessid $sessid ~nfs genqr usr/sess.png "terminal: " $sessid
~nfs save usr/sess.txt "terminal: " $sessid return
~nfs genqr usr/sess.png "terminal: " $sessid
end return
return return
# ~ssh dial chat.shylinux.com:9090 true # ~ssh dial chat.shylinux.com:9090 true
# ~cli # ~cli

19
src/context/aaa/aaa.go
View File

@ -128,25 +128,26 @@ var Index = &ctx.Context{Name: "aaa", Help: "认证中心",
username, password = arg[1], arg[2] username, password = arg[1], arg[2]
} }
msg := m
if username == Pulse.Conf("rootname") { if username == Pulse.Conf("rootname") {
m.Set("detail", group, username).Target().Start(m) msg = Pulse.Spawn(Pulse.Target())
} else if msg := m.Find(username, false); msg == nil { msg.Set("detail", group, username).Target().Start(msg)
} else if msg = Pulse.Find(username, false); msg == nil {
m.Start(username, "认证用户", group, username) m.Start(username, "认证用户", group, username)
msg = m
} else { } else {
m.Target(msg.Target()) m.Target(msg.Target())
} }
m.Cap("password", password) msg.Cap("password", password)
m.Source().Group, m.Source().Owner = m.Cap("group"), m.Target() m.Source().Group, m.Source().Owner = msg.Cap("group"), msg.Target()
aaa.sessions[m.Cap("sessid")] = m.Target() aaa.sessions[m.Cap("sessid")] = msg.Target()
m.Echo(m.Cap("sessid")) m.Echo(msg.Cap("sessid"))
} }
}}, }},
}, },
Index: map[string]*ctx.Context{ Index: map[string]*ctx.Context{
"void": &ctx.Context{Name: "void", "void": &ctx.Context{Name: "void", Commands: map[string]*ctx.Command{"login": &ctx.Command{}}},
Commands: map[string]*ctx.Command{"login": &ctx.Command{}},
},
}, },
} }

191
src/context/cli/cli.go
View File

@ -8,6 +8,7 @@ import (
"io" "io"
"os" "os"
"os/exec" "os/exec"
"regexp"
"strconv" "strconv"
"strings" "strings"
"time" "time"
@ -51,7 +52,7 @@ func (cli *CLI) parse(m *ctx.Message) bool {
if cli.which == len(cli.lines) { if cli.which == len(cli.lines) {
cli.exit = true cli.exit = true
cli.which = 0 cli.which = 0
m.Spawn(cli.target).Set("detail", "end").Post(cli.Context) m.Spawn(cli.Context).Set("detail", "end").Post(cli.Context)
return false return false
} }
line = cli.lines[cli.which] line = cli.lines[cli.which]
@ -60,7 +61,7 @@ func (cli *CLI) parse(m *ctx.Message) bool {
l, e := cli.bio.ReadString('\n') l, e := cli.bio.ReadString('\n')
if e == io.EOF { if e == io.EOF {
cli.exit = true cli.exit = true
m.Spawn(cli.target).Set("detail", "end").Post(cli.Context) m.Spawn(cli.Context).Set("detail", "end").Post(cli.Context)
return false return false
} }
m.Assert(e) m.Assert(e)
@ -98,17 +99,28 @@ func (cli *CLI) parse(m *ctx.Message) bool {
} }
} }
if r := rune(ls[i][0]); r == '$' || r == '_' || (!unicode.IsNumber(r) && !unicode.IsLetter(r)) { if len(ls[i]) > 0 && !cli.test {
if c, ok := cli.alias[string(r)]; ok { if r := rune(ls[i][0]); r == '$' || r == '_' || (!unicode.IsNumber(r) && !unicode.IsLetter(r)) {
if i == 0 { if c, ok := cli.alias[string(r)]; ok {
if msg.Add("detail", c); len(ls[i]) == 1 { if i == 0 {
continue if msg.Add("detail", c); len(ls[i]) == 1 {
continue
}
ls[i] = ls[i][1:]
} else if len(ls[i]) > 1 && !cli.test {
key := ls[i][1:]
switch c {
case "config", "cache":
if cli.Context.Has(key, c) {
ls[i] = m.Cap(key)
break
}
msg := m.Spawn(cli.target)
m.Assert(msg.Exec(c, key))
ls[i] = msg.Get("result")
}
} }
ls[i] = ls[i][1:]
} else if len(ls[i]) > 1 {
msg := m.Spawn(cli.target)
m.Assert(msg.Exec(c, ls[i][1:]))
ls[i] = msg.Get("result")
} }
} }
} }
@ -272,10 +284,9 @@ func (cli *CLI) Start(m *ctx.Message, arg ...string) bool {
} }
cli.Sessions["aaa"] = msg cli.Sessions["aaa"] = msg
} }
} else if len(arg) > 0 { } else if len(arg) > 0 && arg[0] == "stdout" {
m.Cap("stream", "stdout") m.Cap("stream", "stdout")
m.Cap("next", "source "+m.Conf("init.sh")) m.Cap("next", "source "+m.Conf("init.sh"))
cli.Context.Master(cli.Context)
cli.bio = bufio.NewReader(os.Stdin) cli.bio = bufio.NewReader(os.Stdin)
cli.out = os.Stdout cli.out = os.Stdout
cli.Caches["level"] = &ctx.Cache{Name: "操作目标", Value: "0", Help: "操作目标"} cli.Caches["level"] = &ctx.Cache{Name: "操作目标", Value: "0", Help: "操作目标"}
@ -287,9 +298,6 @@ func (cli *CLI) Start(m *ctx.Message, arg ...string) bool {
m.Cap("stream", "file") m.Cap("stream", "file")
cli.bio = bufio.NewReader(stream.(io.ReadWriteCloser)) cli.bio = bufio.NewReader(stream.(io.ReadWriteCloser))
} }
m.Capi("level", 1)
defer m.Capi("level", -1)
cli.test = m.Has("test") cli.test = m.Has("test")
cli.save = m.Has("save") cli.save = m.Has("save")
} }
@ -340,7 +348,6 @@ func (cli *CLI) Start(m *ctx.Message, arg ...string) bool {
return cli.exit == false return cli.exit == false
}) })
m.Cap("status", "close")
return !cli.save return !cli.save
} }
@ -353,7 +360,6 @@ func (cli *CLI) Close(m *ctx.Message, arg ...string) bool {
case m.Source(): case m.Source():
if m.Name == "aaa" { if m.Name == "aaa" {
msg := m.Spawn(cli.Context) msg := m.Spawn(cli.Context)
msg.Master(cli.Context)
if !cli.Context.Close(msg, arg...) { if !cli.Context.Close(msg, arg...) {
return false return false
} }
@ -381,8 +387,9 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心",
"source": &ctx.Command{Name: "source file", Help: "运行脚本", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { "source": &ctx.Command{Name: "source file", Help: "运行脚本", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
f, e := os.Open(arg[0]) // {{{ f, e := os.Open(arg[0]) // {{{
m.Assert(e) m.Assert(e)
m.Put("option", "file", f).Start(key, "脚本文件") m.Put("option", "file", f).Start(fmt.Sprintf("%s(%d)", key, Pulse.Capi("level", 1)), "脚本文件")
<-m.Target().Exit <-m.Target().Exit
Pulse.Capi("level", -1)
// }}} // }}}
}}, }},
"return": &ctx.Command{Name: "return result...", Help: "结束脚本", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { "return": &ctx.Command{Name: "return result...", Help: "结束脚本", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
@ -394,18 +401,55 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心",
} }
// }}} // }}}
}}, }},
"if": &ctx.Command{Name: "if a [ == | != ] b", Help: "条件语句", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { "if": &ctx.Command{Name: "if a [ == | != ] b", Help: "条件语句",
Formats: map[string]int{"~": 0, "!~": 0, "==": 0, "!=": 0, "-z": 0, "-n": 0, "-e": 0, "-f": 0, "-d": 0},
Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
cli, ok := m.Source().Server.(*CLI) // {{{
m.Assert(ok)
run := false
switch {
case m.Has("-e"):
_, e := os.Stat(arg[0])
run = e == nil
case m.Has("-f"):
info, e := os.Stat(arg[0])
run = e == nil && !info.IsDir()
case m.Has("-d"):
info, e := os.Stat(arg[0])
run = e == nil && info.IsDir()
case m.Has("-z"):
run = len(arg) == 0 || len(arg[0]) == 0
case m.Has("-n"):
run = len(arg) > 0 && len(arg[0]) > 0
case m.Has("=="):
run = arg[0] == arg[1]
case m.Has("!="):
run = arg[0] != arg[1]
case m.Has("~"):
m, e := regexp.MatchString(arg[1], arg[0])
run = m && e == nil
case m.Has("!~"):
m, e := regexp.MatchString(arg[1], arg[0])
run = !m || e != nil
}
if !run {
m.Add("option", "test")
}
m.Target(m.Source())
m.Put("option", "file", cli.bio).Start(key, "条件语句")
<-m.Target().Exit
// }}}
}},
"else": &ctx.Command{Name: "else", Help: "条件切换", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
cli, ok := m.Source().Server.(*CLI) // {{{ cli, ok := m.Source().Server.(*CLI) // {{{
m.Assert(ok) m.Assert(ok)
cli.test = !cli.test
if arg[1] == "==" && arg[0] != arg[2] {
m.Add("option", "test")
}
if arg[1] == "!=" && arg[0] == arg[2] {
m.Add("option", "test")
}
m.Put("option", "file", cli.bio).Start(key, "条件语句")
<-m.Target().Exit
// }}} // }}}
}}, }},
"for": &ctx.Command{Name: "for var in list", Help: "循环语句", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { "for": &ctx.Command{Name: "for var in list", Help: "循环语句", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
@ -429,11 +473,30 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心",
// }}} // }}}
}}, }},
"var": &ctx.Command{Name: "var a [= b]", Help: "定义变量", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { "var": &ctx.Command{Name: "var a [= b]", Help: "定义变量", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
cli, ok := m.Source().Server.(*CLI)
if m.Assert(ok); cli.test {
return
}
val := "" val := ""
if len(arg) > 2 { if len(arg) > 2 {
val = arg[2] val = arg[2]
} }
m.Cap(arg[0], arg[0], val, "临时变量") m.Assert(!m.Source().Has(arg[0], "cache"))
m.Spawn(m.Source()).Cap(arg[0], arg[0], val, "临时变量")
}},
"let": &ctx.Command{Name: "let a [=] b", Help: "设置变量", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
cli, ok := m.Source().Server.(*CLI)
if m.Assert(ok); cli.test {
return
}
val := arg[1]
if len(arg) > 2 {
val = arg[2]
}
m.Spawn(m.Source()).Cap(arg[0], val)
}}, }},
"function": &ctx.Command{Name: "function name", Help: "定义函数", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { "function": &ctx.Command{Name: "function name", Help: "定义函数", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
cli, ok := m.Source().Server.(*CLI) // {{{ cli, ok := m.Source().Server.(*CLI) // {{{
@ -465,39 +528,39 @@ var Index = &ctx.Context{Name: "cli", Help: "管理中心",
} }
// }}} // }}}
}}, }},
"remote": &ctx.Command{Name: "remote [send args...]|[[master|slaver] listen|dial address protocol]", Help: "建立远程连接", // "remote": &ctx.Command{Name: "remote [send args...]|[[master|slaver] listen|dial address protocol]", Help: "建立远程连接",
Formats: map[string]int{"send": -1, "master": 0, "slaver": 0, "listen": 1, "dial": 1}, // Formats: map[string]int{"send": -1, "master": 0, "slaver": 0, "listen": 1, "dial": 1},
Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { // Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
action := "dial" // {{{ // action := "dial" // {{{
if m.Has("listen") { // if m.Has("listen") {
action = "listen" // action = "listen"
} // }
//
msg := m.Find(m.Get("args"), true) // msg := m.Find(m.Get("args"), true)
//
if m.Has("master") { // if m.Has("master") {
msg.Template = msg.Spawn(msg.Source()).Add("option", "master") // msg.Template = msg.Spawn(msg.Source()).Add("option", "master")
} // }
msg.Cmd(action, m.Get(action)) // msg.Cmd(action, m.Get(action))
//
}}, // }}} // }}, // }}}
"open": &ctx.Command{Name: "open [master|slaver] [script [log]]", Help: "建立远程连接", // "open": &ctx.Command{Name: "open [master|slaver] [script [log]]", Help: "建立远程连接",
Options: map[string]string{"master": "主控终端", "slaver": "被控终端", "args": "启动参数", "io": "读写流"}, // Options: map[string]string{"master": "主控终端", "slaver": "被控终端", "args": "启动参数", "io": "读写流"},
Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { // Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
m.Start(fmt.Sprintf("PTS%d", m.Capi("nterm")), "管理终端", "void.sh") // {{{ // m.Start(fmt.Sprintf("PTS%d", m.Capi("nterm")), "管理终端", "void.sh") // {{{
// }}} // // }}}
}}, // }},
"master": &ctx.Command{Name: "open [master|slaver] [script [log]]", Help: "建立远程连接", // "master": &ctx.Command{Name: "open [master|slaver] [script [log]]", Help: "建立远程连接",
Options: map[string]string{"master": "主控终端", "slaver": "被控终端", "args": "启动参数", "io": "读写流"}, // Options: map[string]string{"master": "主控终端", "slaver": "被控终端", "args": "启动参数", "io": "读写流"},
Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { // Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
_, ok := c.Server.(*CLI) // {{{ // _, ok := c.Server.(*CLI) // {{{
m.Assert(ok, "模块类型错误") // m.Assert(ok, "模块类型错误")
m.Assert(m.Target() != c, "模块是主控模块") // m.Assert(m.Target() != c, "模块是主控模块")
//
msg := m.Spawn(c) // msg := m.Spawn(c)
msg.Start(fmt.Sprintf("PTS%d", Pulse.Capi("nterm")), arg[0], arg[1:]...) // msg.Start(fmt.Sprintf("PTS%d", Pulse.Capi("nterm")), arg[0], arg[1:]...)
// }}} // // }}}
}}, // }},
}, },
Index: map[string]*ctx.Context{ Index: map[string]*ctx.Context{
"void": &ctx.Context{Name: "void", "void": &ctx.Context{Name: "void",

78
src/context/ctx.go
View File

@ -149,6 +149,7 @@ func (c *Context) Begin(m *Message) *Context { // {{{
// }}} // }}}
func (c *Context) Start(m *Message) bool { // {{{ func (c *Context) Start(m *Message) bool { // {{{
if m != c.Requests[0] { if m != c.Requests[0] {
c.Requests, m.Index = append(c.Requests, m), len(c.Requests)+1 c.Requests, m.Index = append(c.Requests, m), len(c.Requests)+1
} }
@ -169,7 +170,7 @@ func (c *Context) Start(m *Message) bool { // {{{
// }}} // }}}
func (c *Context) Close(m *Message, arg ...string) bool { // {{{ func (c *Context) Close(m *Message, arg ...string) bool { // {{{
m.Log("close", c, "%v", arg) m.Log("close", c, "%d:%d %v", len(m.source.Sessions), len(m.target.Historys), arg)
if m.target == c { if m.target == c {
if m.Index == 0 { if m.Index == 0 {
@ -240,12 +241,25 @@ func (c *Context) Master(s ...*Context) *Context { // {{{
} }
// }}} // }}}
func (c *Context) Has(key string) bool { // {{{ func (c *Context) Has(key ...string) bool { // {{{
if _, ok := c.Caches[key]; ok { switch len(key) {
return true case 1:
} if _, ok := c.Caches[key[0]]; ok {
if _, ok := c.Configs[key]; ok { return true
return true }
if _, ok := c.Configs[key[0]]; ok {
return true
}
case 2:
if _, ok := c.Caches[key[0]]; ok && key[1] == "cache" {
return true
}
if _, ok := c.Configs[key[0]]; ok && key[1] == "config" {
return true
}
if _, ok := c.Commands[key[0]]; ok && key[1] == "command" {
return true
}
} }
return false return false
} }
@ -494,8 +508,7 @@ func (m *Message) Log(action string, ctx *Context, str string, arg ...interface{
} }
info := fmt.Sprintf("%s", ctx.Name) info := fmt.Sprintf("%s", ctx.Name)
// name := fmt.Sprintf("%s->%s", m.source.Name, m.target.Name) name := fmt.Sprintf("%s->%s", m.source.Name, m.target.Name)
name := fmt.Sprintf("%s:%s->%s.%d", m.source.Name, m.Name, m.target.Name, m.Index)
if m.Name != "" { if m.Name != "" {
name = fmt.Sprintf("%s:%s->%s.%d", m.source.Name, m.Name, m.target.Name, m.Index) name = fmt.Sprintf("%s:%s->%s.%d", m.source.Name, m.Name, m.target.Name, m.Index)
} }
@ -912,7 +925,7 @@ func (m *Message) Exec(key string, arg ...string) string { // {{{
m.master = m.source m.master = m.source
if x, ok := s.Commands[key]; ok && x.Hand != nil && m.Check(c, "commands", key) { if x, ok := s.Commands[key]; ok && x.Hand != nil && m.Check(c, "commands", key) {
m.AssertOne(m, true, func(m *Message) { m.AssertOne(m, true, func(m *Message) {
m.Log("cmd", s, "%s %v %v", key, arg, m.Meta["option"]) m.Log("cmd", s, "%d %s %v %v", len(m.target.Historys), key, arg, m.Meta["option"])
if x.Options != nil { if x.Options != nil {
for _, v := range m.Meta["option"] { for _, v := range m.Meta["option"] {
@ -922,6 +935,9 @@ func (m *Message) Exec(key string, arg ...string) string { // {{{
} }
} }
if m.Has("args") {
m.Meta["args"] = nil
}
if x.Formats != nil { if x.Formats != nil {
for i := 0; i < len(arg); i++ { for i := 0; i < len(arg); i++ {
n, ok := x.Formats[arg[i]] n, ok := x.Formats[arg[i]]
@ -955,10 +971,10 @@ func (m *Message) Exec(key string, arg ...string) string { // {{{
} }
} }
if c.Historys == nil { if m.target.Historys == nil {
c.Historys = make([]*Message, 0, 10) m.target.Historys = make([]*Message, 0, 10)
} }
c.Historys = append(c.Historys, m) m.target.Historys = append(m.target.Historys, m)
}) })
return m.Get("result") return m.Get("result")
@ -1082,7 +1098,7 @@ func (m *Message) Conf(key string, arg ...string) string { // {{{
return m.Conf(key, arg[1]) return m.Conf(key, arg[1])
} }
m.Log("error", nil, "配置项不存在") m.Log("error", nil, "%s 配置项不存在", key)
return "" return ""
} }
@ -1120,8 +1136,10 @@ func (m *Message) Cap(key string, arg ...string) string { // {{{
} else { } else {
x.Value = arg[0] x.Value = arg[0]
} }
m.Log("debug", s, "%s %s", x.Name, x.Value)
return x.Value return x.Value
case 0: case 0:
m.Log("debug", s, "%s %s", x.Name, x.Value)
if x.Hand != nil { if x.Hand != nil {
return x.Hand(m, x) return x.Hand(m, x)
} }
@ -1141,7 +1159,7 @@ func (m *Message) Cap(key string, arg ...string) string { // {{{
return m.Cap(key, arg[1]) return m.Cap(key, arg[1])
} }
m.Log("error", nil, "缓存项不存在") m.Log("error", nil, "%s 缓存项不存在", key)
return "" return ""
} }
@ -1328,10 +1346,14 @@ var Index = &Context{Name: "ctx", Help: "模块中心",
// }}} // }}}
}}, }},
"context": &Command{Name: "context [home] [[find|search] name] [info|list|show|spawn|start|switch|close][args]", Help: "查找并操作模块，\n查找起点root:根模块、back:父模块、home:本模块，\n查找方法find:路径匹配、search:模糊匹配，\n查找对象name:支持点分和正则，\n操作类型show:显示信息、switch:切换为当前、start:启动模块、spawn:分裂子模块，args:启动参数", "context": &Command{Name: "context back|[[home] [find|search] name] [info|list|show|spawn|start|switch|close][args]", Help: "查找并操作模块，\n查找起点root:根模块、back:父模块、home:本模块，\n查找方法find:路径匹配、search:模糊匹配，\n查找对象name:支持点分和正则，\n操作类型show:显示信息、switch:切换为当前、start:启动模块、spawn:分裂子模块，args:启动参数",
Formats: map[string]int{"back": 0, "home": 0, "find": 1, "search": 1, "info": 1, "list": 0, "show": 0, "close": 0, "switch": 0, "start": 0, "spawn": 0}, Formats: map[string]int{"back": 0, "home": 0, "find": 1, "search": 1, "info": 1, "list": 0, "show": 0, "close": 0, "switch": 0, "start": 0, "spawn": 0},
Hand: func(m *Message, c *Context, key string, arg ...string) { Hand: func(m *Message, c *Context, key string, arg ...string) {
root := !m.Has("home") // {{{ if m.Has("back") { // {{{
m.target = m.source
return
}
root := !m.Has("home")
ms := []*Message{} ms := []*Message{}
switch { switch {
@ -1355,10 +1377,10 @@ var Index = &Context{Name: "ctx", Help: "模块中心",
} }
for _, v := range ms { for _, v := range ms {
v.Meta = m.Meta // v.Meta = m.Meta
v.Data = m.Data // v.Data = m.Data
switch { switch {
case m.Has("switch"): case m.Has("switch"), m.Has("back"):
m.target = v.target m.target = v.target
case m.Has("spawn"): case m.Has("spawn"):
v.Set("detail", arg[2:]...).target.Spawn(v, arg[0], arg[1]).Begin(v) v.Set("detail", arg[2:]...).target.Spawn(v, arg[0], arg[1]).Begin(v)
@ -1428,9 +1450,9 @@ var Index = &Context{Name: "ctx", Help: "模块中心",
return true return true
}) })
case len(arg) > 0 && v != m: case len(arg) > 0 && v != m:
v.Meta = m.Meta
v.Cmd(arg...) v.Cmd(arg...)
// m.Meta = v.Meta m.Meta = v.Meta
// m.target = target
default: default:
m.target = v.target m.target = v.target
} }
@ -1610,12 +1632,24 @@ var Index = &Context{Name: "ctx", Help: "模块中心",
m.Cap(arg[0], "") m.Cap(arg[0], "")
} }
if m.source == m.source.master {
m.source, m.target = m.target, m.source
}
m.Echo("%s", m.Cap(arg[0])) m.Echo("%s", m.Cap(arg[0]))
case 2: case 2:
if m.source == m.source.master {
m.source, m.target = m.target, m.source
}
m.Cap(arg[0], arg[1]) m.Cap(arg[0], arg[1])
case 3: case 3:
if m.source == m.source.master {
m.source, m.target = m.target, m.source
}
m.Cap(arg[0], arg[2]) m.Cap(arg[0], arg[2])
case 4: case 4:
if m.source == m.source.master {
m.source, m.target = m.target, m.source
}
m.Cap(arg[0], arg[1:]...) m.Cap(arg[0], arg[1:]...)
} }
// }}} // }}}

7
src/context/nfs/nfs.go
View File

@ -127,16 +127,17 @@ var Index = &ctx.Context{Name: "nfs", Help: "存储中心",
} }
defer f.Close() defer f.Close()
m.Meta = nil
size := 1024 size := 1024
if len(arg) > 1 { if len(arg) > 1 {
if s, e := strconv.Atoi(arg[1]); e == nil { if s, e := strconv.Atoi(arg[1]); e == nil {
size = s size = s
} }
} }
buf := make([]byte, size) buf := make([]byte, size)
f.Read(buf) l, e := f.Read(buf)
m.Echo(string(buf)) m.Echo(string(buf[:l]))
m.Log("info", nil, "read %d", l)
}}, }},
"save": &ctx.Command{Name: "save file string...", Help: "写入文件, string: 写入内容, pos: 写入位置", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { "save": &ctx.Command{Name: "save file string...", Help: "写入文件, string: 写入内容, pos: 写入位置", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
f, e := os.Create(arg[0]) f, e := os.Create(arg[0])

3
src/context/ssh/ssh.go
View File

@ -133,6 +133,9 @@ var Index = &ctx.Context{Name: "ssh", Help: "集群中心",
fmt.Fprintf(ssh.Writer, "detail: %v\n", v) fmt.Fprintf(ssh.Writer, "detail: %v\n", v)
} }
for _, k := range m.Meta["option"] { for _, k := range m.Meta["option"] {
if k == "args" {
continue
}
for _, v := range m.Meta[k] { for _, v := range m.Meta[k] {
fmt.Fprintf(ssh.Writer, "%s: %s\n", k, v) fmt.Fprintf(ssh.Writer, "%s: %s\n", k, v)
} }