123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334 |
- // +build go1.3
- // 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 macaron is a high productive and modular web framework in Go.
- package macaron
- import (
- "io"
- "log"
- "net/http"
- "os"
- "reflect"
- "strings"
- "sync"
- "github.com/Unknwon/com"
- "gopkg.in/ini.v1"
- "github.com/go-macaron/inject"
- )
- const _VERSION = "1.2.1.0213"
- func Version() string {
- return _VERSION
- }
- // Handler can be any callable function.
- // Macaron attempts to inject services into the handler's argument list,
- // and panics if an argument could not be fullfilled via dependency injection.
- type Handler interface{}
- // handlerFuncInvoker is an inject.FastInvoker wrapper of func(http.ResponseWriter, *http.Request).
- type handlerFuncInvoker func(http.ResponseWriter, *http.Request)
- func (invoke handlerFuncInvoker) Invoke(params []interface{}) ([]reflect.Value, error) {
- invoke(params[0].(http.ResponseWriter), params[1].(*http.Request))
- return nil, nil
- }
- // internalServerErrorInvoker is an inject.FastInvoker wrapper of func(rw http.ResponseWriter, err error).
- type internalServerErrorInvoker func(rw http.ResponseWriter, err error)
- func (invoke internalServerErrorInvoker) Invoke(params []interface{}) ([]reflect.Value, error) {
- invoke(params[0].(http.ResponseWriter), params[1].(error))
- return nil, nil
- }
- // validateAndWrapHandler makes sure a handler is a callable function, it panics if not.
- // When the handler is also potential to be any built-in inject.FastInvoker,
- // it wraps the handler automatically to have some performance gain.
- func validateAndWrapHandler(h Handler) Handler {
- if reflect.TypeOf(h).Kind() != reflect.Func {
- panic("Macaron handler must be a callable function")
- }
- if !inject.IsFastInvoker(h) {
- switch v := h.(type) {
- case func(*Context):
- return ContextInvoker(v)
- case func(*Context, *log.Logger):
- return LoggerInvoker(v)
- case func(http.ResponseWriter, *http.Request):
- return handlerFuncInvoker(v)
- case func(http.ResponseWriter, error):
- return internalServerErrorInvoker(v)
- }
- }
- return h
- }
- // validateAndWrapHandlers preforms validation and wrapping for each input handler.
- // It accepts an optional wrapper function to perform custom wrapping on handlers.
- func validateAndWrapHandlers(handlers []Handler, wrappers ...func(Handler) Handler) []Handler {
- var wrapper func(Handler) Handler
- if len(wrappers) > 0 {
- wrapper = wrappers[0]
- }
- wrappedHandlers := make([]Handler, len(handlers))
- for i, h := range handlers {
- h = validateAndWrapHandler(h)
- if wrapper != nil && !inject.IsFastInvoker(h) {
- h = wrapper(h)
- }
- wrappedHandlers[i] = h
- }
- return wrappedHandlers
- }
- // Macaron represents the top level web application.
- // inject.Injector methods can be invoked to map services on a global level.
- type Macaron struct {
- inject.Injector
- befores []BeforeHandler
- handlers []Handler
- action Handler
- hasURLPrefix bool
- urlPrefix string // For suburl support.
- *Router
- logger *log.Logger
- }
- // NewWithLogger creates a bare bones Macaron instance.
- // Use this method if you want to have full control over the middleware that is used.
- // You can specify logger output writer with this function.
- func NewWithLogger(out io.Writer) *Macaron {
- m := &Macaron{
- Injector: inject.New(),
- action: func() {},
- Router: NewRouter(),
- logger: log.New(out, "[Macaron] ", 0),
- }
- m.Router.m = m
- m.Map(m.logger)
- m.Map(defaultReturnHandler())
- m.NotFound(http.NotFound)
- m.InternalServerError(func(rw http.ResponseWriter, err error) {
- http.Error(rw, err.Error(), 500)
- })
- return m
- }
- // New creates a bare bones Macaron instance.
- // Use this method if you want to have full control over the middleware that is used.
- func New() *Macaron {
- return NewWithLogger(os.Stdout)
- }
- // Classic creates a classic Macaron with some basic default middleware:
- // macaron.Logger, macaron.Recovery and macaron.Static.
- func Classic() *Macaron {
- m := New()
- m.Use(Logger())
- m.Use(Recovery())
- m.Use(Static("public"))
- return m
- }
- // Handlers sets the entire middleware stack with the given Handlers.
- // This will clear any current middleware handlers,
- // and panics if any of the handlers is not a callable function
- func (m *Macaron) Handlers(handlers ...Handler) {
- m.handlers = make([]Handler, 0)
- for _, handler := range handlers {
- m.Use(handler)
- }
- }
- // Action sets the handler that will be called after all the middleware has been invoked.
- // This is set to macaron.Router in a macaron.Classic().
- func (m *Macaron) Action(handler Handler) {
- handler = validateAndWrapHandler(handler)
- m.action = handler
- }
- // BeforeHandler represents a handler executes at beginning of every request.
- // Macaron stops future process when it returns true.
- type BeforeHandler func(rw http.ResponseWriter, req *http.Request) bool
- func (m *Macaron) Before(handler BeforeHandler) {
- m.befores = append(m.befores, handler)
- }
- // Use adds a middleware Handler to the stack,
- // and panics if the handler is not a callable func.
- // Middleware Handlers are invoked in the order that they are added.
- func (m *Macaron) Use(handler Handler) {
- handler = validateAndWrapHandler(handler)
- m.handlers = append(m.handlers, handler)
- }
- func (m *Macaron) createContext(rw http.ResponseWriter, req *http.Request) *Context {
- c := &Context{
- Injector: inject.New(),
- handlers: m.handlers,
- action: m.action,
- index: 0,
- Router: m.Router,
- Req: Request{req},
- Resp: NewResponseWriter(rw),
- Render: &DummyRender{rw},
- Data: make(map[string]interface{}),
- }
- c.SetParent(m)
- c.Map(c)
- c.MapTo(c.Resp, (*http.ResponseWriter)(nil))
- c.Map(req)
- return c
- }
- // ServeHTTP is the HTTP Entry point for a Macaron instance.
- // Useful if you want to control your own HTTP server.
- // Be aware that none of middleware will run without registering any router.
- func (m *Macaron) ServeHTTP(rw http.ResponseWriter, req *http.Request) {
- if m.hasURLPrefix {
- req.URL.Path = strings.TrimPrefix(req.URL.Path, m.urlPrefix)
- }
- for _, h := range m.befores {
- if h(rw, req) {
- return
- }
- }
- m.Router.ServeHTTP(rw, req)
- }
- func GetDefaultListenInfo() (string, int) {
- host := os.Getenv("HOST")
- if len(host) == 0 {
- host = "0.0.0.0"
- }
- port := com.StrTo(os.Getenv("PORT")).MustInt()
- if port == 0 {
- port = 4000
- }
- return host, port
- }
- // Run the http server. Listening on os.GetEnv("PORT") or 4000 by default.
- func (m *Macaron) Run(args ...interface{}) {
- host, port := GetDefaultListenInfo()
- if len(args) == 1 {
- switch arg := args[0].(type) {
- case string:
- host = arg
- case int:
- port = arg
- }
- } else if len(args) >= 2 {
- if arg, ok := args[0].(string); ok {
- host = arg
- }
- if arg, ok := args[1].(int); ok {
- port = arg
- }
- }
- addr := host + ":" + com.ToStr(port)
- logger := m.GetVal(reflect.TypeOf(m.logger)).Interface().(*log.Logger)
- logger.Printf("listening on %s (%s)\n", addr, safeEnv())
- logger.Fatalln(http.ListenAndServe(addr, m))
- }
- // SetURLPrefix sets URL prefix of router layer, so that it support suburl.
- func (m *Macaron) SetURLPrefix(prefix string) {
- m.urlPrefix = prefix
- m.hasURLPrefix = len(m.urlPrefix) > 0
- }
- // ____ ____ .__ ___. .__
- // \ \ / /____ _______|__|____ \_ |__ | | ____ ______
- // \ Y /\__ \\_ __ \ \__ \ | __ \| | _/ __ \ / ___/
- // \ / / __ \| | \/ |/ __ \| \_\ \ |_\ ___/ \___ \
- // \___/ (____ /__| |__(____ /___ /____/\___ >____ >
- // \/ \/ \/ \/ \/
- const (
- DEV = "development"
- PROD = "production"
- TEST = "test"
- )
- var (
- // Env is the environment that Macaron is executing in.
- // The MACARON_ENV is read on initialization to set this variable.
- Env = DEV
- envLock sync.Mutex
- // Path of work directory.
- Root string
- // Flash applies to current request.
- FlashNow bool
- // Configuration convention object.
- cfg *ini.File
- )
- func setENV(e string) {
- envLock.Lock()
- defer envLock.Unlock()
- if len(e) > 0 {
- Env = e
- }
- }
- func safeEnv() string {
- envLock.Lock()
- defer envLock.Unlock()
- return Env
- }
- func init() {
- setENV(os.Getenv("MACARON_ENV"))
- var err error
- Root, err = os.Getwd()
- if err != nil {
- panic("error getting work directory: " + err.Error())
- }
- }
- // SetConfig sets data sources for configuration.
- func SetConfig(source interface{}, others ...interface{}) (_ *ini.File, err error) {
- cfg, err = ini.Load(source, others...)
- return Config(), err
- }
- // Config returns configuration convention object.
- // It returns an empty object if there is no one available.
- func Config() *ini.File {
- if cfg == nil {
- return ini.Empty()
- }
- return cfg
- }
|