-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathgow.go
91 lines (73 loc) · 2 KB
/
gow.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
package gow
import (
"net/http"
"strings"
)
type HandlerFunc func(*Context)
type RouterGroup struct {
prefix string
middleware []HandlerFunc
engine *Engine
}
func (g *RouterGroup) Group(prefix string) *RouterGroup {
engine := g.engine
newGroup := &RouterGroup{
prefix: g.prefix + prefix,
engine: engine,
}
engine.groups = append(engine.groups, newGroup)
return newGroup
}
func (g *RouterGroup) addRoute(method string, comp string, handler HandlerFunc) {
pattern := g.prefix + comp
g.engine.router.addRoute(method, pattern, handler)
}
func (g *RouterGroup) GET(pattern string, handler HandlerFunc) {
g.addRoute("GET", pattern, handler)
}
func (g *RouterGroup) POST(pattern string, handler HandlerFunc) {
g.addRoute("POST", pattern, handler)
}
type Engine struct {
*RouterGroup
router *router
groups []*RouterGroup
}
func New() *Engine {
engine := &Engine{router: newRouter()}
engine.RouterGroup = &RouterGroup{engine: engine}
engine.groups = []*RouterGroup{engine.RouterGroup}
return engine
}
// Default use Logger() & Recovery middlewares
func Default() *Engine {
engine := New()
engine.Use(Logger(), Recovery())
return engine
}
func (e *Engine) addRoute(method string, pattern string, handler HandlerFunc) {
e.router.addRoute(method, pattern, handler)
}
func (e *Engine) GET(pattern string, handler HandlerFunc) {
e.addRoute("GET", pattern, handler)
}
func (e *Engine) POST(pattern string, handler HandlerFunc) {
e.addRoute("POST", pattern, handler)
}
func (e *Engine) Use(middleware ...HandlerFunc) {
e.RouterGroup.middleware = append(e.RouterGroup.middleware, middleware...)
}
func (e *Engine) Run(addr string) (err error) {
return http.ListenAndServe(addr, e)
}
func (e *Engine) ServeHTTP(w http.ResponseWriter, r *http.Request) {
var middlewares []HandlerFunc
for _, group := range e.groups {
if strings.HasPrefix(r.URL.Path, group.prefix) {
middlewares = append(middlewares, group.middleware...)
}
}
c := newContext(w, r)
c.handlers = middlewares
e.router.handle(c)
}