feat: 음성 콜백 성공 실패 처리 보강

Author: pswaao88

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

@@ -11,7 +11,6 @@
 import com.stackup.stackup.session.application.event.AnswerSubmittedEvent;
 import com.stackup.stackup.session.domain.InterviewMessage;
 import com.stackup.stackup.session.domain.InterviewMessageRepository;
-import com.stackup.stackup.session.domain.MessageStatus;
 import com.stackup.stackup.session.domain.MessageVoiceAnalysis;
 import com.stackup.stackup.session.domain.MessageVoiceAnalysisRepository;
 import lombok.RequiredArgsConstructor;
@@ -64,14 +63,19 @@ public void apply(VoiceCallbackEnvelope envelope) {
         }
 
         if (p.errorCode() != null && !p.errorCode().isBlank()) {
-            message.markStatus(MessageStatus.FAILED);
-            sseEventPublisher.publishToSession(p.sessionId(), SseEventType.SESSION_MESSAGE,
-                new VoiceFailedNotice(p.sessionId(), message.getId(), p.errorCode()));
+            failVoiceMessage(p.sessionId(), message, p.errorCode());
             markProcessed(envelope.messageId());
             log.warn("callback.voice STT failed. sessionId={}, msg={}, code={}",
                 p.sessionId(), message.getId(), p.errorCode());
             return;
         }
+        if (p.transcript() == null || p.transcript().isBlank()) {
+            failVoiceMessage(p.sessionId(), message, "STT_EMPTY_TRANSCRIPT");
+            markProcessed(envelope.messageId());
+            log.warn("callback.voice STT empty transcript. sessionId={}, msg={}",
+                p.sessionId(), message.getId());
+            return;
+        }
 
         message.completeWithTranscript(p.transcript());
 
@@ -113,7 +117,20 @@ public void apply(VoiceCallbackEnvelope envelope) {
     public record VoiceTranscribedNotice(Long sessionId, Long messageId, String transcript) {
     }
 
-    public record VoiceFailedNotice(Long sessionId, Long messageId, String errorCode) {
+    public record VoiceFailedNotice(Long sessionId, Long messageId, String errorCode, String fallbackText) {
+    }
+
+    private void failVoiceMessage(Long sessionId, InterviewMessage message, String errorCode) {
+        message.failVoiceTranscription();
+        VoiceFailedNotice notice = new VoiceFailedNotice(
+            sessionId,
+            message.getId(),
+            errorCode,
+            message.getContent()
+        );
+        sseEventPublisher.publishToSession(sessionId, SseEventType.SESSION_MESSAGE, notice);
+        sseEventPublisher.publishToUser(message.getSession().getUser().getId(),
+            SseEventType.SESSION_MESSAGE, notice);
     }
 
     private String fillerToJson(java.util.Map<String, Integer> map) {

backend/src/main/java/com/stackup/stackup/session/application/dto/MessageResult.java

@@ -11,6 +11,7 @@ public record MessageResult(
     Integer sequenceNumber,
     MessageRole role,
     String content,
+    String audioFilePath,
     Long parentMessageId,
     MessageStatus status,
     Instant createdAt
@@ -22,6 +23,7 @@ public static MessageResult of(InterviewMessage m) {
             m.getSequenceNumber(),
             m.getRole(),
             m.getContent(),
+            m.getAudioFilePath(),
             m.getParentMessage() == null ? null : m.getParentMessage().getId(),
             m.getStatus(),
             m.getCreatedAt()

backend/src/main/java/com/stackup/stackup/session/presentation/dto/MessageResponse.java

@@ -11,6 +11,7 @@ public record MessageResponse(
     Integer sequenceNumber,
     MessageRole role,
     String content,
+    String audioFilePath,
     Long parentMessageId,
     MessageStatus status,
     Instant createdAt
@@ -22,6 +23,7 @@ public static MessageResponse from(MessageResult r) {
             r.sequenceNumber(),
             r.role(),
             r.content(),
+            r.audioFilePath(),
             r.parentMessageId(),
             r.status(),
             r.createdAt()

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

@@ -86,6 +86,31 @@ void apply_marksMessageFailedOnErrorCode() {
         service.apply(env);
 
         assertThat(voiceMsg.getStatus()).isEqualTo(MessageStatus.FAILED);
+        assertThat(voiceMsg.getContent()).isEqualTo(InterviewMessage.VOICE_TRANSCRIPTION_FAILED_TEXT);
+        verify(voiceAnalysisRepository, never()).save(any(MessageVoiceAnalysis.class));
+        verify(events, never()).publishEvent(any(AnswerSubmittedEvent.class));
+        verify(sseEventPublisher).publishToSession(eq(50L), eq(SseEventType.SESSION_MESSAGE), any());
+        verify(sseEventPublisher).publishToUser(eq(1L), eq(SseEventType.SESSION_MESSAGE), any());
+    }
+
+    @Test
+    void apply_marksMessageFailedOnBlankTranscript() {
+        InterviewSession session = sessionFixture(50L);
+        InterviewMessage voiceMsg = InterviewMessage.voiceInterviewee(session, 2, null, null);
+        ReflectionTestUtils.setField(voiceMsg, "id", 200L);
+
+        VoiceCallbackPayload payload = new VoiceCallbackPayload(50L, 200L, " ", 120.0, 1.0,
+            Map.of(), 0.8, null);
+        VoiceCallbackEnvelope env = new VoiceCallbackEnvelope("vc-blank", "callback.voice", "1", "t",
+            null, "ai", payload, null);
+
+        when(processedMessageRepository.existsById("vc-blank")).thenReturn(false);
+        when(messageRepository.findById(200L)).thenReturn(Optional.of(voiceMsg));
+
+        service.apply(env);
+
+        assertThat(voiceMsg.getStatus()).isEqualTo(MessageStatus.FAILED);
+        assertThat(voiceMsg.getContent()).isEqualTo(InterviewMessage.VOICE_TRANSCRIPTION_FAILED_TEXT);
         verify(voiceAnalysisRepository, never()).save(any(MessageVoiceAnalysis.class));
         verify(events, never()).publishEvent(any(AnswerSubmittedEvent.class));
     }