login.go 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183
  1. package api
  2. import (
  3. "net/url"
  4. "github.com/grafana/grafana/pkg/api/dtos"
  5. "github.com/grafana/grafana/pkg/bus"
  6. "github.com/grafana/grafana/pkg/log"
  7. "github.com/grafana/grafana/pkg/login"
  8. "github.com/grafana/grafana/pkg/metrics"
  9. m "github.com/grafana/grafana/pkg/models"
  10. "github.com/grafana/grafana/pkg/setting"
  11. )
  12. const (
  13. ViewIndex = "index"
  14. )
  15. func (hs *HTTPServer) LoginView(c *m.ReqContext) {
  16. viewData, err := hs.setIndexViewData(c)
  17. if err != nil {
  18. c.Handle(500, "Failed to get settings", err)
  19. return
  20. }
  21. enabledOAuths := make(map[string]interface{})
  22. for key, oauth := range setting.OAuthService.OAuthInfos {
  23. enabledOAuths[key] = map[string]string{"name": oauth.Name}
  24. }
  25. viewData.Settings["oauth"] = enabledOAuths
  26. viewData.Settings["disableUserSignUp"] = !setting.AllowUserSignUp
  27. viewData.Settings["loginHint"] = setting.LoginHint
  28. viewData.Settings["disableLoginForm"] = setting.DisableLoginForm
  29. if loginError, ok := c.Session.Get("loginError").(string); ok {
  30. c.Session.Delete("loginError")
  31. viewData.Settings["loginError"] = loginError
  32. }
  33. if tryOAuthAutoLogin(c) {
  34. return
  35. }
  36. //if !hs.tryLoginUsingRememberCookie(c) {
  37. c.HTML(200, ViewIndex, viewData)
  38. return
  39. //}
  40. if redirectTo, _ := url.QueryUnescape(c.GetCookie("redirect_to")); len(redirectTo) > 0 {
  41. c.SetCookie("redirect_to", "", -1, setting.AppSubUrl+"/")
  42. c.Redirect(redirectTo)
  43. return
  44. }
  45. c.Redirect(setting.AppSubUrl + "/")
  46. }
  47. func tryOAuthAutoLogin(c *m.ReqContext) bool {
  48. if !setting.OAuthAutoLogin {
  49. return false
  50. }
  51. oauthInfos := setting.OAuthService.OAuthInfos
  52. if len(oauthInfos) != 1 {
  53. log.Warn("Skipping OAuth auto login because multiple OAuth providers are configured.")
  54. return false
  55. }
  56. for key := range setting.OAuthService.OAuthInfos {
  57. redirectUrl := setting.AppSubUrl + "/login/" + key
  58. log.Info("OAuth auto login enabled. Redirecting to " + redirectUrl)
  59. c.Redirect(redirectUrl, 307)
  60. return true
  61. }
  62. return false
  63. }
  64. func (hs *HTTPServer) tryLoginUsingRememberCookie(c *m.ReqContext) bool {
  65. // Check auto-login.
  66. uname := c.GetCookie(setting.CookieUserName)
  67. if len(uname) == 0 {
  68. return false
  69. }
  70. isSucceed := false
  71. defer func() {
  72. if !isSucceed {
  73. log.Trace("auto-login cookie cleared: %s", uname)
  74. c.SetCookie(setting.CookieUserName, "", -1, setting.AppSubUrl+"/")
  75. c.SetCookie(setting.CookieRememberName, "", -1, setting.AppSubUrl+"/")
  76. return
  77. }
  78. }()
  79. userQuery := m.GetUserByLoginQuery{LoginOrEmail: uname}
  80. if err := bus.Dispatch(&userQuery); err != nil {
  81. return false
  82. }
  83. user := userQuery.Result
  84. // validate remember me cookie
  85. signingKey := user.Rands + user.Password
  86. if len(signingKey) < 10 {
  87. c.Logger.Error("Invalid user signingKey")
  88. return false
  89. }
  90. if val, _ := c.GetSuperSecureCookie(signingKey, setting.CookieRememberName); val != user.Login {
  91. return false
  92. }
  93. isSucceed = true
  94. hs.loginUserWithUser(user, c)
  95. return true
  96. }
  97. func (hs *HTTPServer) LoginAPIPing(c *m.ReqContext) {
  98. if !hs.tryLoginUsingRememberCookie(c) {
  99. c.JsonApiErr(401, "Unauthorized", nil)
  100. return
  101. }
  102. c.JsonOK("Logged in")
  103. }
  104. func (hs *HTTPServer) LoginPost(c *m.ReqContext, cmd dtos.LoginCommand) Response {
  105. if setting.DisableLoginForm {
  106. return Error(401, "Login is disabled", nil)
  107. }
  108. authQuery := &m.LoginUserQuery{
  109. ReqContext: c,
  110. Username: cmd.User,
  111. Password: cmd.Password,
  112. IpAddress: c.Req.RemoteAddr,
  113. }
  114. if err := bus.Dispatch(authQuery); err != nil {
  115. if err == login.ErrInvalidCredentials || err == login.ErrTooManyLoginAttempts {
  116. return Error(401, "Invalid username or password", err)
  117. }
  118. return Error(500, "Error while trying to authenticate user", err)
  119. }
  120. user := authQuery.User
  121. hs.loginUserWithUser(user, c)
  122. result := map[string]interface{}{
  123. "message": "Logged in",
  124. }
  125. if redirectTo, _ := url.QueryUnescape(c.GetCookie("redirect_to")); len(redirectTo) > 0 {
  126. result["redirectUrl"] = redirectTo
  127. c.SetCookie("redirect_to", "", -1, setting.AppSubUrl+"/")
  128. }
  129. metrics.M_Api_Login_Post.Inc()
  130. return JSON(200, result)
  131. }
  132. func (hs *HTTPServer) loginUserWithUser(user *m.User, c *m.ReqContext) {
  133. if user == nil {
  134. hs.log.Error("User login with nil user")
  135. }
  136. err := hs.AuthTokenService.UserAuthenticatedHook(user, c)
  137. if err != nil {
  138. hs.log.Error("User auth hook failed", "error", err)
  139. }
  140. }
  141. func (hs *HTTPServer) Logout(c *m.ReqContext) {
  142. hs.AuthTokenService.UserSignedOutHook(c)
  143. if setting.SignoutRedirectUrl != "" {
  144. c.Redirect(setting.SignoutRedirectUrl)
  145. } else {
  146. c.Redirect(setting.AppSubUrl + "/login")
  147. }
  148. }