| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370 | // Copyright 2014 The Macaron Authors//// Licensed under the Apache License, Version 2.0 (the "License"): you may// not use this file except in compliance with the License. You may obtain// a copy of the License at////     http://www.apache.org/licenses/LICENSE-2.0//// Unless required by applicable law or agreed to in writing, software// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the// License for the specific language governing permissions and limitations// under the License.package macaronimport (	"net/http"	"strings"	"sync")var (	// Known HTTP methods.	_HTTP_METHODS = map[string]bool{		"GET":     true,		"POST":    true,		"PUT":     true,		"DELETE":  true,		"PATCH":   true,		"OPTIONS": true,		"HEAD":    true,	})// routeMap represents a thread-safe map for route tree.type routeMap struct {	lock   sync.RWMutex	routes map[string]map[string]*Leaf}// NewRouteMap initializes and returns a new routeMap.func NewRouteMap() *routeMap {	rm := &routeMap{		routes: make(map[string]map[string]*Leaf),	}	for m := range _HTTP_METHODS {		rm.routes[m] = make(map[string]*Leaf)	}	return rm}// getLeaf returns Leaf object if a route has been registered.func (rm *routeMap) getLeaf(method, pattern string) *Leaf {	rm.lock.RLock()	defer rm.lock.RUnlock()	return rm.routes[method][pattern]}// add adds new route to route tree map.func (rm *routeMap) add(method, pattern string, leaf *Leaf) {	rm.lock.Lock()	defer rm.lock.Unlock()	rm.routes[method][pattern] = leaf}type group struct {	pattern  string	handlers []Handler}// Router represents a Macaron router layer.type Router struct {	m        *Macaron	autoHead bool	routers  map[string]*Tree	*routeMap	namedRoutes map[string]*Leaf	groups              []group	notFound            http.HandlerFunc	internalServerError func(*Context, error)	// handlerWrapper is used to wrap arbitrary function from Handler to inject.FastInvoker.	handlerWrapper func(Handler) Handler}func NewRouter() *Router {	return &Router{		routers:     make(map[string]*Tree),		routeMap:    NewRouteMap(),		namedRoutes: make(map[string]*Leaf),	}}// SetAutoHead sets the value who determines whether add HEAD method automatically// when GET method is added. Combo router will not be affected by this value.func (r *Router) SetAutoHead(v bool) {	r.autoHead = v}type Params map[string]string// Handle is a function that can be registered to a route to handle HTTP requests.// Like http.HandlerFunc, but has a third parameter for the values of wildcards (variables).type Handle func(http.ResponseWriter, *http.Request, Params)// Route represents a wrapper of leaf route and upper level router.type Route struct {	router *Router	leaf   *Leaf}// Name sets name of route.func (r *Route) Name(name string) {	if len(name) == 0 {		panic("route name cannot be empty")	} else if r.router.namedRoutes[name] != nil {		panic("route with given name already exists")	}	r.router.namedRoutes[name] = r.leaf}// handle adds new route to the router tree.func (r *Router) handle(method, pattern string, handle Handle) *Route {	method = strings.ToUpper(method)	var leaf *Leaf	// Prevent duplicate routes.	if leaf = r.getLeaf(method, pattern); leaf != nil {		return &Route{r, leaf}	}	// Validate HTTP methods.	if !_HTTP_METHODS[method] && method != "*" {		panic("unknown HTTP method: " + method)	}	// Generate methods need register.	methods := make(map[string]bool)	if method == "*" {		for m := range _HTTP_METHODS {			methods[m] = true		}	} else {		methods[method] = true	}	// Add to router tree.	for m := range methods {		if t, ok := r.routers[m]; ok {			leaf = t.Add(pattern, handle)		} else {			t := NewTree()			leaf = t.Add(pattern, handle)			r.routers[m] = t		}		r.add(m, pattern, leaf)	}	return &Route{r, leaf}}// Handle registers a new request handle with the given pattern, method and handlers.func (r *Router) Handle(method string, pattern string, handlers []Handler) *Route {	if len(r.groups) > 0 {		groupPattern := ""		h := make([]Handler, 0)		for _, g := range r.groups {			groupPattern += g.pattern			h = append(h, g.handlers...)		}		pattern = groupPattern + pattern		h = append(h, handlers...)		handlers = h	}	handlers = validateAndWrapHandlers(handlers, r.handlerWrapper)	return r.handle(method, pattern, func(resp http.ResponseWriter, req *http.Request, params Params) {		c := r.m.createContext(resp, req)		c.params = params		c.handlers = make([]Handler, 0, len(r.m.handlers)+len(handlers))		c.handlers = append(c.handlers, r.m.handlers...)		c.handlers = append(c.handlers, handlers...)		c.run()	})}func (r *Router) Group(pattern string, fn func(), h ...Handler) {	r.groups = append(r.groups, group{pattern, h})	fn()	r.groups = r.groups[:len(r.groups)-1]}// Get is a shortcut for r.Handle("GET", pattern, handlers)func (r *Router) Get(pattern string, h ...Handler) (leaf *Route) {	leaf = r.Handle("GET", pattern, h)	if r.autoHead {		r.Head(pattern, h...)	}	return leaf}// Patch is a shortcut for r.Handle("PATCH", pattern, handlers)func (r *Router) Patch(pattern string, h ...Handler) *Route {	return r.Handle("PATCH", pattern, h)}// Post is a shortcut for r.Handle("POST", pattern, handlers)func (r *Router) Post(pattern string, h ...Handler) *Route {	return r.Handle("POST", pattern, h)}// Put is a shortcut for r.Handle("PUT", pattern, handlers)func (r *Router) Put(pattern string, h ...Handler) *Route {	return r.Handle("PUT", pattern, h)}// Delete is a shortcut for r.Handle("DELETE", pattern, handlers)func (r *Router) Delete(pattern string, h ...Handler) *Route {	return r.Handle("DELETE", pattern, h)}// Options is a shortcut for r.Handle("OPTIONS", pattern, handlers)func (r *Router) Options(pattern string, h ...Handler) *Route {	return r.Handle("OPTIONS", pattern, h)}// Head is a shortcut for r.Handle("HEAD", pattern, handlers)func (r *Router) Head(pattern string, h ...Handler) *Route {	return r.Handle("HEAD", pattern, h)}// Any is a shortcut for r.Handle("*", pattern, handlers)func (r *Router) Any(pattern string, h ...Handler) *Route {	return r.Handle("*", pattern, h)}// Route is a shortcut for same handlers but different HTTP methods.//// Example:// 		m.Route("/", "GET,POST", h)func (r *Router) Route(pattern, methods string, h ...Handler) (route *Route) {	for _, m := range strings.Split(methods, ",") {		route = r.Handle(strings.TrimSpace(m), pattern, h)	}	return route}// Combo returns a combo router.func (r *Router) Combo(pattern string, h ...Handler) *ComboRouter {	return &ComboRouter{r, pattern, h, map[string]bool{}, nil}}// NotFound configurates http.HandlerFunc which is called when no matching route is// found. If it is not set, http.NotFound is used.// Be sure to set 404 response code in your handler.func (r *Router) NotFound(handlers ...Handler) {	handlers = validateAndWrapHandlers(handlers)	r.notFound = func(rw http.ResponseWriter, req *http.Request) {		c := r.m.createContext(rw, req)		c.handlers = make([]Handler, 0, len(r.m.handlers)+len(handlers))		c.handlers = append(c.handlers, r.m.handlers...)		c.handlers = append(c.handlers, handlers...)		c.run()	}}// InternalServerError configurates handler which is called when route handler returns// error. If it is not set, default handler is used.// Be sure to set 500 response code in your handler.func (r *Router) InternalServerError(handlers ...Handler) {	handlers = validateAndWrapHandlers(handlers)	r.internalServerError = func(c *Context, err error) {		c.index = 0		c.handlers = handlers		c.Map(err)		c.run()	}}// SetHandlerWrapper sets handlerWrapper for the router.func (r *Router) SetHandlerWrapper(f func(Handler) Handler) {	r.handlerWrapper = f}func (r *Router) ServeHTTP(rw http.ResponseWriter, req *http.Request) {	if t, ok := r.routers[req.Method]; ok {		h, p, ok := t.Match(req.URL.Path)		if ok {			if splat, ok := p["*0"]; ok {				p["*"] = splat // Easy name.			}			h(rw, req, p)			return		}	}	r.notFound(rw, req)}// URLFor builds path part of URL by given pair values.func (r *Router) URLFor(name string, pairs ...string) string {	leaf, ok := r.namedRoutes[name]	if !ok {		panic("route with given name does not exists: " + name)	}	return leaf.URLPath(pairs...)}// ComboRouter represents a combo router.type ComboRouter struct {	router   *Router	pattern  string	handlers []Handler	methods  map[string]bool // Registered methods.	lastRoute *Route}func (cr *ComboRouter) checkMethod(name string) {	if cr.methods[name] {		panic("method '" + name + "' has already been registered")	}	cr.methods[name] = true}func (cr *ComboRouter) route(fn func(string, ...Handler) *Route, method string, h ...Handler) *ComboRouter {	cr.checkMethod(method)	cr.lastRoute = fn(cr.pattern, append(cr.handlers, h...)...)	return cr}func (cr *ComboRouter) Get(h ...Handler) *ComboRouter {	return cr.route(cr.router.Get, "GET", h...)}func (cr *ComboRouter) Patch(h ...Handler) *ComboRouter {	return cr.route(cr.router.Patch, "PATCH", h...)}func (cr *ComboRouter) Post(h ...Handler) *ComboRouter {	return cr.route(cr.router.Post, "POST", h...)}func (cr *ComboRouter) Put(h ...Handler) *ComboRouter {	return cr.route(cr.router.Put, "PUT", h...)}func (cr *ComboRouter) Delete(h ...Handler) *ComboRouter {	return cr.route(cr.router.Delete, "DELETE", h...)}func (cr *ComboRouter) Options(h ...Handler) *ComboRouter {	return cr.route(cr.router.Options, "OPTIONS", h...)}func (cr *ComboRouter) Head(h ...Handler) *ComboRouter {	return cr.route(cr.router.Head, "HEAD", h...)}// Name sets name of ComboRouter route.func (cr *ComboRouter) Name(name string) {	if cr.lastRoute == nil {		panic("no corresponding route to be named")	}	cr.lastRoute.Name(name)}
 |