diff --git a/src/main/kotlin/kr/co/vividnext/sodalive/chat/room/repository/ChatRoomRepository.kt b/src/main/kotlin/kr/co/vividnext/sodalive/chat/room/repository/ChatRoomRepository.kt index f161cd8..a5f3d6c 100644 --- a/src/main/kotlin/kr/co/vividnext/sodalive/chat/room/repository/ChatRoomRepository.kt +++ b/src/main/kotlin/kr/co/vividnext/sodalive/chat/room/repository/ChatRoomRepository.kt @@ -62,4 +62,6 @@ interface ChatRoomRepository : JpaRepository { @Param("member") member: Member, pageable: Pageable ): List + + fun findByIdAndIsActiveTrue(id: Long): ChatRoom? } diff --git a/src/main/kotlin/kr/co/vividnext/sodalive/chat/room/service/ChatRoomService.kt b/src/main/kotlin/kr/co/vividnext/sodalive/chat/room/service/ChatRoomService.kt index 8458fdb..975310b 100644 --- a/src/main/kotlin/kr/co/vividnext/sodalive/chat/room/service/ChatRoomService.kt +++ b/src/main/kotlin/kr/co/vividnext/sodalive/chat/room/service/ChatRoomService.kt @@ -69,9 +69,8 @@ class ChatRoomService( @Transactional fun purchaseMessage(member: Member, chatRoomId: Long, messageId: Long, container: String): ChatMessageItemDto { - val room = chatRoomRepository.findById(chatRoomId).orElseThrow { - SodaException("채팅방을 찾을 수 없습니다.") - } + val room = chatRoomRepository.findByIdAndIsActiveTrue(chatRoomId) + ?: throw SodaException("채팅방을 찾을 수 없습니다.") // 참여 여부 검증 participantRepository.findByChatRoomAndMemberAndIsActiveTrue(room, member) ?: throw SodaException("잘못된 접근입니다") @@ -288,9 +287,8 @@ class ChatRoomService( @Transactional(readOnly = true) fun isMyRoomSessionActive(member: Member, chatRoomId: Long): Boolean { - val room = chatRoomRepository.findById(chatRoomId).orElseThrow { - SodaException("채팅방을 찾을 수 없습니다.") - } + val room = chatRoomRepository.findByIdAndIsActiveTrue(chatRoomId) + ?: throw SodaException("채팅방을 찾을 수 없습니다.") val participant = participantRepository.findByChatRoomAndMemberAndIsActiveTrue(room, member) if (participant == null) { throw SodaException("잘못된 접근입니다") @@ -300,9 +298,8 @@ class ChatRoomService( @Transactional fun enterChatRoom(member: Member, chatRoomId: Long, characterImageId: Long? = null): ChatRoomEnterResponse { - val room = chatRoomRepository.findById(chatRoomId).orElseThrow { - SodaException("채팅방을 찾을 수 없습니다.") - } + val room = chatRoomRepository.findByIdAndIsActiveTrue(chatRoomId) + ?: throw SodaException("채팅방을 찾을 수 없습니다.") // 참여 여부 검증 participantRepository.findByChatRoomAndMemberAndIsActiveTrue(room, member) ?: throw SodaException("잘못된 접근입니다") @@ -424,9 +421,8 @@ class ChatRoomService( @Transactional fun leaveChatRoom(member: Member, chatRoomId: Long, throwOnSessionEndFailure: Boolean = false) { - val room = chatRoomRepository.findById(chatRoomId).orElseThrow { - SodaException("채팅방을 찾을 수 없습니다.") - } + val room = chatRoomRepository.findByIdAndIsActiveTrue(chatRoomId) + ?: throw SodaException("채팅방을 찾을 수 없습니다.") val participant = participantRepository.findByChatRoomAndMemberAndIsActiveTrue(room, member) ?: throw SodaException("잘못된 접근입니다") @@ -503,9 +499,8 @@ class ChatRoomService( @Transactional(readOnly = true) fun getChatMessages(member: Member, chatRoomId: Long, cursor: Long?, limit: Int = 20): ChatMessagesPageResponse { - val room = chatRoomRepository.findById(chatRoomId).orElseThrow { - SodaException("채팅방을 찾을 수 없습니다.") - } + val room = chatRoomRepository.findByIdAndIsActiveTrue(chatRoomId) + ?: throw SodaException("채팅방을 찾을 수 없습니다.") participantRepository.findByChatRoomAndMemberAndIsActiveTrue(room, member) ?: throw SodaException("잘못된 접근입니다") @@ -539,9 +534,8 @@ class ChatRoomService( @Transactional fun sendMessage(member: Member, chatRoomId: Long, message: String): SendChatMessageResponse { // 1) 방 존재 확인 - val room = chatRoomRepository.findById(chatRoomId).orElseThrow { - SodaException("채팅방을 찾을 수 없습니다.") - } + val room = chatRoomRepository.findByIdAndIsActiveTrue(chatRoomId) + ?: throw SodaException("채팅방을 찾을 수 없습니다.") // 2) 참여 여부 확인 (USER) val myParticipant = participantRepository.findByChatRoomAndMemberAndIsActiveTrue(room, member) ?: throw SodaException("잘못된 접근입니다") @@ -786,9 +780,8 @@ class ChatRoomService( @Transactional fun resetChatRoom(member: Member, chatRoomId: Long, container: String): CreateChatRoomResponse { // 0) 방 존재 및 내 참여 여부 확인 - val room = chatRoomRepository.findById(chatRoomId).orElseThrow { - SodaException("채팅방을 찾을 수 없습니다.") - } + val room = chatRoomRepository.findByIdAndIsActiveTrue(chatRoomId) + ?: throw SodaException("채팅방을 찾을 수 없습니다.") participantRepository.findByChatRoomAndMemberAndIsActiveTrue(room, member) ?: throw SodaException("잘못된 접근입니다")