Method MarkEmailPrimary

internal/database/users.go:1160–1204

MarkEmailPrimary marks the email address of the given user as primary. It returns ErrEmailNotExist when the email is not found for the user, and ErrEmailNotActivated when the email is not activated.

(ctx context.Context, userID int64, email string)

// returns ErrEmailNotExist when the email is not found for the user, and
// ErrEmailNotActivated when the email is not activated.
func (s *UsersStore) MarkEmailPrimary(ctx context.Context, userID int64, email string) error {
	var emailAddress EmailAddress
	err := s.db.WithContext(ctx).Where("uid = ? AND email = ?", userID, email).First(&emailAddress).Error
	if err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return ErrEmailNotExist{args: errutil.Args{"email": email}}
		}
		return errors.Wrap(err, "get email address")
	}

	if !emailAddress.IsActivated {
		return ErrEmailNotVerified{args: errutil.Args{"email": email}}
	}

	user, err := s.GetByID(ctx, userID)
	if err != nil {
		return errors.Wrap(err, "get user")
	}

	return s.db.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
		// Make sure the former primary email doesn't disappear.
		err = tx.FirstOrCreate(
			&EmailAddress{
				UserID:      user.ID,
				Email:       user.Email,
				IsActivated: user.IsActive,
			},
			&EmailAddress{
				UserID: user.ID,
				Email:  user.Email,
			},
		).Error
		if err != nil {
			return errors.Wrap(err, "upsert former primary email address")
		}

		return tx.Model(&User{}).
			Where("id = ?", user.ID).
			Updates(map[string]any{
				"email":        email,
				"updated_unix": tx.NowFunc().Unix(),
			},
			).Error
	})
}

// DeleteEmail deletes the email address of the given user.
func (s *UsersStore) DeleteEmail(ctx context.Context, userID int64, email string) error {