Feat : 스터디룸 탈퇴 API 구현

src/main/java/com/linkode/api_server/common/exception/LeaveStudyroomExeption.java

@@ -0,0 +1,20 @@
+package com.linkode.api_server.common.exception;
+
+import com.linkode.api_server.common.response.status.ResponseStatus;
+import lombok.Getter;
+
+@Getter
+public class LeaveStudyroomExeption  extends RuntimeException{
+
+    private final ResponseStatus exceptionStatus;
+
+    public LeaveStudyroomExeption(ResponseStatus exceptionStatus) {
+        super(exceptionStatus.getMessage());
+        this.exceptionStatus = exceptionStatus;
+    }
+
+    public LeaveStudyroomExeption(ResponseStatus exceptionStatus, String message) {
+        super(message);
+        this.exceptionStatus = exceptionStatus;
+    }
+}

src/main/java/com/linkode/api_server/common/response/status/BaseExceptionResponseStatus.java

@@ -31,6 +31,8 @@ public enum BaseExceptionResponseStatus implements ResponseStatus{
      */
     NOT_FOUND_MEMBER_STUDYROOM(6000, HttpStatus.OK.value(), "조건에 맞는 멤버_스터디룸을 찾을 수 없습니다."),
     NOT_FOUND_CREW(6001, HttpStatus.OK.value(), "해당 스터디룸의 CREW 를 찾을 수 없습니다."),
+    CANNOT_LEAVE_STUDYROOM(6002, HttpStatus.OK.value(), "방장은 탈퇴할 수 없습니다."),
+
 
     /**
      * color 관련 code : 7000대

src/main/java/com/linkode/api_server/controller/StudyroomController.java

@@ -2,10 +2,7 @@
 
 import com.linkode.api_server.common.response.BaseResponse;
 import com.linkode.api_server.common.response.status.BaseExceptionResponseStatus;
-import com.linkode.api_server.dto.studyroom.CreateStudyroomRequest;
-import com.linkode.api_server.dto.studyroom.CreateStudyroomResponse;
-import com.linkode.api_server.dto.studyroom.DetailStudyroomResponse;
-import com.linkode.api_server.dto.studyroom.PatchStudyroomRequest;
+import com.linkode.api_server.dto.studyroom.*;
 import com.linkode.api_server.service.MemberStudyroomService;
 import com.linkode.api_server.service.StudyroomService;
 import com.linkode.api_server.util.JwtProvider;
@@ -27,6 +24,9 @@ public class StudyroomController {
     @Autowired
     JwtProvider jwtProvider;
 
+    /**
+     * 스터디룸 삭제
+     */
     @PatchMapping("/removal")
     public BaseResponse<BaseExceptionResponseStatus> deleteStudyroom(@RequestHeader("Authorization") String authorization, @RequestParam long studyroomId){
 
@@ -37,7 +37,21 @@ public BaseResponse<BaseExceptionResponseStatus> deleteStudyroom(@RequestHeader(
             return new BaseResponse<>(responseStatus);
         } else {
             return new BaseResponse<>(responseStatus, responseStatus);
-        }    }
+        }
+    }
+
+    /**
+     * 스터디룸 탈퇴
+     * */
+    @PatchMapping("/leave")
+    public BaseResponse<MemberStudyroomListResponse> leaveStudyroom(@RequestHeader("Authorization") String authorization, @RequestParam long studyroomId){
+
+        long memberId = jwtProvider.extractIdFromHeader(authorization);
+        BaseExceptionResponseStatus responseStatus = memberStudyroomService.leaveStudyroom(studyroomId,memberId);
+        MemberStudyroomListResponse latestStudyroomList = memberStudyroomService.getMemberStudyroomList(memberId);
+        log.info("Run leaveStudyroom API ");
+        return new BaseResponse<>(responseStatus,latestStudyroomList);
+    }
 
     @PostMapping("/generation")
     public CreateStudyroomResponse createStudyroom(@RequestHeader("Authorization") String authorization,  @RequestBody CreateStudyroomRequest request){

src/main/java/com/linkode/api_server/dto/studyroom/MemberStudyroomListResponse.java

@@ -0,0 +1,23 @@
+package com.linkode.api_server.dto.studyroom;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.util.List;
+
+@Getter @Setter
+@AllArgsConstructor
+@NoArgsConstructor
+public class MemberStudyroomListResponse {
+
+    private List<MemberStudyroomListResponse.Studyroom> studyroomList;
+
+    @Getter @Setter
+    @AllArgsConstructor
+    public static class Studyroom{
+        Long studyroomId;
+        String studyroomProfile;
+    }
+}

src/main/java/com/linkode/api_server/handler/SignalingHandler.java

@@ -36,7 +36,7 @@ public void afterConnectionEstablished(WebSocketSession session) throws Exceptio
             log.info("WebSocket connection established for studyroomId: {}, userId: {}", studyroomId, userId);
 
             studyroomSessions.computeIfAbsent(studyroomId, k -> ConcurrentHashMap.newKeySet()).add(session);
-            userSessions.put(userId, session);
+            userSessions.put(userId + "_" + studyroomId, session); // 유저 ID와 스터디룸 ID를 키로 사용
 
             session.sendMessage(new TextMessage("Connection Success! for studyroomId : " + studyroomId));
             broadcastMessage(studyroomId, userId, "User " + userId + " has joined the room.");
@@ -61,7 +61,7 @@ protected void handleTextMessage(WebSocketSession session, TextMessage message)
                 String directMessage = payload.substring(index + 1);
 
                 log.info("direct call from {}: {}", targetUserId, directMessage);
-                sendMessageToUser(targetUserId, "[" + userId + " (call)] : " + directMessage);
+                sendMessageToUser(targetUserId + "_" + studyroomId, "[" + userId + " (call)] : " + directMessage);
                 return;
             }
         }
@@ -90,7 +90,7 @@ public void afterConnectionClosed(WebSocketSession session, CloseStatus status)
                 studyroomSessions.remove(studyroomId);
             }
         }
-        userSessions.remove(userId);
+        userSessions.remove(userId + "_" + studyroomId);
 
         broadcastMessage(studyroomId, userId, "User " + userId + " has left the room.");
     }

src/main/java/com/linkode/api_server/repository/MemberstudyroomRepository.java

@@ -44,4 +44,13 @@ public interface MemberstudyroomRepository extends JpaRepository<MemberStudyroom
             "AND ms.member.memberId = :memberId " +
             "AND ms.status = :status")
     Optional<MemberStudyroom> getStudyroomDetail(long studyroomId,long memberId, BaseStatus status);
+
+
+    /**
+     * findByMember_MemberIdAndStatus와 동일하나 N+1 문제 해결버전
+     * */
+    @Query("SELECT ms FROM MemberStudyroom ms JOIN FETCH ms.studyroom WHERE ms.member.memberId = :memberId AND ms.status = :status")
+    Optional<List<MemberStudyroom>> findByMemberIdAndStatus(Long memberId, BaseStatus status);
+
+
 }

src/main/java/com/linkode/api_server/service/MemberStudyroomService.java

@@ -1,11 +1,15 @@
 package com.linkode.api_server.service;
 
+import com.linkode.api_server.common.exception.LeaveStudyroomExeption;
 import com.linkode.api_server.common.exception.MemberStudyroomException;
+import com.linkode.api_server.common.response.BaseResponse;
+import com.linkode.api_server.common.response.status.BaseExceptionResponseStatus;
 import com.linkode.api_server.domain.Studyroom;
 import com.linkode.api_server.domain.base.BaseStatus;
 import com.linkode.api_server.domain.memberstudyroom.MemberRole;
 import com.linkode.api_server.domain.memberstudyroom.MemberStudyroom;
 import com.linkode.api_server.dto.studyroom.DetailStudyroomResponse;
+import com.linkode.api_server.dto.studyroom.MemberStudyroomListResponse;
 import com.linkode.api_server.repository.MemberstudyroomRepository;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -18,8 +22,7 @@
 import java.util.Set;
 import java.util.stream.Collectors;
 
-import static com.linkode.api_server.common.response.status.BaseExceptionResponseStatus.NOT_FOUND_CREW;
-import static com.linkode.api_server.common.response.status.BaseExceptionResponseStatus.NOT_FOUND_MEMBER_STUDYROOM;
+import static com.linkode.api_server.common.response.status.BaseExceptionResponseStatus.*;
 
 @Slf4j
 @Service
@@ -88,4 +91,55 @@ public DetailStudyroomResponse getStudyroomDetail(long studyroomId, long memberI
         return response;
     }
 
+    /**
+     * 스터디룸 탈퇴
+     *
+     * memberStudyroom에 대한 유효성 검증을 한후 적절하지 못한 맴버 스터디룸이면 예외를 던집니다.
+     * 방장이면 탈퇴할 수 없도록 조건문을 통해 방장인지 파악한 뒤 예외를 강제로 던집니다!
+     *
+     * */
+    @Transactional
+    public BaseExceptionResponseStatus leaveStudyroom(long studyroomId, long memberId){
+        try {
+            MemberStudyroom memberStudyroom = memberstudyroomRepository
+                    .findByMember_MemberIdAndStudyroom_StudyroomIdAndStatus(memberId,studyroomId,BaseStatus.ACTIVE)
+                    .orElseThrow(()-> new MemberStudyroomException(NOT_FOUND_MEMBER_STUDYROOM));
+            if(memberStudyroom.getRole()==MemberRole.CAPTAIN) throw new
+                    LeaveStudyroomExeption(CANNOT_LEAVE_STUDYROOM);
+            memberStudyroom.updateMemberStudyroomStatus(BaseStatus.DELETE);
+            memberstudyroomRepository.save(memberStudyroom);
+            return BaseExceptionResponseStatus.SUCCESS;
+        }
+        catch (LeaveStudyroomExeption e) {
+            log.error("MemberStudyroomException! -> ", e);
+            return CANNOT_LEAVE_STUDYROOM;
+        }
+        catch (MemberStudyroomException e) {
+            log.error("MemberStudyroomException! -> ", e);
+            return NOT_FOUND_MEMBER_STUDYROOM;
+        }
+        catch (Exception e){
+            return FAILURE;
+        }
+    }
+
+    /**
+     * 유저의 스터디룸 리스트 조회
+     *
+     * 스트림 문법으로 매핑
+     * */
+    public MemberStudyroomListResponse getMemberStudyroomList(long memberId){
+
+        List<MemberStudyroomListResponse.Studyroom> studyroomList =
+                memberstudyroomRepository.findByMemberIdAndStatus(memberId,BaseStatus.ACTIVE)
+                        .orElseThrow(()->new MemberStudyroomException(NOT_FOUND_MEMBER_STUDYROOM))
+                        .stream()
+                        .map(ms -> new MemberStudyroomListResponse.Studyroom(
+                                ms.getStudyroom().getStudyroomId(),
+                                ms.getStudyroom().getStudyroomProfile()
+                        )).collect(Collectors.toList());
+
+        return new MemberStudyroomListResponse(studyroomList);
+    }
+
 }