Commit 5d4dc18b by Marcus Efraimsson

revert application lifecycle event support

parent 2332b3e2
......@@ -15,9 +15,10 @@ import (
"github.com/grafana/grafana/pkg/api"
"github.com/grafana/grafana/pkg/api/routing"
"github.com/grafana/grafana/pkg/bus"
"github.com/grafana/grafana/pkg/lifecycle"
"github.com/grafana/grafana/pkg/login"
"github.com/grafana/grafana/pkg/middleware"
"github.com/grafana/grafana/pkg/registry"
"github.com/grafana/grafana/pkg/social"
"golang.org/x/sync/errgroup"
......@@ -69,7 +70,8 @@ func (g *GrafanaServerImpl) Run() error {
g.loadConfiguration()
g.writePIDFile()
lifecycle.Notify(lifecycle.ApplicationStarting)
login.Init()
social.NewOAuthService()
serviceGraph := inject.Graph{}
serviceGraph.Provide(&inject.Object{Value: bus.GetBus()})
......@@ -142,7 +144,6 @@ func (g *GrafanaServerImpl) Run() error {
}
sendSystemdNotification("READY=1")
lifecycle.Notify(lifecycle.ApplicationStarted)
return g.childRoutines.Wait()
}
......
package lifecycle
type Event int
const (
ApplicationStarting Event = iota
ApplicationStarted
)
type EventHandlerFunc func()
var listeners = map[int][]EventHandlerFunc{}
func AddListener(evt Event, fn EventHandlerFunc) {
listeners[int(evt)] = append(listeners[int(evt)], fn)
}
func Notify(evt Event) {
for _, handler := range listeners[int(evt)] {
handler()
}
}
package lifecycle
import (
"testing"
. "github.com/smartystreets/goconvey/convey"
)
func TestLifecycle(t *testing.T) {
Convey("TestLifecycle", t, func() {
Convey("Given listeners", func() {
applicationStartingCounter := 0
AddListener(ApplicationStarting, func() {
applicationStartingCounter++
})
applicationStartedCounter := 0
AddListener(ApplicationStarted, func() {
applicationStartedCounter++
})
Convey("When notify application starting should call listener", func() {
Notify(ApplicationStarting)
So(applicationStartingCounter, ShouldEqual, 1)
So(applicationStartedCounter, ShouldEqual, 0)
})
Convey("When notify application started should call listener", func() {
Notify(ApplicationStarted)
So(applicationStartingCounter, ShouldEqual, 0)
So(applicationStartedCounter, ShouldEqual, 1)
})
})
})
}
......@@ -4,7 +4,6 @@ import (
"errors"
"github.com/grafana/grafana/pkg/bus"
"github.com/grafana/grafana/pkg/lifecycle"
m "github.com/grafana/grafana/pkg/models"
)
......@@ -20,11 +19,9 @@ var (
ErrGettingUserQuota = errors.New("Error getting user quota")
)
func init() {
lifecycle.AddListener(lifecycle.ApplicationStarting, func() {
bus.AddHandler("auth", AuthenticateUser)
loadLdapConfig()
})
func Init() {
bus.AddHandler("auth", AuthenticateUser)
loadLdapConfig()
}
func AuthenticateUser(query *m.LoginUserQuery) error {
......
......@@ -8,18 +8,11 @@ import (
"golang.org/x/oauth2"
"github.com/grafana/grafana/pkg/lifecycle"
"github.com/grafana/grafana/pkg/log"
"github.com/grafana/grafana/pkg/setting"
"github.com/grafana/grafana/pkg/util"
)
func init() {
lifecycle.AddListener(lifecycle.ApplicationStarting, func() {
initOAuthService()
})
}
type BasicUserInfo struct {
Id string
Name string
......@@ -63,7 +56,7 @@ var (
allOauthes = []string{"github", "gitlab", "google", "generic_oauth", "grafananet", grafanaCom}
)
func initOAuthService() {
func NewOAuthService() {
setting.OAuthService = &setting.OAuther{}
setting.OAuthService.OAuthInfos = make(map[string]*setting.OAuthInfo)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment