x/ContextOS
1
0
Fork 1
mirror of https://shylinux.com/x/ContextOS synced 2025-04-28 18:02:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

add temp message

Browse Source 
Change-Id: Iee1ace2bbbacb766da8dd2988c308924eab95f7c
This commit is contained in:
shaoying 2019-03-17 15:13:16 +08:00
parent 0ce08465fe
commit 89b2883789
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/contexts/ctx/ctx_type.go
View File

@ -295,6 +295,7 @@ type Message struct {
} }
func (m *Message) Spawn(arg ...interface{}) *Message { func (m *Message) Spawn(arg ...interface{}) *Message {
temp := false
c := m.target c := m.target
if len(arg) > 0 { if len(arg) > 0 {
switch v := arg[0].(type) { switch v := arg[0].(type) {
@ -302,6 +303,8 @@ func (m *Message) Spawn(arg ...interface{}) *Message {
c = v c = v
case *Message: case *Message:
c = v.target c = v.target
case string:
temp = kit.Right(v)
} }
} }
@ -314,6 +317,10 @@ func (m *Message) Spawn(arg ...interface{}) *Message {
root: m.root, root: m.root,
} }
if temp {
return msg
}
m.messages = append(m.messages, msg) m.messages = append(m.messages, msg)
return msg return msg
} }

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

@ -133,7 +133,8 @@ func (web *WEB) Login(msg *ctx.Message, w http.ResponseWriter, r *http.Request)
} }
func (web *WEB) HandleCmd(m *ctx.Message, key string, cmd *ctx.Command) { func (web *WEB) HandleCmd(m *ctx.Message, key string, cmd *ctx.Command) {
web.HandleFunc(key, func(w http.ResponseWriter, r *http.Request) { web.HandleFunc(key, func(w http.ResponseWriter, r *http.Request) {
m.TryCatch(m.Spawn(), true, func(msg *ctx.Message) {
m.TryCatch(m.Spawn(m.Conf("serve", "autofree")), true, func(msg *ctx.Message) {
msg.Option("remote_addr", r.RemoteAddr) msg.Option("remote_addr", r.RemoteAddr)
msg.Option("remote_ip", r.Header.Get("remote_ip")) msg.Option("remote_ip", r.Header.Get("remote_ip"))
msg.Option("index_url", r.Header.Get("index_url")) msg.Option("index_url", r.Header.Get("index_url"))
@ -375,6 +376,7 @@ var Index = &ctx.Context{Name: "web", Help: "应用中心",
}, },
}, Help: "爬虫配置"}, }, Help: "爬虫配置"},
"serve": &ctx.Config{Name: "serve", Value: map[string]interface{}{ "serve": &ctx.Config{Name: "serve", Value: map[string]interface{}{
"autofree": false,
"logheaders": false, "logheaders": false,
"form_size": "102400", "form_size": "102400",
"directory": "usr", "directory": "usr",