Merge pull request #5 from LESSON-MATCHING-PLATFORM/feat/notification-failure-case-tests

test: 알림 실패 케이스 테스트 보강

Author: hwan20202

src/test/java/com/kosa/noticeserver/consumer/PaymentTopicConsumerTest.java

@@ -8,6 +8,7 @@
 
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyList;
 import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.doThrow;
 import static org.mockito.Mockito.mock;
@@ -28,6 +29,14 @@ void consumePaymentEvent_whenPayloadIsInvalid_doesNotRetry() {
         verify(notificationService, never()).notice(any(PaymentEvent.class), any());
     }
 
+    @Test
+    @DisplayName("잘못된 bulk JSON payload는 알림 처리 없이 소비한다")
+    void consumePaymentBulkEvent_whenPayloadIsInvalid_doesNotRetry() {
+        consumer.consumePaymentBulkEvent("{invalid", "event-001");
+
+        verify(notificationService, never()).notice(anyList(), any());
+    }
+
     @Test
     @DisplayName("알림 처리 중 예상하지 못한 예외는 listener 밖으로 전파한다")
     void consumePaymentEvent_whenUnexpectedNotificationFailure_propagatesException() {

src/test/java/com/kosa/noticeserver/domain/service/PaymentEventNotificationServiceTest.java

@@ -76,6 +76,37 @@ void notice_whenDeliveryAlreadyClaimed_skipsFcmSend() throws Throwable {
         verify(fcmSender, never()).send(anyList());
     }
 
+    @Test
+    @DisplayName("알림 수신 설정이 꺼진 사용자는 토큰 조회와 FCM 발송을 건너뛴다")
+    void notice_whenSendSettingIsDisabled_skipsTokenLookupAndFcmSend() throws Throwable {
+        PaymentEvent event = paymentEvent();
+
+        when(notificationService.canSend("user-001", NotificationType.PAYMENT)).thenReturn(false);
+
+        service.notice(event, "event-001");
+
+        verify(notificationService).canSend("user-001", NotificationType.PAYMENT);
+        verify(tokenRepository, never()).findAllTokensByUserId("user-001");
+        verify(notificationDeliveryService, never()).claimPaymentFcmDelivery(any(), any());
+        verify(fcmSender, never()).send(anyList());
+    }
+
+    @Test
+    @DisplayName("FCM 토큰이 없는 사용자는 delivery claim과 FCM 발송을 건너뛴다")
+    void notice_whenTokenIsMissing_skipsDeliveryClaimAndFcmSend() throws Throwable {
+        PaymentEvent event = paymentEvent();
+
+        when(notificationService.canSend("user-001", NotificationType.PAYMENT)).thenReturn(true);
+        when(tokenRepository.findAllTokensByUserId("user-001")).thenReturn(List.of());
+
+        service.notice(event, "event-001");
+
+        verify(notificationService).canSend("user-001", NotificationType.PAYMENT);
+        verify(tokenRepository).findAllTokensByUserId("user-001");
+        verify(notificationDeliveryService, never()).claimPaymentFcmDelivery(any(), any());
+        verify(fcmSender, never()).send(anyList());
+    }
+
     @Test
     @DisplayName("같은 eventId와 사용자 조합을 두 번 처리해도 FCM은 한 번만 발송한다")
     void notice_whenSameEventAndUserIsConsumedTwice_sendsFcmOnce() throws Throwable {