athrow error if user with provided email exists

Author: Mateusz Gajda

src/modules/user/src/core/error/user-exists.error.ts

@@ -0,0 +1,8 @@
+import { TravelhoopError } from "@travelhoop/infrastructure";
+import StatusCodes from "http-status-codes";
+
+export class UserExistsError extends TravelhoopError {
+  constructor() {
+    super("User with provided email exists", StatusCodes.BAD_REQUEST);
+  }
+}

src/modules/user/src/core/repositories/user.repository.ts

@@ -32,4 +32,8 @@ export class UserRepository {
 
     return user;
   }
+
+  async findByEmail(email: string) {
+    return this.deps.dbConnection.em.getRepository(User).findOne({ email });
+  }
 }

src/modules/user/src/core/services/user.service.ts

@@ -7,6 +7,7 @@ import { UserDto } from "../dto/user.dto";
 import { Profile } from "../entities/profile";
 import { User } from "../entities/user";
 import { InvalidEmailOrPasswordError } from "../error/invalid-email-or-password.error";
+import { UserExistsError } from "../error/user-exists.error";
 import { UserCreated } from "../events/user-created.event";
 import { UserRepository } from "../repositories/user.repository";
 import { AuthService } from "./auth.service";
@@ -23,6 +24,12 @@ export class UserService {
   constructor(private readonly deps: UserServiceDependencies) {}
 
   async register(dto: RegisterDto) {
+    const existingUser = await this.deps.userRepository.findByEmail(dto.email);
+
+    if (existingUser) {
+      throw new UserExistsError();
+    }
+
     const userId = Guid.create();
     const profileId = Guid.create();
     const password = await this.deps.passwordManager.hashPassword(dto.password);