find user by id and email

Author: murillolamego

.http

@@ -4,16 +4,22 @@
 ### GET users
 GET {{apiurl}}/users HTTP/1.1
 
+### GET user by ID
+GET {{apiurl}}/getUserById/66777d1b9242370bf4575b31 HTTP/1.1
+
+### GET user by EMAIL
+GET {{apiurl}}/getUserByEmail/test@test.com HTTP/1.1
+
 ### POST users
 POST {{apiurl}}/createUser HTTP/1.1
 Content-Type: application/json
 Authorization: Bearer ACCESS-TOKEN
 
 {
-   "email":"test@test.com",
+   "email":"test2@test.com",
    "password":"test@123",
-   "name":"test",
-   "age":19
+   "name":"test2",
+   "age":20
 }
 
 ### GET categories

go.mod

@@ -22,6 +22,7 @@ require (
 	github.com/gin-contrib/sse v0.1.0 // indirect
 	github.com/goccy/go-json v0.10.2 // indirect
 	github.com/golang/snappy v0.0.1 // indirect
+	github.com/google/uuid v1.6.0 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
 	github.com/klauspost/compress v1.13.6 // indirect
 	github.com/klauspost/cpuid/v2 v2.2.7 // indirect

go.sum

@@ -30,6 +30,8 @@ github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEW
 github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU=
 github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
 github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
 github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=

src/controller/find_user.go

@@ -1,7 +1,49 @@
 package controller
 
-import "github.com/gin-gonic/gin"
+import (
+	"net/http"
+	"net/mail"
 
-func (uc *userControllerInterface) FindUserByID(c *gin.Context) {}
+	"github.com/gin-gonic/gin"
+	"github.com/murillolamego/golang-basic/src/config/rest_err"
+	"github.com/murillolamego/golang-basic/src/view"
+	"go.mongodb.org/mongo-driver/bson/primitive"
+)
 
-func (uc *userControllerInterface) FindUserByEmail(c *gin.Context) {}
+func (uc *userControllerInterface) FindUserByID(c *gin.Context) {
+	userId := c.Param("userId")
+
+	if _, err := primitive.ObjectIDFromHex(userId); err != nil {
+		errorMessage := rest_err.NewBadRequestError("UserID is not a valid id")
+
+		c.JSON(errorMessage.Code, errorMessage.Message)
+		return
+	}
+
+	userDomain, err := uc.service.FindUserByID(userId)
+	if err != nil {
+		c.JSON(err.Code, err)
+		return
+	}
+
+	c.JSON(http.StatusOK, view.ConvertDomainToResponse(userDomain))
+}
+
+func (uc *userControllerInterface) FindUserByEmail(c *gin.Context) {
+	email := c.Param("userEmail")
+
+	if _, err := mail.ParseAddress(email); err != nil {
+		errorMessage := rest_err.NewBadRequestError("Email is not valid")
+
+		c.JSON(errorMessage.Code, errorMessage.Message)
+		return
+	}
+
+	userDomain, err := uc.service.FindUserByEmail(email)
+	if err != nil {
+		c.JSON(err.Code, err)
+		return
+	}
+
+	c.JSON(http.StatusOK, view.ConvertDomainToResponse(userDomain))
+}

src/model/repository/find_user_repository.go

@@ -0,0 +1,67 @@
+package repository
+
+import (
+	"context"
+	"fmt"
+	"os"
+
+	"github.com/murillolamego/golang-basic/src/config/logger"
+	"github.com/murillolamego/golang-basic/src/config/rest_err"
+	"github.com/murillolamego/golang-basic/src/model"
+	"github.com/murillolamego/golang-basic/src/model/repository/entity"
+	"github.com/murillolamego/golang-basic/src/model/repository/entity/converter"
+	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/bson/primitive"
+	"go.mongodb.org/mongo-driver/mongo"
+)
+
+func (ur *userRepository) FindUserByID(id string) (model.UserDomainInterface, *rest_err.RestErr) {
+	logger.Info("init findUserByID repository")
+
+	collection_name := os.Getenv(MONGODB_USER_COLLECTION)
+
+	collection := ur.databaseConnection.Collection(collection_name)
+
+	userEntity := &entity.UserEntity{}
+
+	objectId, _ := primitive.ObjectIDFromHex((id))
+	filter := bson.D{{Key: "_id", Value: objectId}}
+	err := collection.FindOne(context.Background(), filter).Decode(userEntity)
+
+	if err != nil {
+		if err == mongo.ErrNoDocuments {
+			errorMessage := fmt.Sprintf("User with ID %s not found", id)
+
+			return nil, rest_err.NewNotFoundErrorfunc(errorMessage)
+		}
+
+		return nil, rest_err.NewInternalServerErrorfunc("Error trying to find user by ID")
+	}
+
+	return converter.ConvertEntityToDomain(*userEntity), nil
+}
+
+func (ur *userRepository) FindUserByEmail(email string) (model.UserDomainInterface, *rest_err.RestErr) {
+	logger.Info("init findUserByEmail repository")
+
+	collection_name := os.Getenv(MONGODB_USER_COLLECTION)
+
+	collection := ur.databaseConnection.Collection(collection_name)
+
+	userEntity := &entity.UserEntity{}
+
+	filter := bson.D{{Key: "email", Value: email}}
+	err := collection.FindOne(context.Background(), filter).Decode(userEntity)
+
+	if err != nil {
+		if err == mongo.ErrNoDocuments {
+			errorMessage := fmt.Sprintf("User with email %s not found", email)
+
+			return nil, rest_err.NewNotFoundErrorfunc(errorMessage)
+		}
+
+		return nil, rest_err.NewInternalServerErrorfunc("Error trying to find user by email")
+	}
+
+	return converter.ConvertEntityToDomain(*userEntity), nil
+}

src/model/repository/user_repository.go

@@ -22,4 +22,8 @@ type UserRepository interface {
 	CreateUser(
 		userDomain model.UserDomainInterface,
 	) (model.UserDomainInterface, *rest_err.RestErr)
+
+	FindUserByID(id string) (model.UserDomainInterface, *rest_err.RestErr)
+
+	FindUserByEmail(email string) (model.UserDomainInterface, *rest_err.RestErr)
 }

src/model/service/find_user.go

@@ -5,6 +5,10 @@ import (
 	"github.com/murillolamego/golang-basic/src/model"
 )
 
-func (ud *userDomainService) FindUser(userId string) (model.UserDomainInterface, *rest_err.RestErr) {
-	return nil, nil
+func (ud *userDomainService) FindUserByID(id string) (model.UserDomainInterface, *rest_err.RestErr) {
+	return ud.userRepository.FindUserByID(id)
+}
+
+func (ud *userDomainService) FindUserByEmail(email string) (model.UserDomainInterface, *rest_err.RestErr) {
+	return ud.userRepository.FindUserByEmail(email)
 }

src/model/service/user_interface.go

@@ -16,7 +16,8 @@ type userDomainService struct {
 
 type UserDomainService interface {
 	CreateUser(model.UserDomainInterface) (model.UserDomainInterface, *rest_err.RestErr)
-	FindUser(string) (model.UserDomainInterface, *rest_err.RestErr)
+	FindUserByID(id string) (model.UserDomainInterface, *rest_err.RestErr)
+	FindUserByEmail(email string) (model.UserDomainInterface, *rest_err.RestErr)
 	UpdateUser(string, model.UserDomainInterface) (model.UserDomainInterface, *rest_err.RestErr)
 	DeleteUser(string) *rest_err.RestErr
 }