123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914 |
- // Copyright 2014 beego Author. All Rights Reserved.
- //
- // 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 beego
- import (
- "fmt"
- "net/http"
- "os"
- "path"
- "path/filepath"
- "reflect"
- "runtime"
- "strconv"
- "strings"
- "sync"
- "time"
- beecontext "github.com/astaxie/beego/context"
- "github.com/astaxie/beego/logs"
- "github.com/astaxie/beego/toolbox"
- "github.com/astaxie/beego/utils"
- )
- // default filter execution points
- const (
- BeforeStatic = iota
- BeforeRouter
- BeforeExec
- AfterExec
- FinishRouter
- )
- const (
- routerTypeBeego = iota
- routerTypeRESTFul
- routerTypeHandler
- )
- var (
- // HTTPMETHOD list the supported http methods.
- HTTPMETHOD = map[string]string{
- "GET": "GET",
- "POST": "POST",
- "PUT": "PUT",
- "DELETE": "DELETE",
- "PATCH": "PATCH",
- "OPTIONS": "OPTIONS",
- "HEAD": "HEAD",
- "TRACE": "TRACE",
- "CONNECT": "CONNECT",
- "MKCOL": "MKCOL",
- "COPY": "COPY",
- "MOVE": "MOVE",
- "PROPFIND": "PROPFIND",
- "PROPPATCH": "PROPPATCH",
- "LOCK": "LOCK",
- "UNLOCK": "UNLOCK",
- }
- // these beego.Controller's methods shouldn't reflect to AutoRouter
- exceptMethod = []string{"Init", "Prepare", "Finish", "Render", "RenderString",
- "RenderBytes", "Redirect", "Abort", "StopRun", "UrlFor", "ServeJSON", "ServeJSONP",
- "ServeXML", "Input", "ParseForm", "GetString", "GetStrings", "GetInt", "GetBool",
- "GetFloat", "GetFile", "SaveToFile", "StartSession", "SetSession", "GetSession",
- "DelSession", "SessionRegenerateID", "DestroySession", "IsAjax", "GetSecureCookie",
- "SetSecureCookie", "XsrfToken", "CheckXsrfCookie", "XsrfFormHtml",
- "GetControllerAndAction", "ServeFormatted"}
- urlPlaceholder = "{{placeholder}}"
- // DefaultAccessLogFilter will skip the accesslog if return true
- DefaultAccessLogFilter FilterHandler = &logFilter{}
- )
- // FilterHandler is an interface for
- type FilterHandler interface {
- Filter(*beecontext.Context) bool
- }
- // default log filter static file will not show
- type logFilter struct {
- }
- func (l *logFilter) Filter(ctx *beecontext.Context) bool {
- requestPath := path.Clean(ctx.Request.URL.Path)
- if requestPath == "/favicon.ico" || requestPath == "/robots.txt" {
- return true
- }
- for prefix := range BConfig.WebConfig.StaticDir {
- if strings.HasPrefix(requestPath, prefix) {
- return true
- }
- }
- return false
- }
- // ExceptMethodAppend to append a slice's value into "exceptMethod", for controller's methods shouldn't reflect to AutoRouter
- func ExceptMethodAppend(action string) {
- exceptMethod = append(exceptMethod, action)
- }
- type controllerInfo struct {
- pattern string
- controllerType reflect.Type
- methods map[string]string
- handler http.Handler
- runFunction FilterFunc
- routerType int
- }
- // ControllerRegister containers registered router rules, controller handlers and filters.
- type ControllerRegister struct {
- routers map[string]*Tree
- enablePolicy bool
- policies map[string]*Tree
- enableFilter bool
- filters [FinishRouter + 1][]*FilterRouter
- pool sync.Pool
- }
- // NewControllerRegister returns a new ControllerRegister.
- func NewControllerRegister() *ControllerRegister {
- cr := &ControllerRegister{
- routers: make(map[string]*Tree),
- policies: make(map[string]*Tree),
- }
- cr.pool.New = func() interface{} {
- return beecontext.NewContext()
- }
- return cr
- }
- // Add controller handler and pattern rules to ControllerRegister.
- // usage:
- // default methods is the same name as method
- // Add("/user",&UserController{})
- // Add("/api/list",&RestController{},"*:ListFood")
- // Add("/api/create",&RestController{},"post:CreateFood")
- // Add("/api/update",&RestController{},"put:UpdateFood")
- // Add("/api/delete",&RestController{},"delete:DeleteFood")
- // Add("/api",&RestController{},"get,post:ApiFunc"
- // Add("/simple",&SimpleController{},"get:GetFunc;post:PostFunc")
- func (p *ControllerRegister) Add(pattern string, c ControllerInterface, mappingMethods ...string) {
- reflectVal := reflect.ValueOf(c)
- t := reflect.Indirect(reflectVal).Type()
- methods := make(map[string]string)
- if len(mappingMethods) > 0 {
- semi := strings.Split(mappingMethods[0], ";")
- for _, v := range semi {
- colon := strings.Split(v, ":")
- if len(colon) != 2 {
- panic("method mapping format is invalid")
- }
- comma := strings.Split(colon[0], ",")
- for _, m := range comma {
- if _, ok := HTTPMETHOD[strings.ToUpper(m)]; m == "*" || ok {
- if val := reflectVal.MethodByName(colon[1]); val.IsValid() {
- methods[strings.ToUpper(m)] = colon[1]
- } else {
- panic("'" + colon[1] + "' method doesn't exist in the controller " + t.Name())
- }
- } else {
- panic(v + " is an invalid method mapping. Method doesn't exist " + m)
- }
- }
- }
- }
- route := &controllerInfo{}
- route.pattern = pattern
- route.methods = methods
- route.routerType = routerTypeBeego
- route.controllerType = t
- if len(methods) == 0 {
- for _, m := range HTTPMETHOD {
- p.addToRouter(m, pattern, route)
- }
- } else {
- for k := range methods {
- if k == "*" {
- for _, m := range HTTPMETHOD {
- p.addToRouter(m, pattern, route)
- }
- } else {
- p.addToRouter(k, pattern, route)
- }
- }
- }
- }
- func (p *ControllerRegister) addToRouter(method, pattern string, r *controllerInfo) {
- if !BConfig.RouterCaseSensitive {
- pattern = strings.ToLower(pattern)
- }
- if t, ok := p.routers[method]; ok {
- t.AddRouter(pattern, r)
- } else {
- t := NewTree()
- t.AddRouter(pattern, r)
- p.routers[method] = t
- }
- }
- // Include only when the Runmode is dev will generate router file in the router/auto.go from the controller
- // Include(&BankAccount{}, &OrderController{},&RefundController{},&ReceiptController{})
- func (p *ControllerRegister) Include(cList ...ControllerInterface) {
- if BConfig.RunMode == DEV {
- skip := make(map[string]bool, 10)
- for _, c := range cList {
- reflectVal := reflect.ValueOf(c)
- t := reflect.Indirect(reflectVal).Type()
- gopath := os.Getenv("GOPATH")
- if gopath == "" {
- panic("you are in dev mode. So please set gopath")
- }
- pkgpath := ""
- wgopath := filepath.SplitList(gopath)
- for _, wg := range wgopath {
- wg, _ = filepath.EvalSymlinks(filepath.Join(wg, "src", t.PkgPath()))
- if utils.FileExists(wg) {
- pkgpath = wg
- break
- }
- }
- if pkgpath != "" {
- if _, ok := skip[pkgpath]; !ok {
- skip[pkgpath] = true
- parserPkg(pkgpath, t.PkgPath())
- }
- }
- }
- }
- for _, c := range cList {
- reflectVal := reflect.ValueOf(c)
- t := reflect.Indirect(reflectVal).Type()
- key := t.PkgPath() + ":" + t.Name()
- if comm, ok := GlobalControllerRouter[key]; ok {
- for _, a := range comm {
- p.Add(a.Router, c, strings.Join(a.AllowHTTPMethods, ",")+":"+a.Method)
- }
- }
- }
- }
- // Get add get method
- // usage:
- // Get("/", func(ctx *context.Context){
- // ctx.Output.Body("hello world")
- // })
- func (p *ControllerRegister) Get(pattern string, f FilterFunc) {
- p.AddMethod("get", pattern, f)
- }
- // Post add post method
- // usage:
- // Post("/api", func(ctx *context.Context){
- // ctx.Output.Body("hello world")
- // })
- func (p *ControllerRegister) Post(pattern string, f FilterFunc) {
- p.AddMethod("post", pattern, f)
- }
- // Put add put method
- // usage:
- // Put("/api/:id", func(ctx *context.Context){
- // ctx.Output.Body("hello world")
- // })
- func (p *ControllerRegister) Put(pattern string, f FilterFunc) {
- p.AddMethod("put", pattern, f)
- }
- // Delete add delete method
- // usage:
- // Delete("/api/:id", func(ctx *context.Context){
- // ctx.Output.Body("hello world")
- // })
- func (p *ControllerRegister) Delete(pattern string, f FilterFunc) {
- p.AddMethod("delete", pattern, f)
- }
- // Head add head method
- // usage:
- // Head("/api/:id", func(ctx *context.Context){
- // ctx.Output.Body("hello world")
- // })
- func (p *ControllerRegister) Head(pattern string, f FilterFunc) {
- p.AddMethod("head", pattern, f)
- }
- // Patch add patch method
- // usage:
- // Patch("/api/:id", func(ctx *context.Context){
- // ctx.Output.Body("hello world")
- // })
- func (p *ControllerRegister) Patch(pattern string, f FilterFunc) {
- p.AddMethod("patch", pattern, f)
- }
- // Options add options method
- // usage:
- // Options("/api/:id", func(ctx *context.Context){
- // ctx.Output.Body("hello world")
- // })
- func (p *ControllerRegister) Options(pattern string, f FilterFunc) {
- p.AddMethod("options", pattern, f)
- }
- // Any add all method
- // usage:
- // Any("/api/:id", func(ctx *context.Context){
- // ctx.Output.Body("hello world")
- // })
- func (p *ControllerRegister) Any(pattern string, f FilterFunc) {
- p.AddMethod("*", pattern, f)
- }
- // AddMethod add http method router
- // usage:
- // AddMethod("get","/api/:id", func(ctx *context.Context){
- // ctx.Output.Body("hello world")
- // })
- func (p *ControllerRegister) AddMethod(method, pattern string, f FilterFunc) {
- method = strings.ToUpper(method)
- if _, ok := HTTPMETHOD[method]; method != "*" && !ok {
- panic("not support http method: " + method)
- }
- route := &controllerInfo{}
- route.pattern = pattern
- route.routerType = routerTypeRESTFul
- route.runFunction = f
- methods := make(map[string]string)
- if method == "*" {
- for _, val := range HTTPMETHOD {
- methods[val] = val
- }
- } else {
- methods[method] = method
- }
- route.methods = methods
- for k := range methods {
- if k == "*" {
- for _, m := range HTTPMETHOD {
- p.addToRouter(m, pattern, route)
- }
- } else {
- p.addToRouter(k, pattern, route)
- }
- }
- }
- // Handler add user defined Handler
- func (p *ControllerRegister) Handler(pattern string, h http.Handler, options ...interface{}) {
- route := &controllerInfo{}
- route.pattern = pattern
- route.routerType = routerTypeHandler
- route.handler = h
- if len(options) > 0 {
- if _, ok := options[0].(bool); ok {
- pattern = path.Join(pattern, "?:all(.*)")
- }
- }
- for _, m := range HTTPMETHOD {
- p.addToRouter(m, pattern, route)
- }
- }
- // AddAuto router to ControllerRegister.
- // example beego.AddAuto(&MainContorlller{}),
- // MainController has method List and Page.
- // visit the url /main/list to execute List function
- // /main/page to execute Page function.
- func (p *ControllerRegister) AddAuto(c ControllerInterface) {
- p.AddAutoPrefix("/", c)
- }
- // AddAutoPrefix Add auto router to ControllerRegister with prefix.
- // example beego.AddAutoPrefix("/admin",&MainContorlller{}),
- // MainController has method List and Page.
- // visit the url /admin/main/list to execute List function
- // /admin/main/page to execute Page function.
- func (p *ControllerRegister) AddAutoPrefix(prefix string, c ControllerInterface) {
- reflectVal := reflect.ValueOf(c)
- rt := reflectVal.Type()
- ct := reflect.Indirect(reflectVal).Type()
- controllerName := strings.TrimSuffix(ct.Name(), "Controller")
- for i := 0; i < rt.NumMethod(); i++ {
- if !utils.InSlice(rt.Method(i).Name, exceptMethod) {
- route := &controllerInfo{}
- route.routerType = routerTypeBeego
- route.methods = map[string]string{"*": rt.Method(i).Name}
- route.controllerType = ct
- pattern := path.Join(prefix, strings.ToLower(controllerName), strings.ToLower(rt.Method(i).Name), "*")
- patternInit := path.Join(prefix, controllerName, rt.Method(i).Name, "*")
- patternFix := path.Join(prefix, strings.ToLower(controllerName), strings.ToLower(rt.Method(i).Name))
- patternFixInit := path.Join(prefix, controllerName, rt.Method(i).Name)
- route.pattern = pattern
- for _, m := range HTTPMETHOD {
- p.addToRouter(m, pattern, route)
- p.addToRouter(m, patternInit, route)
- p.addToRouter(m, patternFix, route)
- p.addToRouter(m, patternFixInit, route)
- }
- }
- }
- }
- // InsertFilter Add a FilterFunc with pattern rule and action constant.
- // params is for:
- // 1. setting the returnOnOutput value (false allows multiple filters to execute)
- // 2. determining whether or not params need to be reset.
- func (p *ControllerRegister) InsertFilter(pattern string, pos int, filter FilterFunc, params ...bool) error {
- mr := &FilterRouter{
- tree: NewTree(),
- pattern: pattern,
- filterFunc: filter,
- returnOnOutput: true,
- }
- if !BConfig.RouterCaseSensitive {
- mr.pattern = strings.ToLower(pattern)
- }
- paramsLen := len(params)
- if paramsLen > 0 {
- mr.returnOnOutput = params[0]
- }
- if paramsLen > 1 {
- mr.resetParams = params[1]
- }
- mr.tree.AddRouter(pattern, true)
- return p.insertFilterRouter(pos, mr)
- }
- // add Filter into
- func (p *ControllerRegister) insertFilterRouter(pos int, mr *FilterRouter) (err error) {
- if pos < BeforeStatic || pos > FinishRouter {
- err = fmt.Errorf("can not find your filter position")
- return
- }
- p.enableFilter = true
- p.filters[pos] = append(p.filters[pos], mr)
- return nil
- }
- // URLFor does another controller handler in this request function.
- // it can access any controller method.
- func (p *ControllerRegister) URLFor(endpoint string, values ...interface{}) string {
- paths := strings.Split(endpoint, ".")
- if len(paths) <= 1 {
- logs.Warn("urlfor endpoint must like path.controller.method")
- return ""
- }
- if len(values)%2 != 0 {
- logs.Warn("urlfor params must key-value pair")
- return ""
- }
- params := make(map[string]string)
- if len(values) > 0 {
- key := ""
- for k, v := range values {
- if k%2 == 0 {
- key = fmt.Sprint(v)
- } else {
- params[key] = fmt.Sprint(v)
- }
- }
- }
- controllName := strings.Join(paths[:len(paths)-1], "/")
- methodName := paths[len(paths)-1]
- for m, t := range p.routers {
- ok, url := p.geturl(t, "/", controllName, methodName, params, m)
- if ok {
- return url
- }
- }
- return ""
- }
- func (p *ControllerRegister) geturl(t *Tree, url, controllName, methodName string, params map[string]string, httpMethod string) (bool, string) {
- for _, subtree := range t.fixrouters {
- u := path.Join(url, subtree.prefix)
- ok, u := p.geturl(subtree, u, controllName, methodName, params, httpMethod)
- if ok {
- return ok, u
- }
- }
- if t.wildcard != nil {
- u := path.Join(url, urlPlaceholder)
- ok, u := p.geturl(t.wildcard, u, controllName, methodName, params, httpMethod)
- if ok {
- return ok, u
- }
- }
- for _, l := range t.leaves {
- if c, ok := l.runObject.(*controllerInfo); ok {
- if c.routerType == routerTypeBeego &&
- strings.HasSuffix(path.Join(c.controllerType.PkgPath(), c.controllerType.Name()), controllName) {
- find := false
- if _, ok := HTTPMETHOD[strings.ToUpper(methodName)]; ok {
- if len(c.methods) == 0 {
- find = true
- } else if m, ok := c.methods[strings.ToUpper(methodName)]; ok && m == strings.ToUpper(methodName) {
- find = true
- } else if m, ok = c.methods["*"]; ok && m == methodName {
- find = true
- }
- }
- if !find {
- for m, md := range c.methods {
- if (m == "*" || m == httpMethod) && md == methodName {
- find = true
- }
- }
- }
- if find {
- if l.regexps == nil {
- if len(l.wildcards) == 0 {
- return true, strings.Replace(url, "/"+urlPlaceholder, "", 1) + toURL(params)
- }
- if len(l.wildcards) == 1 {
- if v, ok := params[l.wildcards[0]]; ok {
- delete(params, l.wildcards[0])
- return true, strings.Replace(url, urlPlaceholder, v, 1) + toURL(params)
- }
- return false, ""
- }
- if len(l.wildcards) == 3 && l.wildcards[0] == "." {
- if p, ok := params[":path"]; ok {
- if e, isok := params[":ext"]; isok {
- delete(params, ":path")
- delete(params, ":ext")
- return true, strings.Replace(url, urlPlaceholder, p+"."+e, -1) + toURL(params)
- }
- }
- }
- canskip := false
- for _, v := range l.wildcards {
- if v == ":" {
- canskip = true
- continue
- }
- if u, ok := params[v]; ok {
- delete(params, v)
- url = strings.Replace(url, urlPlaceholder, u, 1)
- } else {
- if canskip {
- canskip = false
- continue
- }
- return false, ""
- }
- }
- return true, url + toURL(params)
- }
- var i int
- var startreg bool
- regurl := ""
- for _, v := range strings.Trim(l.regexps.String(), "^$") {
- if v == '(' {
- startreg = true
- continue
- } else if v == ')' {
- startreg = false
- if v, ok := params[l.wildcards[i]]; ok {
- delete(params, l.wildcards[i])
- regurl = regurl + v
- i++
- } else {
- break
- }
- } else if !startreg {
- regurl = string(append([]rune(regurl), v))
- }
- }
- if l.regexps.MatchString(regurl) {
- ps := strings.Split(regurl, "/")
- for _, p := range ps {
- url = strings.Replace(url, urlPlaceholder, p, 1)
- }
- return true, url + toURL(params)
- }
- }
- }
- }
- }
- return false, ""
- }
- func (p *ControllerRegister) execFilter(context *beecontext.Context, urlPath string, pos int) (started bool) {
- var preFilterParams map[string]string
- for _, filterR := range p.filters[pos] {
- if filterR.returnOnOutput && context.ResponseWriter.Started {
- return true
- }
- if filterR.resetParams {
- preFilterParams = context.Input.Params()
- }
- if ok := filterR.ValidRouter(urlPath, context); ok {
- filterR.filterFunc(context)
- if filterR.resetParams {
- context.Input.ResetParams()
- for k, v := range preFilterParams {
- context.Input.SetParam(k, v)
- }
- }
- }
- if filterR.returnOnOutput && context.ResponseWriter.Started {
- return true
- }
- }
- return false
- }
- // Implement http.Handler interface.
- func (p *ControllerRegister) ServeHTTP(rw http.ResponseWriter, r *http.Request) {
- startTime := time.Now()
- var (
- runRouter reflect.Type
- findRouter bool
- runMethod string
- routerInfo *controllerInfo
- isRunnable bool
- )
- context := p.pool.Get().(*beecontext.Context)
- context.Reset(rw, r)
- defer p.pool.Put(context)
- if BConfig.RecoverFunc != nil {
- defer BConfig.RecoverFunc(context)
- }
- context.Output.EnableGzip = BConfig.EnableGzip
- if BConfig.RunMode == DEV {
- context.Output.Header("Server", BConfig.ServerName)
- }
- var urlPath = r.URL.Path
- if !BConfig.RouterCaseSensitive {
- urlPath = strings.ToLower(urlPath)
- }
- // filter wrong http method
- if _, ok := HTTPMETHOD[r.Method]; !ok {
- http.Error(rw, "Method Not Allowed", 405)
- goto Admin
- }
- // filter for static file
- if len(p.filters[BeforeStatic]) > 0 && p.execFilter(context, urlPath, BeforeStatic) {
- goto Admin
- }
- serverStaticRouter(context)
- if context.ResponseWriter.Started {
- findRouter = true
- goto Admin
- }
- if r.Method != "GET" && r.Method != "HEAD" {
- if BConfig.CopyRequestBody && !context.Input.IsUpload() {
- context.Input.CopyBody(BConfig.MaxMemory)
- }
- context.Input.ParseFormOrMulitForm(BConfig.MaxMemory)
- }
- // session init
- if BConfig.WebConfig.Session.SessionOn {
- var err error
- context.Input.CruSession, err = GlobalSessions.SessionStart(rw, r)
- if err != nil {
- logs.Error(err)
- exception("503", context)
- goto Admin
- }
- defer func() {
- if context.Input.CruSession != nil {
- context.Input.CruSession.SessionRelease(rw)
- }
- }()
- }
- if len(p.filters[BeforeRouter]) > 0 && p.execFilter(context, urlPath, BeforeRouter) {
- goto Admin
- }
- // User can define RunController and RunMethod in filter
- if context.Input.RunController != nil && context.Input.RunMethod != "" {
- findRouter = true
- isRunnable = true
- runMethod = context.Input.RunMethod
- runRouter = context.Input.RunController
- } else {
- routerInfo, findRouter = p.FindRouter(context)
- }
- //if no matches to url, throw a not found exception
- if !findRouter {
- exception("404", context)
- goto Admin
- }
- if splat := context.Input.Param(":splat"); splat != "" {
- for k, v := range strings.Split(splat, "/") {
- context.Input.SetParam(strconv.Itoa(k), v)
- }
- }
- //execute middleware filters
- if len(p.filters[BeforeExec]) > 0 && p.execFilter(context, urlPath, BeforeExec) {
- goto Admin
- }
- //check policies
- if p.execPolicy(context, urlPath) {
- goto Admin
- }
- if routerInfo != nil {
- //store router pattern into context
- context.Input.SetData("RouterPattern", routerInfo.pattern)
- if routerInfo.routerType == routerTypeRESTFul {
- if _, ok := routerInfo.methods[r.Method]; ok {
- isRunnable = true
- routerInfo.runFunction(context)
- } else {
- exception("405", context)
- goto Admin
- }
- } else if routerInfo.routerType == routerTypeHandler {
- isRunnable = true
- routerInfo.handler.ServeHTTP(rw, r)
- } else {
- runRouter = routerInfo.controllerType
- method := r.Method
- if r.Method == "POST" && context.Input.Query("_method") == "PUT" {
- method = "PUT"
- }
- if r.Method == "POST" && context.Input.Query("_method") == "DELETE" {
- method = "DELETE"
- }
- if m, ok := routerInfo.methods[method]; ok {
- runMethod = m
- } else if m, ok = routerInfo.methods["*"]; ok {
- runMethod = m
- } else {
- runMethod = method
- }
- }
- }
- // also defined runRouter & runMethod from filter
- if !isRunnable {
- //Invoke the request handler
- vc := reflect.New(runRouter)
- execController, ok := vc.Interface().(ControllerInterface)
- if !ok {
- panic("controller is not ControllerInterface")
- }
- //call the controller init function
- execController.Init(context, runRouter.Name(), runMethod, vc.Interface())
- //call prepare function
- execController.Prepare()
- //if XSRF is Enable then check cookie where there has any cookie in the request's cookie _csrf
- if BConfig.WebConfig.EnableXSRF {
- execController.XSRFToken()
- if r.Method == "POST" || r.Method == "DELETE" || r.Method == "PUT" ||
- (r.Method == "POST" && (context.Input.Query("_method") == "DELETE" || context.Input.Query("_method") == "PUT")) {
- execController.CheckXSRFCookie()
- }
- }
- execController.URLMapping()
- if !context.ResponseWriter.Started {
- //exec main logic
- switch runMethod {
- case "GET":
- execController.Get()
- case "POST":
- execController.Post()
- case "DELETE":
- execController.Delete()
- case "PUT":
- execController.Put()
- case "HEAD":
- execController.Head()
- case "PATCH":
- execController.Patch()
- case "OPTIONS":
- execController.Options()
- default:
- if !execController.HandlerFunc(runMethod) {
- var in []reflect.Value
- method := vc.MethodByName(runMethod)
- method.Call(in)
- }
- }
- //render template
- if !context.ResponseWriter.Started && context.Output.Status == 0 {
- if BConfig.WebConfig.AutoRender {
- if err := execController.Render(); err != nil {
- logs.Error(err)
- }
- }
- }
- }
- // finish all runRouter. release resource
- execController.Finish()
- }
- //execute middleware filters
- if len(p.filters[AfterExec]) > 0 && p.execFilter(context, urlPath, AfterExec) {
- goto Admin
- }
- if len(p.filters[FinishRouter]) > 0 && p.execFilter(context, urlPath, FinishRouter) {
- goto Admin
- }
- Admin:
- //admin module record QPS
- if BConfig.Listen.EnableAdmin {
- timeDur := time.Since(startTime)
- if FilterMonitorFunc(r.Method, r.URL.Path, timeDur) {
- if runRouter != nil {
- go toolbox.StatisticsMap.AddStatistics(r.Method, r.URL.Path, runRouter.Name(), timeDur)
- } else {
- go toolbox.StatisticsMap.AddStatistics(r.Method, r.URL.Path, "", timeDur)
- }
- }
- }
- if BConfig.RunMode == DEV || BConfig.Log.AccessLogs {
- timeDur := time.Since(startTime)
- var devInfo string
- statusCode := context.ResponseWriter.Status
- if statusCode == 0 {
- statusCode = 200
- }
- iswin := (runtime.GOOS == "windows")
- statusColor := logs.ColorByStatus(iswin, statusCode)
- methodColor := logs.ColorByMethod(iswin, r.Method)
- resetColor := logs.ColorByMethod(iswin, "")
- if findRouter {
- if routerInfo != nil {
- devInfo = fmt.Sprintf("|%15s|%s %3d %s|%13s|%8s|%s %-7s %s %-3s r:%s", context.Input.IP(), statusColor, statusCode,
- resetColor, timeDur.String(), "match", methodColor, r.Method, resetColor, r.URL.Path,
- routerInfo.pattern)
- } else {
- devInfo = fmt.Sprintf("|%15s|%s %3d %s|%13s|%8s|%s %-7s %s %-3s", context.Input.IP(), statusColor, statusCode, resetColor,
- timeDur.String(), "match", methodColor, r.Method, resetColor, r.URL.Path)
- }
- } else {
- devInfo = fmt.Sprintf("|%15s|%s %3d %s|%13s|%8s|%s %-7s %s %-3s", context.Input.IP(), statusColor, statusCode, resetColor,
- timeDur.String(), "nomatch", methodColor, r.Method, resetColor, r.URL.Path)
- }
- if iswin {
- logs.W32Debug(devInfo)
- } else {
- logs.Debug(devInfo)
- }
- }
- // Call WriteHeader if status code has been set changed
- if context.Output.Status != 0 {
- context.ResponseWriter.WriteHeader(context.Output.Status)
- }
- }
- // FindRouter Find Router info for URL
- func (p *ControllerRegister) FindRouter(context *beecontext.Context) (routerInfo *controllerInfo, isFind bool) {
- var urlPath = context.Input.URL()
- if !BConfig.RouterCaseSensitive {
- urlPath = strings.ToLower(urlPath)
- }
- httpMethod := context.Input.Method()
- if t, ok := p.routers[httpMethod]; ok {
- runObject := t.Match(urlPath, context)
- if r, ok := runObject.(*controllerInfo); ok {
- return r, true
- }
- }
- return
- }
- func toURL(params map[string]string) string {
- if len(params) == 0 {
- return ""
- }
- u := "?"
- for k, v := range params {
- u += k + "=" + v + "&"
- }
- return strings.TrimRight(u, "&")
- }
|