123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081 |
- // +build appengine
- package bugsnag
- import (
- "appengine"
- "appengine/urlfetch"
- "appengine/user"
- "fmt"
- "log"
- "net/http"
- )
- func defaultPanicHandler() {}
- func init() {
- OnBeforeNotify(appengineMiddleware)
- }
- func appengineMiddleware(event *Event, config *Configuration) (err error) {
- var c appengine.Context
- for _, datum := range event.RawData {
- if r, ok := datum.(*http.Request); ok {
- c = appengine.NewContext(r)
- break
- } else if context, ok := datum.(appengine.Context); ok {
- c = context
- break
- }
- }
- if c == nil {
- return fmt.Errorf("No appengine context given")
- }
- // You can only use the builtin http library if you pay for appengine,
- // so we use the appengine urlfetch service instead.
- config.Transport = &urlfetch.Transport{
- Context: c,
- }
- // Anything written to stderr/stdout is discarded, so lets log to the request.
- if configuredLogger, ok := config.Logger.(*log.Logger); ok {
- config.Logger = log.New(appengineWriter{c}, configuredLogger.Prefix(), configuredLogger.Flags())
- } else {
- config.Logger = log.New(appengineWriter{c}, log.Prefix(), log.Flags())
- }
- // Set the releaseStage appropriately
- if config.ReleaseStage == "" {
- if appengine.IsDevAppServer() {
- config.ReleaseStage = "development"
- } else {
- config.ReleaseStage = "production"
- }
- }
- if event.User == nil {
- u := user.Current(c)
- if u != nil {
- event.User = &User{
- Id: u.ID,
- Email: u.Email,
- }
- }
- }
- return nil
- }
- // Convert an appengine.Context into an io.Writer so we can create a log.Logger.
- type appengineWriter struct {
- appengine.Context
- }
- func (c appengineWriter) Write(b []byte) (int, error) {
- c.Warningf(string(b))
- return len(b), nil
- }
|