You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873
  1. // Copyright 2014 The Gogs Authors. All rights reserved.
  2. // Copyright 2018 The Gitea Authors. All rights reserved.
  3. // SPDX-License-Identifier: MIT
  4. package auth
  5. import (
  6. "errors"
  7. "fmt"
  8. "html/template"
  9. "net/http"
  10. "strings"
  11. "code.gitea.io/gitea/models/auth"
  12. "code.gitea.io/gitea/models/db"
  13. user_model "code.gitea.io/gitea/models/user"
  14. "code.gitea.io/gitea/modules/auth/password"
  15. "code.gitea.io/gitea/modules/base"
  16. "code.gitea.io/gitea/modules/eventsource"
  17. "code.gitea.io/gitea/modules/httplib"
  18. "code.gitea.io/gitea/modules/log"
  19. "code.gitea.io/gitea/modules/optional"
  20. "code.gitea.io/gitea/modules/session"
  21. "code.gitea.io/gitea/modules/setting"
  22. "code.gitea.io/gitea/modules/timeutil"
  23. "code.gitea.io/gitea/modules/util"
  24. "code.gitea.io/gitea/modules/web"
  25. "code.gitea.io/gitea/modules/web/middleware"
  26. auth_service "code.gitea.io/gitea/services/auth"
  27. "code.gitea.io/gitea/services/auth/source/oauth2"
  28. "code.gitea.io/gitea/services/context"
  29. "code.gitea.io/gitea/services/externalaccount"
  30. "code.gitea.io/gitea/services/forms"
  31. "code.gitea.io/gitea/services/mailer"
  32. user_service "code.gitea.io/gitea/services/user"
  33. "github.com/markbates/goth"
  34. )
  35. const (
  36. tplSignIn base.TplName = "user/auth/signin" // for sign in page
  37. tplSignUp base.TplName = "user/auth/signup" // for sign up page
  38. TplActivate base.TplName = "user/auth/activate" // for activate user
  39. TplActivatePrompt base.TplName = "user/auth/activate_prompt" // for showing a message for user activation
  40. )
  41. // autoSignIn reads cookie and try to auto-login.
  42. func autoSignIn(ctx *context.Context) (bool, error) {
  43. isSucceed := false
  44. defer func() {
  45. if !isSucceed {
  46. ctx.DeleteSiteCookie(setting.CookieRememberName)
  47. }
  48. }()
  49. if err := auth.DeleteExpiredAuthTokens(ctx); err != nil {
  50. log.Error("Failed to delete expired auth tokens: %v", err)
  51. }
  52. t, err := auth_service.CheckAuthToken(ctx, ctx.GetSiteCookie(setting.CookieRememberName))
  53. if err != nil {
  54. switch err {
  55. case auth_service.ErrAuthTokenInvalidFormat, auth_service.ErrAuthTokenExpired:
  56. return false, nil
  57. }
  58. return false, err
  59. }
  60. if t == nil {
  61. return false, nil
  62. }
  63. u, err := user_model.GetUserByID(ctx, t.UserID)
  64. if err != nil {
  65. if !user_model.IsErrUserNotExist(err) {
  66. return false, fmt.Errorf("GetUserByID: %w", err)
  67. }
  68. return false, nil
  69. }
  70. isSucceed = true
  71. nt, token, err := auth_service.RegenerateAuthToken(ctx, t)
  72. if err != nil {
  73. return false, err
  74. }
  75. ctx.SetSiteCookie(setting.CookieRememberName, nt.ID+":"+token, setting.LogInRememberDays*timeutil.Day)
  76. if err := updateSession(ctx, nil, map[string]any{
  77. // Set session IDs
  78. "uid": u.ID,
  79. "uname": u.Name,
  80. }); err != nil {
  81. return false, fmt.Errorf("unable to updateSession: %w", err)
  82. }
  83. if err := resetLocale(ctx, u); err != nil {
  84. return false, err
  85. }
  86. ctx.Csrf.DeleteCookie(ctx)
  87. return true, nil
  88. }
  89. func resetLocale(ctx *context.Context, u *user_model.User) error {
  90. // Language setting of the user overwrites the one previously set
  91. // If the user does not have a locale set, we save the current one.
  92. if u.Language == "" {
  93. opts := &user_service.UpdateOptions{
  94. Language: optional.Some(ctx.Locale.Language()),
  95. }
  96. if err := user_service.UpdateUser(ctx, u, opts); err != nil {
  97. return err
  98. }
  99. }
  100. middleware.SetLocaleCookie(ctx.Resp, u.Language, 0)
  101. if ctx.Locale.Language() != u.Language {
  102. ctx.Locale = middleware.Locale(ctx.Resp, ctx.Req)
  103. }
  104. return nil
  105. }
  106. func RedirectAfterLogin(ctx *context.Context) {
  107. redirectTo := ctx.FormString("redirect_to")
  108. if redirectTo == "" {
  109. redirectTo = ctx.GetSiteCookie("redirect_to")
  110. }
  111. middleware.DeleteRedirectToCookie(ctx.Resp)
  112. nextRedirectTo := setting.AppSubURL + string(setting.LandingPageURL)
  113. if setting.LandingPageURL == setting.LandingPageLogin {
  114. nextRedirectTo = setting.AppSubURL + "/" // do not cycle-redirect to the login page
  115. }
  116. ctx.RedirectToCurrentSite(redirectTo, nextRedirectTo)
  117. }
  118. func CheckAutoLogin(ctx *context.Context) bool {
  119. isSucceed, err := autoSignIn(ctx) // try to auto-login
  120. if err != nil {
  121. if errors.Is(err, auth_service.ErrAuthTokenInvalidHash) {
  122. ctx.Flash.Error(ctx.Tr("auth.remember_me.compromised"), true)
  123. return false
  124. }
  125. ctx.ServerError("autoSignIn", err)
  126. return true
  127. }
  128. redirectTo := ctx.FormString("redirect_to")
  129. if len(redirectTo) > 0 {
  130. middleware.SetRedirectToCookie(ctx.Resp, redirectTo)
  131. }
  132. if isSucceed {
  133. RedirectAfterLogin(ctx)
  134. return true
  135. }
  136. return false
  137. }
  138. // SignIn render sign in page
  139. func SignIn(ctx *context.Context) {
  140. ctx.Data["Title"] = ctx.Tr("sign_in")
  141. if CheckAutoLogin(ctx) {
  142. return
  143. }
  144. if ctx.IsSigned {
  145. RedirectAfterLogin(ctx)
  146. return
  147. }
  148. oauth2Providers, err := oauth2.GetOAuth2Providers(ctx, optional.Some(true))
  149. if err != nil {
  150. ctx.ServerError("UserSignIn", err)
  151. return
  152. }
  153. ctx.Data["OAuth2Providers"] = oauth2Providers
  154. ctx.Data["Title"] = ctx.Tr("sign_in")
  155. ctx.Data["SignInLink"] = setting.AppSubURL + "/user/login"
  156. ctx.Data["PageIsSignIn"] = true
  157. ctx.Data["PageIsLogin"] = true
  158. ctx.Data["EnableSSPI"] = auth.IsSSPIEnabled(ctx)
  159. if setting.Service.EnableCaptcha && setting.Service.RequireCaptchaForLogin {
  160. context.SetCaptchaData(ctx)
  161. }
  162. ctx.HTML(http.StatusOK, tplSignIn)
  163. }
  164. // SignInPost response for sign in request
  165. func SignInPost(ctx *context.Context) {
  166. ctx.Data["Title"] = ctx.Tr("sign_in")
  167. oauth2Providers, err := oauth2.GetOAuth2Providers(ctx, optional.Some(true))
  168. if err != nil {
  169. ctx.ServerError("UserSignIn", err)
  170. return
  171. }
  172. ctx.Data["OAuth2Providers"] = oauth2Providers
  173. ctx.Data["Title"] = ctx.Tr("sign_in")
  174. ctx.Data["SignInLink"] = setting.AppSubURL + "/user/login"
  175. ctx.Data["PageIsSignIn"] = true
  176. ctx.Data["PageIsLogin"] = true
  177. ctx.Data["EnableSSPI"] = auth.IsSSPIEnabled(ctx)
  178. if ctx.HasError() {
  179. ctx.HTML(http.StatusOK, tplSignIn)
  180. return
  181. }
  182. form := web.GetForm(ctx).(*forms.SignInForm)
  183. if setting.Service.EnableCaptcha && setting.Service.RequireCaptchaForLogin {
  184. context.SetCaptchaData(ctx)
  185. context.VerifyCaptcha(ctx, tplSignIn, form)
  186. if ctx.Written() {
  187. return
  188. }
  189. }
  190. u, source, err := auth_service.UserSignIn(ctx, form.UserName, form.Password)
  191. if err != nil {
  192. if errors.Is(err, util.ErrNotExist) || errors.Is(err, util.ErrInvalidArgument) {
  193. ctx.RenderWithErr(ctx.Tr("form.username_password_incorrect"), tplSignIn, &form)
  194. log.Info("Failed authentication attempt for %s from %s: %v", form.UserName, ctx.RemoteAddr(), err)
  195. } else if user_model.IsErrEmailAlreadyUsed(err) {
  196. ctx.RenderWithErr(ctx.Tr("form.email_been_used"), tplSignIn, &form)
  197. log.Info("Failed authentication attempt for %s from %s: %v", form.UserName, ctx.RemoteAddr(), err)
  198. } else if user_model.IsErrUserProhibitLogin(err) {
  199. log.Info("Failed authentication attempt for %s from %s: %v", form.UserName, ctx.RemoteAddr(), err)
  200. ctx.Data["Title"] = ctx.Tr("auth.prohibit_login")
  201. ctx.HTML(http.StatusOK, "user/auth/prohibit_login")
  202. } else if user_model.IsErrUserInactive(err) {
  203. if setting.Service.RegisterEmailConfirm {
  204. ctx.Data["Title"] = ctx.Tr("auth.active_your_account")
  205. ctx.HTML(http.StatusOK, TplActivate)
  206. } else {
  207. log.Info("Failed authentication attempt for %s from %s: %v", form.UserName, ctx.RemoteAddr(), err)
  208. ctx.Data["Title"] = ctx.Tr("auth.prohibit_login")
  209. ctx.HTML(http.StatusOK, "user/auth/prohibit_login")
  210. }
  211. } else {
  212. ctx.ServerError("UserSignIn", err)
  213. }
  214. return
  215. }
  216. // Now handle 2FA:
  217. // First of all if the source can skip local two fa we're done
  218. if skipper, ok := source.Cfg.(auth_service.LocalTwoFASkipper); ok && skipper.IsSkipLocalTwoFA() {
  219. handleSignIn(ctx, u, form.Remember)
  220. return
  221. }
  222. // If this user is enrolled in 2FA TOTP, we can't sign the user in just yet.
  223. // Instead, redirect them to the 2FA authentication page.
  224. hasTOTPtwofa, err := auth.HasTwoFactorByUID(ctx, u.ID)
  225. if err != nil {
  226. ctx.ServerError("UserSignIn", err)
  227. return
  228. }
  229. // Check if the user has webauthn registration
  230. hasWebAuthnTwofa, err := auth.HasWebAuthnRegistrationsByUID(ctx, u.ID)
  231. if err != nil {
  232. ctx.ServerError("UserSignIn", err)
  233. return
  234. }
  235. if !hasTOTPtwofa && !hasWebAuthnTwofa {
  236. // No two factor auth configured we can sign in the user
  237. handleSignIn(ctx, u, form.Remember)
  238. return
  239. }
  240. updates := map[string]any{
  241. // User will need to use 2FA TOTP or WebAuthn, save data
  242. "twofaUid": u.ID,
  243. "twofaRemember": form.Remember,
  244. }
  245. if hasTOTPtwofa {
  246. // User will need to use WebAuthn, save data
  247. updates["totpEnrolled"] = u.ID
  248. }
  249. if err := updateSession(ctx, nil, updates); err != nil {
  250. ctx.ServerError("UserSignIn: Unable to update session", err)
  251. return
  252. }
  253. // If we have WebAuthn redirect there first
  254. if hasWebAuthnTwofa {
  255. ctx.Redirect(setting.AppSubURL + "/user/webauthn")
  256. return
  257. }
  258. // Fallback to 2FA
  259. ctx.Redirect(setting.AppSubURL + "/user/two_factor")
  260. }
  261. // This handles the final part of the sign-in process of the user.
  262. func handleSignIn(ctx *context.Context, u *user_model.User, remember bool) {
  263. redirect := handleSignInFull(ctx, u, remember, true)
  264. if ctx.Written() {
  265. return
  266. }
  267. ctx.Redirect(redirect)
  268. }
  269. func handleSignInFull(ctx *context.Context, u *user_model.User, remember, obeyRedirect bool) string {
  270. if remember {
  271. nt, token, err := auth_service.CreateAuthTokenForUserID(ctx, u.ID)
  272. if err != nil {
  273. ctx.ServerError("CreateAuthTokenForUserID", err)
  274. return setting.AppSubURL + "/"
  275. }
  276. ctx.SetSiteCookie(setting.CookieRememberName, nt.ID+":"+token, setting.LogInRememberDays*timeutil.Day)
  277. }
  278. if err := updateSession(ctx, []string{
  279. // Delete the openid, 2fa and linkaccount data
  280. "openid_verified_uri",
  281. "openid_signin_remember",
  282. "openid_determined_email",
  283. "openid_determined_username",
  284. "twofaUid",
  285. "twofaRemember",
  286. "linkAccount",
  287. }, map[string]any{
  288. "uid": u.ID,
  289. "uname": u.Name,
  290. }); err != nil {
  291. ctx.ServerError("RegenerateSession", err)
  292. return setting.AppSubURL + "/"
  293. }
  294. // Language setting of the user overwrites the one previously set
  295. // If the user does not have a locale set, we save the current one.
  296. if u.Language == "" {
  297. opts := &user_service.UpdateOptions{
  298. Language: optional.Some(ctx.Locale.Language()),
  299. }
  300. if err := user_service.UpdateUser(ctx, u, opts); err != nil {
  301. ctx.ServerError("UpdateUser Language", fmt.Errorf("Error updating user language [user: %d, locale: %s]", u.ID, ctx.Locale.Language()))
  302. return setting.AppSubURL + "/"
  303. }
  304. }
  305. middleware.SetLocaleCookie(ctx.Resp, u.Language, 0)
  306. if ctx.Locale.Language() != u.Language {
  307. ctx.Locale = middleware.Locale(ctx.Resp, ctx.Req)
  308. }
  309. // Clear whatever CSRF cookie has right now, force to generate a new one
  310. ctx.Csrf.DeleteCookie(ctx)
  311. // Register last login
  312. if err := user_service.UpdateUser(ctx, u, &user_service.UpdateOptions{SetLastLogin: true}); err != nil {
  313. ctx.ServerError("UpdateUser", err)
  314. return setting.AppSubURL + "/"
  315. }
  316. if redirectTo := ctx.GetSiteCookie("redirect_to"); redirectTo != "" && httplib.IsCurrentGiteaSiteURL(redirectTo) {
  317. middleware.DeleteRedirectToCookie(ctx.Resp)
  318. if obeyRedirect {
  319. ctx.RedirectToCurrentSite(redirectTo)
  320. }
  321. return redirectTo
  322. }
  323. if obeyRedirect {
  324. ctx.Redirect(setting.AppSubURL + "/")
  325. }
  326. return setting.AppSubURL + "/"
  327. }
  328. // extractUserNameFromOAuth2 tries to extract a normalized username from the given OAuth2 user.
  329. // It returns ("", nil) if the required field doesn't exist.
  330. func extractUserNameFromOAuth2(gothUser *goth.User) (string, error) {
  331. switch setting.OAuth2Client.Username {
  332. case setting.OAuth2UsernameEmail:
  333. return user_model.NormalizeUserName(gothUser.Email)
  334. case setting.OAuth2UsernamePreferredUsername:
  335. if preferredUsername, ok := gothUser.RawData["preferred_username"].(string); ok {
  336. return user_model.NormalizeUserName(preferredUsername)
  337. }
  338. return "", nil
  339. case setting.OAuth2UsernameNickname:
  340. return user_model.NormalizeUserName(gothUser.NickName)
  341. default: // OAuth2UsernameUserid
  342. return gothUser.UserID, nil
  343. }
  344. }
  345. // HandleSignOut resets the session and sets the cookies
  346. func HandleSignOut(ctx *context.Context) {
  347. _ = ctx.Session.Flush()
  348. _ = ctx.Session.Destroy(ctx.Resp, ctx.Req)
  349. ctx.DeleteSiteCookie(setting.CookieRememberName)
  350. ctx.Csrf.DeleteCookie(ctx)
  351. middleware.DeleteRedirectToCookie(ctx.Resp)
  352. }
  353. // SignOut sign out from login status
  354. func SignOut(ctx *context.Context) {
  355. if ctx.Doer != nil {
  356. eventsource.GetManager().SendMessageBlocking(ctx.Doer.ID, &eventsource.Event{
  357. Name: "logout",
  358. Data: ctx.Session.ID(),
  359. })
  360. }
  361. HandleSignOut(ctx)
  362. ctx.JSONRedirect(setting.AppSubURL + "/")
  363. }
  364. // SignUp render the register page
  365. func SignUp(ctx *context.Context) {
  366. ctx.Data["Title"] = ctx.Tr("sign_up")
  367. ctx.Data["SignUpLink"] = setting.AppSubURL + "/user/sign_up"
  368. oauth2Providers, err := oauth2.GetOAuth2Providers(ctx, optional.Some(true))
  369. if err != nil {
  370. ctx.ServerError("UserSignUp", err)
  371. return
  372. }
  373. ctx.Data["OAuth2Providers"] = oauth2Providers
  374. context.SetCaptchaData(ctx)
  375. ctx.Data["PageIsSignUp"] = true
  376. // Show Disabled Registration message if DisableRegistration or AllowOnlyExternalRegistration options are true
  377. ctx.Data["DisableRegistration"] = setting.Service.DisableRegistration || setting.Service.AllowOnlyExternalRegistration
  378. redirectTo := ctx.FormString("redirect_to")
  379. if len(redirectTo) > 0 {
  380. middleware.SetRedirectToCookie(ctx.Resp, redirectTo)
  381. }
  382. ctx.HTML(http.StatusOK, tplSignUp)
  383. }
  384. // SignUpPost response for sign up information submission
  385. func SignUpPost(ctx *context.Context) {
  386. form := web.GetForm(ctx).(*forms.RegisterForm)
  387. ctx.Data["Title"] = ctx.Tr("sign_up")
  388. ctx.Data["SignUpLink"] = setting.AppSubURL + "/user/sign_up"
  389. oauth2Providers, err := oauth2.GetOAuth2Providers(ctx, optional.Some(true))
  390. if err != nil {
  391. ctx.ServerError("UserSignUp", err)
  392. return
  393. }
  394. ctx.Data["OAuth2Providers"] = oauth2Providers
  395. context.SetCaptchaData(ctx)
  396. ctx.Data["PageIsSignUp"] = true
  397. // Permission denied if DisableRegistration or AllowOnlyExternalRegistration options are true
  398. if setting.Service.DisableRegistration || setting.Service.AllowOnlyExternalRegistration {
  399. ctx.Error(http.StatusForbidden)
  400. return
  401. }
  402. if ctx.HasError() {
  403. ctx.HTML(http.StatusOK, tplSignUp)
  404. return
  405. }
  406. context.VerifyCaptcha(ctx, tplSignUp, form)
  407. if ctx.Written() {
  408. return
  409. }
  410. if !form.IsEmailDomainAllowed() {
  411. ctx.RenderWithErr(ctx.Tr("auth.email_domain_blacklisted"), tplSignUp, &form)
  412. return
  413. }
  414. if form.Password != form.Retype {
  415. ctx.Data["Err_Password"] = true
  416. ctx.RenderWithErr(ctx.Tr("form.password_not_match"), tplSignUp, &form)
  417. return
  418. }
  419. if len(form.Password) < setting.MinPasswordLength {
  420. ctx.Data["Err_Password"] = true
  421. ctx.RenderWithErr(ctx.Tr("auth.password_too_short", setting.MinPasswordLength), tplSignUp, &form)
  422. return
  423. }
  424. if !password.IsComplexEnough(form.Password) {
  425. ctx.Data["Err_Password"] = true
  426. ctx.RenderWithErr(password.BuildComplexityError(ctx.Locale), tplSignUp, &form)
  427. return
  428. }
  429. if err := password.IsPwned(ctx, form.Password); err != nil {
  430. errMsg := ctx.Tr("auth.password_pwned")
  431. if password.IsErrIsPwnedRequest(err) {
  432. log.Error(err.Error())
  433. errMsg = ctx.Tr("auth.password_pwned_err")
  434. }
  435. ctx.Data["Err_Password"] = true
  436. ctx.RenderWithErr(errMsg, tplSignUp, &form)
  437. return
  438. }
  439. u := &user_model.User{
  440. Name: form.UserName,
  441. Email: form.Email,
  442. Passwd: form.Password,
  443. }
  444. if !createAndHandleCreatedUser(ctx, tplSignUp, form, u, nil, nil, false) {
  445. // error already handled
  446. return
  447. }
  448. ctx.Flash.Success(ctx.Tr("auth.sign_up_successful"))
  449. handleSignIn(ctx, u, false)
  450. }
  451. // createAndHandleCreatedUser calls createUserInContext and
  452. // then handleUserCreated.
  453. func createAndHandleCreatedUser(ctx *context.Context, tpl base.TplName, form any, u *user_model.User, overwrites *user_model.CreateUserOverwriteOptions, gothUser *goth.User, allowLink bool) bool {
  454. if !createUserInContext(ctx, tpl, form, u, overwrites, gothUser, allowLink) {
  455. return false
  456. }
  457. return handleUserCreated(ctx, u, gothUser)
  458. }
  459. // createUserInContext creates a user and handles errors within a given context.
  460. // Optionally a template can be specified.
  461. func createUserInContext(ctx *context.Context, tpl base.TplName, form any, u *user_model.User, overwrites *user_model.CreateUserOverwriteOptions, gothUser *goth.User, allowLink bool) (ok bool) {
  462. if err := user_model.CreateUser(ctx, u, overwrites); err != nil {
  463. if allowLink && (user_model.IsErrUserAlreadyExist(err) || user_model.IsErrEmailAlreadyUsed(err)) {
  464. if setting.OAuth2Client.AccountLinking == setting.OAuth2AccountLinkingAuto {
  465. var user *user_model.User
  466. user = &user_model.User{Name: u.Name}
  467. hasUser, err := user_model.GetUser(ctx, user)
  468. if !hasUser || err != nil {
  469. user = &user_model.User{Email: u.Email}
  470. hasUser, err = user_model.GetUser(ctx, user)
  471. if !hasUser || err != nil {
  472. ctx.ServerError("UserLinkAccount", err)
  473. return false
  474. }
  475. }
  476. // TODO: probably we should respect 'remember' user's choice...
  477. linkAccount(ctx, user, *gothUser, true)
  478. return false // user is already created here, all redirects are handled
  479. } else if setting.OAuth2Client.AccountLinking == setting.OAuth2AccountLinkingLogin {
  480. showLinkingLogin(ctx, *gothUser)
  481. return false // user will be created only after linking login
  482. }
  483. }
  484. // handle error without template
  485. if len(tpl) == 0 {
  486. ctx.ServerError("CreateUser", err)
  487. return false
  488. }
  489. // handle error with template
  490. switch {
  491. case user_model.IsErrUserAlreadyExist(err):
  492. ctx.Data["Err_UserName"] = true
  493. ctx.RenderWithErr(ctx.Tr("form.username_been_taken"), tpl, form)
  494. case user_model.IsErrEmailAlreadyUsed(err):
  495. ctx.Data["Err_Email"] = true
  496. ctx.RenderWithErr(ctx.Tr("form.email_been_used"), tpl, form)
  497. case user_model.IsErrEmailCharIsNotSupported(err):
  498. ctx.Data["Err_Email"] = true
  499. ctx.RenderWithErr(ctx.Tr("form.email_invalid"), tpl, form)
  500. case user_model.IsErrEmailInvalid(err):
  501. ctx.Data["Err_Email"] = true
  502. ctx.RenderWithErr(ctx.Tr("form.email_invalid"), tpl, form)
  503. case db.IsErrNameReserved(err):
  504. ctx.Data["Err_UserName"] = true
  505. ctx.RenderWithErr(ctx.Tr("user.form.name_reserved", err.(db.ErrNameReserved).Name), tpl, form)
  506. case db.IsErrNamePatternNotAllowed(err):
  507. ctx.Data["Err_UserName"] = true
  508. ctx.RenderWithErr(ctx.Tr("user.form.name_pattern_not_allowed", err.(db.ErrNamePatternNotAllowed).Pattern), tpl, form)
  509. case db.IsErrNameCharsNotAllowed(err):
  510. ctx.Data["Err_UserName"] = true
  511. ctx.RenderWithErr(ctx.Tr("user.form.name_chars_not_allowed", err.(db.ErrNameCharsNotAllowed).Name), tpl, form)
  512. default:
  513. ctx.ServerError("CreateUser", err)
  514. }
  515. return false
  516. }
  517. log.Trace("Account created: %s", u.Name)
  518. return true
  519. }
  520. // handleUserCreated does additional steps after a new user is created.
  521. // It auto-sets admin for the only user, updates the optional external user and
  522. // sends a confirmation email if required.
  523. func handleUserCreated(ctx *context.Context, u *user_model.User, gothUser *goth.User) (ok bool) {
  524. // Auto-set admin for the only user.
  525. if user_model.CountUsers(ctx, nil) == 1 {
  526. opts := &user_service.UpdateOptions{
  527. IsActive: optional.Some(true),
  528. IsAdmin: optional.Some(true),
  529. SetLastLogin: true,
  530. }
  531. if err := user_service.UpdateUser(ctx, u, opts); err != nil {
  532. ctx.ServerError("UpdateUser", err)
  533. return false
  534. }
  535. }
  536. // update external user information
  537. if gothUser != nil {
  538. if err := externalaccount.UpdateExternalUser(ctx, u, *gothUser); err != nil {
  539. if !errors.Is(err, util.ErrNotExist) {
  540. log.Error("UpdateExternalUser failed: %v", err)
  541. }
  542. }
  543. }
  544. // for active user or the first (admin) user, we don't need to send confirmation email
  545. if u.IsActive || u.ID == 1 {
  546. return true
  547. }
  548. if setting.Service.RegisterManualConfirm {
  549. renderActivationPromptMessage(ctx, ctx.Locale.Tr("auth.manual_activation_only"))
  550. return false
  551. }
  552. sendActivateEmail(ctx, u)
  553. return false
  554. }
  555. func renderActivationPromptMessage(ctx *context.Context, msg template.HTML) {
  556. ctx.Data["ActivationPromptMessage"] = msg
  557. ctx.HTML(http.StatusOK, TplActivatePrompt)
  558. }
  559. func sendActivateEmail(ctx *context.Context, u *user_model.User) {
  560. if ctx.Cache.IsExist("MailResendLimit_" + u.LowerName) {
  561. renderActivationPromptMessage(ctx, ctx.Locale.Tr("auth.resent_limit_prompt"))
  562. return
  563. }
  564. if err := ctx.Cache.Put("MailResendLimit_"+u.LowerName, u.LowerName, 180); err != nil {
  565. log.Error("Set cache(MailResendLimit) fail: %v", err)
  566. renderActivationPromptMessage(ctx, ctx.Locale.Tr("auth.resent_limit_prompt"))
  567. return
  568. }
  569. mailer.SendActivateAccountMail(ctx.Locale, u)
  570. activeCodeLives := timeutil.MinutesToFriendly(setting.Service.ActiveCodeLives, ctx.Locale)
  571. msgHTML := ctx.Locale.Tr("auth.confirmation_mail_sent_prompt_ex", u.Email, activeCodeLives)
  572. renderActivationPromptMessage(ctx, msgHTML)
  573. }
  574. func renderActivationVerifyPassword(ctx *context.Context, code string) {
  575. ctx.Data["ActivationCode"] = code
  576. ctx.Data["NeedVerifyLocalPassword"] = true
  577. ctx.HTML(http.StatusOK, TplActivate)
  578. }
  579. func renderActivationChangeEmail(ctx *context.Context) {
  580. ctx.HTML(http.StatusOK, TplActivate)
  581. }
  582. // Activate render activate user page
  583. func Activate(ctx *context.Context) {
  584. code := ctx.FormString("code")
  585. if code == "" {
  586. if ctx.Doer == nil {
  587. ctx.Redirect(setting.AppSubURL + "/user/login")
  588. return
  589. } else if ctx.Doer.IsActive {
  590. ctx.Redirect(setting.AppSubURL + "/")
  591. return
  592. }
  593. if setting.MailService == nil || !setting.Service.RegisterEmailConfirm {
  594. renderActivationPromptMessage(ctx, ctx.Tr("auth.disable_register_mail"))
  595. return
  596. }
  597. // Resend confirmation email. FIXME: ideally this should be in a POST request
  598. sendActivateEmail(ctx, ctx.Doer)
  599. return
  600. }
  601. // TODO: ctx.Doer/ctx.Data["SignedUser"] could be nil or not the same user as the one being activated
  602. user := user_model.VerifyUserActiveCode(ctx, code)
  603. if user == nil { // if code is wrong
  604. renderActivationPromptMessage(ctx, ctx.Locale.Tr("auth.invalid_code"))
  605. return
  606. }
  607. // if account is local account, verify password
  608. if user.LoginSource == 0 {
  609. renderActivationVerifyPassword(ctx, code)
  610. return
  611. }
  612. handleAccountActivation(ctx, user)
  613. }
  614. // ActivatePost handles account activation with password check
  615. func ActivatePost(ctx *context.Context) {
  616. code := ctx.FormString("code")
  617. if ctx.Doer != nil && ctx.Doer.IsActive {
  618. ctx.Redirect(setting.AppSubURL + "/user/activate") // it will redirect again to the correct page
  619. return
  620. }
  621. if code == "" {
  622. newEmail := strings.TrimSpace(ctx.FormString("change_email"))
  623. if ctx.Doer != nil && newEmail != "" && !strings.EqualFold(ctx.Doer.Email, newEmail) {
  624. if user_model.ValidateEmail(newEmail) != nil {
  625. ctx.Flash.Error(ctx.Locale.Tr("form.email_invalid"), true)
  626. renderActivationChangeEmail(ctx)
  627. return
  628. }
  629. err := user_model.ChangeInactivePrimaryEmail(ctx, ctx.Doer.ID, ctx.Doer.Email, newEmail)
  630. if err != nil {
  631. ctx.Flash.Error(ctx.Locale.Tr("admin.emails.not_updated", newEmail), true)
  632. renderActivationChangeEmail(ctx)
  633. return
  634. }
  635. ctx.Doer.Email = newEmail
  636. }
  637. // FIXME: at the moment, GET request handles the "send confirmation email" action. But the old code does this redirect and then send a confirmation email.
  638. ctx.Redirect(setting.AppSubURL + "/user/activate")
  639. return
  640. }
  641. // TODO: ctx.Doer/ctx.Data["SignedUser"] could be nil or not the same user as the one being activated
  642. user := user_model.VerifyUserActiveCode(ctx, code)
  643. if user == nil { // if code is wrong
  644. renderActivationPromptMessage(ctx, ctx.Locale.Tr("auth.invalid_code"))
  645. return
  646. }
  647. // if account is local account, verify password
  648. if user.LoginSource == 0 {
  649. password := ctx.FormString("password")
  650. if password == "" {
  651. renderActivationVerifyPassword(ctx, code)
  652. return
  653. }
  654. if !user.ValidatePassword(password) {
  655. ctx.Flash.Error(ctx.Locale.Tr("auth.invalid_password"), true)
  656. renderActivationVerifyPassword(ctx, code)
  657. return
  658. }
  659. }
  660. handleAccountActivation(ctx, user)
  661. }
  662. func handleAccountActivation(ctx *context.Context, user *user_model.User) {
  663. user.IsActive = true
  664. var err error
  665. if user.Rands, err = user_model.GetUserSalt(); err != nil {
  666. ctx.ServerError("UpdateUser", err)
  667. return
  668. }
  669. if err := user_model.UpdateUserCols(ctx, user, "is_active", "rands"); err != nil {
  670. if user_model.IsErrUserNotExist(err) {
  671. ctx.NotFound("UpdateUserCols", err)
  672. } else {
  673. ctx.ServerError("UpdateUser", err)
  674. }
  675. return
  676. }
  677. if err := user_model.ActivateUserEmail(ctx, user.ID, user.Email, true); err != nil {
  678. log.Error("Unable to activate email for user: %-v with email: %s: %v", user, user.Email, err)
  679. ctx.ServerError("ActivateUserEmail", err)
  680. return
  681. }
  682. log.Trace("User activated: %s", user.Name)
  683. if err := updateSession(ctx, nil, map[string]any{
  684. "uid": user.ID,
  685. "uname": user.Name,
  686. }); err != nil {
  687. log.Error("Unable to regenerate session for user: %-v with email: %s: %v", user, user.Email, err)
  688. ctx.ServerError("ActivateUserEmail", err)
  689. return
  690. }
  691. if err := resetLocale(ctx, user); err != nil {
  692. ctx.ServerError("resetLocale", err)
  693. return
  694. }
  695. if err := user_service.UpdateUser(ctx, user, &user_service.UpdateOptions{SetLastLogin: true}); err != nil {
  696. ctx.ServerError("UpdateUser", err)
  697. return
  698. }
  699. ctx.Flash.Success(ctx.Tr("auth.account_activated"))
  700. if redirectTo := ctx.GetSiteCookie("redirect_to"); len(redirectTo) > 0 {
  701. middleware.DeleteRedirectToCookie(ctx.Resp)
  702. ctx.RedirectToCurrentSite(redirectTo)
  703. return
  704. }
  705. ctx.Redirect(setting.AppSubURL + "/")
  706. }
  707. // ActivateEmail render the activate email page
  708. func ActivateEmail(ctx *context.Context) {
  709. code := ctx.FormString("code")
  710. emailStr := ctx.FormString("email")
  711. // Verify code.
  712. if email := user_model.VerifyActiveEmailCode(ctx, code, emailStr); email != nil {
  713. if err := user_model.ActivateEmail(ctx, email); err != nil {
  714. ctx.ServerError("ActivateEmail", err)
  715. }
  716. log.Trace("Email activated: %s", email.Email)
  717. ctx.Flash.Success(ctx.Tr("settings.add_email_success"))
  718. if u, err := user_model.GetUserByID(ctx, email.UID); err != nil {
  719. log.Warn("GetUserByID: %d", email.UID)
  720. } else {
  721. // Allow user to validate more emails
  722. _ = ctx.Cache.Delete("MailResendLimit_" + u.LowerName)
  723. }
  724. }
  725. // FIXME: e-mail verification does not require the user to be logged in,
  726. // so this could be redirecting to the login page.
  727. // Should users be logged in automatically here? (consider 2FA requirements, etc.)
  728. ctx.Redirect(setting.AppSubURL + "/user/settings/account")
  729. }
  730. func updateSession(ctx *context.Context, deletes []string, updates map[string]any) error {
  731. if _, err := session.RegenerateSession(ctx.Resp, ctx.Req); err != nil {
  732. return fmt.Errorf("regenerate session: %w", err)
  733. }
  734. sess := ctx.Session
  735. sessID := sess.ID()
  736. for _, k := range deletes {
  737. if err := sess.Delete(k); err != nil {
  738. return fmt.Errorf("delete %v in session[%s]: %w", k, sessID, err)
  739. }
  740. }
  741. for k, v := range updates {
  742. if err := sess.Set(k, v); err != nil {
  743. return fmt.Errorf("set %v in session[%s]: %w", k, sessID, err)
  744. }
  745. }
  746. if err := sess.Release(); err != nil {
  747. return fmt.Errorf("store session[%s]: %w", sessID, err)
  748. }
  749. return nil
  750. }