socket user 조회 api 수정

src/docs/asciidoc/index.adoc

@@ -26,7 +26,11 @@ include::{snippets}/sample-controller-test/샘플_전체_조회/auto-section.ado
 == user API
 
 include::{snippets}/user-controller-test/유저_조회/auto-section.adoc[]
-include::{snippets}/user-controller-test/코스_동시_접속_유저_조회/auto-section.adoc[]
+
+=== Get socket users API
+
+include::{snippets}/../../src/docs/custom-snippets/socket/user/get-socket-user-request.adoc[]
+include::{snippets}/../../src/docs/custom-snippets/socket/user/get-socket-user-response.adoc[]
 
 == pin API
 

src/docs/custom-snippets/socket/user/get-socket-user-request.adoc

@@ -0,0 +1,5 @@
+[source,http,options="nowrap"]
+----
+SEND /pub/{courseId}/user
+EX /pub/1/user
+----

src/docs/custom-snippets/socket/user/get-socket-user-response.adoc

@@ -0,0 +1,18 @@
+[source,http,options="nowrap"]
+----
+SUBSCRIBE /sub/{courseId}/user
+EX /sub/1/user
+Content-Type: application/json
+{
+  "code" : 0,
+  "message" : "실행에 성공했습니다.",
+  "data" : {
+    "total" : 1,
+    "users" : [
+        {
+            "userId": 1
+        }
+    ]
+  }
+}
+----

src/main/java/com/pcb/audy/domain/user/controller/UserController.java

@@ -31,6 +31,7 @@ public BasicResponse<UserGetRes> getUser(
 
     @GetMapping("/course")
     public BasicResponse<UserGetResList> getCourseUser(@RequestParam Long courseId) {
+        // TODO delete
         return BasicResponse.success(userService.getUsers(courseId));
     }
 }

src/main/java/com/pcb/audy/domain/user/controller/UserSocketController.java

@@ -0,0 +1,22 @@
+package com.pcb.audy.domain.user.controller;
+
+import com.pcb.audy.domain.user.dto.response.UserGetResList;
+import com.pcb.audy.domain.user.service.UserService;
+import com.pcb.audy.global.response.BasicResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.messaging.handler.annotation.DestinationVariable;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.messaging.handler.annotation.SendTo;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+public class UserSocketController {
+    private final UserService userService;
+
+    @MessageMapping("/{courseId}/user")
+    @SendTo("/sub/{courseId}/user")
+    public BasicResponse<UserGetResList> getCourseUser(@DestinationVariable Long courseId) {
+        return BasicResponse.success(userService.getUsers(courseId));
+    }
+}

src/main/java/com/pcb/audy/domain/user/service/UserService.java

@@ -31,10 +31,13 @@ public UserGetResList getUsers(Long courseId) {
         String key = COURSE_PREFIX + courseId;
 
         List<SocketUserGetRes> users =
-                UserServiceMapper.INSTANCE.toUserGetResList(
-                        redisProvider.getValues(key).stream()
-                                .map(user -> objectMapper.convertValue(user, User.class))
-                                .toList());
+                redisProvider.getValues(key).stream()
+                        .map(
+                                user ->
+                                        SocketUserGetRes.builder()
+                                                .userId(objectMapper.convertValue(user, Long.class))
+                                                .build())
+                        .toList();
 
         return UserGetResList.builder().users(users).total(users.size()).build();
     }

src/main/java/com/pcb/audy/domain/user/service/UserServiceMapper.java

@@ -1,9 +1,7 @@
 package com.pcb.audy.domain.user.service;
 
-import com.pcb.audy.domain.user.dto.response.SocketUserGetRes;
 import com.pcb.audy.domain.user.dto.response.UserGetRes;
 import com.pcb.audy.domain.user.entity.User;
-import java.util.List;
 import org.mapstruct.Mapper;
 import org.mapstruct.factory.Mappers;
 
@@ -12,6 +10,4 @@ public interface UserServiceMapper {
     UserServiceMapper INSTANCE = Mappers.getMapper(UserServiceMapper.class);
 
     UserGetRes toUserGetRes(User user);
-
-    List<SocketUserGetRes> toUserGetResList(List<User> users);
 }