mirror of
https://gitee.com/johng/gf.git
synced 2024-12-02 20:28:17 +08:00
252 lines
7.2 KiB
Go
252 lines
7.2 KiB
Go
// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
|
|
//
|
|
// This Source Code Form is subject to the terms of the MIT License.
|
|
// If a copy of the MIT was not distributed with this file,
|
|
// You can obtain one at https://github.com/gogf/gf.
|
|
|
|
package ghttp_test
|
|
|
|
import (
|
|
"fmt"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/gogf/gf/frame/g"
|
|
"github.com/gogf/gf/frame/gmvc"
|
|
"github.com/gogf/gf/net/ghttp"
|
|
"github.com/gogf/gf/test/gtest"
|
|
)
|
|
|
|
// 执行对象
|
|
type GroupObject struct{}
|
|
|
|
func (o *GroupObject) Init(r *ghttp.Request) {
|
|
r.Response.Write("1")
|
|
}
|
|
|
|
func (o *GroupObject) Shut(r *ghttp.Request) {
|
|
r.Response.Write("2")
|
|
}
|
|
|
|
func (o *GroupObject) Index(r *ghttp.Request) {
|
|
r.Response.Write("Object Index")
|
|
}
|
|
|
|
func (o *GroupObject) Show(r *ghttp.Request) {
|
|
r.Response.Write("Object Show")
|
|
}
|
|
|
|
func (o *GroupObject) Delete(r *ghttp.Request) {
|
|
r.Response.Write("Object Delete")
|
|
}
|
|
|
|
// 控制器
|
|
type GroupController struct {
|
|
gmvc.Controller
|
|
}
|
|
|
|
func (c *GroupController) Init(r *ghttp.Request) {
|
|
c.Controller.Init(r)
|
|
c.Response.Write("1")
|
|
}
|
|
|
|
func (c *GroupController) Shut() {
|
|
c.Response.Write("2")
|
|
}
|
|
|
|
func (c *GroupController) Index() {
|
|
c.Response.Write("Controller Index")
|
|
}
|
|
|
|
func (c *GroupController) Show() {
|
|
c.Response.Write("Controller Show")
|
|
}
|
|
|
|
func (c *GroupController) Post() {
|
|
c.Response.Write("Controller Post")
|
|
}
|
|
|
|
func Handler(r *ghttp.Request) {
|
|
r.Response.Write("Handler")
|
|
}
|
|
|
|
func Test_Router_GroupBasic1(t *testing.T) {
|
|
p, _ := ports.PopRand()
|
|
s := g.Server(p)
|
|
obj := new(GroupObject)
|
|
ctl := new(GroupController)
|
|
// 分组路由方法注册
|
|
group := s.Group("/api")
|
|
group.ALL("/handler", Handler)
|
|
group.ALL("/ctl", ctl)
|
|
group.GET("/ctl/my-show", ctl, "Show")
|
|
group.REST("/ctl/rest", ctl)
|
|
group.ALL("/obj", obj)
|
|
group.GET("/obj/my-show", obj, "Show")
|
|
group.REST("/obj/rest", obj)
|
|
s.SetPort(p)
|
|
s.SetDumpRouterMap(false)
|
|
s.Start()
|
|
defer s.Shutdown()
|
|
|
|
time.Sleep(100 * time.Millisecond)
|
|
gtest.C(t, func(t *gtest.T) {
|
|
client := g.Client()
|
|
client.SetPrefix(fmt.Sprintf("http://127.0.0.1:%d", p))
|
|
|
|
t.Assert(client.GetContent("/api/handler"), "Handler")
|
|
|
|
t.Assert(client.GetContent("/api/ctl"), "1Controller Index2")
|
|
t.Assert(client.GetContent("/api/ctl/"), "1Controller Index2")
|
|
t.Assert(client.GetContent("/api/ctl/index"), "1Controller Index2")
|
|
t.Assert(client.GetContent("/api/ctl/my-show"), "1Controller Show2")
|
|
t.Assert(client.GetContent("/api/ctl/post"), "1Controller Post2")
|
|
t.Assert(client.GetContent("/api/ctl/show"), "1Controller Show2")
|
|
t.Assert(client.PostContent("/api/ctl/rest"), "1Controller Post2")
|
|
|
|
t.Assert(client.GetContent("/api/obj"), "1Object Index2")
|
|
t.Assert(client.GetContent("/api/obj/"), "1Object Index2")
|
|
t.Assert(client.GetContent("/api/obj/index"), "1Object Index2")
|
|
t.Assert(client.GetContent("/api/obj/delete"), "1Object Delete2")
|
|
t.Assert(client.GetContent("/api/obj/my-show"), "1Object Show2")
|
|
t.Assert(client.GetContent("/api/obj/show"), "1Object Show2")
|
|
t.Assert(client.DeleteContent("/api/obj/rest"), "1Object Delete2")
|
|
|
|
t.Assert(client.DeleteContent("/ThisDoesNotExist"), "Not Found")
|
|
t.Assert(client.DeleteContent("/api/ThisDoesNotExist"), "Not Found")
|
|
})
|
|
}
|
|
|
|
func Test_Router_GroupBasic2(t *testing.T) {
|
|
p, _ := ports.PopRand()
|
|
s := g.Server(p)
|
|
obj := new(GroupObject)
|
|
ctl := new(GroupController)
|
|
// 分组路由批量注册
|
|
s.Group("/api").Bind([]g.Slice{
|
|
{"ALL", "/handler", Handler},
|
|
{"ALL", "/ctl", ctl},
|
|
{"GET", "/ctl/my-show", ctl, "Show"},
|
|
{"REST", "/ctl/rest", ctl},
|
|
{"ALL", "/obj", obj},
|
|
{"GET", "/obj/my-show", obj, "Show"},
|
|
{"REST", "/obj/rest", obj},
|
|
})
|
|
s.SetPort(p)
|
|
s.SetDumpRouterMap(false)
|
|
s.Start()
|
|
defer s.Shutdown()
|
|
|
|
time.Sleep(100 * time.Millisecond)
|
|
gtest.C(t, func(t *gtest.T) {
|
|
client := g.Client()
|
|
client.SetPrefix(fmt.Sprintf("http://127.0.0.1:%d", p))
|
|
|
|
t.Assert(client.GetContent("/api/handler"), "Handler")
|
|
|
|
t.Assert(client.GetContent("/api/ctl/my-show"), "1Controller Show2")
|
|
t.Assert(client.GetContent("/api/ctl/post"), "1Controller Post2")
|
|
t.Assert(client.GetContent("/api/ctl/show"), "1Controller Show2")
|
|
t.Assert(client.PostContent("/api/ctl/rest"), "1Controller Post2")
|
|
|
|
t.Assert(client.GetContent("/api/obj/delete"), "1Object Delete2")
|
|
t.Assert(client.GetContent("/api/obj/my-show"), "1Object Show2")
|
|
t.Assert(client.GetContent("/api/obj/show"), "1Object Show2")
|
|
t.Assert(client.DeleteContent("/api/obj/rest"), "1Object Delete2")
|
|
|
|
t.Assert(client.DeleteContent("/ThisDoesNotExist"), "Not Found")
|
|
t.Assert(client.DeleteContent("/api/ThisDoesNotExist"), "Not Found")
|
|
})
|
|
}
|
|
|
|
func Test_Router_GroupBuildInVar(t *testing.T) {
|
|
p, _ := ports.PopRand()
|
|
s := g.Server(p)
|
|
obj := new(GroupObject)
|
|
ctl := new(GroupController)
|
|
// 分组路由方法注册
|
|
group := s.Group("/api")
|
|
group.ALL("/{.struct}/{.method}", ctl)
|
|
group.ALL("/{.struct}/{.method}", obj)
|
|
s.SetPort(p)
|
|
s.SetDumpRouterMap(false)
|
|
s.Start()
|
|
defer s.Shutdown()
|
|
|
|
time.Sleep(100 * time.Millisecond)
|
|
gtest.C(t, func(t *gtest.T) {
|
|
client := g.Client()
|
|
client.SetPrefix(fmt.Sprintf("http://127.0.0.1:%d", p))
|
|
|
|
t.Assert(client.GetContent("/api/group-controller/index"), "1Controller Index2")
|
|
t.Assert(client.GetContent("/api/group-controller/post"), "1Controller Post2")
|
|
t.Assert(client.GetContent("/api/group-controller/show"), "1Controller Show2")
|
|
|
|
t.Assert(client.GetContent("/api/group-object/index"), "1Object Index2")
|
|
t.Assert(client.GetContent("/api/group-object/delete"), "1Object Delete2")
|
|
t.Assert(client.GetContent("/api/group-object/show"), "1Object Show2")
|
|
|
|
t.Assert(client.DeleteContent("/ThisDoesNotExist"), "Not Found")
|
|
t.Assert(client.DeleteContent("/api/ThisDoesNotExist"), "Not Found")
|
|
})
|
|
}
|
|
|
|
func Test_Router_Group_Mthods(t *testing.T) {
|
|
p, _ := ports.PopRand()
|
|
s := g.Server(p)
|
|
obj := new(GroupObject)
|
|
ctl := new(GroupController)
|
|
group := s.Group("/")
|
|
group.ALL("/obj", obj, "Show, Delete")
|
|
group.ALL("/ctl", ctl, "Show, Post")
|
|
s.SetPort(p)
|
|
s.SetDumpRouterMap(false)
|
|
s.Start()
|
|
defer s.Shutdown()
|
|
|
|
time.Sleep(100 * time.Millisecond)
|
|
gtest.C(t, func(t *gtest.T) {
|
|
client := g.Client()
|
|
client.SetPrefix(fmt.Sprintf("http://127.0.0.1:%d", p))
|
|
t.Assert(client.GetContent("/ctl/show"), "1Controller Show2")
|
|
t.Assert(client.GetContent("/ctl/post"), "1Controller Post2")
|
|
t.Assert(client.GetContent("/obj/show"), "1Object Show2")
|
|
t.Assert(client.GetContent("/obj/delete"), "1Object Delete2")
|
|
})
|
|
}
|
|
|
|
func Test_Router_Group_MultiServer(t *testing.T) {
|
|
p1, _ := ports.PopRand()
|
|
p2, _ := ports.PopRand()
|
|
s1 := g.Server(p1)
|
|
s2 := g.Server(p2)
|
|
s1.Group("/", func(group *ghttp.RouterGroup) {
|
|
group.POST("/post", func(r *ghttp.Request) {
|
|
r.Response.Write("post1")
|
|
})
|
|
})
|
|
s2.Group("/", func(group *ghttp.RouterGroup) {
|
|
group.POST("/post", func(r *ghttp.Request) {
|
|
r.Response.Write("post2")
|
|
})
|
|
})
|
|
s1.SetPort(p1)
|
|
s2.SetPort(p2)
|
|
s1.SetDumpRouterMap(false)
|
|
s2.SetDumpRouterMap(false)
|
|
gtest.Assert(s1.Start(), nil)
|
|
gtest.Assert(s2.Start(), nil)
|
|
defer s1.Shutdown()
|
|
defer s2.Shutdown()
|
|
|
|
time.Sleep(100 * time.Millisecond)
|
|
gtest.C(t, func(t *gtest.T) {
|
|
c1 := g.Client()
|
|
c1.SetPrefix(fmt.Sprintf("http://127.0.0.1:%d", p1))
|
|
c2 := g.Client()
|
|
c2.SetPrefix(fmt.Sprintf("http://127.0.0.1:%d", p2))
|
|
t.Assert(c1.PostContent("/post"), "post1")
|
|
t.Assert(c2.PostContent("/post"), "post2")
|
|
})
|
|
}
|