minor improvements; take server port / address from config
This commit is contained in:
parent
1d7d1f3b1b
commit
2286aef4ce
1 changed files with 9 additions and 8 deletions
|
@ -33,16 +33,17 @@ func Serve(ctx lib.Context) {
|
||||||
r.Use(gin.Recovery())
|
r.Use(gin.Recovery())
|
||||||
r.Use(Logger(ctx))
|
r.Use(Logger(ctx))
|
||||||
cfg := ctx.Config().(*Cfg)
|
cfg := ctx.Config().(*Cfg)
|
||||||
|
if cfg.Addr == "" {
|
||||||
|
if cfg.Port == "" {
|
||||||
|
cfg.Port = "8123"
|
||||||
|
}
|
||||||
|
cfg.Addr = ":" + cfg.Port
|
||||||
|
}
|
||||||
for _, rcfg := range cfg.routes {
|
for _, rcfg := range cfg.routes {
|
||||||
setRoute(ctx, rcfg, r)
|
setRoute(ctx, rcfg, r)
|
||||||
}
|
}
|
||||||
srv := &http.Server{
|
srv := &http.Server{Addr: cfg.Addr, Handler: r}
|
||||||
Addr: ":8123",
|
ctx.WithState(&ServerState{server: srv})
|
||||||
Handler: r,
|
|
||||||
}
|
|
||||||
ctx.WithState(&ServerState{
|
|
||||||
server: srv,
|
|
||||||
})
|
|
||||||
lib.RunCtx(ctx, func(ctx lib.Context) {
|
lib.RunCtx(ctx, func(ctx lib.Context) {
|
||||||
srv.ListenAndServe()
|
srv.ListenAndServe()
|
||||||
})
|
})
|
||||||
|
@ -67,7 +68,7 @@ func handleMsg(ctx lib.Context, cfg *mhSpec, gc *gin.Context) {
|
||||||
msg := message.New(head...).WithSender(cctx)
|
msg := message.New(head...).WithSender(cctx)
|
||||||
// if gc.Request.Method == "POST" && data != "": msg.WithPayload(data)
|
// if gc.Request.Method == "POST" && data != "": msg.WithPayload(data)
|
||||||
core.HandleMessage(cctx, msg)
|
core.HandleMessage(cctx, msg)
|
||||||
code, data := cfg.proc(ctx, msg)
|
code, data := cfg.proc(cctx, msg)
|
||||||
gc.JSON(code, data)
|
gc.JSON(code, data)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue