Documentation
¶
Index ¶
- Variables
- type MUX
- type WEB
- func (web *WEB) Begin(m *ctx.Message, arg ...string) ctx.Server
- func (web *WEB) Close(m *ctx.Message, arg ...string) bool
- func (web *WEB) HandleCmd(m *ctx.Message, key string, cmd *ctx.Command)
- func (web *WEB) Merge(m *ctx.Message, uri string, arg ...string) string
- func (web *WEB) ServeHTTP(w http.ResponseWriter, r *http.Request)
- func (web *WEB) Spawn(m *ctx.Message, c *ctx.Context, arg ...string) ctx.Server
- func (web *WEB) Start(m *ctx.Message, arg ...string) bool
Constants ¶
This section is empty.
Variables ¶
View Source
var Index = &ctx.Context{Name: "web", Help: "应用中心", Caches: map[string]*ctx.Cache{ "nserve": &ctx.Cache{Name: "nserve", Value: "0", Help: "主机数量"}, "nroute": &ctx.Cache{Name: "nroute", Value: "0", Help: "路由数量"}, }, Configs: map[string]*ctx.Config{ "login_right": &ctx.Config{Name: "login_right", Value: "1", Help: "缓存大小"}, "multipart_bsize": &ctx.Config{Name: "multipart_bsize", Value: "102400", Help: "缓存大小"}, "body_response": &ctx.Config{Name: "body_response", Value: "response", Help: "响应缓存"}, "method": &ctx.Config{Name: "method", Value: "GET", Help: "请求方法"}, "brow_home": &ctx.Config{Name: "brow_home", Value: "http://localhost:9094", Help: "服务"}, "directory": &ctx.Config{Name: "directory", Value: "usr", Help: "服务目录"}, "address": &ctx.Config{Name: "address", Value: ":9094", Help: "服务地址"}, "protocol": &ctx.Config{Name: "protocol", Value: "http", Help: "服务协议"}, "cert": &ctx.Config{Name: "cert", Value: "etc/cert.pem", Help: "路由数量"}, "key": &ctx.Config{Name: "key", Value: "etc/key.pem", Help: "路由数量"}, "web_site": &ctx.Config{Name: "web_site", Value: []interface{}{ map[string]interface{}{"_name": "MDN", "site": "https://developer.mozilla.org"}, map[string]interface{}{"_name": "github", "site": "https://github.com"}, }, Help: "web_site"}, "template_dir": &ctx.Config{Name: "template_dir", Value: "usr/template", Help: "模板路径"}, "componet_context": &ctx.Config{Name: "component_context", Value: "nfs", Help: "默认模块"}, "componet_command": &ctx.Config{Name: "component_command", Value: "pwd", Help: "默认命令"}, "componet_group": &ctx.Config{Name: "component_group", Value: "index", Help: "默认组件"}, "componet": &ctx.Config{Name: "componet", Value: map[string]interface{}{ "login": []interface{}{ map[string]interface{}{"name": "head", "template": "head"}, map[string]interface{}{"name": "userinfo", "help": "userinfo", "context": "aaa", "command": "userinfo", "arguments": []interface{}{"@sessid"}, }, map[string]interface{}{"name": "login", "help": "login", "template": "componet", "context": "aaa", "command": "login", "arguments": []interface{}{"@username", "@password"}, "inputs": []interface{}{ map[string]interface{}{"type": "text", "name": "username", "label": "username"}, map[string]interface{}{"type": "password", "name": "password", "label": "password"}, map[string]interface{}{"type": "button", "label": "login"}, }, "display_append": "", "display_result": "", "result_reload": "10", }, map[string]interface{}{"name": "tail", "template": "tail"}, }, "index": []interface{}{ map[string]interface{}{"name": "head", "template": "head"}, map[string]interface{}{"name": "clipbaord", "help": "clipbaord", "template": "clipboard"}, map[string]interface{}{"name": "prompt", "help": "prompt", "template": "componet", "context": "nfs.stdio", "command": "prompt", "arguments": []interface{}{"@string"}, "inputs": []interface{}{ map[string]interface{}{"type": "text", "name": "string", "label": "string"}, map[string]interface{}{"type": "button", "label": "refresh"}, }, }, map[string]interface{}{"name": "exec", "help": "exec", "template": "componet", "context": "nfs.stdio", "command": "exec", "arguments": []interface{}{"@string"}, "inputs": []interface{}{ map[string]interface{}{"type": "text", "name": "string"}, }, }, map[string]interface{}{"name": "show", "help": "show", "template": "componet", "context": "nfs.stdio", "command": "show", "arguments": []interface{}{"\n", "@string", "\n"}, "inputs": []interface{}{ map[string]interface{}{"type": "text", "name": "string", "label": "string"}, map[string]interface{}{"type": "button", "label": "refresh"}, }, }, map[string]interface{}{"name": "buffer", "help": "buffer", "template": "componet", "context": "cli", "command": "tmux", "arguments": []interface{}{"buffer"}, "inputs": []interface{}{ map[string]interface{}{"type": "text", "name": "limit", "label": "limit", "value": "3"}, map[string]interface{}{"type": "text", "name": "index", "label": "index"}, map[string]interface{}{"type": "button", "label": "refresh"}, }, }, map[string]interface{}{"name": "command", "help": "command", "template": "componet", "context": "cli.shell1", "command": "source", "arguments": []interface{}{"@cmd"}, "inputs": []interface{}{ map[string]interface{}{"type": "text", "name": "cmd", "value": "pwd", "class": "cmd", "clipstack": "clistack", }, }, }, map[string]interface{}{"name": "time", "help": "time", "template": "componet", "context": "cli", "command": "time", "arguments": []interface{}{"@string"}, "inputs": []interface{}{ map[string]interface{}{"type": "text", "name": "time_format", "label": "format", "value": "2006-01-02 15:04:05", }, map[string]interface{}{"type": "text", "name": "string", "label": "string"}, map[string]interface{}{"type": "button", "label": "refresh"}, }, }, map[string]interface{}{"name": "json", "help": "json", "template": "componet", "context": "nfs", "command": "json", "arguments": []interface{}{"@string"}, "inputs": []interface{}{ map[string]interface{}{"type": "text", "name": "string", "label": "string"}, map[string]interface{}{"type": "button", "label": "refresh"}, }, }, map[string]interface{}{"name": "dir", "help": "dir", "template": "componet", "context": "nfs", "command": "dir", "arguments": []interface{}{"@dir", "dir_deep", "no", "dir_name", "name", "dir_info", "", "dir_link", "<a class='download' data-type='%s'>%s<a>", }, "form_type": "upload", "inputs": []interface{}{ map[string]interface{}{"type": "text", "name": "dir", "label": "dir"}, map[string]interface{}{"type": "choice", "name": "dir_type", "label": "dir_type", "value": "both", "choice": []interface{}{ map[string]interface{}{"name": "both", "value": "both"}, map[string]interface{}{"name": "file", "value": "file"}, map[string]interface{}{"name": "dir", "value": "dir"}, }, }, map[string]interface{}{"type": "choice", "name": "sort_field", "label": "sort_field", "value": "time", "choice": []interface{}{ map[string]interface{}{"name": "filename", "value": "filename"}, map[string]interface{}{"name": "is_dir", "value": "is_dir"}, map[string]interface{}{"name": "line", "value": "line"}, map[string]interface{}{"name": "size", "value": "size"}, map[string]interface{}{"name": "time", "value": "time"}, }, }, map[string]interface{}{"type": "choice", "name": "sort_order", "label": "sort_order", "value": "time_r", "choice": []interface{}{ map[string]interface{}{"name": "str", "value": "str"}, map[string]interface{}{"name": "str_r", "value": "str_r"}, map[string]interface{}{"name": "int", "value": "int"}, map[string]interface{}{"name": "int_r", "value": "int_r"}, map[string]interface{}{"name": "time", "value": "time"}, map[string]interface{}{"name": "time_r", "value": "time_r"}, }, }, map[string]interface{}{"type": "file", "name": "upload"}, map[string]interface{}{"type": "submit", "value": "submit"}, }, }, map[string]interface{}{"name": "web_site", "help": "web_site", "template": "componet", "context": "web", "command": "config", "arguments": []interface{}{ "web_site", "format_field", "site", "<a href='%s'>%s<a>", }, "display_result": "", }, map[string]interface{}{"name": "tail", "template": "tail"}, }, }, Help: "组件列表"}, }, Commands: map[string]*ctx.Command{ "client": &ctx.Command{Name: "client address [output [editor]]", Help: "添加浏览器配置, address: 默认地址, output: 输出路径, editor: 编辑器", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { uri, e := url.Parse(arg[0]) m.Assert(e) m.Conf("method", "method", "GET", "请求方法") m.Conf("protocol", "protocol", uri.Scheme, "服务协议") m.Conf("hostname", "hostname", uri.Host, "服务主机") dir, file := path.Split(uri.EscapedPath()) m.Conf("path", "path", dir, "服务路由") m.Conf("file", "file", file, "服务文件") m.Conf("query", "query", uri.RawQuery, "服务参数") if m.Conf("output", "output", "stdout", "文件缓存"); len(arg) > 1 { m.Conf("output", arg[1]) } if m.Conf("editor", "editor", "vim", "文件编辑器"); len(arg) > 2 { m.Conf("editor", arg[2]) } }}, "cookie": &ctx.Command{Name: "cookie [create]|[name [value]]", Help: "读写浏览器的Cookie, create: 创建cookiejar, name: 变量名, value: 变量值", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { switch len(arg) { case 0: for k, v := range m.Confv("cookie").(map[string]interface{}) { m.Echo("%s: %v\n", k, v.(*http.Cookie).Value) } case 1: if arg[0] == "create" { m.Target().Configs["cookie"] = &ctx.Config{Name: "cookie", Value: map[string]interface{}{}, Help: "cookie"} break } if v, ok := m.Confv("cookie", arg[0]).(*http.Cookie); ok { m.Echo("%s", v.Value) } default: if m.Confv("cookie") == nil { m.Target().Configs["cookie"] = &ctx.Config{Name: "cookie", Value: map[string]interface{}{}, Help: "cookie"} } if v, ok := m.Confv("cookie", arg[0]).(*http.Cookie); ok { v.Value = arg[1] } else { m.Confv("cookie", arg[0], &http.Cookie{Name: arg[0], Value: arg[1]}) } } }}, "get": &ctx.Command{Name: "get [method GET|POST] url arg...", Help: "访问服务, method: 请求方法, url: 请求地址, arg: 请求参数", Form: map[string]int{"method": 1, "headers": 2, "content_type": 1, "body": 1, "path_value": 1, "body_response": 1, "trans": 1, "parse": 1}, Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if web, ok := m.Target().Server.(*WEB); m.Assert(ok) { if m.Has("path_value") { values := []interface{}{} for _, v := range strings.Split(m.Option("path_value"), " ") { if len(v) > 1 && v[0] == '$' { values = append(values, m.Cap(v[1:])) } else { values = append(values, v) } } arg[0] = fmt.Sprintf(arg[0], values...) } method := m.Confx("method") uri := web.Merge(m, arg[0], arg[1:]...) body, _ := m.Optionv("body").(io.Reader) if method == "POST" && body == nil { if index := strings.Index(uri, "?"); index > 0 { uri, body = uri[:index], strings.NewReader(uri[index+1:]) } } req, e := http.NewRequest(method, uri, body) m.Assert(e) for i := 0; i < len(m.Meta["headers"]); i += 2 { req.Header.Set(m.Meta["headers"][i], m.Meta["headers"][i+1]) } if m.Options("content_type") { req.Header.Set("Content-Type", m.Option("content_type")) } switch cs := m.Confv("cookie").(type) { case map[string]interface{}: for _, v := range cs { req.AddCookie(v.(*http.Cookie)) } } m.Log("info", "%s %s", req.Method, req.URL) m.Echo("%s: %s\n", req.Method, req.URL) for k, v := range req.Header { m.Log("fuck", "%s: %s", k, v) } if web.Client == nil { web.Client = &http.Client{} } res, e := web.Client.Do(req) m.Assert(e) for _, v := range res.Cookies() { m.Confv("cookie", v.Name, v) m.Log("info", "set-cookie %s: %v", v.Name, v.Value) } buf, e := ioutil.ReadAll(res.Body) m.Assert(e) var result interface{} ct := res.Header.Get("Content-Type") switch { case strings.HasPrefix(ct, "application/json"): json.Unmarshal(buf, &result) if m.Has("trans") { msg := m.Spawn() msg.Put("option", "response", result) msg.Cmd("trans", "response", m.Option("trans")) m.Copy(msg, "append") m.Copy(msg, "result") return } default: result = string(buf) } m.Target().Configs[m.Confx("body_response")] = &ctx.Config{Value: result} m.Echo(string(buf)) } }}, "post": &ctx.Command{Name: "post [file fieldname filename]", Help: "post请求", Form: map[string]int{"file": 2, "content_type": 1}, Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { msg := m.Spawn() if m.Has("file") { file, e := os.Open(m.Meta["file"][1]) m.Assert(e) defer file.Close() buf := &bytes.Buffer{} writer := multipart.NewWriter(buf) writer.SetBoundary(fmt.Sprintf("\r\n--%s--\r\n", writer.Boundary())) part, e := writer.CreateFormFile(m.Option("file"), filepath.Base(m.Meta["file"][1])) m.Assert(e) io.Copy(part, file) writer.Close() msg.Optionv("body", buf) msg.Option("content_type", writer.FormDataContentType()) msg.Option("headers", "Content-Length", buf.Len()) } else if m.Option("content_type") == "json" { data := map[string]interface{}{} for i := 1; i < len(arg)-1; i += 2 { switch arg[i+1] { case "false": data[arg[i]] = false case "true": data[arg[i]] = true default: if len(arg[i+1]) > 1 && arg[i+1][0] == '$' { data[arg[i]] = m.Cap(arg[i+1][1:]) } else { data[arg[i]] = arg[i+1] } } } b, e := json.Marshal(data) m.Assert(e) msg.Optionv("body", bytes.NewReader(b)) msg.Option("content_type", "application/json") arg = arg[:1] } else if m.Option("content_type") == "json_fmt" { data := []interface{}{} for _, v := range arg[2:] { if len(v) > 1 && v[0] == '$' { v = m.Cap(v[1:]) } else if len(v) > 1 && v[0] == '@' { v = m.Cap(v[1:]) } data = append(data, v) } msg.Optionv("body", strings.NewReader(fmt.Sprintf(arg[1], data...))) msg.Option("content_type", "application/json") arg = arg[:1] } else { msg.Option("content_type", "application/x-www-form-urlencoded") } msg.Cmd("get", "method", "POST", arg) m.Copy(msg, "result").Copy(msg, "append") }}, "brow": &ctx.Command{Name: "brow url", Help: "浏览网页", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { url := m.Confx("brow_home", arg, 0) switch runtime.GOOS { case "windows": m.Sess("cli").Cmd("system", "explorer", url) case "darwin": m.Sess("cli").Cmd("system", "open", url) case "linux": m.Spawn().Cmd("open", url) } }}, "serve": &ctx.Command{Name: "serve [directory [address [protocol [cert [key]]]]", Help: "启动服务, directory: 服务路径, address: 服务地址, protocol: 服务协议(https/http), cert: 服务证书, key: 服务密钥", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { m.Set("detail", arg...).Target().Start(m) }}, "route": &ctx.Command{Name: "route index content [help]", Help: "添加路由响应, index: 路由, context: 响应, help: 说明", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if mux, ok := m.Target().Server.(MUX); m.Assert(ok) { switch len(arg) { case 0: for k, v := range m.Target().Commands { if k[0] == '/' { m.Add("append", "route", k) m.Add("append", "name", v.Name) } } m.Sort("route").Table() case 1: for k, v := range m.Target().Commands { if k == arg[0] { m.Echo("%s: %s\n%s", k, v.Name, v.Help) } } default: help := "dynamic route" if len(arg) > 2 { help = arg[2] } hand := func(m *ctx.Message, c *ctx.Context, key string, a ...string) { w := m.Optionv("response").(http.ResponseWriter) template.Must(template.New("temp").Parse(arg[1])).Execute(w, m) } if s, e := os.Stat(arg[1]); e == nil { if s.IsDir() { mux.Handle(arg[0]+"/", http.StripPrefix(arg[0], http.FileServer(http.Dir(arg[1])))) } else if strings.HasSuffix(arg[1], ".shy") { hand = func(m *ctx.Message, c *ctx.Context, key string, a ...string) { msg := m.Sess("cli").Cmd("source", arg[1]) m.Copy(msg, "result").Copy(msg, "append") } } else { hand = func(m *ctx.Message, c *ctx.Context, key string, a ...string) { w := m.Optionv("response").(http.ResponseWriter) template.Must(template.ParseGlob(arg[1])).Execute(w, m) } } } if _, ok := m.Target().Commands[arg[0]]; ok { m.Target().Commands[arg[0]].Help = help m.Target().Commands[arg[0]].Name = arg[1] m.Target().Commands[arg[0]].Hand = hand } else { cmd := &ctx.Command{Name: arg[1], Help: help, Hand: hand} m.Target().Commands[arg[0]] = cmd mux.HandleCmd(m, arg[0], cmd) } } } }}, "template": &ctx.Command{Name: "template [file [directory]]|[name [content]]", Help: "添加模板, content: 模板内容, directory: 模板目录", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if web, ok := m.Target().Server.(*WEB); m.Assert(ok) { if len(arg) == 0 { for _, v := range web.template.Templates() { m.Add("append", "name", v.Name()) } m.Sort("name").Table() return } if web.template == nil { web.template = template.New("render").Funcs(ctx.CGI) } dir := path.Join(m.Confx("template_dir", arg, 1), arg[0]) if t, e := web.template.ParseGlob(dir); e == nil { web.template = t } else { m.Log("info", "%s", e) if len(arg) > 1 { web.template = template.Must(web.template.New(arg[0]).Parse(arg[1])) } else { tmpl, e := web.template.Clone() m.Assert(e) tmpl.Funcs(ctx.CGI) buf := bytes.NewBuffer(make([]byte, 1024)) tmpl.ExecuteTemplate(buf, arg[0], m) m.Echo(string(buf.Bytes())) } } } }}, "componet": &ctx.Command{Name: "componet [group [order [arg...]]]", Help: "添加组件, group: 组件分组, arg...: 组件参数", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { switch len(arg) { case 0: for k, v := range m.Confv("componet").(map[string]interface{}) { for i, val := range v.([]interface{}) { value := val.(map[string]interface{}) m.Add("append", "group", k) m.Add("append", "order", i) m.Add("append", "name", value["name"]) m.Add("append", "help", value["help"]) m.Add("append", "context", value["context"]) m.Add("append", "command", value["command"]) } } m.Sort("group").Table() case 1: for i, val := range m.Confv("componet", arg[0]).([]interface{}) { value := val.(map[string]interface{}) m.Add("append", "order", i) m.Add("append", "name", value["name"]) m.Add("append", "help", value["help"]) m.Add("append", "context", value["context"]) m.Add("append", "command", value["command"]) } m.Table() case 2: value := m.Confv("componet", []interface{}{arg[0], arg[1]}).(map[string]interface{}) for k, v := range value { m.Add("append", k, v) } m.Table() default: if com, ok := m.Confv("componet", []interface{}{arg[0], arg[1]}).(map[string]interface{}); ok { for i := 2; i < len(arg)-1; i += 2 { com[arg[i]] = arg[i+1] } } else { m.Confv("componet", []interface{}{arg[0], arg[1]}, map[string]interface{}{ "name": arg[2], "help": arg[3], "context": m.Confx("componet_context", arg, 4), "command": m.Confx("componet_command", arg, 5), }) break } } }}, "session": &ctx.Command{Name: "session", Help: "用户登录", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { sessid := m.Option("sessid") if sessid == "" && m.Options("username") && m.Options("password") { sessid = m.Sess("aaa").Cmd("login", m.Option("username"), m.Option("password")).Result(0) } if sessid == "" && m.Options("remote_addr") { sessid = m.Sess("aaa").Cmd("login", "ip", m.Option("remote_addr")).Result(0) } login := m.Sess("aaa").Cmd("login", sessid).Sess("login", false) m.Appendv("login", login) m.Echo(sessid) }}, "/upload": &ctx.Command{Name: "/upload", Help: "上传文件", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { r := m.Optionv("request").(*http.Request) f, h, e := r.FormFile("upload") m.Assert(e) defer f.Close() p := path.Join(m.Conf("directory"), m.Option("dir"), h.Filename) o, e := os.Create(p) m.Assert(e) defer o.Close() io.Copy(o, f) m.Log("upload", "file(%d): %s", h.Size, p) m.Append("redirect", m.Option("referer")) }}, "/render": &ctx.Command{Name: "/render template", Help: "渲染模板, template: 模板名称", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) { if _, ok := m.Target().Server.(*WEB); m.Assert(ok) { accept_json := strings.HasPrefix(m.Option("accept"), "application/json") list := []interface{}{} tmpl := template.New("render").Funcs(ctx.CGI) tmpl.ParseGlob(fmt.Sprintf("%s/context/usr/template/common/base.tmpl", os.Getenv("HOME"))) w := m.Optionv("response").(http.ResponseWriter) if accept_json { w.Header().Add("Content-Type", "application/json") } else { w.Header().Add("Content-Type", "text/html") } if m.Option("componet_group") == "" { m.Option("componet_group", m.Conf("componet_group")) } group := m.Option("componet_group") order := m.Option("componet_order") right := group == "login" if !right { right = !m.Confs("login_right") } login := m login = nil if !right { login = m.Spawn().Cmd("session").Appendv("login").(*ctx.Message) } if !right && login != nil { if role := login.Confv("right", []interface{}{"right", "role"}); role != nil && role.(string) == "root" { right = true } } if !right && login != nil { if role := login.Confv("right", []interface{}{group, "right", "role"}); role != nil && role.(string) == "owner" { right = true } } for count := 0; count == 0; group, order, right = "login", "", true { for _, v := range m.Confv("componet", group).([]interface{}) { val := v.(map[string]interface{}) if order != "" && val["name"].(string) != order { continue } order_right := right if !order_right && login != nil { if role := login.Confv("right", []interface{}{group, val["name"], "right", "role"}); role != nil && role.(string) == "share" { order_right = true } } if !order_right { continue } context := m.Cap("module") if val["context"] != nil { context = val["context"].(string) } msg := m.Find(context) if msg == nil { if !accept_json && val["template"] != nil { m.Assert(tmpl.ExecuteTemplate(w, val["template"].(string), m)) } continue } count++ msg.Option("componet_order", val["name"].(string)) for k, v := range val { if msg.Option(k) != "" { continue } switch value := v.(type) { case []string: msg.Add("option", k, value) case string: msg.Add("option", k, value) default: msg.Put("option", k, value) } } if val["inputs"] != nil { for _, v := range val["inputs"].([]interface{}) { value := v.(map[string]interface{}) if value["name"] != nil && msg.Option(value["name"].(string)) == "" { msg.Add("option", value["name"].(string), value["value"]) } } } args := []string{} if val["arguments"] != nil { for _, v := range val["arguments"].([]interface{}) { switch value := v.(type) { case string: args = append(args, msg.Parse(value)) } } } if val["command"] != nil { msg.Cmd(val["command"], args) } if accept_json { list = append(list, msg.Meta) } else if val["template"] != nil { m.Assert(tmpl.ExecuteTemplate(w, val["template"].(string), msg)) } if msg.Detail(0) == "login" && msg.Appends("sessid") { http.SetCookie(w, &http.Cookie{Name: "sessid", Value: msg.Append("sessid")}) m.Append("page_refresh", "10") return } } } if accept_json { en := json.NewEncoder(w) en.SetIndent("", " ") en.Encode(list) } } }}, }, }
Functions ¶
This section is empty.
Types ¶
type MUX ¶
Source Files
Click to show internal directories.
Click to hide internal directories.