[RELEASE] v0.1.9

.coderabbit.yml

@@ -0,0 +1,80 @@
+language: "ko-KR"
+
+tone_instructions: |
+  존댓말을 사용해주세요. 코드 리뷰는 친절하고 건설적인 어조로 작성해주세요.
+  문제점을 지적할 때는 이유와 개선 방향을 함께 제시해주세요.
+
+reviews:
+  auto_review:
+    enabled: true
+    drafts: false
+  profile: "assertive"
+  request_changes_workflow: false
+  high_level_summary: true
+  poem: false
+  review_status: true
+  collapse_walkthrough: false
+  path_filters:
+    - "!**/Q*.java"
+    - "!**/*MapperImpl.java"
+    - "!**/generated/**"
+    - "!**/.claude/**"
+    - "!**/build/**"
+    - "!**/*.md"
+
+  path_instructions:
+    - path: "BE/src/main/java/**/ui/**"
+      instructions: |
+        - Controller 네이밍: `{동사}{도메인}Controller` (예: `CreateRoomController`)
+        - Controller에 `@Transactional` 금지. 트랜잭션은 UseCase 계층에서 처리.
+        - 응답은 반드시 `BaseResponse.onSuccess(data)` 또는 `BaseResponse.onSuccess()` 사용.
+        - 인증이 필요한 엔드포인트는 `@CurrentUser` 파라미터 존재 여부 확인.
+        - 입력값 검증에 `@Valid` 적용 여부 확인.
+
+    - path: "BE/src/main/java/**/application/usecase/**"
+      instructions: |
+        - UseCase 네이밍: `{동사}{도메인}UseCase` (예: `CreateRoomUseCase`)
+        - 메서드명은 `execute()` 고정. 단, 이벤트 리스너 역할을 겸하는 경우 `handle()` 허용.
+        - 트랜잭션은 UseCase 단위에서 `@Transactional` 적용.
+        - Cross-domain 의존 시 이벤트 발행 방식 사용. 직접 도메인 서비스 호출 지양.
+        - `@TransactionalEventListener(phase = BEFORE_COMMIT)` 사용 시 부모 트랜잭션과 원자성 보장 여부 확인.
+
+    - path: "BE/src/main/java/**/domain/**"
+      instructions: |
+        - Service 네이밍: `{도메인}Service` (예: `RoomService`)
+        - 도메인 레이어는 다른 도메인에 직접 의존하면 안 됨. 이벤트/인터페이스로 분리.
+        - 엔티티 상태 변경은 도메인 메서드로 캡슐화. setter 직접 호출 지양.
+
+    - path: "BE/src/main/java/**/application/dto/**"
+      instructions: |
+        - DTO는 `record` 타입 사용.
+        - 응답 DTO 이름: `{도메인}{동작}Response` (예: `RoomDetailResponse`)
+        - 요청 DTO 이름: `{동작}{도메인}Request` (예: `CreateRoomRequest`)
+
+    - path: "BE/src/main/java/**/infra/**"
+      instructions: |
+        - infra 레이어는 domain 인터페이스 구현체.
+        - domain 레이어의 Repository 인터페이스를 구현할 때는 `Impl` 접미사 사용.
+        - QueryDSL 사용 시 Q클래스는 자동생성이므로 직접 편집 금지.
+
+    - path: "BE/src/main/java/**/global/exception/**"
+      instructions: |
+        - 에러 발생 시 `throw new RestApiException({Domain}ErrorStatus.XXX)` 형식만 사용.
+        - `RuntimeException` 직접 throw 금지.
+        - ErrorStatus enum은 해당 도메인 패키지의 `code/status/` 하위에 위치.
+
+    - path: "BE/src/main/java/**/global/alert/**"
+      instructions: |
+        - Discord 알림은 `SystemAlertPublisher.publish(...)` 통해서만 발행.
+        - CRITICAL: 즉각 대응 필요한 서비스 장애. ERROR: 기능 실패. WARN: 주의 필요. INFO: 참고 정보.
+
+    - path: "BE/src/test/**"
+      instructions: |
+        - 테스트는 성공/실패/경계값 케이스 모두 작성.
+        - UseCase 단위 테스트: `src/test/java/.../unit/usecase/`
+        - Service 단위 테스트: `src/test/java/.../unit/service/`
+        - `@Transactional` 롤백 사용 시 의도 명시.
+        - Mock 남용 지양. 도메인 로직 테스트는 실제 객체 사용 권장.
+
+chat:
+  auto_reply: true

.github/workflows/cicd.yml

@@ -33,6 +33,11 @@ jobs:
       - name: Setup Gradle cache
         uses: gradle/actions/setup-gradle@v4
 
+      - name: Ensure Docker is available (Testcontainers)
+        run: |
+          echo ">>> [CI] Checking Docker daemon..."
+          docker info
+
       - name: Run tests
         run: |
           echo ">>> [CI] Running tests..."

.gitignore

@@ -52,4 +52,8 @@ pinpoint-agent/tools/
 .claude
 
 ### env ###
-.env
+.env
+/analysis/
+
+# macOS artefacts
+.DS_Store

src/main/java/com/project/dorumdorum/domain/calendar/application/usecase/LoadCalendarEventsUseCase.java

@@ -19,6 +19,11 @@ public class LoadCalendarEventsUseCase {
     private final CalendarEventService calendarEventService;
     private final CalendarEventMapper calendarEventMapper;
 
+    /**
+     * 기간 내 캘린더 일정 조회
+     * - 시작일~종료일 범위의 일정을 조회
+     * - 응답 DTO 목록으로 변환해 반환
+     */
     public List<CalendarEventResponse> execute(LocalDate startDate, LocalDate endDate) {
         List<CalendarEvent> events = calendarEventService.loadBetween(startDate, endDate);
         return calendarEventMapper.toResponseList(events);

src/main/java/com/project/dorumdorum/domain/chat/application/dto/response/ChatMessageResponse.java

@@ -9,5 +9,6 @@ public record ChatMessageResponse(
         String senderNickname,
         String content,
         String messageType,
-        LocalDateTime sentAt
+        LocalDateTime sentAt,
+        int unreadCount
 ) {}

src/main/java/com/project/dorumdorum/domain/chat/application/dto/response/ChatReadReceiptResponse.java

@@ -0,0 +1,9 @@
+package com.project.dorumdorum.domain.chat.application.dto.response;
+
+import java.time.LocalDateTime;
+
+public record ChatReadReceiptResponse(
+        String chatRoomNo,
+        String readerUserNo,
+        LocalDateTime readAt
+) {}

src/main/java/com/project/dorumdorum/domain/chat/application/event/RoommateKickedEventListener.java

@@ -3,6 +3,7 @@
 import com.project.dorumdorum.domain.chat.application.dto.response.ChatMessageResponse;
 import com.project.dorumdorum.domain.chat.domain.entity.ChatMessage;
 import com.project.dorumdorum.domain.chat.domain.entity.ChatRoom;
+import com.project.dorumdorum.domain.chat.domain.entity.ChatRoomMember;
 import com.project.dorumdorum.domain.chat.domain.entity.MessageType;
 import com.project.dorumdorum.domain.chat.domain.service.ChatMessageService;
 import com.project.dorumdorum.domain.chat.domain.service.ChatRoomMemberService;
@@ -11,13 +12,15 @@
 import com.project.dorumdorum.domain.user.domain.entity.User;
 import com.project.dorumdorum.domain.user.domain.service.UserService;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.stereotype.Component;
-import org.springframework.transaction.annotation.Propagation;
-import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.event.TransactionPhase;
 import org.springframework.transaction.event.TransactionalEventListener;
 
+import java.time.LocalDateTime;
+
+@Slf4j
 @Component
 @RequiredArgsConstructor
 public class RoommateKickedEventListener {
@@ -31,25 +34,39 @@ public class RoommateKickedEventListener {
     /**
      * 룸메이트 강퇴(RoommateKickedEvent) → 채팅방에서 퇴장 처리
      * 발행: KickRoommateUseCase (room 도메인 담당자)
+     *
+     * BEFORE_COMMIT: 부모 트랜잭션(KickRoommateUseCase)에 참여하여 방 강퇴 + 채팅방 퇴장을 하나의 트랜잭션으로 처리.
+     * 채팅방 퇴장 실패 시 방 강퇴도 롤백되어 데이터 정합성 보장.
+     * WebSocket 브로드캐스트는 트랜잭션 외부 작업이므로 실패가 TX에 영향을 주지 않도록 독립 처리.
      */
-    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
-    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    @TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT)
     public void handle(RoommateKickedEvent event) {
         chatRoomService.findByRoomNo(event.roomNo()).ifPresent(chatRoom -> {
             if (chatRoomMemberService.isMember(chatRoom, event.kickedUserNo())) {
-                chatRoomMemberService.leave(
-                        chatRoomMemberService.findByChatRoomAndUserNo(chatRoom, event.kickedUserNo())
-                );
+                ChatRoomMember member = chatRoomMemberService.findByChatRoomAndUserNo(chatRoom, event.kickedUserNo());
+                LocalDateTime fromTime = member.getLastReadAt() != null
+                        ? member.getLastReadAt()
+                        : member.getJoinedAt();
+                chatMessageService.decreaseUnreadCount(chatRoom.getChatRoomNo(), fromTime, event.kickedUserNo());
+                chatRoomMemberService.leave(member);
                 User kicked = userService.findById(event.kickedUserNo());
                 String displayName = (kicked.getNickname() != null && !kicked.getNickname().isBlank())
                         ? kicked.getNickname() : kicked.getName();
                 String content = displayName + "가 퇴장했습니다.";
                 ChatMessage message = chatMessageService.save(chatRoom, "SYSTEM", content, MessageType.SYSTEM, 0);
                 ChatMessageResponse response = new ChatMessageResponse(
                         message.getMessageNo(), chatRoom.getChatRoomNo(),
-                        "SYSTEM", null, content, MessageType.SYSTEM.name(), message.getCreatedAt());
-                messagingTemplate.convertAndSend("/topic/chat-room/" + chatRoom.getChatRoomNo(), response);
+                        "SYSTEM", null, content, MessageType.SYSTEM.name(), message.getCreatedAt(), message.getUnreadCount());
+                broadcastSafely(chatRoom, response);
             }
         });
     }
+
+    private void broadcastSafely(ChatRoom chatRoom, ChatMessageResponse response) {
+        try {
+            messagingTemplate.convertAndSend("/topic/chat-room/" + chatRoom.getChatRoomNo(), response);
+        } catch (Exception e) {
+            log.warn("[Chat] WebSocket 브로드캐스트 실패. chatRoomNo={}", chatRoom.getChatRoomNo(), e);
+        }
+    }
 }

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/CreateChatRoomUseCase.java

@@ -5,12 +5,13 @@
 import com.project.dorumdorum.domain.chat.domain.service.ChatRoomService;
 import com.project.dorumdorum.domain.room.application.event.RoomConfirmedEvent;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.dao.DataIntegrityViolationException;
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Propagation;
-import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.event.TransactionPhase;
 import org.springframework.transaction.event.TransactionalEventListener;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class CreateChatRoomUseCase {
@@ -22,15 +23,38 @@ public class CreateChatRoomUseCase {
      * 방 전원 확정 완료(RoomConfirmedEvent) 수신 → 채팅방 생성 및 전원 입장
      * - 채팅방 없으면 생성 후 미입장 멤버 전원 입장
      * - 채팅방 있으면 아직 미입장인 멤버만 추가 (RoommateAcceptedEvent로 일부 이미 입장했을 수 있음)
+     *
+     * BEFORE_COMMIT: 부모 트랜잭션(ConfirmRoomAssignmentUseCase)에 참여.
+     * 채팅방 생성 실패 시 방 확정도 롤백 → 원자성 보장.
+     * DataIntegrityViolationException: 동시 요청으로 인한 중복 생성/입장 시 재조회로 처리.
      */
-    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
-    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    @TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT)
     public void handle(RoomConfirmedEvent event) {
-        ChatRoom chatRoom = chatRoomService.findByRoomNo(event.roomNo())
-                .orElseGet(() -> chatRoomService.create(event.roomNo()));
+        ChatRoom chatRoom = findOrCreate(event.roomNo());
 
         event.allMemberUserNos().stream()
                 .filter(userNo -> !chatRoomMemberService.isMember(chatRoom, userNo))
-                .forEach(userNo -> chatRoomMemberService.join(chatRoom, userNo));
+                .forEach(userNo -> joinSafely(chatRoom, userNo));
+    }
+
+    private ChatRoom findOrCreate(String roomNo) {
+        return chatRoomService.findByRoomNo(roomNo).orElseGet(() -> {
+            try {
+                return chatRoomService.create(roomNo);
+            } catch (DataIntegrityViolationException e) {
+                log.debug("[Chat] 채팅방 중복 생성 (동시 요청). roomNo={}", roomNo);
+                return chatRoomService.findByRoomNo(roomNo)
+                        .orElseThrow(() -> e);
+            }
+        });
+    }
+
+    private void joinSafely(ChatRoom chatRoom, String userNo) {
+        try {
+            chatRoomMemberService.join(chatRoom, userNo);
+        } catch (DataIntegrityViolationException e) {
+            log.debug("[Chat] 채팅방 중복 입장 (동시 요청). chatRoomNo={}, userNo={}",
+                    chatRoom.getChatRoomNo(), userNo);
+        }
     }
 }

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/GetChatRoomMembersUseCase.java

@@ -24,6 +24,12 @@ public class GetChatRoomMembersUseCase {
     private final RoommateService roommateService;
     private final UserService userService;
 
+    /**
+     * 채팅방 멤버 목록 조회
+     * - 요청 사용자가 채팅방 멤버인지 검증
+     * - 멤버별 닉네임과 방장 여부를 조회
+     * - 방장이 먼저 보이도록 정렬해 반환
+     */
     @Transactional(readOnly = true)
     public List<ChatRoomMemberResponse> execute(String chatRoomNo, String requestingUserNo) {
         ChatRoom chatRoom = chatRoomService.findByChatRoomNo(chatRoomNo);

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/GetOrCreateDirectChatRoomUseCase.java

@@ -23,9 +23,9 @@ public class GetOrCreateDirectChatRoomUseCase {
 
     /**
      * 지원자-방장 1:1 채팅방 조회 또는 생성
-     * - 이미 존재하면 기존 채팅방 반환
-     * - 없으면 생성 후 반환
-     * - 호출자는 방장 또는 지원자여야 함
+     * - 호출자가 방장 또는 지원자인지 검증
+     * - 기존 채팅방이 있으면 그대로 반환
+     * - 없으면 생성 후 양쪽 사용자를 입장시켜 반환
      */
     public String execute(String callerUserNo, String roomNo, String applicantUserNo) {
         Room room = roomService.findById(roomNo);
@@ -46,7 +46,10 @@ public String execute(String callerUserNo, String roomNo, String applicantUserNo
     }
 
     /**
-     * 이벤트 리스너에서 사용 — 인증 없이 채팅방 생성 (방 지원 시 자동 생성)
+     * 지원자-방장 1:1 채팅방 선생성
+     * - 이벤트 리스너에서 인증 없이 호출
+     * - 기존 채팅방이 있으면 그대로 반환
+     * - 없으면 생성 후 양쪽 사용자를 입장시켜 반환
      */
     public String createIfAbsent(String roomNo, String applicantUserNo, String hostUserNo) {
         return chatRoomService.findDirectChatRoom(roomNo, applicantUserNo)

src/main/java/com/project/dorumdorum/domain/chat/application/usecase/JoinChatRoomUseCase.java

@@ -11,13 +11,14 @@
 import com.project.dorumdorum.domain.user.domain.entity.User;
 import com.project.dorumdorum.domain.user.domain.service.UserService;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.dao.DataIntegrityViolationException;
 import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Propagation;
-import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.event.TransactionPhase;
 import org.springframework.transaction.event.TransactionalEventListener;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class JoinChatRoomUseCase {
@@ -33,28 +34,50 @@ public class JoinChatRoomUseCase {
      * - 채팅방 없으면 생성 후 방장 + 신규 멤버 입장
      * - 채팅방 있으면 신규 멤버만 입장 (중복 방지)
      * - 입장 시스템 메시지 저장
+     *
+     * BEFORE_COMMIT: 부모 트랜잭션(DecideApplicationRequestUseCase.approve)에 참여.
+     * 채팅방 입장 실패 시 룸메이트 승인도 롤백 → 원자성 보장.
+     * WebSocket 브로드캐스트는 트랜잭션 외부 작업이므로 실패가 TX에 영향을 주지 않도록 독립 처리.
      */
-    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
-    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    @TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT)
     public void handle(RoommateAcceptedEvent event) {
         ChatRoom chatRoom = chatRoomService.findByRoomNo(event.roomNo())
                 .orElseGet(() -> {
                     ChatRoom created = chatRoomService.create(event.roomNo());
-                    chatRoomMemberService.join(created, event.hostUserNo());
+                    try {
+                        chatRoomMemberService.join(created, event.hostUserNo());
+                    } catch (DataIntegrityViolationException e) {
+                        log.debug("[Chat] 방장 중복 입장 (동시 요청). roomNo={}, hostUserNo={}",
+                                event.roomNo(), event.hostUserNo());
+                    }
                     return created;
                 });
 
         if (!chatRoomMemberService.isMember(chatRoom, event.acceptedUserNo())) {
-            chatRoomMemberService.join(chatRoom, event.acceptedUserNo());
+            try {
+                chatRoomMemberService.join(chatRoom, event.acceptedUserNo());
+            } catch (DataIntegrityViolationException e) {
+                log.debug("[Chat] 신규 멤버 중복 입장 (동시 요청). roomNo={}, userNo={}",
+                        event.roomNo(), event.acceptedUserNo());
+                return;
+            }
             User accepted = userService.findById(event.acceptedUserNo());
             String displayName = (accepted.getNickname() != null && !accepted.getNickname().isBlank())
                     ? accepted.getNickname() : accepted.getName();
             String content = displayName + "가 입장했습니다.";
             ChatMessage message = chatMessageService.save(chatRoom, "SYSTEM", content, MessageType.SYSTEM, 0);
             ChatMessageResponse response = new ChatMessageResponse(
                     message.getMessageNo(), chatRoom.getChatRoomNo(),
-                    "SYSTEM", null, content, MessageType.SYSTEM.name(), message.getCreatedAt());
+                    "SYSTEM", null, content, MessageType.SYSTEM.name(), message.getCreatedAt(), message.getUnreadCount());
+            broadcastSafely(chatRoom, response);
+        }
+    }
+
+    private void broadcastSafely(ChatRoom chatRoom, ChatMessageResponse response) {
+        try {
             messagingTemplate.convertAndSend("/topic/chat-room/" + chatRoom.getChatRoomNo(), response);
+        } catch (Exception e) {
+            log.warn("[Chat] WebSocket 브로드캐스트 실패. chatRoomNo={}", chatRoom.getChatRoomNo(), e);
         }
     }
 }