fix: TTS 콜백 알림 발행 경로 정리

Author: pswaao88

backend/src/main/java/com/stackup/stackup/session/application/TtsCallbackService.java

@@ -2,7 +2,7 @@
 
 import com.stackup.stackup.common.messaging.domain.ProcessedMessage;
 import com.stackup.stackup.common.messaging.domain.ProcessedMessageRepository;
-import com.stackup.stackup.common.sse.SseEventPublisher;
+import com.stackup.stackup.common.messaging.RealtimeNotifyEvent;
 import com.stackup.stackup.common.sse.SseEventType;
 import com.stackup.stackup.session.application.dto.TtsCallbackEnvelope;
 import com.stackup.stackup.session.application.dto.TtsCallbackPayload;
@@ -13,6 +13,7 @@
 import lombok.RequiredArgsConstructor;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.dao.DataIntegrityViolationException;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -27,7 +28,7 @@ public class TtsCallbackService {
 
     private final InterviewMessageRepository messageRepository;
     private final ProcessedMessageRepository processedMessageRepository;
-    private final SseEventPublisher sseEventPublisher;
+    private final ApplicationEventPublisher events;
 
     @Transactional
     public void apply(TtsCallbackEnvelope envelope) {
@@ -94,9 +95,9 @@ private void publishNotice(InterviewMessage message, String errorCode) {
             message.getTtsDurationSec(),
             errorCode
         );
-        sseEventPublisher.publishToSession(sessionId, SseEventType.SESSION_MESSAGE, notice);
-        sseEventPublisher.publishToUser(message.getSession().getUser().getId(),
-            SseEventType.SESSION_MESSAGE, notice);
+        events.publishEvent(RealtimeNotifyEvent.session(sessionId, SseEventType.SESSION_MESSAGE, notice));
+        events.publishEvent(RealtimeNotifyEvent.user(message.getSession().getUser().getId(),
+            SseEventType.SESSION_MESSAGE, notice));
     }
 
     private boolean isProcessed(String messageId) {

backend/src/test/java/com/stackup/stackup/session/application/TtsCallbackServiceTest.java

@@ -2,15 +2,15 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.ArgumentMatchers.argThat;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.stackup.stackup.common.messaging.RealtimeNotifyEvent;
 import com.stackup.stackup.common.messaging.domain.ProcessedMessage;
 import com.stackup.stackup.common.messaging.domain.ProcessedMessageRepository;
-import com.stackup.stackup.common.sse.SseEventPublisher;
 import com.stackup.stackup.common.sse.SseEventType;
 import com.stackup.stackup.session.application.dto.MessageResult;
 import com.stackup.stackup.session.application.dto.TtsCallbackEnvelope;
@@ -28,6 +28,7 @@
 import org.mockito.InjectMocks;
 import org.mockito.Mock;
 import org.mockito.junit.jupiter.MockitoExtension;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.test.util.ReflectionTestUtils;
 
 @ExtendWith(MockitoExtension.class)
@@ -37,7 +38,7 @@ class TtsCallbackServiceTest {
 
     @Mock InterviewMessageRepository messageRepository;
     @Mock ProcessedMessageRepository processedMessageRepository;
-    @Mock SseEventPublisher sseEventPublisher;
+    @Mock ApplicationEventPublisher events;
     @InjectMocks TtsCallbackService service;
 
     @Test
@@ -57,8 +58,10 @@ void apply_successStoresTtsFieldsWithoutChangingMessageStatus() {
         assertThat(question.getTtsAudioPath()).isEqualTo("interview/tts/50/100.mp3");
         assertThat(question.getTtsDurationSec()).isEqualTo(2.4);
         assertThat(MessageResult.of(question).ttsAudioPath()).isEqualTo("interview/tts/50/100.mp3");
-        verify(sseEventPublisher).publishToSession(eq(50L), eq(SseEventType.SESSION_MESSAGE), any());
-        verify(sseEventPublisher).publishToUser(eq(1L), eq(SseEventType.SESSION_MESSAGE), any());
+        verify(events).publishEvent(argThat(event ->
+            isNotice(event, RealtimeNotifyEvent.Channel.SESSION, 50L)));
+        verify(events).publishEvent(argThat(event ->
+            isNotice(event, RealtimeNotifyEvent.Channel.USER, 1L)));
         verify(processedMessageRepository).save(any(ProcessedMessage.class));
     }
 
@@ -78,7 +81,8 @@ void apply_failedMarksOnlyTtsFailedAndLeavesQuestionUsable() {
         assertThat(question.getTtsStatus()).isEqualTo(TtsStatus.FAILED);
         assertThat(question.getContent()).isEqualTo("Q?");
         assertThat(question.getTtsAudioPath()).isNull();
-        verify(sseEventPublisher).publishToSession(eq(50L), eq(SseEventType.SESSION_MESSAGE), any());
+        verify(events).publishEvent(argThat(event ->
+            isNotice(event, RealtimeNotifyEvent.Channel.SESSION, 50L)));
         verify(processedMessageRepository).save(any(ProcessedMessage.class));
     }
 
@@ -96,7 +100,7 @@ void apply_ignoresIntervieweeMessages() {
         )));
 
         assertThat(answer.getTtsStatus()).isEqualTo(TtsStatus.NOT_REQUESTED);
-        verify(sseEventPublisher, never()).publishToSession(any(), any(), any());
+        verify(events, never()).publishEvent(any());
         verify(processedMessageRepository).save(any(ProcessedMessage.class));
     }
 
@@ -132,6 +136,15 @@ private TtsCallbackEnvelope envelope(String messageId, TtsCallbackPayload payloa
             null, "ai", payload, null);
     }
 
+    private boolean isNotice(Object event, RealtimeNotifyEvent.Channel channel, Long id) {
+        if (!(event instanceof RealtimeNotifyEvent realtimeNotifyEvent)) {
+            return false;
+        }
+        return realtimeNotifyEvent.channel() == channel
+            && realtimeNotifyEvent.id().equals(id)
+            && realtimeNotifyEvent.type() == SseEventType.SESSION_MESSAGE;
+    }
+
     private InterviewSession sessionFixture(Long id) {
         User user = User.createGithubUser(1L, "u", null, null, "t");
         ReflectionTestUtils.setField(user, "id", 1L);