Merge pull request #18 from bouanani-soufiane/PIG-64-Lofts

PIG-64-Lofts

src/main/java/ma/yc/PigeonSkyRace/piegon/domain/service/impl/DefaultLoftDomainService.java

@@ -13,6 +13,9 @@
 import ma.yc.PigeonSkyRace.piegon.domain.service.LoftDomainService;
 import ma.yc.PigeonSkyRace.piegon.domain.service.LoftNameGenerator;
 import ma.yc.PigeonSkyRace.piegon.infrastructure.repository.LoftRepository;
+import ma.yc.PigeonSkyRace.user.application.service.UserApplicationService;
+import ma.yc.PigeonSkyRace.user.domain.exception.InvalidUserException;
+import ma.yc.PigeonSkyRace.user.domain.model.valueobject.UserId;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
@@ -25,6 +28,7 @@ public class DefaultLoftDomainService implements LoftDomainService, LoftApplicat
     private final LoftRepository repository;
     private final LoftMapper mapper;
     private final LoftNameGenerator loftNameGenerator;
+    private final UserApplicationService userApplicationService;
 
     @Override
     public boolean existsById ( LoftId id ) {
@@ -33,24 +37,26 @@ public boolean existsById ( LoftId id ) {
 
     @Override
     public LoftResponseDTO findById ( LoftId id ) {
-        return repository.findById(id)
-                .map(mapper::toDto)
-                .orElseThrow(() -> new NotFoundException("Loft", id));
+        return repository.findById(id).map(mapper::toDto).orElseThrow(() -> new NotFoundException("Loft", id));
     }
 
     @Override
     public List<LoftResponseDTO> findAll () {
-        return repository.findAll()
-                .stream()
-                .map(mapper::toDto)
-                .toList();
+        return repository.findAll().stream().map(mapper::toDto).toList();
     }
 
     @Override
     public LoftResponseDTO create ( LoftRequestDTO dto ) {
+        try {
+            userApplicationService.getById(UserId.fromString(dto.userId()));
+        } catch (NotFoundException e) {
+            throw new InvalidUserException("User with ID " + dto.userId() + " does not exist", e);
+        }
+
         Loft loft = mapper.toEntity(dto);
         String uniqueName = generateUniqueLoftName();
         loft.setName(uniqueName);
+
         return mapper.toDto(repository.save(loft));
     }
 

src/main/java/ma/yc/PigeonSkyRace/user/domain/exception/InvalidUserException.java

@@ -0,0 +1,11 @@
+package ma.yc.PigeonSkyRace.user.domain.exception;
+
+public class InvalidUserException extends RuntimeException {
+    public InvalidUserException(String message) {
+        super(message);
+    }
+
+    public InvalidUserException(String message, Throwable cause) {
+        super(message, cause);
+    }
+}