[Feat] 댓글 수정 삭제 SSE 이벤트 반영

Author: issuejong

backend/src/main/java/com/example/Piroin/project/domain/question/dto/QuestionResDTO.java

@@ -197,6 +197,17 @@ public record CommentCreatedEvent(
     ) {
     }
 
+    // 댓글 수정/삭제 시 SSE로 내려가는 목록 갱신 이벤트 응답
+    public record CommentUpdatedEvent(
+            String type,
+            Long sessionId,
+            Long questionId,
+            Boolean isResolved,
+            Integer commentCount,
+            List<PreviewCommentResponse> previewComments
+    ) {
+    }
+
     // O/X 클릭 직후 응답. selectedChoice가 null이면 같은 선택지를 다시 눌러 취소된 상태다.
     public record UnderstandingResponseResult(
             Long checkId,

backend/src/main/java/com/example/Piroin/project/domain/question/service/QuestionEventService.java

@@ -45,6 +45,11 @@ public void publishCommentCreated(Long sessionId, QuestionResDTO.CommentCreatedE
         broadcast(sessionId, "comment-created", event);
     }
 
+    // 댓글 수정/삭제 이벤트를 같은 세션 질문방을 구독 중인 모든 클라이언트에게 전파한다.
+    public void publishCommentUpdated(Long sessionId, QuestionResDTO.CommentUpdatedEvent event) {
+        broadcast(sessionId, "comment-updated", event);
+    }
+
     // 질문 등록 이벤트를 같은 세션 질문방을 구독 중인 모든 클라이언트에게 전파한다.
     public void publishQuestionCreated(Long sessionId, QuestionResDTO.QuestionCreatedEvent event) {
         broadcast(sessionId, "question-created", event);

backend/src/main/java/com/example/Piroin/project/domain/question/service/QuestionService.java

@@ -354,6 +354,8 @@ public QuestionResDTO.CommentUpdateDeleteRes updateComment(
 
         comment.updateContent(request.getContent());
 
+        publishCommentUpdatedEventAfterCommit(comment.getQuestion());
+
         return new QuestionResDTO.CommentUpdateDeleteRes(
                 comment.getId(), comment.getContent(),
                 comment.getUpdatedAt(), comment.getDeletedAt()
@@ -369,6 +371,8 @@ public QuestionResDTO.CommentUpdateDeleteRes deleteComment(Long commentId, Long
 
         comment.softDelete();
 
+        publishCommentUpdatedEventAfterCommit(comment.getQuestion());
+
         return new QuestionResDTO.CommentUpdateDeleteRes(
                 comment.getId(), comment.getContent(),
                 comment.getUpdatedAt(), comment.getDeletedAt()
@@ -751,6 +755,32 @@ private void publishCommentCreatedEventAfterCommit(Question question) {
         publishAfterCommit(() -> questionEventService.publishCommentCreated(sessionId, event));
     }
 
+    private void publishCommentUpdatedEventAfterCommit(Question question) {
+        Long sessionId = question.getSession().getId();
+        Long questionId = question.getId();
+        List<Long> questionIds = List.of(questionId);
+
+        Map<Long, Integer> commentCounts = new HashMap<>();
+        questionCommentRepository.countByQuestionIds(questionIds)
+                .forEach(row -> commentCounts.put(row.getQuestionId(), Math.toIntExact(row.getCommentCount())));
+
+        Map<Long, List<QuestionResDTO.PreviewCommentResponse>> previewComments = new HashMap<>();
+        questionCommentRepository.findPreviewCommentsByQuestionIds(questionIds)
+                .forEach(row -> previewComments.computeIfAbsent(row.getQuestionId(), key -> new ArrayList<>())
+                        .add(toPreviewCommentResponse(question, row)));
+
+        QuestionResDTO.CommentUpdatedEvent event = new QuestionResDTO.CommentUpdatedEvent(
+                "COMMENT_UPDATED",
+                sessionId,
+                questionId,
+                question.getIsResolved(),
+                commentCounts.getOrDefault(questionId, 0),
+                previewComments.getOrDefault(questionId, List.of())
+        );
+
+        publishAfterCommit(() -> questionEventService.publishCommentUpdated(sessionId, event));
+    }
+
     private void publishQuestionCreatedEventAfterCommit(Question question) {
         Long sessionId = question.getSession().getId();
 

frontend/src/pages/qna/QnADetailPage.js

@@ -135,7 +135,7 @@ function QnADetailPage() {
             return;
         }
 
-        if (message.event === 'comment-created') {
+        if (message.event === 'comment-created' || message.event === 'comment-updated') {
             void fetchQuestion();
             return;
         }

frontend/src/pages/qna/QnAListPage.js

@@ -386,6 +386,9 @@ function QnAListPage() {
             case 'comment-created':
                 handleCommentCreatedEvent(data);
                 break;
+            case 'comment-updated':
+                handleCommentCreatedEvent(data);
+                break;
             case 'question-created':
                 void handleQuestionCreatedEvent(data);
                 break;