mirror of
https://github.com/hanzoai/team.git
synced 2026-09-30 01:57:35 +00:00
* Add parser and hasher packages The new `password` module includes two packages: - `hashers` provides a structure allowing for seamless migrations between password hashing methods. It also implements two password hashers: bcrypt, which was the current hashing method, and PBKDF2, which is the one we are migrating to. - `parser` provides types and primitives to parse PHC[0] strings, serving as the foundation of the `PasswordHasher` interface and implementations, which are all PHC-based. [0] https://github.com/P-H-C/phc-string-format/blob/master/phc-sf-spec.md * Use latest hasher to hash new passwords The previous commit added a LatestHasher variable, that contains the `PasswordHasher` currently in use. Here, we make sure we use it for hashing new passwords, instead of the currently hardcoded bcrypt. * Use errors from hashers' package Some chore work to unify errors defined in `hashers`, not from external packages like `bcrypt`. * Implement password migration logic This commit implements the actual logic to migrate passwords, which can be summarized as: 0. When the user enters their password (either for login in `App.CheckPasswordAndAllCriteria` or for double-checking the password when the app needs additional confirmation for anything in `App.DoubleCheckPassword`), this process is started. 1. The new `App.checkUserPassword` is called. In `users.CheckUserPassword`, we parse the stored hashed password with the new PHC parser and identify whether it was generated with the current hashing method (PBKDF2). If it is, just verify the password as usual and continue normally. 2. If not, start the migration calling `App.migratePassword`: a. First, we call `Users.MigratePassword`, which validates that the stored hash and the provided password match, using the hasher that generated the old hash. b. If the user-provided password matches the old hash, then we simply re-hash that password with our current hasher, the one in `hashers.LatestHasher`. If not, we fail. c. Back in `App.migratePassword`, if the migration was successful, then we update the user in the database with the newly generated hash. * make i18n-extract * Rename getDefaultHasher to getOriginalHasher * Refactor App checkUserPsasword and migratePassword Simplify the flow in these two methods, removing the similarly named users.CheckUserPassword and users.MigratePassword, inlining the logic needed in the App layer and at the same time removing the need to parse the stored hash twice. This implements a package-level function, CompareHashAndPassword: the first step to unexport LatestHasher. * Add a package level Hash method This completely removes the need to expose LatestHasher, and lets us also remove model.HashPassword, in favour of the new hashers.Hash * Unexport LatestHasher * Remove tests for removed functions * Make the linter happy * Remove error no longer used * Allow for parameter migrations on the same hasher Before this, we were only checking that the function ID of the stored hash was the ID of the latest hashing method. Here, we no longer ignore the parameters, so that if in the future we need to migrate to the same hashing method with a different parameter (let's say PBKDF2 with work factor 120,000 instead of work factor 60,000), we can do it by updating the latestHasher variable. IsPHCValid will detect this change and force a migration if needed. * Document new functions * make i18n-extract * Fix typo in comment Co-authored-by: Ben Cooke <[email protected]> * Rename parser package to phcparser * Simplify phcparser.New documentation * Rename scanSymbol to scanSeparator Redefine the list of separator tokens, including EOF as one. * Document undocumented functions that are unexported * Reorder error block in checkUserPassword * Add unit tests for IsLatestHasher * Reorder code in parser.go * Enforce SHA256 as internal function for PBKDF2 * Fix typo in comment Co-authored-by: Eva Sarafianou <[email protected]> --------- Co-authored-by: Ben Cooke <[email protected]> Co-authored-by: Eva Sarafianou <[email protected]> Co-authored-by: Mattermost Build <[email protected]>
1112 lines
29 KiB
Go
1112 lines
29 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package model
|
|
|
|
import (
|
|
"crypto/sha256"
|
|
"encoding/json"
|
|
"fmt"
|
|
"net/http"
|
|
"regexp"
|
|
"slices"
|
|
"sort"
|
|
"strings"
|
|
"time"
|
|
"unicode/utf8"
|
|
|
|
"github.com/pkg/errors"
|
|
|
|
"golang.org/x/text/language"
|
|
|
|
"github.com/mattermost/mattermost/server/public/shared/mlog"
|
|
"github.com/mattermost/mattermost/server/public/shared/timezones"
|
|
"github.com/mattermost/mattermost/server/v8/channels/app/password/hashers"
|
|
)
|
|
|
|
const (
|
|
Me = "me"
|
|
UserNotifyAll = "all"
|
|
UserNotifyHere = "here"
|
|
UserNotifyMention = "mention"
|
|
UserNotifyNone = "none"
|
|
DesktopNotifyProp = "desktop"
|
|
DesktopSoundNotifyProp = "desktop_sound"
|
|
MarkUnreadNotifyProp = "mark_unread"
|
|
PushNotifyProp = "push"
|
|
PushStatusNotifyProp = "push_status"
|
|
EmailNotifyProp = "email"
|
|
ChannelMentionsNotifyProp = "channel"
|
|
CommentsNotifyProp = "comments"
|
|
MentionKeysNotifyProp = "mention_keys"
|
|
HighlightsNotifyProp = "highlight_keys"
|
|
CommentsNotifyNever = "never"
|
|
CommentsNotifyRoot = "root"
|
|
CommentsNotifyAny = "any"
|
|
CommentsNotifyCRT = "crt"
|
|
FirstNameNotifyProp = "first_name"
|
|
AutoResponderActiveNotifyProp = "auto_responder_active"
|
|
AutoResponderMessageNotifyProp = "auto_responder_message"
|
|
DesktopThreadsNotifyProp = "desktop_threads"
|
|
PushThreadsNotifyProp = "push_threads"
|
|
EmailThreadsNotifyProp = "email_threads"
|
|
|
|
DefaultLocale = "en"
|
|
UserAuthServiceEmail = "email"
|
|
|
|
UserEmailMaxLength = 128
|
|
UserNicknameMaxRunes = 64
|
|
UserPositionMaxRunes = 128
|
|
UserFirstNameMaxRunes = 64
|
|
UserLastNameMaxRunes = 64
|
|
UserAuthDataMaxLength = 128
|
|
UserNameMaxLength = 64
|
|
UserNameMinLength = 1
|
|
UserPasswordMaxLength = 72
|
|
UserLocaleMaxLength = 5
|
|
UserTimezoneMaxRunes = 256
|
|
UserRolesMaxLength = 256
|
|
|
|
DesktopTokenTTL = time.Minute * 3
|
|
)
|
|
|
|
//msgp:tuple User
|
|
|
|
// User contains the details about the user.
|
|
// This struct's serializer methods are auto-generated. If a new field is added/removed,
|
|
// please run make gen-serialized.
|
|
type User struct {
|
|
Id string `json:"id"`
|
|
CreateAt int64 `json:"create_at,omitempty"`
|
|
UpdateAt int64 `json:"update_at,omitempty"`
|
|
DeleteAt int64 `json:"delete_at"`
|
|
Username string `json:"username"`
|
|
Password string `json:"password,omitempty"`
|
|
AuthData *string `json:"auth_data,omitempty"`
|
|
AuthService string `json:"auth_service"`
|
|
Email string `json:"email"`
|
|
EmailVerified bool `json:"email_verified,omitempty"`
|
|
Nickname string `json:"nickname"`
|
|
FirstName string `json:"first_name"`
|
|
LastName string `json:"last_name"`
|
|
Position string `json:"position"`
|
|
Roles string `json:"roles"`
|
|
AllowMarketing bool `json:"allow_marketing,omitempty"`
|
|
Props StringMap `json:"props,omitempty"`
|
|
NotifyProps StringMap `json:"notify_props,omitempty"`
|
|
LastPasswordUpdate int64 `json:"last_password_update,omitempty"`
|
|
LastPictureUpdate int64 `json:"last_picture_update,omitempty"`
|
|
FailedAttempts int `json:"failed_attempts,omitempty"`
|
|
Locale string `json:"locale"`
|
|
Timezone StringMap `json:"timezone"`
|
|
MfaActive bool `json:"mfa_active,omitempty"`
|
|
MfaSecret string `json:"mfa_secret,omitempty"`
|
|
RemoteId *string `json:"remote_id,omitempty"`
|
|
LastActivityAt int64 `json:"last_activity_at,omitempty"`
|
|
IsBot bool `json:"is_bot,omitempty"`
|
|
BotDescription string `json:"bot_description,omitempty"`
|
|
BotLastIconUpdate int64 `json:"bot_last_icon_update,omitempty"`
|
|
TermsOfServiceId string `json:"terms_of_service_id,omitempty"`
|
|
TermsOfServiceCreateAt int64 `json:"terms_of_service_create_at,omitempty"`
|
|
DisableWelcomeEmail bool `json:"disable_welcome_email"`
|
|
LastLogin int64 `json:"last_login,omitempty"`
|
|
MfaUsedTimestamps StringArray `json:"mfa_used_timestamps,omitempty"`
|
|
}
|
|
|
|
func (u *User) Auditable() map[string]any {
|
|
return map[string]any{
|
|
"id": u.Id,
|
|
"create_at": u.CreateAt,
|
|
"update_at": u.UpdateAt,
|
|
"delete_at": u.DeleteAt,
|
|
"username": u.Username,
|
|
"auth_service": u.AuthService,
|
|
"email": u.Email,
|
|
"email_verified": u.EmailVerified,
|
|
"position": u.Position,
|
|
"roles": u.Roles,
|
|
"allow_marketing": u.AllowMarketing,
|
|
"props": u.Props,
|
|
"notify_props": u.NotifyProps,
|
|
"last_password_update": u.LastPasswordUpdate,
|
|
"last_picture_update": u.LastPictureUpdate,
|
|
"failed_attempts": u.FailedAttempts,
|
|
"locale": u.Locale,
|
|
"timezone": u.Timezone,
|
|
"mfa_active": u.MfaActive,
|
|
"remote_id": u.GetRemoteID(),
|
|
"last_activity_at": u.LastActivityAt,
|
|
"is_bot": u.IsBot,
|
|
"bot_description": u.BotDescription,
|
|
"bot_last_icon_update": u.BotLastIconUpdate,
|
|
"terms_of_service_id": u.TermsOfServiceId,
|
|
"terms_of_service_create_at": u.TermsOfServiceCreateAt,
|
|
"disable_welcome_email": u.DisableWelcomeEmail,
|
|
}
|
|
}
|
|
|
|
func (u *User) LogClone() any {
|
|
return map[string]any{
|
|
"id": u.Id,
|
|
"create_at": u.CreateAt,
|
|
"update_at": u.UpdateAt,
|
|
"delete_at": u.DeleteAt,
|
|
"username": u.Username,
|
|
"auth_data": u.GetAuthData(),
|
|
"auth_service": u.AuthService,
|
|
"email": u.Email,
|
|
"email_verified": u.EmailVerified,
|
|
"position": u.Position,
|
|
"roles": u.Roles,
|
|
"allow_marketing": u.AllowMarketing,
|
|
"props": u.Props,
|
|
"notify_props": u.NotifyProps,
|
|
"locale": u.Locale,
|
|
"timezone": u.Timezone,
|
|
"mfa_active": u.MfaActive,
|
|
"remote_id": u.GetRemoteID(),
|
|
}
|
|
}
|
|
|
|
//msgp UserMap
|
|
|
|
// UserMap is a map from a userId to a user object.
|
|
// It is used to generate methods which can be used for fast serialization/de-serialization.
|
|
type UserMap map[string]*User
|
|
|
|
//msgp:ignore UserUpdate
|
|
type UserUpdate struct {
|
|
Old *User
|
|
New *User
|
|
}
|
|
|
|
//msgp:ignore UserPatch
|
|
type UserPatch struct {
|
|
Username *string `json:"username"`
|
|
Password *string `json:"password,omitempty"`
|
|
Nickname *string `json:"nickname"`
|
|
FirstName *string `json:"first_name"`
|
|
LastName *string `json:"last_name"`
|
|
Position *string `json:"position"`
|
|
Email *string `json:"email"`
|
|
Props StringMap `json:"props,omitempty"`
|
|
NotifyProps StringMap `json:"notify_props,omitempty"`
|
|
Locale *string `json:"locale"`
|
|
Timezone StringMap `json:"timezone"`
|
|
RemoteId *string `json:"remote_id"`
|
|
}
|
|
|
|
func (u *UserPatch) Auditable() map[string]any {
|
|
return map[string]any{
|
|
"username": u.Username,
|
|
"nickname": u.Nickname,
|
|
"first_name": u.FirstName,
|
|
"last_name": u.LastName,
|
|
"position": u.Position,
|
|
"email": u.Email,
|
|
"props": u.Props,
|
|
"notify_props": u.NotifyProps,
|
|
"locale": u.Locale,
|
|
"timezone": u.Timezone,
|
|
"remote_id": u.RemoteId,
|
|
}
|
|
}
|
|
|
|
//msgp:ignore UserAuth
|
|
type UserAuth struct {
|
|
AuthData *string `json:"auth_data,omitempty"`
|
|
AuthService string `json:"auth_service,omitempty"`
|
|
}
|
|
|
|
func (u *UserAuth) Auditable() map[string]any {
|
|
return map[string]any{
|
|
"auth_service": u.AuthService,
|
|
}
|
|
}
|
|
|
|
//msgp:ignore UserForIndexing
|
|
type UserForIndexing struct {
|
|
Id string `json:"id"`
|
|
Username string `json:"username"`
|
|
Nickname string `json:"nickname"`
|
|
FirstName string `json:"first_name"`
|
|
LastName string `json:"last_name"`
|
|
Roles string `json:"roles"`
|
|
CreateAt int64 `json:"create_at"`
|
|
DeleteAt int64 `json:"delete_at"`
|
|
TeamsIds []string `json:"team_id"`
|
|
ChannelsIds []string `json:"channel_id"`
|
|
}
|
|
|
|
//msgp:ignore ViewUsersRestrictions
|
|
type ViewUsersRestrictions struct {
|
|
Teams []string
|
|
Channels []string
|
|
}
|
|
|
|
//msgp:ignore GetUsersNotInChannelOptions
|
|
type GetUsersNotInChannelOptions struct {
|
|
TeamID string `json:"team_id"`
|
|
// Page-based pagination (used for non-ABAC channels)
|
|
// This will be discarded if the channel has an ABAC policy and CursorID will be used.
|
|
Page int `json:"page"`
|
|
Limit int `json:"limit"`
|
|
// Cursor-based pagination (used for ABAC channels)
|
|
// If CursorID is empty for ABAC channels, it will start from the beginning
|
|
CursorID string `json:"cursor_id"`
|
|
Etag string `json:"etag"`
|
|
}
|
|
|
|
func (r *ViewUsersRestrictions) Hash() string {
|
|
if r == nil {
|
|
return ""
|
|
}
|
|
ids := append(r.Teams, r.Channels...)
|
|
sort.Strings(ids)
|
|
hash := sha256.New()
|
|
hash.Write([]byte(strings.Join(ids, "")))
|
|
return fmt.Sprintf("%x", hash.Sum(nil))
|
|
}
|
|
|
|
//msgp:ignore UserSlice
|
|
type UserSlice []*User
|
|
|
|
func (u UserSlice) Usernames() []string {
|
|
usernames := []string{}
|
|
for _, user := range u {
|
|
usernames = append(usernames, user.Username)
|
|
}
|
|
sort.Strings(usernames)
|
|
return usernames
|
|
}
|
|
|
|
func (u UserSlice) IDs() []string {
|
|
ids := []string{}
|
|
for _, user := range u {
|
|
ids = append(ids, user.Id)
|
|
}
|
|
return ids
|
|
}
|
|
|
|
func (u UserSlice) FilterWithoutBots() UserSlice {
|
|
var matches []*User
|
|
|
|
for _, user := range u {
|
|
if !user.IsBot {
|
|
matches = append(matches, user)
|
|
}
|
|
}
|
|
return UserSlice(matches)
|
|
}
|
|
|
|
func (u UserSlice) FilterByActive(active bool) UserSlice {
|
|
var matches []*User
|
|
|
|
for _, user := range u {
|
|
if user.DeleteAt == 0 && active {
|
|
matches = append(matches, user)
|
|
} else if user.DeleteAt != 0 && !active {
|
|
matches = append(matches, user)
|
|
}
|
|
}
|
|
return UserSlice(matches)
|
|
}
|
|
|
|
func (u UserSlice) FilterByID(ids []string) UserSlice {
|
|
var matches []*User
|
|
for _, user := range u {
|
|
for _, id := range ids {
|
|
if id == user.Id {
|
|
matches = append(matches, user)
|
|
}
|
|
}
|
|
}
|
|
return UserSlice(matches)
|
|
}
|
|
|
|
func (u UserSlice) FilterWithoutID(ids []string) UserSlice {
|
|
var keep []*User
|
|
for _, user := range u {
|
|
present := false
|
|
for _, id := range ids {
|
|
if id == user.Id {
|
|
present = true
|
|
}
|
|
}
|
|
if !present {
|
|
keep = append(keep, user)
|
|
}
|
|
}
|
|
return UserSlice(keep)
|
|
}
|
|
|
|
func (u *User) DeepCopy() *User {
|
|
copyUser := *u
|
|
if u.AuthData != nil {
|
|
copyUser.AuthData = NewPointer(*u.AuthData)
|
|
}
|
|
if u.Props != nil {
|
|
copyUser.Props = CopyStringMap(u.Props)
|
|
}
|
|
if u.NotifyProps != nil {
|
|
copyUser.NotifyProps = CopyStringMap(u.NotifyProps)
|
|
}
|
|
if u.Timezone != nil {
|
|
copyUser.Timezone = CopyStringMap(u.Timezone)
|
|
}
|
|
return ©User
|
|
}
|
|
|
|
// IsValid validates the user and returns an error if it isn't configured
|
|
// correctly.
|
|
func (u *User) IsValid() *AppError {
|
|
if !IsValidId(u.Id) {
|
|
return InvalidUserError("id", "", u.Id)
|
|
}
|
|
|
|
if u.CreateAt == 0 {
|
|
return InvalidUserError("create_at", u.Id, u.CreateAt)
|
|
}
|
|
|
|
if u.UpdateAt == 0 {
|
|
return InvalidUserError("update_at", u.Id, u.UpdateAt)
|
|
}
|
|
|
|
if u.IsRemote() {
|
|
if !IsValidUsernameAllowRemote(u.Username) {
|
|
return InvalidUserError("username", u.Id, u.Username)
|
|
}
|
|
} else {
|
|
if !IsValidUsername(u.Username) {
|
|
return InvalidUserError("username", u.Id, u.Username)
|
|
}
|
|
}
|
|
|
|
if len(u.Email) > UserEmailMaxLength || u.Email == "" || (!IsValidEmail(u.Email) && !u.IsRemote()) {
|
|
return InvalidUserError("email", u.Id, u.Email)
|
|
}
|
|
|
|
if utf8.RuneCountInString(u.Nickname) > UserNicknameMaxRunes {
|
|
return InvalidUserError("nickname", u.Id, u.Nickname)
|
|
}
|
|
|
|
if utf8.RuneCountInString(u.Position) > UserPositionMaxRunes {
|
|
return InvalidUserError("position", u.Id, u.Position)
|
|
}
|
|
|
|
if utf8.RuneCountInString(u.FirstName) > UserFirstNameMaxRunes {
|
|
return InvalidUserError("first_name", u.Id, u.FirstName)
|
|
}
|
|
|
|
if utf8.RuneCountInString(u.LastName) > UserLastNameMaxRunes {
|
|
return InvalidUserError("last_name", u.Id, u.LastName)
|
|
}
|
|
|
|
if u.AuthData != nil && len(*u.AuthData) > UserAuthDataMaxLength {
|
|
return InvalidUserError("auth_data", u.Id, u.AuthData)
|
|
}
|
|
|
|
if u.AuthData != nil && *u.AuthData != "" && u.AuthService == "" {
|
|
return InvalidUserError("auth_data_type", u.Id, *u.AuthData+" "+u.AuthService)
|
|
}
|
|
|
|
if u.Password != "" && u.AuthData != nil && *u.AuthData != "" {
|
|
return InvalidUserError("auth_data_pwd", u.Id, *u.AuthData)
|
|
}
|
|
|
|
if !IsValidLocale(u.Locale) {
|
|
return InvalidUserError("locale", u.Id, u.Locale)
|
|
}
|
|
|
|
if len(u.Timezone) > 0 {
|
|
if tzJSON, err := json.Marshal(u.Timezone); err != nil {
|
|
return NewAppError("User.IsValid", "model.user.is_valid.marshal.app_error", nil, "", http.StatusInternalServerError).Wrap(err)
|
|
} else if utf8.RuneCount(tzJSON) > UserTimezoneMaxRunes {
|
|
return InvalidUserError("timezone_limit", u.Id, u.Timezone)
|
|
}
|
|
}
|
|
|
|
if len(u.Roles) > UserRolesMaxLength {
|
|
return NewAppError("User.IsValid", "model.user.is_valid.roles_limit.app_error",
|
|
map[string]any{"Limit": UserRolesMaxLength}, "user_id="+u.Id+" roles_limit="+u.Roles, http.StatusBadRequest)
|
|
}
|
|
|
|
if u.Props != nil {
|
|
if !u.ValidateCustomStatus() {
|
|
return NewAppError("User.IsValid", "model.user.is_valid.invalidProperty.app_error",
|
|
map[string]any{"Props": u.Props}, "user_id="+u.Id, http.StatusBadRequest)
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func InvalidUserError(fieldName, userId string, fieldValue any) *AppError {
|
|
id := fmt.Sprintf("model.user.is_valid.%s.app_error", fieldName)
|
|
details := ""
|
|
if userId != "" {
|
|
details = "user_id=" + userId
|
|
}
|
|
details += fmt.Sprintf(" %s=%v", fieldName, fieldValue)
|
|
return NewAppError("User.IsValid", id, nil, details, http.StatusBadRequest)
|
|
}
|
|
|
|
func NormalizeUsername(username string) string {
|
|
return strings.ToLower(username)
|
|
}
|
|
|
|
func NormalizeEmail(email string) string {
|
|
return strings.ToLower(email)
|
|
}
|
|
|
|
// PreSave will set the Id and Username if missing. It will also fill
|
|
// in the CreateAt, UpdateAt times. It will also hash the password. It should
|
|
// be run before saving the user to the db.
|
|
func (u *User) PreSave() *AppError {
|
|
if u.Id == "" {
|
|
u.Id = NewId()
|
|
}
|
|
|
|
if u.Username == "" {
|
|
u.Username = NewUsername()
|
|
}
|
|
|
|
if u.AuthData != nil && *u.AuthData == "" {
|
|
u.AuthData = nil
|
|
}
|
|
|
|
u.Username = SanitizeUnicode(u.Username)
|
|
u.FirstName = SanitizeUnicode(u.FirstName)
|
|
u.LastName = SanitizeUnicode(u.LastName)
|
|
u.Nickname = SanitizeUnicode(u.Nickname)
|
|
|
|
u.Username = NormalizeUsername(u.Username)
|
|
u.Email = NormalizeEmail(u.Email)
|
|
|
|
if u.CreateAt == 0 {
|
|
u.CreateAt = GetMillis()
|
|
}
|
|
u.UpdateAt = u.CreateAt
|
|
|
|
u.LastPasswordUpdate = u.CreateAt
|
|
|
|
u.MfaActive = false
|
|
|
|
if u.Locale == "" {
|
|
u.Locale = DefaultLocale
|
|
}
|
|
|
|
if u.Props == nil {
|
|
u.Props = make(map[string]string)
|
|
}
|
|
|
|
if len(u.NotifyProps) == 0 {
|
|
u.SetDefaultNotifications()
|
|
}
|
|
|
|
if u.Timezone == nil {
|
|
u.Timezone = timezones.DefaultUserTimezone()
|
|
}
|
|
|
|
if u.Password != "" {
|
|
hashed, err := hashers.Hash(u.Password)
|
|
if errors.Is(err, hashers.ErrPasswordTooLong) {
|
|
return NewAppError("User.PreSave", "model.user.pre_save.password_too_long.app_error",
|
|
nil, "user_id="+u.Id, http.StatusBadRequest).Wrap(err)
|
|
} else if err != nil {
|
|
return NewAppError("User.PreSave", "model.user.pre_save.password_hash.app_error",
|
|
nil, "user_id="+u.Id, http.StatusBadRequest).Wrap(err)
|
|
}
|
|
u.Password = hashed
|
|
}
|
|
|
|
cs := u.GetCustomStatus()
|
|
if cs != nil {
|
|
cs.PreSave()
|
|
u.SetCustomStatus(cs)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// PreUpdate should be run before updating the user in the db.
|
|
func (u *User) PreUpdate() {
|
|
u.Username = SanitizeUnicode(u.Username)
|
|
u.FirstName = SanitizeUnicode(u.FirstName)
|
|
u.LastName = SanitizeUnicode(u.LastName)
|
|
u.Nickname = SanitizeUnicode(u.Nickname)
|
|
u.BotDescription = SanitizeUnicode(u.BotDescription)
|
|
|
|
u.Username = NormalizeUsername(u.Username)
|
|
u.Email = NormalizeEmail(u.Email)
|
|
u.UpdateAt = GetMillis()
|
|
|
|
u.FirstName = SanitizeUnicode(u.FirstName)
|
|
u.LastName = SanitizeUnicode(u.LastName)
|
|
u.Nickname = SanitizeUnicode(u.Nickname)
|
|
u.BotDescription = SanitizeUnicode(u.BotDescription)
|
|
|
|
if u.AuthData != nil && *u.AuthData == "" {
|
|
u.AuthData = nil
|
|
}
|
|
|
|
if len(u.NotifyProps) == 0 {
|
|
u.SetDefaultNotifications()
|
|
} else if _, ok := u.NotifyProps[MentionKeysNotifyProp]; ok {
|
|
// Remove any blank mention keys
|
|
splitKeys := strings.Split(u.NotifyProps[MentionKeysNotifyProp], ",")
|
|
goodKeys := []string{}
|
|
for _, key := range splitKeys {
|
|
if key != "" {
|
|
goodKeys = append(goodKeys, strings.ToLower(key))
|
|
}
|
|
}
|
|
u.NotifyProps[MentionKeysNotifyProp] = strings.Join(goodKeys, ",")
|
|
}
|
|
|
|
if u.Props != nil {
|
|
cs := u.GetCustomStatus()
|
|
if cs != nil {
|
|
cs.PreSave()
|
|
u.SetCustomStatus(cs)
|
|
}
|
|
}
|
|
}
|
|
|
|
func (u *User) SetDefaultNotifications() {
|
|
u.NotifyProps = make(map[string]string)
|
|
u.NotifyProps[EmailNotifyProp] = "true"
|
|
u.NotifyProps[PushNotifyProp] = UserNotifyMention
|
|
u.NotifyProps[DesktopNotifyProp] = UserNotifyMention
|
|
u.NotifyProps[DesktopSoundNotifyProp] = "true"
|
|
u.NotifyProps[MentionKeysNotifyProp] = ""
|
|
u.NotifyProps[ChannelMentionsNotifyProp] = "true"
|
|
u.NotifyProps[PushStatusNotifyProp] = StatusOnline
|
|
u.NotifyProps[CommentsNotifyProp] = CommentsNotifyNever
|
|
u.NotifyProps[FirstNameNotifyProp] = "false"
|
|
u.NotifyProps[DesktopThreadsNotifyProp] = UserNotifyAll
|
|
u.NotifyProps[EmailThreadsNotifyProp] = UserNotifyAll
|
|
u.NotifyProps[PushThreadsNotifyProp] = UserNotifyAll
|
|
}
|
|
|
|
func (u *User) UpdateMentionKeysFromUsername(oldUsername string) {
|
|
nonUsernameKeys := []string{}
|
|
for _, key := range u.GetMentionKeys() {
|
|
if key != oldUsername && key != "@"+oldUsername {
|
|
nonUsernameKeys = append(nonUsernameKeys, key)
|
|
}
|
|
}
|
|
|
|
u.NotifyProps[MentionKeysNotifyProp] = ""
|
|
if len(nonUsernameKeys) > 0 {
|
|
u.NotifyProps[MentionKeysNotifyProp] += "," + strings.Join(nonUsernameKeys, ",")
|
|
}
|
|
}
|
|
|
|
func (u *User) GetMentionKeys() []string {
|
|
var keys []string
|
|
|
|
for key := range strings.SplitSeq(u.NotifyProps[MentionKeysNotifyProp], ",") {
|
|
trimmedKey := strings.TrimSpace(key)
|
|
|
|
if trimmedKey == "" {
|
|
continue
|
|
}
|
|
|
|
keys = append(keys, trimmedKey)
|
|
}
|
|
|
|
return keys
|
|
}
|
|
|
|
func (u *User) Patch(patch *UserPatch) {
|
|
if patch.Username != nil {
|
|
u.Username = *patch.Username
|
|
}
|
|
|
|
if patch.Nickname != nil {
|
|
u.Nickname = *patch.Nickname
|
|
}
|
|
|
|
if patch.FirstName != nil {
|
|
u.FirstName = *patch.FirstName
|
|
}
|
|
|
|
if patch.LastName != nil {
|
|
u.LastName = *patch.LastName
|
|
}
|
|
|
|
if patch.Position != nil {
|
|
u.Position = *patch.Position
|
|
}
|
|
|
|
if patch.Email != nil {
|
|
u.Email = *patch.Email
|
|
}
|
|
|
|
if patch.Props != nil {
|
|
u.Props = patch.Props
|
|
}
|
|
|
|
if patch.NotifyProps != nil {
|
|
u.NotifyProps = patch.NotifyProps
|
|
}
|
|
|
|
if patch.Locale != nil {
|
|
u.Locale = *patch.Locale
|
|
}
|
|
|
|
if patch.Timezone != nil {
|
|
u.Timezone = patch.Timezone
|
|
}
|
|
|
|
if patch.RemoteId != nil {
|
|
u.RemoteId = patch.RemoteId
|
|
}
|
|
}
|
|
|
|
// Generate a valid strong etag so the browser can cache the results
|
|
func (u *User) Etag(showFullName, showEmail bool) string {
|
|
return Etag(u.Id, u.UpdateAt, u.TermsOfServiceId, u.TermsOfServiceCreateAt, showFullName, showEmail, u.BotLastIconUpdate)
|
|
}
|
|
|
|
// Remove any private data from the user object
|
|
func (u *User) Sanitize(options map[string]bool) {
|
|
u.Password = ""
|
|
u.MfaSecret = ""
|
|
u.MfaUsedTimestamps = nil
|
|
u.LastLogin = 0
|
|
|
|
if len(options) != 0 {
|
|
if !options["email"] {
|
|
u.Email = ""
|
|
delete(u.Props, UserPropsKeyRemoteEmail)
|
|
}
|
|
if !options["fullname"] {
|
|
u.FirstName = ""
|
|
u.LastName = ""
|
|
}
|
|
if !options["passwordupdate"] {
|
|
u.LastPasswordUpdate = 0
|
|
}
|
|
if !options["authservice"] {
|
|
u.AuthService = ""
|
|
}
|
|
if !options["authdata"] {
|
|
u.AuthData = NewPointer("")
|
|
}
|
|
}
|
|
}
|
|
|
|
// Remove any input data from the user object that is not user controlled
|
|
func (u *User) SanitizeInput(isAdmin bool) {
|
|
if !isAdmin {
|
|
u.AuthData = NewPointer("")
|
|
u.AuthService = ""
|
|
u.EmailVerified = false
|
|
}
|
|
u.RemoteId = NewPointer("")
|
|
u.CreateAt = 0
|
|
u.UpdateAt = 0
|
|
u.DeleteAt = 0
|
|
u.LastPasswordUpdate = 0
|
|
u.LastPictureUpdate = 0
|
|
u.FailedAttempts = 0
|
|
u.MfaActive = false
|
|
u.MfaSecret = ""
|
|
u.MfaUsedTimestamps = StringArray{}
|
|
u.Email = strings.TrimSpace(u.Email)
|
|
u.LastActivityAt = 0
|
|
}
|
|
|
|
func (u *User) ClearNonProfileFields(asAdmin bool) {
|
|
u.Password = ""
|
|
u.MfaSecret = ""
|
|
u.MfaUsedTimestamps = nil
|
|
u.EmailVerified = false
|
|
u.AllowMarketing = false
|
|
u.LastPasswordUpdate = 0
|
|
|
|
if !asAdmin {
|
|
u.AuthData = NewPointer("")
|
|
u.NotifyProps = StringMap{}
|
|
u.FailedAttempts = 0
|
|
}
|
|
}
|
|
|
|
func (u *User) SanitizeProfile(options map[string]bool, asAdmin bool) {
|
|
u.ClearNonProfileFields(asAdmin)
|
|
|
|
u.Sanitize(options)
|
|
}
|
|
|
|
func (u *User) MakeNonNil() {
|
|
if u.Props == nil {
|
|
u.Props = make(map[string]string)
|
|
}
|
|
|
|
if u.NotifyProps == nil {
|
|
u.NotifyProps = make(map[string]string)
|
|
}
|
|
}
|
|
|
|
func (u *User) AddNotifyProp(key string, value string) {
|
|
u.MakeNonNil()
|
|
|
|
u.NotifyProps[key] = value
|
|
}
|
|
|
|
func (u *User) SetCustomStatus(cs *CustomStatus) error {
|
|
u.MakeNonNil()
|
|
statusJSON, jsonErr := json.Marshal(cs)
|
|
if jsonErr != nil {
|
|
return jsonErr
|
|
}
|
|
u.Props[UserPropsKeyCustomStatus] = string(statusJSON)
|
|
return nil
|
|
}
|
|
|
|
func (u *User) GetCustomStatus() *CustomStatus {
|
|
var o *CustomStatus
|
|
|
|
data := u.Props[UserPropsKeyCustomStatus]
|
|
_ = json.Unmarshal([]byte(data), &o)
|
|
|
|
return o
|
|
}
|
|
|
|
func (u *User) CustomStatus() *CustomStatus {
|
|
var o *CustomStatus
|
|
|
|
data := u.Props[UserPropsKeyCustomStatus]
|
|
_ = json.Unmarshal([]byte(data), &o)
|
|
|
|
return o
|
|
}
|
|
|
|
func (u *User) ClearCustomStatus() {
|
|
u.MakeNonNil()
|
|
u.Props[UserPropsKeyCustomStatus] = ""
|
|
}
|
|
|
|
func (u *User) ValidateCustomStatus() bool {
|
|
status, exists := u.Props[UserPropsKeyCustomStatus]
|
|
if exists && status != "" {
|
|
cs := u.GetCustomStatus()
|
|
if cs == nil {
|
|
return false
|
|
}
|
|
}
|
|
return true
|
|
}
|
|
|
|
func (u *User) GetFullName() string {
|
|
if u.FirstName != "" && u.LastName != "" {
|
|
return u.FirstName + " " + u.LastName
|
|
} else if u.FirstName != "" {
|
|
return u.FirstName
|
|
} else if u.LastName != "" {
|
|
return u.LastName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (u *User) getDisplayName(baseName, nameFormat string) string {
|
|
displayName := baseName
|
|
|
|
if nameFormat == ShowNicknameFullName {
|
|
if u.Nickname != "" {
|
|
displayName = u.Nickname
|
|
} else if fullName := u.GetFullName(); fullName != "" {
|
|
displayName = fullName
|
|
}
|
|
} else if nameFormat == ShowFullName {
|
|
if fullName := u.GetFullName(); fullName != "" {
|
|
displayName = fullName
|
|
}
|
|
}
|
|
|
|
return displayName
|
|
}
|
|
|
|
func (u *User) GetDisplayName(nameFormat string) string {
|
|
displayName := u.Username
|
|
|
|
return u.getDisplayName(displayName, nameFormat)
|
|
}
|
|
|
|
func (u *User) GetDisplayNameWithPrefix(nameFormat, prefix string) string {
|
|
displayName := prefix + u.Username
|
|
|
|
return u.getDisplayName(displayName, nameFormat)
|
|
}
|
|
|
|
func (u *User) GetRoles() []string {
|
|
return strings.Fields(u.Roles)
|
|
}
|
|
|
|
func (u *User) GetRawRoles() string {
|
|
return u.Roles
|
|
}
|
|
|
|
func IsValidUserRoles(userRoles string) bool {
|
|
roles := strings.Fields(userRoles)
|
|
|
|
for _, r := range roles {
|
|
if !IsValidRoleName(r) {
|
|
return false
|
|
}
|
|
}
|
|
|
|
// Exclude just the system_admin role explicitly to prevent mistakes
|
|
if len(roles) == 1 && roles[0] == "system_admin" {
|
|
return false
|
|
}
|
|
|
|
return true
|
|
}
|
|
|
|
// Make sure you actually want to use this function. In context.go there are functions to check permissions
|
|
// This function should not be used to check permissions.
|
|
func (u *User) IsGuest() bool {
|
|
return IsInRole(u.Roles, SystemGuestRoleId)
|
|
}
|
|
|
|
func (u *User) IsSystemAdmin() bool {
|
|
return IsInRole(u.Roles, SystemAdminRoleId)
|
|
}
|
|
|
|
// Make sure you actually want to use this function. In context.go there are functions to check permissions
|
|
// This function should not be used to check permissions.
|
|
func (u *User) IsInRole(inRole string) bool {
|
|
return IsInRole(u.Roles, inRole)
|
|
}
|
|
|
|
// Make sure you actually want to use this function. In context.go there are functions to check permissions
|
|
// This function should not be used to check permissions.
|
|
func IsInRole(userRoles string, inRole string) bool {
|
|
roles := strings.Split(userRoles, " ")
|
|
|
|
return slices.Contains(roles, inRole)
|
|
}
|
|
|
|
func (u *User) IsSSOUser() bool {
|
|
return u.AuthService != "" && u.AuthService != UserAuthServiceEmail
|
|
}
|
|
|
|
func (u *User) IsOAuthUser() bool {
|
|
return u.AuthService == ServiceGitlab ||
|
|
u.AuthService == ServiceGoogle ||
|
|
u.AuthService == ServiceOffice365 ||
|
|
u.AuthService == ServiceOpenid
|
|
}
|
|
|
|
func (u *User) IsLDAPUser() bool {
|
|
return u.AuthService == UserAuthServiceLdap
|
|
}
|
|
|
|
func (u *User) IsSAMLUser() bool {
|
|
return u.AuthService == UserAuthServiceSaml
|
|
}
|
|
|
|
func (u *User) GetPreferredTimezone() string {
|
|
return GetPreferredTimezone(u.Timezone)
|
|
}
|
|
|
|
func (u *User) GetTimezoneLocation() *time.Location {
|
|
loc, _ := time.LoadLocation(u.GetPreferredTimezone())
|
|
if loc == nil {
|
|
loc = time.Now().UTC().Location()
|
|
}
|
|
return loc
|
|
}
|
|
|
|
// IsRemote returns true if the user belongs to a remote cluster (has RemoteId).
|
|
func (u *User) IsRemote() bool {
|
|
return SafeDereference(u.RemoteId) != ""
|
|
}
|
|
|
|
// GetRemoteID returns the remote id for this user or "" if not a remote user.
|
|
func (u *User) GetRemoteID() string {
|
|
return SafeDereference(u.RemoteId)
|
|
}
|
|
|
|
func (u *User) GetOriginalRemoteID() string {
|
|
if u.Props == nil {
|
|
if u.IsRemote() {
|
|
return UserOriginalRemoteIdUnknown
|
|
}
|
|
return "" // Local user
|
|
}
|
|
if originalId, exists := u.Props[UserPropsKeyOriginalRemoteId]; exists && originalId != "" {
|
|
return originalId
|
|
}
|
|
if u.IsRemote() {
|
|
return UserOriginalRemoteIdUnknown
|
|
}
|
|
return "" // Local user
|
|
}
|
|
|
|
func (u *User) GetAuthData() string {
|
|
return SafeDereference(u.AuthData)
|
|
}
|
|
|
|
// GetProp fetches a prop value by name.
|
|
func (u *User) GetProp(name string) (string, bool) {
|
|
val, ok := u.Props[name]
|
|
return val, ok
|
|
}
|
|
|
|
// SetProp sets a prop value by name, creating the map if nil.
|
|
// Not thread safe.
|
|
func (u *User) SetProp(name string, value string) {
|
|
if u.Props == nil {
|
|
u.Props = make(map[string]string)
|
|
}
|
|
u.Props[name] = value
|
|
}
|
|
|
|
func (u *User) ToPatch() *UserPatch {
|
|
return &UserPatch{
|
|
Username: &u.Username, Password: &u.Password,
|
|
Nickname: &u.Nickname, FirstName: &u.FirstName, LastName: &u.LastName,
|
|
Position: &u.Position, Email: &u.Email,
|
|
Props: u.Props, NotifyProps: u.NotifyProps,
|
|
Locale: &u.Locale, Timezone: u.Timezone,
|
|
}
|
|
}
|
|
|
|
func (u *UserPatch) SetField(fieldName string, fieldValue string) {
|
|
switch fieldName {
|
|
case "FirstName":
|
|
u.FirstName = &fieldValue
|
|
case "LastName":
|
|
u.LastName = &fieldValue
|
|
case "Nickname":
|
|
u.Nickname = &fieldValue
|
|
case "Email":
|
|
u.Email = &fieldValue
|
|
case "Position":
|
|
u.Position = &fieldValue
|
|
case "Username":
|
|
u.Username = &fieldValue
|
|
}
|
|
}
|
|
|
|
var validUsernameChars = regexp.MustCompile(`^[a-z0-9\.\-_]+$`)
|
|
var validUsernameCharsForRemote = regexp.MustCompile(`^[a-z0-9\.\-_:]*$`)
|
|
|
|
var restrictedUsernames = map[string]struct{}{
|
|
"all": {},
|
|
"channel": {},
|
|
"matterbot": {},
|
|
"system": {},
|
|
}
|
|
|
|
func IsValidUsername(s string) bool {
|
|
if len(s) < UserNameMinLength || len(s) > UserNameMaxLength {
|
|
return false
|
|
}
|
|
|
|
if !validUsernameChars.MatchString(s) {
|
|
return false
|
|
}
|
|
|
|
_, found := restrictedUsernames[s]
|
|
return !found
|
|
}
|
|
|
|
func IsValidUsernameAllowRemote(s string) bool {
|
|
if len(s) < UserNameMinLength || len(s) > UserNameMaxLength {
|
|
return false
|
|
}
|
|
|
|
if !validUsernameCharsForRemote.MatchString(s) {
|
|
return false
|
|
}
|
|
|
|
_, found := restrictedUsernames[s]
|
|
return !found
|
|
}
|
|
|
|
func CleanUsername(logger mlog.LoggerIFace, username string) string {
|
|
s := NormalizeUsername(strings.Replace(username, " ", "-", -1))
|
|
|
|
for _, value := range reservedName {
|
|
if s == value {
|
|
s = strings.Replace(s, value, "", -1)
|
|
}
|
|
}
|
|
|
|
s = strings.TrimSpace(s)
|
|
|
|
for _, c := range s {
|
|
char := fmt.Sprintf("%c", c)
|
|
if !validUsernameChars.MatchString(char) {
|
|
s = strings.Replace(s, char, "-", -1)
|
|
}
|
|
}
|
|
|
|
s = strings.Trim(s, "-")
|
|
|
|
if !IsValidUsername(s) {
|
|
s = NewUsername()
|
|
logger.Warn("Generating new username since provided username was invalid",
|
|
mlog.String("provided_username", username), mlog.String("new_username", s))
|
|
}
|
|
|
|
return s
|
|
}
|
|
|
|
func IsValidLocale(locale string) bool {
|
|
if locale != "" {
|
|
if len(locale) > UserLocaleMaxLength {
|
|
return false
|
|
} else if _, err := language.Parse(locale); err != nil {
|
|
return false
|
|
}
|
|
}
|
|
|
|
return true
|
|
}
|
|
|
|
//msgp:ignore UserWithGroups
|
|
type UserWithGroups struct {
|
|
User
|
|
GroupIDs *string `json:"-"`
|
|
Groups []*Group `json:"groups"`
|
|
SchemeGuest bool `json:"scheme_guest"`
|
|
SchemeUser bool `json:"scheme_user"`
|
|
SchemeAdmin bool `json:"scheme_admin"`
|
|
}
|
|
|
|
func (u *UserWithGroups) GetGroupIDs() []string {
|
|
if u.GroupIDs == nil {
|
|
return nil
|
|
}
|
|
trimmed := strings.TrimSpace(*u.GroupIDs)
|
|
if trimmed == "" {
|
|
return nil
|
|
}
|
|
return strings.Split(trimmed, ",")
|
|
}
|
|
|
|
//msgp:ignore UsersWithGroupsAndCount
|
|
type UsersWithGroupsAndCount struct {
|
|
Users []*UserWithGroups `json:"users"`
|
|
Count int64 `json:"total_count"`
|
|
}
|
|
|
|
func (u *User) EmailDomain() string {
|
|
at := strings.LastIndex(u.Email, "@")
|
|
// at >= 0 holds true and this is not checked here. It holds true, because during signup we run `mail.ParseAddress(email)`
|
|
return u.Email[at+1:]
|
|
}
|
|
|
|
type UserPostStats struct {
|
|
LastStatusAt *int64 `json:"last_status_at,omitempty"`
|
|
LastPostDate *int64 `json:"last_post_date,omitempty"`
|
|
DaysActive *int `json:"days_active,omitempty"`
|
|
TotalPosts *int `json:"total_posts,omitempty"`
|
|
}
|