-
Notifications
You must be signed in to change notification settings - Fork 3
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Feature/#29 채팅 관련 로직 구현 #183
Merged
Merged
Changes from 1 commit
Commits
Show all changes
15 commits
Select commit
Hold shift + click to select a range
8fa3862
Feat: 채팅방 및 관련기능, 채팅 메세지 전송을 위한 웹소켓 설정
runtime-zer0 63714f3
Feat: 채팅방 관련 로직을 구현을 위한 레포지토리 및 DTO 구현
runtime-zer0 ee55eae
Feat: 채팅방에 참여한 사용자 정보 관리 로직 구현을 위한 레포지토리 및 DTO 구현
runtime-zer0 51fc1f9
Feat: 채팅 메세지 발행 및 전송, 메세지 수신 구현을 위한 레포지토리 및 DTO 구현
runtime-zer0 d0dee9a
Feat: 채팅방 입장, 퇴장 관련 로직을 구현하기 위한 비즈니스 로직 구현
runtime-zer0 ec84270
Feat: 메세지 발행 및 전송, 수신 관련 로직을 구현하기 위한 비즈니스 로직 및 유틸 클래스 구현
runtime-zer0 8392c8e
Feat: 채팅방 입장/퇴장 요청을 캐치하기 위한 컨트롤러 구현
runtime-zer0 8df6cef
Feat: 채팅 메세지 발행 및 전송, 채팅방 메세지 조회 요청을 캐치하기 위한 컨트롤러 구현
runtime-zer0 4686033
Feat: 채팅방 정보와 연관된 모집글 요약 정보 조희를 위한 로직 및 DTO 구현
runtime-zer0 c447551
Feat: 채팅방 입장/퇴장시 발생할 수 있는 예외 클래스 및 예외 핸들러 구현
runtime-zer0 84dafca
Feat: 채팅방에 입장한 사용자 관련 정보 관리시 발생할 수 있는 예외 클래스 및 예외 핸들러 구현
runtime-zer0 9db6afe
Feat: 채팅 메세지 발행 및 전송시 발생할 수 있는 예외 클래스 및 예외 핸들러 구현
runtime-zer0 b6cfb5d
Refactor: 클래스 이름 변경으로 인한 리팩토링 및 필드 이름 수정
runtime-zer0 7ac0dee
Refactor: 스프링의 단일 책임 원칙을 위한 리팩토링
runtime-zer0 42ff90c
Merge branch 'main' into feature/#29
runtime-zer0 File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
There are no files selected for viewing
122 changes: 122 additions & 0 deletions
122
src/main/java/sumcoda/boardbuddy/service/ChatRoomService.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,122 @@ | ||
package sumcoda.boardbuddy.service; | ||
|
||
import lombok.RequiredArgsConstructor; | ||
import org.springframework.stereotype.Service; | ||
import org.springframework.transaction.annotation.Transactional; | ||
import sumcoda.boardbuddy.dto.ChatRoomResponse; | ||
import sumcoda.boardbuddy.dto.MemberChatRoomResponse; | ||
import sumcoda.boardbuddy.entity.ChatRoom; | ||
import sumcoda.boardbuddy.entity.Member; | ||
import sumcoda.boardbuddy.entity.MemberChatRoom; | ||
import sumcoda.boardbuddy.enumerate.MemberChatRoomRole; | ||
import sumcoda.boardbuddy.exception.*; | ||
import sumcoda.boardbuddy.exception.member.MemberNotFoundException; | ||
import sumcoda.boardbuddy.exception.member.MemberRetrievalException; | ||
import sumcoda.boardbuddy.repository.chatRoom.ChatRoomRepository; | ||
import sumcoda.boardbuddy.repository.memberChatRoom.MemberChatRoomRepository; | ||
import sumcoda.boardbuddy.repository.MemberRepository; | ||
|
||
import java.time.LocalDateTime; | ||
import java.util.List; | ||
|
||
@Service | ||
@RequiredArgsConstructor | ||
@Transactional(readOnly = true) | ||
public class ChatRoomService { | ||
|
||
private final ChatRoomRepository chatRoomRepository; | ||
|
||
private final MemberChatRoomRepository memberChatRoomRepository; | ||
|
||
private final MemberRepository memberRepository; | ||
|
||
/** | ||
* 사용자가 특정 모집글과 관련된 채팅방에 입장 | ||
* | ||
* @param gatherArticleId 모집글 Id | ||
* @param nickname 사용자 닉네임 | ||
**/ | ||
@Transactional | ||
public Long enterChatRoom(Long gatherArticleId, String nickname) { | ||
ChatRoom chatRoom = chatRoomRepository.findByGatherArticleId(gatherArticleId) | ||
.orElseThrow(() -> new ChatRoomNotFoundException("해당 모집글에 대한 채팅방이 존재하지 않습니다.")); | ||
|
||
Long chatRoomId = chatRoom.getId(); | ||
|
||
if (chatRoomId == null) { | ||
throw new ChatRoomRetrievalException("서버 문제로 해당 채팅방의 정보를 찾을 수 없습니다. 관리자에게 문의하세요."); | ||
} | ||
|
||
Member member = memberRepository.findByNickname(nickname) | ||
.orElseThrow(() -> new MemberNotFoundException("해당 사용자를 찾을 수 없습니다.")); | ||
|
||
Boolean isMemberChatRoomExists = memberChatRoomRepository.existsByGatherArticleIdAndNickname(gatherArticleId, nickname); | ||
if (isMemberChatRoomExists) { | ||
throw new AlreadyEnteredChatRoomException("해당 채팅방은 이미 입장한 채팅방입니다."); | ||
} | ||
|
||
MemberChatRoom memberChatRoom = MemberChatRoom.buildMemberChatRoom(LocalDateTime.now(), MemberChatRoomRole.PARTICIPANT, member, chatRoom); | ||
|
||
Long memberChatRoomId = memberChatRoomRepository.save(memberChatRoom).getId(); | ||
|
||
if (memberChatRoomId == null) { | ||
throw new MemberChatRoomSaveException("서버 문제로 채팅방 관련 사용자의 정보를 저장하지 못했습니다. 관리자에게 문의하세요."); | ||
} | ||
|
||
return chatRoomId; | ||
} | ||
|
||
/** | ||
* 사용자가 특정 모집글과 관련된 채팅방에서 퇴장 | ||
* | ||
* @param gatherArticleId 모집글 Id | ||
* @param username 사용자 아이디 | ||
**/ | ||
@Transactional | ||
public Long leaveChatRoom(Long gatherArticleId, String username) { | ||
ChatRoomResponse.ValidateDTO chatRoomValidateDTO = chatRoomRepository.findValidateDTOByGatherArticleId(gatherArticleId) | ||
.orElseThrow(() -> new ChatRoomNotFoundException("해당 모집글에 대한 채팅방이 존재하지 않습니다")); | ||
|
||
Long chatRoomId = chatRoomValidateDTO.getId(); | ||
if (chatRoomId == null) { | ||
throw new ChatRoomRetrievalException("서버문제로 해당 모집글에 대한 채팅방 정보를 찾을 수 없습니다. 관리자에게 문의하세요."); | ||
} | ||
|
||
MemberChatRoomResponse.ValidateDTO memberChatRoomValidateDTO = memberChatRoomRepository.findByGatherArticleIdAndUsername(gatherArticleId, username) | ||
.orElseThrow(() -> new MemberChatRoomNotFoundException("채팅방 관련 사용자의 정보를 찾을 수 없습니다.")); | ||
|
||
MemberChatRoomRole memberChatRoomRole = memberChatRoomValidateDTO.getMemberChatRoomRole(); | ||
if (memberChatRoomRole == null) { | ||
throw new MemberChatRoomRetrievalException("서버 문제로 채팅방 관련 사용자의 정보를 찾을 수 없습니다. 관리자에게 문의하세요."); | ||
} | ||
|
||
if (memberChatRoomValidateDTO.getMemberChatRoomRole() == MemberChatRoomRole.HOST) { | ||
throw new ChatRoomHostCannotLeaveException("채팅방의 방장은 채팅방을 퇴장할 수 없습니다."); | ||
} | ||
|
||
Long memberChatRoomId = memberChatRoomValidateDTO.getId(); | ||
|
||
if (memberChatRoomId == null) { | ||
throw new MemberChatRoomRetrievalException("서버 문제로 채팅방 관련 사용자의 정보를 찾을 수 없습니다. 관리자에게 문의하세요."); | ||
} | ||
|
||
memberChatRoomRepository.deleteById(memberChatRoomId); | ||
|
||
return chatRoomId; | ||
} | ||
|
||
/** | ||
* 특정 사용자가 참여하고 있는 채팅방 상세 정보 목록 조회 | ||
* | ||
* @param username 사용자 아이디 | ||
* @return 사용자가 참여하고 있는 채팅방 상세 정보 목록 | ||
**/ | ||
public List<ChatRoomResponse.ChatRoomDetailsDTO> getChatRoomDetailsListByUsername(String username) { | ||
Boolean isMemberExists = memberRepository.existsByUsername(username); | ||
if (!isMemberExists) { | ||
throw new MemberRetrievalException("서버 문제로 사용자의 정보를 찾을 수 없습니다. 관리자에게 문의하세요."); | ||
} | ||
|
||
return chatRoomRepository.findChatRoomDetailsListByUsername(username); | ||
} | ||
} |
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ChatRoom을 조회하는 시점에 ChatRoom 엔티티가 있는지 확인하고 있으므로 밑에 있는 chatRommId == null 을 검증하는 이미 앞선 로직에서 확인이 된다고 생각이 됩니다. 리팩토링 때 고려해주시면 감사하겠습니다!
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
확인했습니다.