photoprism/internal/entity/auth_user_add.go

package entity

import (
	"fmt"

	"github.com/jinzhu/gorm"

	"github.com/photoprism/photoprism/internal/form"
	"github.com/photoprism/photoprism/pkg/authn"
	"github.com/photoprism/photoprism/pkg/clean"
	"github.com/photoprism/photoprism/pkg/txt"
)

// AddUser creates a new user record and sets the password in a single transaction.
func AddUser(frm form.User) error {
	user := NewUser().SetFormValues(frm)

	// Check auth id and password.
	if authId := clean.Auth(frm.AuthID); frm.Provider().Is(authn.ProviderOIDC) && len(authId) < 4 {
		return authn.ErrAuthIDRequired
	} else if len(frm.Password) > txt.ClipPassword {
		return fmt.Errorf("password must have less than %d characters", txt.ClipPassword)
	} else if (frm.Provider().RequiresLocalPassword() || frm.Password != "") && len([]rune(frm.Password)) < PasswordLength {
		return fmt.Errorf("password must have at least %d characters", PasswordLength)
	}

	// Check username, role and email.
	if err := user.Validate(); err != nil {
		return err
	}

	return Db().Transaction(func(tx *gorm.DB) error {
		if err := tx.Create(user).Error; err != nil {
			return err
		}

		if frm.Password != "" {
			pw := NewPassword(user.UserUID, frm.Password, false)

			if err := tx.Create(&pw).Error; err != nil {
				return err
			}
		}

		log.Infof("successfully added user %s", clean.LogQuote(user.Username()))

		return nil
	})
}