Feat/#163/participant service

src/main/java/space/space_spring/controller/VoiceRoomController.java

@@ -16,6 +16,7 @@
 import space.space_spring.exception.CustomException;
 import space.space_spring.response.BaseResponse;
 import space.space_spring.service.LiveKitService;
+import space.space_spring.service.VoiceRoomParticipantService;
 import space.space_spring.service.VoiceRoomService;
 import space.space_spring.util.space.SpaceUtils;
 import space.space_spring.util.user.UserUtils;
@@ -40,6 +41,7 @@ public class VoiceRoomController {
     private final UserSpaceDao userSpaceDao;
     private final UserUtils userUtils;
     private final SpaceUtils spaceUtils;
+    private final VoiceRoomParticipantService voiceRoomParticipantService;
 
     //VoiceRoom 생성/수정
     @PostMapping("")
@@ -133,10 +135,11 @@ public BaseResponse<GetParticipantList.Response> getParticipants(
         //해당 voiceRoom이 해당 space에 속한것이 맞는지 확인
         validateVoiceRoomInSpace(spaceId,roomId);
 
-        List<GetParticipantList.ParticipantInfo> participantInfoList = voiceRoomService.getParticipantInfoListById(roomId);
+        //List<GetParticipantList.ParticipantInfo> participantInfoList = voiceRoomService.getParticipantInfoListById(roomId);
+        List<GetParticipantList.ParticipantInfo> participantInfoList = voiceRoomParticipantService.getParticipantInfoListById(roomId);
+
         return new BaseResponse<GetParticipantList.Response>(new GetParticipantList.Response(participantInfoList));
     }
-
     @PatchMapping("")
     public BaseResponse<String> updateVoiceRoom(
             @PathVariable("spaceId") @NotNull long spaceId,

src/main/java/space/space_spring/dto/VoiceRoom/GetParticipantList.java

@@ -28,7 +28,7 @@ public static class Response{
     @Setter
     public static class ParticipantInfo{
         private String name;
-        private Long userId;
+        private Long id;
         private Long userSpaceId;
         private boolean isMute;
         private String profileImage;
@@ -39,7 +39,7 @@ public static ParticipantInfo convertParticipantDto(ParticipantDto participantDt
                     .name(participantDto.getName())
                     .isMute(participantDto.isMicMute())
                     .profileImage(participantDto.getProfileImage())
-                    .userId(participantDto.getId())
+                    .id(participantDto.getId())
                     .userSpaceId(participantDto.getUserSpaceId())
                     .build();
         }

src/main/java/space/space_spring/dto/VoiceRoom/GetVoiceRoomList.java

@@ -48,7 +48,7 @@ public static VoiceRoomInfo convertRoomDto(RoomDto roomDto){
                     .order(roomDto.getOrder())
                     .metadate(roomDto.getMetadata())
                     .participantInfoList(
-                            GetParticipantList.ParticipantInfo.convertParticipantDtoList(roomDto.getParticipantDTOList())
+                            GetParticipantList.ParticipantInfo.convertParticipantDtoList(roomDto.getParticipantListDto().getParticipantDtoList())
                     )
                     .build();
         }

src/main/java/space/space_spring/dto/VoiceRoom/ParticipantDto.java

@@ -31,8 +31,11 @@ public void setProfileImage(String imageUrl){
 
     public static ParticipantDto convertParticipant(LivekitModels.ParticipantInfo participantInfo){
         if(participantInfo==null){return null;}
+        Long id = Long.valueOf(participantInfo.getIdentity());
+        Long userSpaceId = id;
         return ParticipantDto.builder()
-                .id(Long.valueOf(participantInfo.getIdentity()))
+                .id(id)
+                .userSpaceId(userSpaceId)
                 .name(participantInfo.getName())
                 .isMicMute(checkMicMute(participantInfo.getTracksList()))
 

src/main/java/space/space_spring/dto/VoiceRoom/ParticipantListDto.java

@@ -0,0 +1,49 @@
+package space.space_spring.dto.VoiceRoom;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+public class ParticipantListDto {
+
+
+    private List<ParticipantDto> participantDtoList;
+
+    private ParticipantListDto(List<ParticipantDto> participantDtoList){
+        this.participantDtoList=participantDtoList;
+    }
+
+    public static ParticipantListDto from(List<ParticipantDto> participantDtoList ){
+        return new ParticipantListDto(participantDtoList);
+    }
+    public static  ParticipantListDto empty(){
+        return new ParticipantListDto(Collections.emptyList());
+    }
+
+    public static ParticipantListDto nullList(){
+        return new ParticipantListDto(null);
+    }
+
+    public void setProfileImage(Function<Long, String> profileFinder){
+        this.participantDtoList.forEach(participantDto -> {
+            String profileImage = profileFinder.apply(participantDto.getUserSpaceId());
+            participantDto.setProfileImage(profileImage);
+        });
+    }
+
+
+
+    //Todo 생성/변환 책임분리 필요
+    public List<GetParticipantList.ParticipantInfo> convertParticipantDtoList(){
+        if(this.participantDtoList==null){System.out.print("\n[DEBUG] participant List is NULL\n"); return null;}
+        if(this.participantDtoList.isEmpty()){System.out.print("\n[DEBUG] participant List is Empty\n"); return Collections.emptyList();}
+        return this.participantDtoList.stream()
+                .map(GetParticipantList.ParticipantInfo::convertParticipantDto)
+                .collect(Collectors.toList());
+    }
+
+    public List<ParticipantDto> getParticipantDtoList() {
+        return participantDtoList;
+    }
+}

src/main/java/space/space_spring/dto/VoiceRoom/RoomDto.java

@@ -20,23 +20,34 @@ public class RoomDto {
     private int numParticipants;
     private long startTime; //time Stamp
     private long createdAt;
-    private List<ParticipantDto> participantDTOList;
+    //private List<ParticipantDto> participantDTOList;
+    private ParticipantListDto participantListDto;
     private int order;
     private String sid;
     private String metadata;
 
 
-    public void setParticipantDTOListByInfo(List<LivekitModels.ParticipantInfo> participantInfoList){
-        if(participantInfoList==null||participantInfoList.isEmpty()){return;}
-        this.participantDTOList =  participantInfoList.stream()
-                .map(ParticipantDto::convertParticipant)
-                .collect(Collectors.toList());
-    }
+//    public void setParticipantDTOListByInfo(List<LivekitModels.ParticipantInfo> participantInfoList){
+//        if(participantInfoList==null||participantInfoList.isEmpty()){return;}
+//        this.participantDTOList =  participantInfoList.stream()
+//                .map(ParticipantDto::convertParticipant)
+//                .collect(Collectors.toList());
+//    }
     public RoomDto setParticipantDTOList(List<ParticipantDto> participantDtoList){
-        this.participantDTOList =  participantDtoList;
+        if(participantDtoList==null){
+            this.participantListDto = ParticipantListDto.empty();
+        }
+        this.participantListDto =  ParticipantListDto.from(participantDtoList);
         return this;
     }
 
+    public RoomDto setParticipantDTOList(ParticipantListDto participants){
+        if(participants==null){
+            this.participantListDto = ParticipantListDto.empty();
+        }
+        this.participantListDto =  participants;
+        return this;
+    }
     public static RoomDto convertRoom(LivekitModels.Room room){
         if(room==null){return null;}
         return RoomDto.builder()
@@ -45,7 +56,7 @@ public static RoomDto convertRoom(LivekitModels.Room room){
                 .startTime(room.getCreationTime())
                 .sid(room.getSid())
                 .metadata(room.getMetadata())
-                .participantDTOList(null)
+                .participantListDto(ParticipantListDto.nullList())
                 .build();
     }
 
@@ -67,7 +78,7 @@ public static RoomDto convertRoom(VoiceRoom voiceRoom){
                 .sid(null)
                 .metadata(null)
                 //.startTime()
-                .participantDTOList(null)
+                .participantListDto(ParticipantListDto.nullList())
                 .build();
     }
 
@@ -128,6 +139,6 @@ public String toString() {
         }
     }
 
-
-
+    public ParticipantListDto getParticipantListDto(){return participantListDto;}
+    //public List<ParticipantDto> getParticipantDtoList(){return participantListDto.getParticipantDtoList();}
 }

src/main/java/space/space_spring/dto/VoiceRoom/VoiceRoomListDto.java

@@ -65,5 +65,11 @@ public List<GetVoiceRoomList.VoiceRoomInfo> convertVoicRoomInfoList() {
         return convertVoicRoomInfoList( null);
     }
 
+    public void setParticipantListDto(Map<Long,ParticipantListDto> participantListDtoMap){
+
+        for(RoomDto roomDto : this.roomDtoList){
+            roomDto.setParticipantDTOList(participantListDtoMap.get(roomDto.getId()));
+        }
+    }
 
 }

src/main/java/space/space_spring/entity/VoiceRoom.java

@@ -63,7 +63,7 @@ public RoomDto convertRoomDto(){
                 .sid(null)
                 .metadata(null)
                 //.startTime()
-                .participantDTOList(null)
+                .participantListDto(null)
                 .build();
     }
 }

src/main/java/space/space_spring/service/VoiceRoomParticipantService.java

@@ -0,0 +1,113 @@
+package space.space_spring.service;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.core.task.TaskExecutor;
+import org.springframework.stereotype.Service;
+import space.space_spring.dao.UserSpaceDao;
+import space.space_spring.dao.VoiceRoomRepository;
+import space.space_spring.domain.user.repository.UserDao;
+import space.space_spring.dto.VoiceRoom.GetParticipantList;
+import space.space_spring.dto.VoiceRoom.ParticipantDto;
+import space.space_spring.dto.VoiceRoom.ParticipantListDto;
+import space.space_spring.dto.VoiceRoom.RoomDto;
+import space.space_spring.entity.Space;
+import space.space_spring.entity.User;
+import space.space_spring.entity.UserSpace;
+import space.space_spring.util.LiveKitUtils;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import java.util.stream.Collectors;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class VoiceRoomParticipantService {
+    final private UserSpaceDao userSpaceDao;
+    final private UserDao userDao;
+    final private VoiceRoomRepository voiceRoomRepository;
+    final private LiveKitUtils liveKitUtils;
+    private final TaskExecutor taskExecutor;
+    public List<GetParticipantList.ParticipantInfo> getParticipantInfoListById(long voiceRoomId){
+        return getParticipantDtoListById(voiceRoomId).convertParticipantDtoList();
+    }
+    private ParticipantListDto getParticipantDtoListById(long voiceRoomId){
+        Space space = voiceRoomRepository.findById(voiceRoomId).getSpace();
+        //Todo 다른 네이밍 고려
+        List<ParticipantDto> participantDtos =  liveKitUtils.getParticipantInfo(String.valueOf(voiceRoomId));
+        if(participantDtos==null || participantDtos.isEmpty()){
+            participantDtos =  Collections.emptyList();
+        }
+
+        ParticipantListDto participantListDto = ParticipantListDto.from(participantDtos);
+        participantListDto.setProfileImage(this::findProfileImageByUserSpaceId);
+        return participantListDto;
+    }
+    private String findProfileImageByUserSpaceId(Long userSpaceId){
+        return userSpaceDao.findProfileImageById(userSpaceId).orElse("");
+    }
+
+
+
+
+    //1. 이 함수를 VoiceRoomListDto의 parameter로 넘긴다
+    //장점. 동기 처리의 책임을 service가 질 수 있음
+    //단점. 굳이 이렇게까지 코드를 꼬야야하나 싶을 수 있음. 그냥 getRoomList해서 RoomList를 밖으로 빼는게 나을지도
+
+    //2. 이 함수를 VoiceRoomListDto 내부로 이전
+    //장점. findProfileImageByUserSpaceId만 function parameter로 넘기면 됨 -> 책임과 구조가 더 명확하게 보인다고
+    //단점. 비동기 병렬처리의 책임을 VoiceRoomListDto가 가져야함.
+    public void setParticipant(List<RoomDto> roomDtoList){
+        List<CompletableFuture<Void>> roomDtoFutureList = roomDtoList.stream()
+                .map(r->CompletableFuture.runAsync(()->r.setParticipantDTOList(getParticipantDtoListById(r.getId())),taskExecutor)
+                        //.exceptionally(ex->{throws ex;})
+                )
+                .collect(Collectors.toList());
+
+
+        // 모든 Future의 완료를 기다림
+        CompletableFuture<Void> allOf = CompletableFuture.allOf(
+                roomDtoFutureList.toArray(new CompletableFuture[0]));
+
+        // 결과 수집 및 출력
+        allOf.join();
+    }
+    public Map<Long,ParticipantListDto> getParticipantList(List<Long> roomIdList){
+
+        Map<Long,CompletableFuture<ParticipantListDto>> futureMap = roomIdList.stream()
+                .collect(Collectors.toMap(
+                        roomId->roomId,
+                        roomId->CompletableFuture.supplyAsync(
+                                ()-> getParticipantDtoListById(roomId),
+                                taskExecutor
+
+                        ).exceptionally(throwable -> {
+                            log.error("failed to fetch and get participantList",throwable);
+                            return null;//empty ParticipantListDto
+                        })
+                ));
+        try {
+            // 모든 Future의 완료를 기다림
+            CompletableFuture.allOf(
+                futureMap.values().toArray(new CompletableFuture[0]))
+                .exceptionally(throwable -> {
+                    log.error("Error while waiting for all participant fetches to complete",throwable);
+                    return null;
+                })
+                .join();
+
+            return futureMap.entrySet().stream()
+                    .collect(Collectors.toMap(
+                            entry -> entry.getKey(),
+                            entry->entry.getValue().getNow(ParticipantListDto.empty())
+                    ));
+
+        }catch (Exception e){
+            log.error("Critical error while processing participant fetches", e);
+            return Collections.emptyMap();  // 심각한 오류 발생 시 빈 Map 반환
+        }
+    }
+}