2012-12-17 05:53:03 +00:00
|
|
|
package beego
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
2013-01-01 15:11:15 +00:00
|
|
|
"github.com/astaxie/session"
|
|
|
|
_ "github.com/astaxie/session/providers/memory"
|
2012-12-17 05:53:03 +00:00
|
|
|
"net/http"
|
|
|
|
"os"
|
|
|
|
"path"
|
2013-01-01 15:11:15 +00:00
|
|
|
"strconv"
|
2012-12-17 05:53:03 +00:00
|
|
|
)
|
|
|
|
|
|
|
|
var (
|
|
|
|
BeeApp *App
|
|
|
|
AppName string
|
|
|
|
AppPath string
|
|
|
|
StaticDir map[string]string
|
|
|
|
HttpAddr string
|
|
|
|
HttpPort int
|
|
|
|
RecoverPanic bool
|
|
|
|
AutoRender bool
|
2012-12-27 14:27:26 +00:00
|
|
|
PprofOn bool
|
2012-12-17 05:53:03 +00:00
|
|
|
ViewsPath string
|
|
|
|
RunMode string //"dev" or "prod"
|
|
|
|
AppConfig *Config
|
2013-01-01 15:11:15 +00:00
|
|
|
//related to session
|
|
|
|
SessionOn bool // wheather auto start session,default is false
|
|
|
|
SessionProvider string // default session provider memory
|
|
|
|
SessionName string // sessionName cookie's name
|
|
|
|
SessionGCMaxLifetime int64 // session's gc maxlifetime
|
|
|
|
|
|
|
|
GlobalSessions *session.Manager //GlobalSessions
|
2012-12-17 05:53:03 +00:00
|
|
|
)
|
|
|
|
|
|
|
|
func init() {
|
|
|
|
BeeApp = NewApp()
|
|
|
|
AppPath, _ = os.Getwd()
|
|
|
|
StaticDir = make(map[string]string)
|
|
|
|
var err error
|
|
|
|
AppConfig, err = LoadConfig(path.Join(AppPath, "conf", "app.conf"))
|
|
|
|
if err != nil {
|
|
|
|
//Trace("open Config err:", err)
|
|
|
|
HttpAddr = ""
|
|
|
|
HttpPort = 8080
|
|
|
|
AppName = "beego"
|
|
|
|
RunMode = "prod" //default runmod
|
|
|
|
AutoRender = true
|
|
|
|
RecoverPanic = true
|
2012-12-27 14:27:26 +00:00
|
|
|
PprofOn = false
|
2012-12-17 05:53:03 +00:00
|
|
|
ViewsPath = "views"
|
2013-01-01 15:11:15 +00:00
|
|
|
SessionOn = false
|
|
|
|
SessionProvider = "memory"
|
|
|
|
SessionName = "beegosessionID"
|
|
|
|
SessionGCMaxLifetime = 3600
|
2012-12-17 05:53:03 +00:00
|
|
|
} else {
|
|
|
|
HttpAddr = AppConfig.String("httpaddr")
|
|
|
|
if v, err := AppConfig.Int("httpport"); err != nil {
|
|
|
|
HttpPort = 8080
|
|
|
|
} else {
|
|
|
|
HttpPort = v
|
|
|
|
}
|
|
|
|
AppName = AppConfig.String("appname")
|
|
|
|
if runmode := AppConfig.String("runmode"); runmode != "" {
|
|
|
|
RunMode = runmode
|
|
|
|
} else {
|
|
|
|
RunMode = "prod"
|
|
|
|
}
|
|
|
|
if ar, err := AppConfig.Bool("autorender"); err != nil {
|
|
|
|
AutoRender = true
|
|
|
|
} else {
|
|
|
|
AutoRender = ar
|
|
|
|
}
|
|
|
|
if ar, err := AppConfig.Bool("autorecover"); err != nil {
|
|
|
|
RecoverPanic = true
|
|
|
|
} else {
|
|
|
|
RecoverPanic = ar
|
|
|
|
}
|
2012-12-27 14:27:26 +00:00
|
|
|
if ar, err := AppConfig.Bool("pprofon"); err != nil {
|
|
|
|
PprofOn = false
|
|
|
|
} else {
|
|
|
|
PprofOn = ar
|
|
|
|
}
|
2012-12-17 05:53:03 +00:00
|
|
|
if views := AppConfig.String("viewspath"); views == "" {
|
|
|
|
ViewsPath = "views"
|
|
|
|
} else {
|
|
|
|
ViewsPath = views
|
|
|
|
}
|
2013-01-01 15:11:15 +00:00
|
|
|
if ar, err := AppConfig.Bool("sessionon"); err != nil {
|
|
|
|
SessionOn = false
|
|
|
|
} else {
|
|
|
|
SessionOn = ar
|
|
|
|
}
|
|
|
|
if ar := AppConfig.String("sessionprovider"); ar == "" {
|
|
|
|
SessionProvider = "memory"
|
|
|
|
} else {
|
|
|
|
SessionProvider = ar
|
|
|
|
}
|
|
|
|
if ar := AppConfig.String("sessionname"); ar == "" {
|
|
|
|
SessionName = "beegosessionID"
|
|
|
|
} else {
|
|
|
|
SessionName = ar
|
|
|
|
}
|
2013-01-01 16:06:44 +00:00
|
|
|
if ar, err := AppConfig.Int("sessiongcmaxlifetime"); err != nil && ar != 0 {
|
2013-01-01 15:11:15 +00:00
|
|
|
int64val, _ := strconv.ParseInt(strconv.Itoa(ar), 10, 64)
|
|
|
|
SessionGCMaxLifetime = int64val
|
|
|
|
} else {
|
|
|
|
SessionGCMaxLifetime = 3600
|
|
|
|
}
|
2012-12-17 05:53:03 +00:00
|
|
|
}
|
|
|
|
StaticDir["/static"] = "static"
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
type App struct {
|
|
|
|
Handlers *ControllerRegistor
|
|
|
|
}
|
|
|
|
|
|
|
|
// New returns a new PatternServeMux.
|
|
|
|
func NewApp() *App {
|
|
|
|
cr := NewControllerRegistor()
|
|
|
|
app := &App{Handlers: cr}
|
|
|
|
return app
|
|
|
|
}
|
|
|
|
|
|
|
|
func (app *App) Run() {
|
|
|
|
addr := fmt.Sprintf("%s:%d", HttpAddr, HttpPort)
|
|
|
|
err := http.ListenAndServe(addr, app.Handlers)
|
|
|
|
if err != nil {
|
|
|
|
BeeLogger.Fatal("ListenAndServe: ", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func (app *App) RegisterController(path string, c ControllerInterface) *App {
|
|
|
|
app.Handlers.Add(path, c)
|
|
|
|
return app
|
|
|
|
}
|
|
|
|
|
|
|
|
func (app *App) Filter(filter http.HandlerFunc) *App {
|
|
|
|
app.Handlers.Filter(filter)
|
|
|
|
return app
|
|
|
|
}
|
|
|
|
|
|
|
|
func (app *App) FilterParam(param string, filter http.HandlerFunc) *App {
|
|
|
|
app.Handlers.FilterParam(param, filter)
|
|
|
|
return app
|
|
|
|
}
|
|
|
|
|
|
|
|
func (app *App) FilterPrefixPath(path string, filter http.HandlerFunc) *App {
|
|
|
|
app.Handlers.FilterParam(path, filter)
|
|
|
|
return app
|
|
|
|
}
|
|
|
|
|
|
|
|
func (app *App) SetViewsPath(path string) *App {
|
|
|
|
ViewsPath = path
|
|
|
|
return app
|
|
|
|
}
|
|
|
|
|
|
|
|
func (app *App) SetStaticPath(url string, path string) *App {
|
|
|
|
StaticDir[url] = path
|
|
|
|
return app
|
|
|
|
}
|
|
|
|
|
|
|
|
func (app *App) ErrorLog(ctx *Context) {
|
|
|
|
BeeLogger.Printf("[ERR] host: '%s', request: '%s %s', proto: '%s', ua: '%s', remote: '%s'\n", ctx.Request.Host, ctx.Request.Method, ctx.Request.URL.Path, ctx.Request.Proto, ctx.Request.UserAgent(), ctx.Request.RemoteAddr)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (app *App) AccessLog(ctx *Context) {
|
|
|
|
BeeLogger.Printf("[ACC] host: '%s', request: '%s %s', proto: '%s', ua: %s'', remote: '%s'\n", ctx.Request.Host, ctx.Request.Method, ctx.Request.URL.Path, ctx.Request.Proto, ctx.Request.UserAgent(), ctx.Request.RemoteAddr)
|
|
|
|
}
|
2012-12-17 14:15:21 +00:00
|
|
|
|
|
|
|
func RegisterController(path string, c ControllerInterface) *App {
|
|
|
|
BeeApp.RegisterController(path, c)
|
|
|
|
return BeeApp
|
|
|
|
}
|
|
|
|
|
|
|
|
func Filter(filter http.HandlerFunc) *App {
|
|
|
|
BeeApp.Filter(filter)
|
|
|
|
return BeeApp
|
|
|
|
}
|
|
|
|
|
|
|
|
func FilterParam(param string, filter http.HandlerFunc) *App {
|
|
|
|
BeeApp.FilterParam(param, filter)
|
|
|
|
return BeeApp
|
|
|
|
}
|
|
|
|
|
|
|
|
func FilterPrefixPath(path string, filter http.HandlerFunc) *App {
|
|
|
|
BeeApp.FilterParam(path, filter)
|
|
|
|
return BeeApp
|
|
|
|
}
|
|
|
|
|
|
|
|
func Run() {
|
2012-12-27 14:27:26 +00:00
|
|
|
if PprofOn {
|
|
|
|
BeeApp.RegisterController(`/debug/pprof`, &ProfController{})
|
2012-12-27 14:42:16 +00:00
|
|
|
BeeApp.RegisterController(`/debug/pprof/:pp([\w]+)`, &ProfController{})
|
2012-12-27 14:27:26 +00:00
|
|
|
}
|
2013-01-01 15:11:15 +00:00
|
|
|
if SessionOn {
|
|
|
|
GlobalSessions, _ = session.NewManager(SessionProvider, SessionName, SessionGCMaxLifetime)
|
|
|
|
go GlobalSessions.GC()
|
|
|
|
}
|
2012-12-17 14:15:21 +00:00
|
|
|
BeeApp.Run()
|
|
|
|
}
|