Merge pull request #83 from DorumDorum/feat/#79/discord-시스템-알림-연동-및-coderabbitai-설정

[FEAT] Discord 시스템 알림 연동 및 CodeRabbit AI 설정

Author: ydking0911

.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

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

@@ -11,13 +11,13 @@
 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;
 
+@Slf4j
 @Component
 @RequiredArgsConstructor
 public class RoommateKickedEventListener {
@@ -31,9 +31,12 @@ 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())) {
@@ -48,8 +51,16 @@ public void handle(RoommateKickedEvent event) {
                 ChatMessageResponse response = new ChatMessageResponse(
                         message.getMessageNo(), chatRoom.getChatRoomNo(),
                         "SYSTEM", null, content, MessageType.SYSTEM.name(), message.getCreatedAt());
-                messagingTemplate.convertAndSend("/topic/chat-room/" + chatRoom.getChatRoomNo(), response);
+                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/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 {
@@ -29,23 +30,37 @@ public class JoinChatRoomUseCase {
     private final SimpMessagingTemplate messagingTemplate;
 
     /**
-     * 룸메이트 승인 이벤트 처리
-     * - 그룹 채팅방이 없으면 생성하고 방장을 먼저 입장
-     * - 승인된 사용자를 중복 없이 입장 처리
-     * - 입장 시스템 메시지를 저장하고 실시간 전송
+     * 방장이 룸메이트 승인(RoommateAcceptedEvent) → 채팅방 입장
+     * - 채팅방 없으면 생성 후 방장 + 신규 멤버 입장
+     * - 채팅방 있으면 신규 멤버만 입장 (중복 방지)
+     * - 입장 시스템 메시지 저장
+     *
+     * 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();
@@ -54,7 +69,15 @@ public void handle(RoommateAcceptedEvent event) {
             ChatMessageResponse response = new ChatMessageResponse(
                     message.getMessageNo(), chatRoom.getChatRoomNo(),
                     "SYSTEM", null, content, MessageType.SYSTEM.name(), message.getCreatedAt());
+            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/global/alert/AlertDeduplicationService.java

@@ -0,0 +1,45 @@
+package com.project.dorumdorum.global.alert;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Service;
+
+import java.time.Duration;
+
+/**
+ * 동일한 알림이 짧은 시간 내에 반복 발송되는 것을 방지하는 서비스.
+ * Redis TTL 기반으로 중복 여부를 판단한다.
+ */
+@Service
+@RequiredArgsConstructor
+public class AlertDeduplicationService {
+
+    private static final String KEY_PREFIX = "alert:dedup:";
+
+    private final StringRedisTemplate redisTemplate;
+
+    /**
+     * 해당 알림이 중복인지 확인하고, 중복이 아니면 TTL을 설정한다.
+     *
+     * @return true이면 중복 — 발송 건너뜀. false이면 신규 — 발송 진행.
+     */
+    public boolean isDuplicate(SystemAlert alert) {
+        String key = buildKey(alert);
+        Duration ttl = resolveTtl(alert.severity());
+        Boolean isNew = redisTemplate.opsForValue().setIfAbsent(key, "1", ttl);
+        return !Boolean.TRUE.equals(isNew);
+    }
+
+    private String buildKey(SystemAlert alert) {
+        return KEY_PREFIX + alert.severity() + ":" + Math.abs(alert.title().hashCode());
+    }
+
+    private Duration resolveTtl(AlertSeverity severity) {
+        return switch (severity) {
+            case CRITICAL -> Duration.ofSeconds(60);
+            case ERROR    -> Duration.ofSeconds(300);
+            case WARN     -> Duration.ofSeconds(900);
+            case INFO     -> Duration.ofSeconds(1800);
+        };
+    }
+}

src/main/java/com/project/dorumdorum/global/alert/ApplicationLifecycleAlertListener.java

@@ -0,0 +1,34 @@
+package com.project.dorumdorum.global.alert;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.event.ContextClosedEvent;
+import org.springframework.context.event.EventListener;
+import org.springframework.boot.context.event.ApplicationReadyEvent;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class ApplicationLifecycleAlertListener {
+
+    private final SystemAlertPublisher systemAlertPublisher;
+
+    @EventListener(ApplicationReadyEvent.class)
+    public void onApplicationReady() {
+        systemAlertPublisher.publish(
+                AlertSeverity.INFO,
+                AlertType.DEPLOYMENT,
+                "[배포] 서버 시작 완료",
+                "dorumdorum 서버가 정상 시작되었습니다."
+        );
+    }
+
+    @EventListener(ContextClosedEvent.class)
+    public void onContextClosed() {
+        systemAlertPublisher.publish(
+                AlertSeverity.WARN,
+                AlertType.DEPLOYMENT,
+                "[배포] 서버 종료",
+                "dorumdorum 서버가 종료되고 있습니다."
+        );
+    }
+}

src/main/java/com/project/dorumdorum/global/alert/DiscordAlertEventListener.java

@@ -1,11 +1,13 @@
 package com.project.dorumdorum.global.alert;
 
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.event.TransactionPhase;
 import org.springframework.transaction.event.TransactionalEventListener;
 
+@Slf4j
 @Component
 @RequiredArgsConstructor
 public class DiscordAlertEventListener {
@@ -18,6 +20,10 @@ public class DiscordAlertEventListener {
             fallbackExecution = true
     )
     public void handle(SystemAlertEvent event) {
-        discordAlertSender.send(event.alert());
+        try {
+            discordAlertSender.send(event.alert());
+        } catch (Exception e) {
+            log.error("[Alert] Discord 전송 실패 (Async). title={}", event.alert().title(), e);
+        }
     }
 }