2021-07-24 18:16:34 +08:00
|
|
|
// Copyright 2021 The Gitea Authors. All rights reserved.
|
2022-11-28 02:20:29 +08:00
|
|
|
// SPDX-License-Identifier: MIT
|
2021-07-24 18:16:34 +08:00
|
|
|
|
|
|
|
package ldap
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"strings"
|
|
|
|
|
2021-12-10 16:14:24 +08:00
|
|
|
asymkey_model "code.gitea.io/gitea/models/asymkey"
|
2022-01-02 21:12:35 +08:00
|
|
|
"code.gitea.io/gitea/models/auth"
|
2021-11-22 23:21:55 +08:00
|
|
|
"code.gitea.io/gitea/models/db"
|
2022-03-29 14:29:02 +08:00
|
|
|
"code.gitea.io/gitea/models/organization"
|
2021-11-24 17:49:20 +08:00
|
|
|
user_model "code.gitea.io/gitea/models/user"
|
2022-04-30 03:38:11 +08:00
|
|
|
"code.gitea.io/gitea/modules/util"
|
2021-08-12 15:26:33 +08:00
|
|
|
"code.gitea.io/gitea/services/mailer"
|
2021-11-22 23:21:55 +08:00
|
|
|
user_service "code.gitea.io/gitea/services/user"
|
2021-07-24 18:16:34 +08:00
|
|
|
)
|
|
|
|
|
|
|
|
// Authenticate queries if login/password is valid against the LDAP directory pool,
|
|
|
|
// and create a local user if success when enabled.
|
2021-11-24 17:49:20 +08:00
|
|
|
func (source *Source) Authenticate(user *user_model.User, userName, password string) (*user_model.User, error) {
|
2022-02-18 17:33:00 +08:00
|
|
|
loginName := userName
|
|
|
|
if user != nil {
|
|
|
|
loginName = user.LoginName
|
|
|
|
}
|
|
|
|
sr := source.SearchEntry(loginName, password, source.authSource.Type == auth.DLDAP)
|
2021-07-24 18:16:34 +08:00
|
|
|
if sr == nil {
|
|
|
|
// User not in LDAP, do nothing
|
2022-02-18 17:33:00 +08:00
|
|
|
return nil, user_model.ErrUserNotExist{Name: loginName}
|
2021-07-24 18:16:34 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
isAttributeSSHPublicKeySet := len(strings.TrimSpace(source.AttributeSSHPublicKey)) > 0
|
|
|
|
|
|
|
|
// Update User admin flag if exist
|
2022-05-20 22:08:52 +08:00
|
|
|
if isExist, err := user_model.IsUserExist(db.DefaultContext, 0, sr.Username); err != nil {
|
2021-07-24 18:16:34 +08:00
|
|
|
return nil, err
|
|
|
|
} else if isExist {
|
|
|
|
if user == nil {
|
2022-05-20 22:08:52 +08:00
|
|
|
user, err = user_model.GetUserByName(db.DefaultContext, sr.Username)
|
2021-07-24 18:16:34 +08:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if user != nil && !user.ProhibitLogin {
|
|
|
|
cols := make([]string, 0)
|
|
|
|
if len(source.AdminFilter) > 0 && user.IsAdmin != sr.IsAdmin {
|
|
|
|
// Change existing admin flag only if AdminFilter option is set
|
|
|
|
user.IsAdmin = sr.IsAdmin
|
|
|
|
cols = append(cols, "is_admin")
|
|
|
|
}
|
|
|
|
if !user.IsAdmin && len(source.RestrictedFilter) > 0 && user.IsRestricted != sr.IsRestricted {
|
|
|
|
// Change existing restricted flag only if RestrictedFilter option is set
|
|
|
|
user.IsRestricted = sr.IsRestricted
|
|
|
|
cols = append(cols, "is_restricted")
|
|
|
|
}
|
|
|
|
if len(cols) > 0 {
|
2021-11-24 17:49:20 +08:00
|
|
|
err = user_model.UpdateUserCols(db.DefaultContext, user, cols...)
|
2021-07-24 18:16:34 +08:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if user != nil {
|
2022-02-11 22:24:58 +08:00
|
|
|
if source.GroupsEnabled && (source.GroupTeamMap != "" || source.GroupTeamMapRemoval) {
|
2022-03-29 14:29:02 +08:00
|
|
|
orgCache := make(map[string]*organization.Organization)
|
|
|
|
teamCache := make(map[string]*organization.Team)
|
2022-02-11 22:24:58 +08:00
|
|
|
source.SyncLdapGroupsToTeams(user, sr.LdapTeamAdd, sr.LdapTeamRemove, orgCache, teamCache)
|
|
|
|
}
|
2022-01-02 21:12:35 +08:00
|
|
|
if isAttributeSSHPublicKeySet && asymkey_model.SynchronizePublicKeys(user, source.authSource, sr.SSHPublicKey) {
|
2021-12-10 16:14:24 +08:00
|
|
|
return user, asymkey_model.RewriteAllPublicKeys()
|
2021-07-24 18:16:34 +08:00
|
|
|
}
|
|
|
|
return user, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
// Fallback.
|
|
|
|
if len(sr.Username) == 0 {
|
2021-09-24 19:32:56 +08:00
|
|
|
sr.Username = userName
|
2021-07-24 18:16:34 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
if len(sr.Mail) == 0 {
|
|
|
|
sr.Mail = fmt.Sprintf("%s@localhost", sr.Username)
|
|
|
|
}
|
|
|
|
|
2021-11-24 17:49:20 +08:00
|
|
|
user = &user_model.User{
|
2022-04-30 03:38:11 +08:00
|
|
|
LowerName: strings.ToLower(sr.Username),
|
|
|
|
Name: sr.Username,
|
|
|
|
FullName: composeFullName(sr.Name, sr.Surname, sr.Username),
|
|
|
|
Email: sr.Mail,
|
|
|
|
LoginType: source.authSource.Type,
|
|
|
|
LoginSource: source.authSource.ID,
|
|
|
|
LoginName: userName,
|
|
|
|
IsAdmin: sr.IsAdmin,
|
|
|
|
}
|
|
|
|
overwriteDefault := &user_model.CreateUserOverwriteOptions{
|
|
|
|
IsRestricted: util.OptionalBoolOf(sr.IsRestricted),
|
|
|
|
IsActive: util.OptionalBoolTrue,
|
2021-07-24 18:16:34 +08:00
|
|
|
}
|
|
|
|
|
2022-04-30 03:38:11 +08:00
|
|
|
err := user_model.CreateUser(user, overwriteDefault)
|
2021-08-12 15:26:33 +08:00
|
|
|
if err != nil {
|
|
|
|
return user, err
|
|
|
|
}
|
|
|
|
|
|
|
|
mailer.SendRegisterNotifyMail(user)
|
2021-07-24 18:16:34 +08:00
|
|
|
|
2022-01-02 21:12:35 +08:00
|
|
|
if isAttributeSSHPublicKeySet && asymkey_model.AddPublicKeysBySource(user, source.authSource, sr.SSHPublicKey) {
|
2021-12-10 16:14:24 +08:00
|
|
|
err = asymkey_model.RewriteAllPublicKeys()
|
2021-07-24 18:16:34 +08:00
|
|
|
}
|
2021-09-27 10:39:36 +08:00
|
|
|
if err == nil && len(source.AttributeAvatar) > 0 {
|
2021-11-22 23:21:55 +08:00
|
|
|
_ = user_service.UploadAvatar(user, sr.Avatar)
|
2021-09-27 10:39:36 +08:00
|
|
|
}
|
2022-02-11 22:24:58 +08:00
|
|
|
if source.GroupsEnabled && (source.GroupTeamMap != "" || source.GroupTeamMapRemoval) {
|
2022-03-29 14:29:02 +08:00
|
|
|
orgCache := make(map[string]*organization.Organization)
|
|
|
|
teamCache := make(map[string]*organization.Team)
|
2022-02-11 22:24:58 +08:00
|
|
|
source.SyncLdapGroupsToTeams(user, sr.LdapTeamAdd, sr.LdapTeamRemove, orgCache, teamCache)
|
|
|
|
}
|
2021-09-27 10:39:36 +08:00
|
|
|
|
2021-07-24 18:16:34 +08:00
|
|
|
return user, err
|
|
|
|
}
|
2021-09-17 19:43:47 +08:00
|
|
|
|
|
|
|
// IsSkipLocalTwoFA returns if this source should skip local 2fa for password authentication
|
|
|
|
func (source *Source) IsSkipLocalTwoFA() bool {
|
|
|
|
return source.SkipLocalTwoFA
|
|
|
|
}
|