테스트코드 수정:

Author: jypLord

src/test/java/com/jypLord/auth/AuthServiceTest.java

@@ -93,7 +93,7 @@ void login_successWithExistingRefreshToken() {
         given(redis.opsForValue()).willReturn(valueOperations);
         given(userRepository.findByEmail("user@test.com")).willReturn(Mono.just(user));
         given(passwordEncoder.matches("raw-password", "encoded")).willReturn(true);
-        given(jwtProvider.generateAccessToken("user@test.com")).willReturn("access-token");
+        given(jwtProvider.generateAccessToken(1L, "user@test.com")).willReturn("access-token");
         given(valueOperations.get("refresh:user@test.com")).willReturn(Mono.just("refresh-token"));
         given(valueOperations.set(eq("refresh:user@test.com"), eq("refresh-token"), any())).willReturn(Mono.just(true));
 

src/test/java/com/jypLord/domain/trade/service/TradeServiceTest.java

@@ -0,0 +1,90 @@
+package com.jypLord.domain.trade.service;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.BDDMockito.given;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.verify;
+
+import com.jypLord.api.BrokerageFirm;
+import com.jypLord.domain.trade.TradeStatus;
+import com.jypLord.domain.trade.dto.request.RegisterTradeInfoRequest;
+import com.jypLord.domain.trade.entity.Trade;
+import com.jypLord.domain.trade.repository.TradeRepository;
+import com.jypLord.domain.user.UserRepository;
+import com.jypLord.redis.pub.RedisAssetPricePublisher;
+import com.jypLord.redis.streams.publisher.RedisStockEventPublisher;
+import com.jypLord.redis.sub.RedisStockPriceSubscriber;
+import java.rmi.AlreadyBoundException;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
+
+@ExtendWith(MockitoExtension.class)
+class TradeServiceTest {
+
+    @Mock
+    private com.jypLord.api.handler.BrokerClient brokerClient;
+    @Mock
+    private TradeRepository tradeRepository;
+    @Mock
+    private UserRepository userRepository;
+    @Mock
+    private RedisAssetPricePublisher redisAssetPricePublisher;
+    @Mock
+    private RedisStockPriceSubscriber redisStockPriceSubscriber;
+    @Mock
+    private RedisStockEventPublisher redisStockEventPublisher;
+
+    @InjectMocks
+    private TradeService tradeService;
+
+    private final RegisterTradeInfoRequest request =
+        new RegisterTradeInfoRequest(BrokerageFirm.LS, "005930", 99000, 1);
+
+    @Test
+    void registerTradeInfo_savesWhenNoActiveTradeExists() {
+        Trade saved = new Trade(1L, "005930", BrokerageFirm.LS, 99000, 1, TradeStatus.ACTIVE);
+
+        given(tradeRepository.findByUserIdAndStockCodeAndStatus(1L, "005930", TradeStatus.ACTIVE))
+            .willReturn(Mono.empty());
+        given(tradeRepository.save(any(Trade.class))).willReturn(Mono.just(saved));
+
+        StepVerifier.create(tradeService.registerTradeInfo(1L, request))
+            .verifyComplete();
+
+        verify(tradeRepository).save(any(Trade.class));
+    }
+
+    @Test
+    void registerTradeInfo_throwsWhenSamePriceAlreadyExists() {
+        Trade existing = new Trade(1L, "005930", BrokerageFirm.LS, 99000, 1, TradeStatus.ACTIVE);
+
+        given(tradeRepository.findByUserIdAndStockCodeAndStatus(1L, "005930", TradeStatus.ACTIVE))
+            .willReturn(Mono.just(existing));
+
+        StepVerifier.create(tradeService.registerTradeInfo(1L, request))
+            .expectError(AlreadyBoundException.class)
+            .verify();
+
+        verify(tradeRepository, never()).save(any());
+    }
+
+    @Test
+    void updateTradeStatusForIdempotency_delegatesToRepository() {
+        given(tradeRepository.updateTradeStatus(10L, TradeStatus.ACTIVE, TradeStatus.EXECUTED_LOSSCUT))
+            .willReturn(Mono.just(true));
+
+        StepVerifier.create(
+                tradeService.updateTradeStatusForIdempotency(10L, TradeStatus.ACTIVE, TradeStatus.EXECUTED_LOSSCUT)
+            )
+            .expectNext(true)
+            .verifyComplete();
+
+        verify(tradeRepository).updateTradeStatus(10L, TradeStatus.ACTIVE, TradeStatus.EXECUTED_LOSSCUT);
+    }
+}

src/test/java/com/jypLord/domain/user/UserServiceTest.java

@@ -30,27 +30,27 @@ class UserServiceTest {
 
     @Test
     void getStockOAuthAndSave_success() {
-        LsStockOAuthSaveRequest request = new LsStockOAuthSaveRequest(BrokerageFirm.LS, 1L, "app-key", "app-secret");
+        LsStockOAuthSaveRequest request = new LsStockOAuthSaveRequest(BrokerageFirm.LS, "app-key", "app-secret");
         User user = new User(1L, "test@test.com", "pw", "name", LocalDate.of(2000, 1, 1), null, null);
 
         given(brokerClient.getOAuthToken(any())).willReturn(Mono.just("oauth-token"));
         given(userRepository.findById(1L)).willReturn(Mono.just(user));
         given(userRepository.save(any(User.class))).willReturn(Mono.just(user));
 
-        StepVerifier.create(userService.getStockOAuthAndSave(request))
+        StepVerifier.create(userService.getStockOAuthAndSave(1L, request))
             .verifyComplete();
 
         verify(userRepository).save(any(User.class));
     }
 
     @Test
     void getStockOAuthAndSave_userNotFound_completesWithoutSave() {
-        LsStockOAuthSaveRequest request = new LsStockOAuthSaveRequest(BrokerageFirm.LS, 99L, "app-key", "app-secret");
+        LsStockOAuthSaveRequest request = new LsStockOAuthSaveRequest(BrokerageFirm.LS, "app-key", "app-secret");
 
         given(brokerClient.getOAuthToken(any())).willReturn(Mono.just("oauth-token"));
         given(userRepository.findById(99L)).willReturn(Mono.empty());
 
-        StepVerifier.create(userService.getStockOAuthAndSave(request))
+        StepVerifier.create(userService.getStockOAuthAndSave(99L, request))
             .verifyComplete();
 
         verify(userRepository, never()).save(any());

src/test/java/com/jypLord/usertest/UserTest.java

@@ -31,14 +31,14 @@ class UserTest {
 
     @Test
     void get_accessToken_test() {
-        LsStockOAuthSaveRequest request = new LsStockOAuthSaveRequest(BrokerageFirm.LS, 1L, "appKey", "appSecret");
+        LsStockOAuthSaveRequest request = new LsStockOAuthSaveRequest(BrokerageFirm.LS, "appKey", "appSecret");
         User user = new User(1L, "test@test.com", "pw", "name", LocalDate.of(2000, 1, 1), null, null);
 
         given(brokerClient.getOAuthToken(any())).willReturn(Mono.just("access-token"));
         given(userRepository.findById(1L)).willReturn(Mono.just(user));
         given(userRepository.save(any(User.class))).willReturn(Mono.just(user));
 
-        StepVerifier.create(userService.getStockOAuthAndSave(request))
+        StepVerifier.create(userService.getStockOAuthAndSave(1L, request))
             .verifyComplete();
     }
 }