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

mac opt web

Browse Source
This commit is contained in:
shaoying 2018-10-15 07:26:04 +08:00
parent 933ca60296
commit 71cf3a7e3a
22 changed files with 694 additions and 578 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Makefile
View File

@ -1,5 +1,5 @@
BENCH=src/example/bench.go
BENCH=src/examples/bench.go
install:
@go get github.com/go-sql-driver/mysql

2
src/contexts/aaa/aaa.go
View File

@ -1,7 +1,7 @@
package aaa
import (
"contexts"
"contexts/ctx"
"crypto"
"crypto/aes"
"crypto/cipher"

2
src/contexts/cli/cli.go
View File

@ -1,7 +1,7 @@
package cli // {{{
// }}}
import ( // {{{
"contexts"
"contexts/ctx"
"fmt"
"regexp"

6
src/contexts/ctx.go → src/contexts/ctx/ctx.go
View File

@ -334,6 +334,10 @@ func (c *Context) Start(m *Message, arg ...string) bool {
m.Sess("log", m.Sess("log"))
m.Sess("lex", m.Sess("lex"))
if c.Name == "aaa" {
debug.PrintStack()
panic(1)
}
running := make(chan bool)
go m.TryCatch(m, true, func(m *Message) {
@ -3393,8 +3397,6 @@ func Start(args ...string) {
Pulse.Options("log", true)
log := Pulse.Sess("log", false)
log.target.Start(log)
aaa := Pulse.Sess("aaa", false)
aaa.target.Start(aaa, "lark")
Pulse.Options("terminal_color", true)
Pulse.Sess("cli", false).Cmd("source", "stdio")

0
src/contexts/ctx_test.go → src/contexts/ctx/ctx_test.go
View File

49
src/contexts/gdb/gdb.go Normal file
View File

@ -0,0 +1,49 @@
package gdb
import (
"contexts/ctx"
)
type GDB struct {
*ctx.Context
}
func (gdb *GDB) Spawn(m *ctx.Message, c *ctx.Context, arg ...string) ctx.Server { // {{{
c.Caches = map[string]*ctx.Cache{}
c.Configs = map[string]*ctx.Config{}
s := new(GDB)
s.Context = c
return s
}
// }}}
func (gdb *GDB) Begin(m *ctx.Message, arg ...string) ctx.Server { // {{{
return gdb
}
// }}}
func (gdb *GDB) Start(m *ctx.Message, arg ...string) bool { // {{{
return false
}
// }}}
func (gdb *GDB) Close(m *ctx.Message, arg ...string) bool { // {{{
switch gdb.Context {
case m.Target():
case m.Source():
}
return true
}
var Index = &ctx.Context{Name: "gdb", Help: "调试中心",
Caches: map[string]*ctx.Cache{},
Configs: map[string]*ctx.Config{},
Commands: map[string]*ctx.Command{},
}
func init() {
gdb := &GDB{}
gdb.Context = Index
ctx.Index.Register(Index, gdb)
}

2
src/contexts/lex/lex.go
View File

@ -1,7 +1,7 @@
package lex // {{{
// }}}
import ( // {{{
"contexts"
"contexts/ctx"
"fmt"
"strconv"
)

2
src/contexts/log/log.go
View File

@ -1,7 +1,7 @@
package log // {{{
// }}}
import ( // {{{
"contexts"
"contexts/ctx"
"fmt"
"os"
"strings"

2
src/contexts/mdb/mdb.go
View File

@ -2,7 +2,7 @@ package mdb // {{{
// }}}
import ( // {{{
"bufio"
"contexts"
"contexts/ctx"
"database/sql"
"encoding/json"
_ "github.com/go-sql-driver/mysql"

2
src/contexts/nfs/nfs.go
View File

@ -2,7 +2,7 @@ package nfs
import (
"bufio"
"contexts"
"contexts/ctx"
"encoding/json"
"errors"
"fmt"

2
src/contexts/ssh/ssh.go
View File

@ -1,7 +1,7 @@
package ssh
import (
"contexts"
"contexts/ctx"
"fmt"
"strings"
)

2
src/contexts/tcp/tcp.go
View File

@ -1,7 +1,7 @@
package tcp
import (
"contexts"
"contexts/ctx"
"crypto/tls"
"fmt"
"io"

553
src/contexts/web/web.go
View File

@ -1,27 +1,21 @@
package web
import (
"bufio"
"contexts"
"github.com/gomarkdown/markdown"
"path/filepath"
"runtime"
"bytes"
"contexts/ctx"
"encoding/json"
"encoding/xml"
"fmt"
"html/template"
"io"
"io/ioutil"
"mime/multipart"
"net/http"
"net/url"
"path"
"bytes"
"mime/multipart"
"fmt"
"io"
"os"
"os/exec"
"path"
"path/filepath"
"runtime"
"strings"
"time"
)
@ -29,15 +23,15 @@ import (
type MUX interface {
Handle(string, http.Handler)
HandleFunc(string, func(http.ResponseWriter, *http.Request))
Trans(*ctx.Message, string, func(*ctx.Message, *ctx.Context, string, ...string))
HandleCmd(*ctx.Message, string, func(*ctx.Message, *ctx.Context, string, ...string))
ServeHTTP(http.ResponseWriter, *http.Request)
}
type WEB struct {
client *http.Client
*http.ServeMux
*http.Server
client *http.Client
cookie map[string]*http.Cookie
*ctx.Context
}
@ -83,7 +77,7 @@ func (web *WEB) Merge(m *ctx.Message, uri string, arg ...string) string {
return strings.Join(adds, "")
}
func (web *WEB) Trans(m *ctx.Message, key string, hand func(*ctx.Message, *ctx.Context, string, ...string)) {
func (web *WEB) HandleCmd(m *ctx.Message, key string, hand func(*ctx.Message, *ctx.Context, string, ...string)) {
web.HandleFunc(key, func(w http.ResponseWriter, r *http.Request) {
msg := m.Spawn()
msg.TryCatch(msg, true, func(msg *ctx.Message) {
@ -121,6 +115,12 @@ func (web *WEB) Trans(m *ctx.Message, key string, hand func(*ctx.Message, *ctx.C
}
msg.Option("record_count", count)
if r.ParseForm(); len(r.PostForm) > 0 {
for k, v := range r.PostForm {
m.Log("info", "%s: %v", k, v)
}
m.Log("info", "")
}
for _, v := range r.Cookies() {
msg.Option(v.Name, v.Value)
}
@ -133,10 +133,10 @@ func (web *WEB) Trans(m *ctx.Message, key string, hand func(*ctx.Message, *ctx.C
hand(msg, msg.Target(), msg.Option("path"))
switch {
case msg.Has("directory"):
http.ServeFile(w, r, msg.Append("directory"))
case msg.Has("redirect"):
http.Redirect(w, r, msg.Append("redirect"), http.StatusFound)
case msg.Has("directory"):
http.ServeFile(w, r, msg.Append("directory"))
case msg.Has("template"):
msg.Spawn().Cmd("/render", msg.Meta["template"])
case msg.Has("append"):
@ -159,13 +159,6 @@ func (web *WEB) ServeHTTP(w http.ResponseWriter, r *http.Request) {
m.Log("info", "")
}
if r.ParseForm(); len(r.PostForm) > 0 {
for k, v := range r.PostForm {
m.Log("info", "%s: %v", k, v)
}
m.Log("info", "")
}
if r.URL.Path == "/" && m.Confs("root_index") {
http.Redirect(w, r, m.Conf("root_index"), http.StatusFound)
} else {
@ -179,61 +172,49 @@ func (web *WEB) ServeHTTP(w http.ResponseWriter, r *http.Request) {
m.Log("info", "")
}
}
func (web *WEB) Spawn(m *ctx.Message, c *ctx.Context, arg ...string) ctx.Server {
c.Caches = map[string]*ctx.Cache{}
c.Configs = map[string]*ctx.Config{}
s := new(WEB)
s.Context = c
s.cookie = web.cookie
return s
}
func (web *WEB) Begin(m *ctx.Message, arg ...string) ctx.Server {
web.Caches["route"] = &ctx.Cache{Name: "请求路径", Value: "/" + web.Context.Name + "/", Help: "请求路径"}
web.Caches["register"] = &ctx.Cache{Name: "已初始化(yes/no)", Value: "no", Help: "模块是否已初始化"}
web.Caches["master"] = &ctx.Cache{Name: "服务入口(yes/no)", Value: "no", Help: "服务入口"}
web.Caches["directory"] = &ctx.Cache{Name: "服务目录", Value: "usr", Help: "服务目录"}
if len(arg) > 0 {
m.Cap("directory", arg[0])
}
web.Configs["logheaders"] = &ctx.Config{Name: "logheaders(yes/no)", Value: "no", Help: "日志输出报文头"}
web.Configs["root_index"] = &ctx.Config{Name: "root_index", Value: "/wiki/", Help: "默认路由"}
web.Caches["directory"] = &ctx.Cache{Name: "directory", Value: m.Confx("directory", arg, 0), Help: "服务目录"}
web.Caches["route"] = &ctx.Cache{Name: "route", Value: "/" + web.Context.Name + "/", Help: "模块路由"}
web.Caches["register"] = &ctx.Cache{Name: "register(yes/no)", Value: "no", Help: "是否已初始化"}
web.Caches["master"] = &ctx.Cache{Name: "master(yes/no)", Value: "no", Help: "服务入口"}
web.ServeMux = http.NewServeMux()
if mux, ok := m.Target().Server.(MUX); ok {
for k, x := range web.Commands {
if k[0] == '/' {
mux.Trans(m, k, x.Hand)
}
}
}
return web
}
func (web *WEB) Start(m *ctx.Message, arg ...string) bool {
if len(arg) > 0 {
m.Cap("directory", arg[0])
}
m.Cap("directory", m.Confx("directory", arg, 0))
m.Travel(func(m *ctx.Message, i int) bool {
if h, ok := m.Target().Server.(http.Handler); ok && m.Cap("register") == "no" {
if h, ok := m.Target().Server.(MUX); ok && m.Cap("register") == "no" {
m.Cap("register", "yes")
m.Capi("nroute", 1)
p, i := m.Target(), 0
m.BackTrace(func(m *ctx.Message) bool {
p = m.Target()
if i++; i == 2 {
return false
}
return true
})
p := m.Target().Context()
if s, ok := p.Server.(MUX); ok {
m.Log("info", "route %s -> %s", m.Cap("route"), m.Target().Name)
m.Log("info", "route: /%s <- /%s", p.Name, m.Target().Name)
s.Handle(m.Cap("route"), http.StripPrefix(path.Dir(m.Cap("route")), h))
}
if s, ok := m.Target().Server.(MUX); ok && m.Cap("directory") != "" {
m.Log("info", "dir / -> [%s]", m.Cap("directory"))
s.Handle("/", http.FileServer(http.Dir(m.Cap("directory"))))
for k, x := range m.Target().Commands {
if k[0] == '/' {
m.Log("info", "route: %s", k)
h.HandleCmd(m, k, x.Hand)
m.Capi("nroute", 1)
}
}
if m.Cap("directory") != "" {
m.Log("info", "route: %s <- [%s]\n", m.Cap("route"), m.Cap("directory"))
h.Handle("/", http.FileServer(http.Dir(m.Cap("directory"))))
}
}
return true
@ -248,24 +229,6 @@ func (web *WEB) Start(m *ctx.Message, arg ...string) bool {
web.Configs["travel_tmpl"] = &ctx.Config{Name: "travel_tmpl", Value: "travel.html", Help: "浏览模块模板"}
web.Configs["travel_main"] = &ctx.Config{Name: "travel_main", Value: "main.html", Help: "浏览模块框架"}
web.Caches["address"] = &ctx.Cache{Name: "服务地址", Value: ":9191", Help: "服务地址"}
web.Caches["protocol"] = &ctx.Cache{Name: "服务协议", Value: "http", Help: "服务协议"}
if len(arg) > 1 {
m.Cap("address", arg[1])
}
if len(arg) > 2 {
m.Cap("protocol", arg[2])
}
m.Cap("master", "yes")
m.Cap("stream", m.Cap("address"))
m.Log("info", "address [%s]", m.Cap("address"))
m.Log("info", "protocol [%s]", m.Cap("protocol"))
web.Server = &http.Server{Addr: m.Cap("address"), Handler: web}
web.Configs["logheaders"] = &ctx.Config{Name: "日志输出报文头(yes/no)", Value: "no", Help: "日志输出报文头"}
m.Capi("nserve", 1)
// yac := m.Sess("tags", m.Sess("yac").Cmd("scan"))
// yac.Cmd("train", "void", "void", "[\t ]+")
// yac.Cmd("train", "other", "other", "[^\n]+")
@ -280,17 +243,21 @@ func (web *WEB) Start(m *ctx.Message, arg ...string) bool {
// yac.Cmd("train", "code", "variable", "struct", "key", "key", "other")
// yac.Cmd("train", "code", "define", "#define", "key", "other")
//
if m.Cap("protocol") == "https" {
web.Caches["cert"] = &ctx.Cache{Name: "服务证书", Value: m.Conf("cert"), Help: "服务证书"}
web.Caches["key"] = &ctx.Cache{Name: "服务密钥", Value: m.Conf("key"), Help: "服务密钥"}
web.Caches["protocol"] = &ctx.Cache{Name: "protocol", Value: m.Confx("protocol", arg, 2), Help: "服务协议"}
web.Caches["address"] = &ctx.Cache{Name: "address", Value: m.Confx("address", arg, 1), Help: "服务地址"}
m.Log("info", "%d %s://%s", m.Capi("nserve", 1), m.Cap("protocol"), m.Cap("stream", m.Cap("address")))
web.Server = &http.Server{Addr: m.Cap("address"), Handler: web}
if m.Caps("master", true); m.Cap("protocol") == "https" {
web.Caches["cert"] = &ctx.Cache{Name: "cert", Value: m.Confx("cert", arg, 3), Help: "服务证书"}
web.Caches["key"] = &ctx.Cache{Name: "key", Value: m.Confx("key", arg, 4), Help: "服务密钥"}
m.Log("info", "cert [%s]", m.Cap("cert"))
m.Log("info", "key [%s]", m.Cap("key"))
web.Server.ListenAndServeTLS(m.Cap("cert"), m.Cap("key"))
} else {
web.Server.ListenAndServe()
}
return true
}
func (web *WEB) Close(m *ctx.Message, arg ...string) bool {
@ -307,17 +274,14 @@ var Index = &ctx.Context{Name: "web", Help: "应用中心",
"nroute": &ctx.Cache{Name: "nroute", Value: "0", Help: "路由数量"},
},
Configs: map[string]*ctx.Config{
"cmd": &ctx.Config{Name: "cmd", Value: "tmux", 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: "路由数量"},
"record": &ctx.Config{Name: "record", Value: map[string]interface{}{}, Help: "访问记录"},
"lark_msg": &ctx.Config{Name: "lark_msg", Value: []interface{}{}, Help: "聊天记录"},
"wiki_dir": &ctx.Config{Name: "wiki_dir", Value: "usr/wiki", Help: "路由数量"},
"wiki_list_show": &ctx.Config{Name: "wiki_list_show", Value: map[string]interface{}{
"md": true,
}, Help: "路由数量"},
"which": &ctx.Config{Name: "which", Value: "redis.note", Help: "路由数量"},
"root_index": &ctx.Config{Name: "root_index", Value: "/wiki/", Help: "路由数量"},
"auto_create": &ctx.Config{Name: "auto_create(true/false)", Value: "true", Help: "路由数量"},
"refresh_time": &ctx.Config{Name: "refresh_time(ms)", Value: "1000", Help: "路由数量"},
"define": &ctx.Config{Name: "define", Value: map[string]interface{}{
@ -491,15 +455,8 @@ var Index = &ctx.Context{Name: "web", Help: "应用中心",
}, 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) {
if _, e := m.Target().Server.(*WEB); m.Assert(e) {
if len(arg) == 0 {
return
}
"client": &ctx.Command{Name: "client address [output [editor]]", Help: "添加浏览器配置, address: 默认地址, output: 输出路径, editor: 编辑器", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
if _, e := m.Target().Server.(*WEB); m.Assert(e) && len(arg) > 0 {
uri, e := url.Parse(arg[0])
m.Assert(e)
m.Conf("method", "method", "GET", "请求方法")
@ -519,32 +476,26 @@ var Index = &ctx.Context{Name: "web", Help: "应用中心",
}
}
}},
"cookie": &ctx.Command{
Name: "cookie [create]|[name [value]]",
Help: "读写请求的Cookie, name: 变量名, value: 变量值",
Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
if web, ok := m.Target().Server.(*WEB); m.Assert(ok) {
"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) {
if _, ok := m.Target().Server.(*WEB); m.Assert(ok) {
switch len(arg) {
case 0:
for k, v := range web.cookie {
m.Echo("%s: %v\n", k, v.Value)
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" {
web.cookie = make(map[string]*http.Cookie)
m.Target().Configs["cookie"] = &ctx.Config{Name: "cookie", Value: map[string]interface{}{}, Help: "cookie"}
break
}
if v, ok := web.cookie[arg[0]]; ok {
if v, ok := m.Confv("cookie", arg[0]).(*http.Cookie); ok {
m.Echo("%s", v.Value)
}
default:
if web.cookie == nil {
web.cookie = make(map[string]*http.Cookie)
}
if v, ok := web.cookie[arg[0]]; ok {
if v, ok := m.Confv("cookie", arg[0]).(*http.Cookie); ok {
v.Value = arg[1]
} else {
web.cookie[arg[0]] = &http.Cookie{Name: arg[0], Value: arg[1]}
m.Confv("cookie", arg[0], &http.Cookie{Name: arg[0], Value: arg[1]})
}
}
}
@ -671,18 +622,15 @@ var Index = &ctx.Context{Name: "web", Help: "应用中心",
m.Log("info", "content-type: %s", contenttype)
}
for _, v := range web.cookie {
req.AddCookie(v)
for _, v := range m.Confv("cookie").(map[string]interface{}) {
req.AddCookie(v.(*http.Cookie))
}
res, e := web.client.Do(req)
m.Assert(e)
if web.cookie == nil {
web.cookie = make(map[string]*http.Cookie)
}
for _, v := range res.Cookies() {
web.cookie[v.Name] = v
m.Confv("cookie", v.Name, v)
m.Log("info", "set-cookie %s: %v", v.Name, v.Value)
}
@ -810,36 +758,25 @@ var Index = &ctx.Context{Name: "web", Help: "应用中心",
}
}
}},
"post": &ctx.Command{Name: "post", Help: "访问服务",
Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
"post": &ctx.Command{Name: "post", Help: "post请求", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
msg := m.Spawn().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 := fmt.Sprintf("http://localhost:9094") //{{{
if len(arg) > 0 {
url = arg[0]
}
"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.Find("cli").Cmd("system", "explorer", url)
m.Sess("cli").Cmd("system", "explorer", url)
case "darwin":
m.Find("cli").Cmd("system", "open", url)
m.Sess("cli").Cmd("system", "open", url)
case "linux":
m.Spawn().Cmd("open", url)
}
}},
"serve": &ctx.Command{
Name: "serve [directory [address [protocol]]]",
Help: "启动服务, directory: 服务路径, address: 服务地址, protocol: 服务协议(https/http)",
Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
"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 script|template|directory route content",
Help: "添加响应, script: 脚本响应, template: 模板响应, directory: 目录响应, route: 请求路由, content: 响应内容",
Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
"route": &ctx.Command{Name: "route script|template|directory route content", Help: "添加响应, script: 脚本响应, template: 模板响应, directory: 目录响应, route: 请求路由, content: 响应内容", 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:
@ -857,12 +794,12 @@ var Index = &ctx.Context{Name: "web", Help: "应用中心",
case 3:
switch arg[0] {
case "script":
mux.Trans(m, arg[1], func(m *ctx.Message, c *ctx.Context, key string, a ...string) {
msg := m.Find("cli").Cmd("source", arg[2])
mux.HandleCmd(m, arg[1], func(m *ctx.Message, c *ctx.Context, key string, a ...string) {
msg := m.Sess("cli").Cmd("source", arg[2])
m.Copy(msg, "result").Copy(msg, "append")
})
case "template":
mux.Trans(m, arg[1], func(m *ctx.Message, c *ctx.Context, key string, a ...string) {
mux.HandleCmd(m, arg[1], func(m *ctx.Message, c *ctx.Context, key string, a ...string) {
w := m.Optionv("response").(http.ResponseWriter)
if _, e := os.Stat(arg[2]); e == nil {
template.Must(template.ParseGlob(arg[2])).Execute(w, m)
@ -1309,317 +1246,6 @@ var Index = &ctx.Context{Name: "web", Help: "应用中心",
}
}},
"/blog": &ctx.Command{Name: "/blog", Help: "博客", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
if m.Has("title") && m.Has("content") {
}
m.Echo("blog service")
}},
"/wiki_tags": &ctx.Command{Name: "/wiki_tags ", Help: "博客", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
if len(arg) > 0 {
m.Option("dir", arg[0])
}
yac := m.Find("yac.parse4", true)
msg := m.Sess("nfs").Cmd("dir", path.Join(m.Conf("wiki_dir"), "src", m.Option("dir")), "dir_name", "path")
for _, v := range msg.Meta["filename"] {
name := strings.TrimSpace(v)
es := strings.Split(name, ".")
switch es[len(es)-1] {
case "pyc", "o", "gz", "tar":
continue
case "c":
case "py":
case "h":
default:
continue
}
f, e := os.Open(name)
m.Assert(e)
defer f.Close()
bio := bufio.NewScanner(f)
for line := 1; bio.Scan(); line++ {
yac.Options("silent", true)
l := yac.Cmd("parse", "code", "void", bio.Text())
key := ""
switch l.Result(1) {
case "struct":
switch l.Result(2) {
case "struct", "}":
key = l.Result(3)
case "typedef":
if l.Result(3) == "struct" {
key = l.Result(5)
}
}
case "function":
switch l.Result(3) {
case "*":
key = l.Result(4)
default:
key = l.Result(3)
}
case "variable":
switch l.Result(2) {
case "struct":
key = l.Result(4)
}
case "define":
key = l.Result(3)
}
if key != "" {
m.Confv("define", strings.Join([]string{key, "position", "-2"}, "."), map[string]interface{}{
"file": strings.TrimPrefix(name, m.Confx("wiki_dir")+"/src"),
"line": line,
"type": l.Result(1),
})
}
yac.Meta = nil
}
}
}},
"/wiki_body": &ctx.Command{Name: "/wiki_body", Help: "维基", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
which := path.Join(m.Conf("wiki_dir"), m.Confx("which"))
st, _ := os.Stat(which)
if ls, e := ioutil.ReadFile(which); e == nil {
pre := false
es := strings.Split(m.Confx("which"), ".")
if len(es) > 0 {
switch es[len(es)-1] {
case "md":
m.Option("modify_count", 1)
m.Option("modify_time", st.ModTime().Format("2006/01/02 15:03:04"))
switch v := m.Confv("record", []interface{}{m.Option("path"), "local", "modify_count"}).(type) {
case int:
if m.Confv("record", []interface{}{m.Option("path"), "local", "modify_time"}).(string) != m.Option("modify_time") {
m.Confv("record", []interface{}{m.Option("path"), "local", "modify_time"}, m.Option("modify_time"))
m.Confv("record", []interface{}{m.Option("path"), "local", "modify_count"}, v+1)
}
m.Option("modify_count", v+1)
case float64:
if m.Confv("record", []interface{}{m.Option("path"), "local", "modify_time"}).(string) != m.Option("modify_time") {
m.Confv("record", []interface{}{m.Option("path"), "local", "modify_time"}, m.Option("modify_time"))
m.Confv("record", []interface{}{m.Option("path"), "local", "modify_count"}, v+1)
}
m.Option("modify_count", v+1)
case nil:
m.Confv("record", []interface{}{m.Option("path"), "local"}, map[string]interface{}{
"modify_count": m.Optioni("modify_count"),
"modify_time": m.Option("modify_time"),
})
default:
m.Log("fuck", "5")
}
ls = markdown.ToHTML(ls, nil, nil)
default:
pre = true
}
}
if pre {
m.Option("nline", bytes.Count(ls, []byte("\n")))
m.Option("nbyte", len(ls))
m.Add("append", "code", string(ls))
m.Add("append", "body", "")
} else {
m.Add("append", "body", string(ls))
m.Add("append", "code", "")
}
return
}
if m.Options("query") {
if v, ok := m.Confv("define", m.Option("query")).(map[string]interface{}); ok {
for _, val := range v["position"].([]interface{}) {
value := val.(map[string]interface{})
m.Add("append", "name", fmt.Sprintf("src/%v#hash_%v", value["file"], value["line"]))
}
return
}
msg := m.Sess("nfs").Cmd("dir", path.Join(m.Conf("wiki_dir"), m.Option("dir")), "dir_name", "path")
for _, v := range msg.Meta["filename"] {
name := strings.TrimPrefix(strings.TrimSpace(v), m.Conf("wiki_dir"))
es := strings.Split(name, ".")
switch es[len(es)-1] {
case "pyc", "o", "gz", "tar":
continue
}
if strings.Contains(name, m.Option("query")) {
m.Add("append", "name", name)
}
}
return
}
msg := m.Spawn().Cmd("/wiki_list")
m.Copy(msg, "append").Copy(msg, "option")
}},
"/wiki_list": &ctx.Command{Name: "/wiki_list", Help: "维基", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
ls, e := ioutil.ReadDir(path.Join(m.Conf("wiki_dir"), m.Option("which")))
m.Option("dir", m.Option("which"))
if e != nil {
dir, _ := path.Split(m.Option("which"))
m.Option("dir", dir)
ls, e = ioutil.ReadDir(path.Join(m.Conf("wiki_dir"), dir))
}
parent, _ := path.Split(strings.TrimSuffix(m.Option("dir"), "/"))
m.Option("parent", parent)
for _, l := range ls {
if l.Name()[0] == '.' {
continue
}
if !l.IsDir() {
es := strings.Split(l.Name(), ".")
if len(es) > 0 {
if show, ok := m.Confv("wiki_list_show", es[len(es)-1]).(bool); !ok || !show {
continue
}
}
}
m.Add("append", "name", l.Name())
m.Add("append", "time", l.ModTime().Format("2006-01-02 15:04:05"))
if l.IsDir() {
m.Add("append", "pend", "/")
} else {
m.Add("append", "pend", "")
}
m.Option("time_layout", "2006-01-02 15:04:05")
m.Sort("time", "time_r")
}
}},
"/wiki/": &ctx.Command{Name: "/wiki", Help: "维基", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
m.Option("which", strings.TrimPrefix(key, "/wiki/"))
if f, e := os.Stat(path.Join(m.Conf("wiki_dir"), m.Option("which"))); e == nil && !f.IsDir() && (strings.HasSuffix(m.Option("which"), ".json") || strings.HasSuffix(m.Option("which"), ".js") || strings.HasSuffix(m.Option("which"), ".css")) {
m.Append("directory", path.Join(m.Conf("wiki_dir"), m.Option("which")))
return
}
m.Append("template", "wiki")
}},
"/wx/": &ctx.Command{Name: "/wx/", Help: "微信", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
if !m.Sess("aaa").Cmd("wx").Results(0) {
return
}
if m.Has("echostr") {
m.Echo(m.Option("echostr"))
return
}
r := m.Optionv("request").(*http.Request)
switch r.Header.Get("Content-Type") {
case "text/xml":
type Article struct {
XMLName xml.Name `xml:"item"`
PicUrl string
Title string
Description string
Url string
}
type WXMsg struct {
XMLName xml.Name `xml:"xml"`
ToUserName string
FromUserName string
CreateTime int32
MsgId int64
MsgType string
Event string
EventKey string
Content string
Format string
Recognition string
PicUrl string
MediaId string
Location_X float64
Location_Y float64
Scale int64
Label string
ArticleCount int
Articles struct {
XMLName xml.Name `xml:"Articles"`
Articles []*Article
}
}
var data WXMsg
b, e := ioutil.ReadAll(r.Body)
e = xml.Unmarshal(b, &data)
// de := xml.NewDecoder(r.Body)
// e := de.Decode(&data)
m.Assert(e)
var echo WXMsg
echo.FromUserName = data.ToUserName
echo.ToUserName = data.FromUserName
echo.CreateTime = data.CreateTime
fs, e := ioutil.ReadDir("usr/wiki")
m.Assert(e)
msg := m.Spawn()
for _, f := range fs {
if !strings.HasSuffix(f.Name(), ".md") {
continue
}
msg.Add("append", "name", f.Name())
msg.Add("append", "title", strings.TrimSuffix(f.Name(), ".md")+"源码解析")
msg.Add("append", "time", f.ModTime().Format("01/02 15:03"))
}
msg.Option("time_layout", "01/02 15:03")
msg.Sort("time", "time_r")
articles := []*Article{}
articles = append(articles, &Article{PicUrl: "http://mmbiz.qpic.cn/mmbiz_jpg/sCJZHmp0V0doWEFBe6gS2HjgB0abiaK7H5WjkXGTvAI0CkCFrVJDEBBbJX8Kz0VegZ54ZoCo4We0sKJUOTuf1Tw/0",
Title: "wiki首页", Description: "技术文章", Url: "https://shylinux.com/wiki/"})
for i, v := range msg.Meta["title"] {
if i > 6 {
continue
}
articles = append(articles, &Article{PicUrl: "http://mmbiz.qpic.cn/mmbiz_jpg/sCJZHmp0V0doWEFBe6gS2HjgB0abiaK7H5WjkXGTvAI0CkCFrVJDEBBbJX8Kz0VegZ54ZoCo4We0sKJUOTuf1Tw/0",
Title: msg.Meta["time"][i] + " " + v, Description: "技术文章", Url: "https://shylinux.com/wiki/" + msg.Meta["name"][i]})
}
switch data.MsgType {
case "event":
echo.MsgType = "news"
echo.Articles.Articles = articles
echo.ArticleCount = len(echo.Articles.Articles)
case "text":
echo.MsgType = "news"
echo.Articles.Articles = articles
echo.ArticleCount = len(echo.Articles.Articles)
case "voice":
echo.MsgType = "text"
echo.Content = "你好"
case "image":
echo.MsgType = "text"
echo.Content = "你好"
case "location":
echo.MsgType = "text"
echo.Content = "你好"
}
b, e = xml.Marshal(echo)
m.Echo(string(b))
}
}},
"user": &ctx.Command{Name: "user", Help: "应用示例", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
aaa := m.Sess("aaa")
m.Spawn().Cmd("get", fmt.Sprintf("%suser/get", aaa.Conf("wx_api")), "access_token", aaa.Cap("access_token"))
@ -1635,25 +1261,6 @@ var Index = &ctx.Context{Name: "web", Help: "应用中心",
msg.Cmd("get", "method", "POST", "evaluating_add/", "questions", qs)
m.Add("append", "hi", "hello")
}},
"/lark": &ctx.Command{Name: "user", Help: "应用示例", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
r := m.Optionv("request").(*http.Request)
w := m.Optionv("response").(http.ResponseWriter)
data := map[string]interface{}{}
switch r.Header.Get("Content-Type") {
case "application/json":
b, e := ioutil.ReadAll(r.Body)
e = json.Unmarshal(b, &data)
m.Assert(e)
}
if _, ok := data["challenge"]; ok {
w.Header().Set("Content-Type", "application/javascript")
fmt.Fprintf(w, "{\"challenge\": \"%s\"}", data["challenge"])
return
}
m.Confv("lark_msg", "-1", data)
}},
"/lookup": &ctx.Command{Name: "user", Help: "应用示例", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
if len(arg) > 0 {
m.Option("service", arg[0])

2
src/contexts/yac/yac.go
View File

@ -1,7 +1,7 @@
package yac // {{{
// }}}
import ( // {{{
"contexts"
"contexts/ctx"
"fmt"
"strconv"
)

23
src/example/bench.go
View File

@ -1,23 +0,0 @@
package main
import (
"os"
"contexts"
_ "contexts/aaa"
_ "contexts/cli"
_ "contexts/web"
_ "contexts/lex"
_ "contexts/log"
_ "contexts/yac"
_ "contexts/mdb"
_ "contexts/nfs"
_ "contexts/ssh"
_ "contexts/tcp"
)
func main() {
ctx.Start(os.Args[1:]...)
}

29
src/examples/bench.go Normal file
View File

@ -0,0 +1,29 @@
package main
import (
"os"
// 数据层
_ "contexts/mdb" //数据中心
_ "contexts/nfs" //存储中心
_ "contexts/ssh" //集群中心
_ "contexts/tcp" //网络中心
// 控制层
_ "contexts/gdb" //调试中心
_ "contexts/lex" //词法中心
_ "contexts/log" //日志中心
_ "contexts/yac" //语法中心
// 服务层
_ "contexts/aaa" //认证中心
_ "contexts/cli" //管理中心
c "contexts/ctx" //模块中心
_ "contexts/web" //应用中心
// 应用层
_ "examples/code" //代码中心
_ "examples/jira" //任务中心
_ "examples/lark" //会议中心
_ "examples/wiki" //文档中心
)
func main() {
c.Start(os.Args[1:]...)
}

26
src/examples/code/code.go Normal file
View File

@ -0,0 +1,26 @@
package code
import (
"contexts/ctx"
"contexts/web"
)
type CODE struct {
web.WEB
}
var Index = &ctx.Context{Name: "code", Help: "代码中心",
Caches: map[string]*ctx.Cache{},
Configs: map[string]*ctx.Config{},
Commands: map[string]*ctx.Command{
"/demo": &ctx.Command{Name: "/demo", Help: "demo", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
m.Echo("demo")
}},
},
}
func init() {
code := &CODE{}
code.Context = Index
web.Index.Register(Index, code)
}

0
src/example/findgrep.go → src/examples/findgrep.go
View File

26
src/examples/jira/jira.go Normal file
View File

@ -0,0 +1,26 @@
package jira
import (
"contexts/ctx"
"contexts/web"
)
type JIRA struct {
web.WEB
}
var Index = &ctx.Context{Name: "jira", Help: "任务中心",
Caches: map[string]*ctx.Cache{},
Configs: map[string]*ctx.Config{},
Commands: map[string]*ctx.Command{
"/demo": &ctx.Command{Name: "/demo", Help: "demo", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
m.Echo("demo")
}},
},
}
func init() {
jira := &JIRA{}
jira.Context = Index
web.Index.Register(Index, jira)
}

48
src/examples/lark/lark.go Normal file
View File

@ -0,0 +1,48 @@
package lark
import (
"contexts/ctx"
"contexts/web"
"encoding/json"
"fmt"
"io/ioutil"
"net/http"
)
type LARK struct {
web.WEB
}
var Index = &ctx.Context{Name: "lark", Help: "会议中心",
Caches: map[string]*ctx.Cache{},
Configs: map[string]*ctx.Config{
"lark_msg": &ctx.Config{Name: "lark_msg", Value: []interface{}{}, Help: "聊天记录"},
},
Commands: map[string]*ctx.Command{
"/lark": &ctx.Command{Name: "user", Help: "应用示例", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
r := m.Optionv("request").(*http.Request)
w := m.Optionv("response").(http.ResponseWriter)
data := map[string]interface{}{}
switch r.Header.Get("Content-Type") {
case "application/json":
b, e := ioutil.ReadAll(r.Body)
e = json.Unmarshal(b, &data)
m.Assert(e)
}
if _, ok := data["challenge"]; ok {
w.Header().Set("Content-Type", "application/javascript")
fmt.Fprintf(w, "{\"challenge\": \"%s\"}", data["challenge"])
return
}
m.Confv("lark_msg", "-1", data)
}},
},
}
func init() {
lark := &LARK{}
lark.Context = Index
web.Index.Register(Index, lark)
}

352
src/examples/wiki/wiki.go Normal file
View File

@ -0,0 +1,352 @@
package wiki
import (
"bufio"
"contexts/ctx"
"contexts/web"
"encoding/xml"
"github.com/gomarkdown/markdown"
"io/ioutil"
"net/http"
"path"
"bytes"
"fmt"
"os"
"strings"
)
type WIKI struct {
web.WEB
}
var Index = &ctx.Context{Name: "wiki", Help: "文档中心",
Caches: map[string]*ctx.Cache{},
Configs: map[string]*ctx.Config{
"which": &ctx.Config{Name: "which", Value: "redis.note", Help: "路由数量"},
"wiki_dir": &ctx.Config{Name: "wiki_dir", Value: "usr/wiki", Help: "路由数量"},
"wiki_list_show": &ctx.Config{Name: "wiki_list_show", Value: map[string]interface{}{
"md": true,
}, Help: "路由数量"},
},
Commands: map[string]*ctx.Command{
"/blog": &ctx.Command{Name: "/blog", Help: "博客", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
if m.Has("title") && m.Has("content") {
}
m.Echo("blog service")
}},
"/wiki_tags": &ctx.Command{Name: "/wiki_tags ", Help: "博客", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
if len(arg) > 0 {
m.Option("dir", arg[0])
}
yac := m.Find("yac.parse4", true)
msg := m.Sess("nfs").Cmd("dir", path.Join(m.Conf("wiki_dir"), "src", m.Option("dir")), "dir_name", "path")
for _, v := range msg.Meta["filename"] {
name := strings.TrimSpace(v)
es := strings.Split(name, ".")
switch es[len(es)-1] {
case "pyc", "o", "gz", "tar":
continue
case "c":
case "py":
case "h":
default:
continue
}
f, e := os.Open(name)
m.Assert(e)
defer f.Close()
bio := bufio.NewScanner(f)
for line := 1; bio.Scan(); line++ {
yac.Options("silent", true)
l := yac.Cmd("parse", "code", "void", bio.Text())
key := ""
switch l.Result(1) {
case "struct":
switch l.Result(2) {
case "struct", "}":
key = l.Result(3)
case "typedef":
if l.Result(3) == "struct" {
key = l.Result(5)
}
}
case "function":
switch l.Result(3) {
case "*":
key = l.Result(4)
default:
key = l.Result(3)
}
case "variable":
switch l.Result(2) {
case "struct":
key = l.Result(4)
}
case "define":
key = l.Result(3)
}
if key != "" {
m.Confv("define", strings.Join([]string{key, "position", "-2"}, "."), map[string]interface{}{
"file": strings.TrimPrefix(name, m.Confx("wiki_dir")+"/src"),
"line": line,
"type": l.Result(1),
})
}
yac.Meta = nil
}
}
}},
"/wiki_body": &ctx.Command{Name: "/wiki_body", Help: "维基", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
which := path.Join(m.Conf("wiki_dir"), m.Confx("which"))
st, _ := os.Stat(which)
if ls, e := ioutil.ReadFile(which); e == nil {
pre := false
es := strings.Split(m.Confx("which"), ".")
if len(es) > 0 {
switch es[len(es)-1] {
case "md":
m.Option("modify_count", 1)
m.Option("modify_time", st.ModTime().Format("2006/01/02 15:03:04"))
switch v := m.Confv("record", []interface{}{m.Option("path"), "local", "modify_count"}).(type) {
case int:
if m.Confv("record", []interface{}{m.Option("path"), "local", "modify_time"}).(string) != m.Option("modify_time") {
m.Confv("record", []interface{}{m.Option("path"), "local", "modify_time"}, m.Option("modify_time"))
m.Confv("record", []interface{}{m.Option("path"), "local", "modify_count"}, v+1)
}
m.Option("modify_count", v+1)
case float64:
if m.Confv("record", []interface{}{m.Option("path"), "local", "modify_time"}).(string) != m.Option("modify_time") {
m.Confv("record", []interface{}{m.Option("path"), "local", "modify_time"}, m.Option("modify_time"))
m.Confv("record", []interface{}{m.Option("path"), "local", "modify_count"}, v+1)
}
m.Option("modify_count", v+1)
case nil:
m.Confv("record", []interface{}{m.Option("path"), "local"}, map[string]interface{}{
"modify_count": m.Optioni("modify_count"),
"modify_time": m.Option("modify_time"),
})
default:
m.Log("fuck", "5")
}
ls = markdown.ToHTML(ls, nil, nil)
default:
pre = true
}
}
if pre {
m.Option("nline", bytes.Count(ls, []byte("\n")))
m.Option("nbyte", len(ls))
m.Add("append", "code", string(ls))
m.Add("append", "body", "")
} else {
m.Add("append", "body", string(ls))
m.Add("append", "code", "")
}
return
}
if m.Options("query") {
if v, ok := m.Confv("define", m.Option("query")).(map[string]interface{}); ok {
for _, val := range v["position"].([]interface{}) {
value := val.(map[string]interface{})
m.Add("append", "name", fmt.Sprintf("src/%v#hash_%v", value["file"], value["line"]))
}
return
}
msg := m.Sess("nfs").Cmd("dir", path.Join(m.Conf("wiki_dir"), m.Option("dir")), "dir_name", "path")
for _, v := range msg.Meta["filename"] {
name := strings.TrimPrefix(strings.TrimSpace(v), m.Conf("wiki_dir"))
es := strings.Split(name, ".")
switch es[len(es)-1] {
case "pyc", "o", "gz", "tar":
continue
}
if strings.Contains(name, m.Option("query")) {
m.Add("append", "name", name)
}
}
return
}
msg := m.Spawn().Cmd("/wiki_list")
m.Copy(msg, "append").Copy(msg, "option")
}},
"/wiki_list": &ctx.Command{Name: "/wiki_list", Help: "维基", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
ls, e := ioutil.ReadDir(path.Join(m.Conf("wiki_dir"), m.Option("which")))
m.Option("dir", m.Option("which"))
if e != nil {
dir, _ := path.Split(m.Option("which"))
m.Option("dir", dir)
ls, e = ioutil.ReadDir(path.Join(m.Conf("wiki_dir"), dir))
}
parent, _ := path.Split(strings.TrimSuffix(m.Option("dir"), "/"))
m.Option("parent", parent)
for _, l := range ls {
if l.Name()[0] == '.' {
continue
}
if !l.IsDir() {
es := strings.Split(l.Name(), ".")
if len(es) > 0 {
if show, ok := m.Confv("wiki_list_show", es[len(es)-1]).(bool); !ok || !show {
continue
}
}
}
m.Add("append", "name", l.Name())
m.Add("append", "time", l.ModTime().Format("2006-01-02 15:04:05"))
if l.IsDir() {
m.Add("append", "pend", "/")
} else {
m.Add("append", "pend", "")
}
m.Option("time_layout", "2006-01-02 15:04:05")
m.Sort("time", "time_r")
}
}},
"/wiki/": &ctx.Command{Name: "/wiki", Help: "维基", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
m.Option("which", strings.TrimPrefix(key, "/wiki/"))
if f, e := os.Stat(path.Join(m.Conf("wiki_dir"), m.Option("which"))); e == nil && !f.IsDir() && (strings.HasSuffix(m.Option("which"), ".json") || strings.HasSuffix(m.Option("which"), ".js") || strings.HasSuffix(m.Option("which"), ".css")) {
m.Append("directory", path.Join(m.Conf("wiki_dir"), m.Option("which")))
return
}
m.Append("template", "wiki")
}},
"/wx/": &ctx.Command{Name: "/wx/", Help: "微信", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) {
if !m.Sess("aaa").Cmd("wx").Results(0) {
return
}
if m.Has("echostr") {
m.Echo(m.Option("echostr"))
return
}
r := m.Optionv("request").(*http.Request)
switch r.Header.Get("Content-Type") {
case "text/xml":
type Article struct {
XMLName xml.Name `xml:"item"`
PicUrl string
Title string
Description string
Url string
}
type WXMsg struct {
XMLName xml.Name `xml:"xml"`
ToUserName string
FromUserName string
CreateTime int32
MsgId int64
MsgType string
Event string
EventKey string
Content string
Format string
Recognition string
PicUrl string
MediaId string
Location_X float64
Location_Y float64
Scale int64
Label string
ArticleCount int
Articles struct {
XMLName xml.Name `xml:"Articles"`
Articles []*Article
}
}
var data WXMsg
b, e := ioutil.ReadAll(r.Body)
e = xml.Unmarshal(b, &data)
// de := xml.NewDecoder(r.Body)
// e := de.Decode(&data)
m.Assert(e)
var echo WXMsg
echo.FromUserName = data.ToUserName
echo.ToUserName = data.FromUserName
echo.CreateTime = data.CreateTime
fs, e := ioutil.ReadDir("usr/wiki")
m.Assert(e)
msg := m.Spawn()
for _, f := range fs {
if !strings.HasSuffix(f.Name(), ".md") {
continue
}
msg.Add("append", "name", f.Name())
msg.Add("append", "title", strings.TrimSuffix(f.Name(), ".md")+"源码解析")
msg.Add("append", "time", f.ModTime().Format("01/02 15:03"))
}
msg.Option("time_layout", "01/02 15:03")
msg.Sort("time", "time_r")
articles := []*Article{}
articles = append(articles, &Article{PicUrl: "http://mmbiz.qpic.cn/mmbiz_jpg/sCJZHmp0V0doWEFBe6gS2HjgB0abiaK7H5WjkXGTvAI0CkCFrVJDEBBbJX8Kz0VegZ54ZoCo4We0sKJUOTuf1Tw/0",
Title: "wiki首页", Description: "技术文章", Url: "https://shylinux.com/wiki/"})
for i, v := range msg.Meta["title"] {
if i > 6 {
continue
}
articles = append(articles, &Article{PicUrl: "http://mmbiz.qpic.cn/mmbiz_jpg/sCJZHmp0V0doWEFBe6gS2HjgB0abiaK7H5WjkXGTvAI0CkCFrVJDEBBbJX8Kz0VegZ54ZoCo4We0sKJUOTuf1Tw/0",
Title: msg.Meta["time"][i] + " " + v, Description: "技术文章", Url: "https://shylinux.com/wiki/" + msg.Meta["name"][i]})
}
switch data.MsgType {
case "event":
echo.MsgType = "news"
echo.Articles.Articles = articles
echo.ArticleCount = len(echo.Articles.Articles)
case "text":
echo.MsgType = "news"
echo.Articles.Articles = articles
echo.ArticleCount = len(echo.Articles.Articles)
case "voice":
echo.MsgType = "text"
echo.Content = "你好"
case "image":
echo.MsgType = "text"
echo.Content = "你好"
case "location":
echo.MsgType = "text"
echo.Content = "你好"
}
b, e = xml.Marshal(echo)
m.Echo(string(b))
}
}},
},
}
func init() {
wiki := &WIKI{}
wiki.Context = Index
web.Index.Register(Index, wiki)
}

2
usr/wiki/zsh_tmux_vim.md
View File

@ -1407,7 +1407,7 @@ $ git submodule update --init --recursive
不论是用vundle安装或手动下载，都需要进入插件目录进行编译安装。
```
$ cd ~/.vim/bundle/YouCompleteMe
$ ./install.py --clang-completer
$ ./install.py --clang-completer --gocompleter
```
Ubuntu上如果没有cmake还需要安装一下。
```