Merge pull request #9 from Kimjipang/round04

Round04

Author: Kimjipang

apps/commerce-api/src/main/java/com/loopers/domain/like/LikeRepository.java

@@ -10,4 +10,6 @@ public interface LikeRepository {
     void delete(Like like);
 
     int countByProductId(Long productId);
+
+    int countByUserIdAndProductId(Long userId, Long productId);
 }

apps/commerce-api/src/main/java/com/loopers/infrastructure/like/LikeJpaRepository.java

@@ -9,4 +9,6 @@ public interface LikeJpaRepository extends JpaRepository<Like, Long> {
     Optional<Like> findByUserIdAndProductId(Long userId, Long productId);
 
     int countByProductId(Long productId);
+
+    int countByUserIdAndProductId(Long userId, Long productId);
 }

apps/commerce-api/src/main/java/com/loopers/infrastructure/like/LikeRepositoryImpl.java

@@ -31,4 +31,9 @@ public void delete(Like like) {
     public int countByProductId(Long productId) {
         return likeJpaRepository.countByProductId(productId);
     }
+
+    @Override
+    public int countByUserIdAndProductId(Long userId, Long productId) {
+        return likeJpaRepository.countByUserIdAndProductId(userId, productId);
+    }
 }

apps/commerce-api/src/test/java/com/loopers/domain/like/LikeConcurrencyIntegrationTest.java

@@ -0,0 +1,51 @@
+package com.loopers.domain.like;
+
+import com.loopers.application.like.LikeFacade;
+import com.loopers.interfaces.api.like.LikeV1Dto;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+@SpringBootTest
+@Transactional
+public class LikeConcurrencyIntegrationTest {
+
+    @Autowired
+    private LikeFacade likeFacade;
+
+    @Autowired
+    private LikeRepository likeRepository;
+
+    @Test
+    void 동시에_100개의_좋아요요청이_들어오면_좋아요는_1개만_생성된다() throws Exception {
+        Long userId = 1L;
+        Long productId = 1L;
+
+        int threadCount = 100;
+        ExecutorService executor = Executors.newFixedThreadPool(threadCount);
+        CountDownLatch latch = new CountDownLatch(threadCount);
+
+        for (int i = 0; i < threadCount; i++) {
+            executor.submit(() -> {
+                try {
+                    likeFacade.doLike(new LikeV1Dto.LikeRequest(userId, productId));
+                } finally {
+                    latch.countDown();
+                }
+            });
+        }
+
+        // 모든 스레드 작업이 종료될 때까지 대기
+        latch.await();
+
+        long count = likeRepository.countByUserIdAndProductId(userId, productId);
+        assertThat(count).isEqualTo(1);
+    }
+}

apps/commerce-api/src/test/java/com/loopers/domain/user/UserServiceIntegrationTest.java

@@ -109,7 +109,7 @@ void returnsUserEntity_when_user_exists() {
         userService.save(userEntity);
 
         // act
-        UserEntity foundUser = userService.getUserByLoginId(loginId);
+        UserEntity foundUser = userService.findUserByLoginId(loginId);
 
         // assert
         assertThat(foundUser).isNotNull();
@@ -127,7 +127,7 @@ void returnsNull_when_user_not_exists() {
 
         // act
         final CoreException result = assertThrows(CoreException.class, () -> {
-            userService.getUserByLoginId(loginId);
+            userService.findUserByLoginId(loginId);
         });
 
         // assert