MAIN 머지 PR

backend/build.gradle

@@ -41,6 +41,9 @@ dependencies {
 	implementation 'org.flywaydb:flyway-core'
 	implementation 'org.flywaydb:flyway-database-postgresql'
 
+	// Validation
+	implementation 'org.springframework.boot:spring-boot-starter-validation'
+
 	// Spring Security
 	implementation 'org.springframework.boot:spring-boot-starter-security'
 

backend/src/main/java/com/example/Piroin/project/domain/curriculum/controller/CurriculumController.java

@@ -3,6 +3,7 @@
 import com.example.Piroin.project.domain.curriculum.dto.CurriculumReqDTO;
 import com.example.Piroin.project.domain.curriculum.dto.CurriculumResDTO;
 import com.example.Piroin.project.domain.curriculum.service.CurriculumService;
+import jakarta.validation.Valid;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
@@ -26,14 +27,14 @@ public ResponseEntity<List<CurriculumResDTO.CreateDayRes>> getAllDays() {
 
     @PostMapping
     public ResponseEntity<CurriculumResDTO.CreateDayRes> createDay(
-            @RequestBody CurriculumReqDTO.CreateDayReq req) {
+            @RequestBody @Valid CurriculumReqDTO.CreateDayReq req) {
         return ResponseEntity.status(HttpStatus.CREATED).body(curriculumService.createDay(req));
     }
 
     @PatchMapping("/{sessionDate}")
     public ResponseEntity<CurriculumResDTO.CreateDayRes> updateDay(
             @PathVariable LocalDate sessionDate,
-            @RequestBody CurriculumReqDTO.UpdateDayReq req) {
+            @RequestBody @Valid CurriculumReqDTO.UpdateDayReq req) {
         return ResponseEntity.ok(curriculumService.updateDay(sessionDate, req));
     }
 

backend/src/main/java/com/example/Piroin/project/domain/curriculum/dto/CurriculumReqDTO.java

@@ -2,6 +2,9 @@
 
 import com.example.Piroin.project.domain.curriculum.enums.SessionDayPart;
 import com.example.Piroin.project.domain.curriculum.enums.SessionStatus;
+import jakarta.validation.Valid;
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 
@@ -13,18 +16,32 @@ public class CurriculumReqDTO {
     @Getter
     @NoArgsConstructor
     public static class CreateDayReq {
+        @NotNull(message = "기수를 입력해주세요.")
         private Integer generation;
+
+        @NotNull(message = "주차를 입력해주세요.")
         private Long week;
+
+        @NotNull(message = "세션 날짜를 입력해주세요.")
         private LocalDate sessionDate;
+
+        @NotEmpty(message = "세션 목록을 입력해주세요.")
+        @Valid
         private List<SessionReq> sessions;
     }
 
     @Getter
     @NoArgsConstructor
     public static class SessionReq {
+        @NotNull(message = "세션 시간대를 입력해주세요.")
         private SessionDayPart dayPart;
+
+        @NotNull(message = "세션 제목을 입력해주세요.")
         private String title;
+
+        @NotNull(message = "발표자를 입력해주세요.")
         private String hostName;
+
         private String sessionMaterialUrl;
         private String sessionMaterialName;
         private String recordingUrl;
@@ -37,16 +54,25 @@ public static class SessionReq {
     @Getter
     @NoArgsConstructor
     public static class UpdateDayReq {
+        @NotNull(message = "기수를 입력해주세요.")
         private Integer generation;
+
+        @NotNull(message = "주차를 입력해주세요.")
         private Long week;
+
         private LocalDate newSessionDate;
+
+        @NotEmpty(message = "세션 목록을 입력해주세요.")
+        @Valid
         private List<UpdateSessionItemReq> sessions;
     }
 
     @Getter
     @NoArgsConstructor
     public static class UpdateSessionItemReq {
+        @NotNull(message = "세션 시간대를 입력해주세요.")
         private SessionDayPart dayPart;
+
         private SessionStatus status;
         private String title;
         private String hostName;

backend/src/main/java/com/example/Piroin/project/domain/question/controller/QuestionController.java

@@ -35,8 +35,12 @@ public ResponseEntity<ApiResponse<QuestionResDTO.QuestionRoomResponse>> getQuest
     // text/event-stream으로 연결을 유지하며, 댓글 생성 같은 목록 갱신 이벤트를 받는다.
     // 인증 헤더가 필요하므로 프론트에서는 기본 EventSource 대신 fetch 기반 SSE 클라이언트로 구독한다.
     @GetMapping(value = "/api/sessions/{sessionId}/questions/events", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
-    public SseEmitter subscribeQuestionEvents(@PathVariable Long sessionId) {
-        return questionService.subscribeQuestionEvents(sessionId);
+    public ResponseEntity<SseEmitter> subscribeQuestionEvents(@PathVariable Long sessionId) {
+        return ResponseEntity.ok()
+                .contentType(MediaType.TEXT_EVENT_STREAM)
+                .header("Cache-Control", "no-cache")
+                .header("X-Accel-Buffering", "no")
+                .body(questionService.subscribeQuestionEvents(sessionId));
     }
 
     // 질문 상세 조회

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

@@ -145,6 +145,8 @@ public record UnderstandingCheckResponse(
             Integer understoodCount,
             // 오른쪽 X 뱃지 숫자
             Integer notUnderstoodCount,
+            // 현재 로그인 유저가 누른 선택지. 누르지 않았거나 취소한 상태면 null
+            UnderstandResChoice selectedChoice,
             LocalDateTime createdAt
     ) {
     }
@@ -195,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,
@@ -241,6 +254,19 @@ public record QuestionCreatedEvent(
     ) {
     }
 
+    // 좋아요, 해결 상태, 본문 수정, 삭제처럼 기존 질문의 상태가 바뀔 때 내려가는 SSE 이벤트
+    public record QuestionUpdatedEvent(
+            String type,
+            Long sessionId,
+            Long questionId,
+            String content,
+            Boolean isResolved,
+            Integer likeCount,
+            Boolean isDeleted,
+            LocalDateTime updatedAt
+    ) {
+    }
+
     // 운영진이 이해도 체크를 생성했을 때 SSE로 내려가는 이벤트.
     // 같은 세션 질문방을 보고 있는 모든 클라이언트에게 전파된다.
     public record UnderstandingCheckCreatedEvent(

backend/src/main/java/com/example/Piroin/project/domain/question/entity/Question.java

@@ -27,7 +27,7 @@ public class Question {
     @JoinColumn(name = "user_id", nullable = false)
     private User user;
 
-    @Column(nullable = false, columnDefinition = "TEXT")
+    @Column(columnDefinition = "TEXT")
     private String content;
 
     @Column(name = "image_url", columnDefinition = "TEXT")

backend/src/main/java/com/example/Piroin/project/domain/question/entity/QuestionComment.java

@@ -36,7 +36,7 @@ public class QuestionComment {
     @JoinColumn(name = "parent_comment_id")
     private QuestionComment parentComment;
 
-    @Column(nullable = false, columnDefinition = "TEXT")
+    @Column(columnDefinition = "TEXT")
     private String content;
 
     @Column(name = "image_url", columnDefinition = "TEXT")

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

@@ -45,11 +45,21 @@ 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);
     }
 
+    // 질문 상태 변경 이벤트를 같은 세션 질문방을 구독 중인 모든 클라이언트에게 전파한다.
+    public void publishQuestionUpdated(Long sessionId, QuestionResDTO.QuestionUpdatedEvent event) {
+        broadcast(sessionId, "question-updated", event);
+    }
+
     // 이해도 체크 생성 이벤트를 같은 세션 질문방을 구독 중인 모든 클라이언트에게 전파한다.
     public void publishUnderstandingCheckCreated(Long sessionId, QuestionResDTO.UnderstandingCheckCreatedEvent event) {
         broadcast(sessionId, "understanding-check-created", event);