cco/go-scopes
3
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

server: set payload if request body present

Browse source
This commit is contained in:
Helmut Merz 2023-08-14 11:05:00 +02:00
parent 32acd23f26
commit 89abbb79dd
2 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
server/server.go
View file

@ -1,6 +1,7 @@
package server package server
import ( import (
"io/ioutil"
"net/http" "net/http"
"strings" "strings"
"time" "time"
@ -70,8 +71,11 @@ func handleMsg(ctx lib.Context, cfg *mhSpec, gc *gin.Context) {
head := strings.Split(gc.Param("msg"), "/")[1:] head := strings.Split(gc.Param("msg"), "/")[1:]
cctx := ctx.ChildContext(cfg) cctx := ctx.ChildContext(cfg)
msg := message.New(head...).WithSender(cctx) msg := message.New(head...).WithSender(cctx)
// if gc.Request.Method == "POST" && data != "": msg.WithPayload(data) if body, _ := ioutil.ReadAll(gc.Request.Body); len(body) > 0 {
logging.DebugM(cctx, msg).Msg("server.handleMessage") pl := message.PayloadFromJson[lib.Data](string(body))
msg.WithPayload(pl)
}
logging.DebugM(cctx, msg).Msg("server.handleMsg")
var proc msgProc var proc msgProc
for _, act := range action.Select(cctx, msg) { for _, act := range action.Select(cctx, msg) {
act.Handle() act.Handle()

2
tests/etc/etc.go
View file

@ -26,8 +26,6 @@ func Config() lib.Config {
} }
app_c.AddAction("demo", action.Base(action.Forward, "test-receiver")) app_c.AddAction("demo", action.Base(action.Forward, "test-receiver"))
//server_amh := server.MsgHandler()
//server_amh.AddActionProc("demo", server.Async, "test-receiver")
server_c := b("server", server.Start( server_c := b("server", server.Start(
(&server.Cfg{Port: ovr("8123", SERVER_PORT)}). (&server.Cfg{Port: ovr("8123", SERVER_PORT)}).
AddRoute("/docs", server.FileServer("html")). AddRoute("/docs", server.FileServer("html")).