144 lines
3.7 KiB
Go
144 lines
3.7 KiB
Go
package services
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"strings"
|
|
|
|
"GoMembership/internal/constants"
|
|
"GoMembership/internal/models"
|
|
"GoMembership/internal/repositories"
|
|
"GoMembership/internal/utils"
|
|
"GoMembership/pkg/logger"
|
|
|
|
"github.com/alexedwards/argon2id"
|
|
"github.com/go-playground/validator/v10"
|
|
|
|
"time"
|
|
)
|
|
|
|
type UserServiceInterface interface {
|
|
RegisterUser(user *models.User) (int64, string, error)
|
|
GetUserByEmail(email string) (*models.User, error)
|
|
GetUsers(where map[string]interface{}) (*[]models.User, error)
|
|
VerifyUser(token *string) (*models.User, error)
|
|
}
|
|
|
|
type UserService struct {
|
|
Repo repositories.UserRepositoryInterface
|
|
}
|
|
|
|
func (service *UserService) RegisterUser(user *models.User) (int64, string, error) {
|
|
if err := validateRegistrationData(user); err != nil {
|
|
return http.StatusNotAcceptable, "", err
|
|
}
|
|
|
|
setPassword(user.Password, user)
|
|
|
|
user.Status = constants.UnverifiedStatus
|
|
user.CreatedAt = time.Now()
|
|
user.UpdatedAt = time.Now()
|
|
|
|
id, err := service.Repo.CreateUser(user)
|
|
|
|
if err != nil && strings.Contains(err.Error(), "UNIQUE constraint failed") {
|
|
return http.StatusConflict, "", err
|
|
} else if err != nil {
|
|
return http.StatusInternalServerError, "", err
|
|
}
|
|
|
|
user.ID = id
|
|
|
|
token, err := utils.GenerateVerificationToken()
|
|
if err != nil {
|
|
return http.StatusInternalServerError, "", err
|
|
}
|
|
|
|
logger.Info.Printf("TOKEN: %v", token)
|
|
|
|
_, err = service.Repo.SetVerificationToken(user, &token)
|
|
if err != nil {
|
|
return http.StatusInternalServerError, "", err
|
|
}
|
|
|
|
return id, token, nil
|
|
}
|
|
|
|
func (service *UserService) Update(user *models.User) (int64, string, error) {
|
|
if err := validateRegistrationData(user); err != nil {
|
|
return http.StatusNotAcceptable, "", err
|
|
}
|
|
|
|
if user.Password == "" && user.RoleID != constants.Roles.Member {
|
|
return http.StatusNotAcceptable, "", fmt.Errorf("No password provided")
|
|
}
|
|
hash, err := utils.HashPassword(user.Password)
|
|
if err != nil {
|
|
return http.StatusInternalServerError, "", err
|
|
}
|
|
user.Password = hash
|
|
|
|
user.Status = constants.UnverifiedStatus
|
|
user.CreatedAt = time.Now()
|
|
user.UpdatedAt = time.Now()
|
|
|
|
id, err := service.Repo.CreateUser(user)
|
|
|
|
if err != nil && strings.Contains(err.Error(), "UNIQUE constraint failed") {
|
|
return http.StatusConflict, "", err
|
|
} else if err != nil {
|
|
return http.StatusInternalServerError, "", err
|
|
}
|
|
|
|
user.ID = id
|
|
|
|
token, err := utils.GenerateVerificationToken()
|
|
if err != nil {
|
|
return http.StatusInternalServerError, "", err
|
|
}
|
|
|
|
logger.Info.Printf("TOKEN: %v", token)
|
|
|
|
_, err = service.Repo.SetVerificationToken(user, &token)
|
|
if err != nil {
|
|
return http.StatusInternalServerError, "", err
|
|
}
|
|
|
|
return id, token, nil
|
|
}
|
|
func (service *UserService) GetUserByEmail(email string) (*models.User, error) {
|
|
return service.Repo.GetUserByEmail(email)
|
|
}
|
|
|
|
func (service *UserService) GetUsers(where map[string]interface{}) (*[]models.User, error) {
|
|
return service.Repo.GetUsers(where)
|
|
}
|
|
|
|
func (service *UserService) VerifyUser(token *string) (*models.User, error) {
|
|
user, err := service.Repo.VerifyUserOfToken(token)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return user, nil
|
|
}
|
|
|
|
func validateRegistrationData(user *models.User) error {
|
|
validate := validator.New()
|
|
validate.RegisterValidation("age", utils.AgeValidator)
|
|
validate.RegisterValidation("bic", utils.BICValidator)
|
|
validate.RegisterValidation("iban", utils.IBANValidator)
|
|
validate.RegisterValidation("subscriptionModel", utils.SubscriptionModelValidator)
|
|
validate.RegisterValidation("membershipField", utils.ValidateRequiredMembershipField)
|
|
|
|
return validate.Struct(user)
|
|
}
|
|
|
|
func setPassword(plaintextPassword string, u *models.User) error {
|
|
hash, err := argon2id.CreateHash(plaintextPassword, argon2id.DefaultParams)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
u.Password = hash
|
|
return nil
|
|
}
|