feat : webrtc 관련 설정 추가

#15

Author: JeongA-Shin

build.gradle

@@ -27,6 +27,8 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-websocket'
     implementation 'org.webjars:sockjs-client:1.1.2'
     implementation 'org.webjars:stomp-websocket:2.3.3-1'
+    implementation 'com.googlecode.json-simple:json-simple:1.1.1'
+
 
     ////view
       implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'

src/main/java/oncoding/concoder/config/SocketHandler.java

@@ -0,0 +1,32 @@
+package oncoding.concoder.config;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
+import org.springframework.stereotype.Component;
+import org.springframework.web.socket.TextMessage;
+import org.springframework.web.socket.WebSocketSession;
+import org.springframework.web.socket.handler.TextWebSocketHandler;
+
+@Component
+public class SocketHandler extends TextWebSocketHandler {
+
+  List<WebSocketSession> sessions = new CopyOnWriteArrayList<>();
+
+  @Override
+  public void handleTextMessage(WebSocketSession session, TextMessage message)
+      throws InterruptedException, IOException {
+    for (WebSocketSession webSocketSession : sessions) {
+      if (webSocketSession.isOpen() && !session.getId().equals(webSocketSession.getId())) {
+        webSocketSession.sendMessage(message);
+      }
+    }
+  }
+
+  @Override
+  public void afterConnectionEstablished(WebSocketSession session) throws Exception {
+    sessions.add(session);
+  }
+
+
+}

src/main/java/oncoding/concoder/config/WebSocketConfig.java

@@ -5,12 +5,14 @@
 import org.springframework.messaging.simp.config.MessageBrokerRegistry;
 import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
 import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
+import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
+import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
 import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
 import org.springframework.web.socket.messaging.SessionDisconnectEvent;
 
 @Configuration
 @EnableWebSocketMessageBroker //웹 소켓 메시지 처리 활성화
-public class WebSocketConfig implements WebSocketMessageBrokerConfigurer{
+public class WebSocketConfig implements WebSocketMessageBrokerConfigurer, WebSocketConfigurer {
 
   @Override
   public void configureMessageBroker(final MessageBrokerRegistry registry) {
@@ -36,4 +38,10 @@ public void onDisconnectEvent(final SessionDisconnectEvent event) {
     System.out.println("DisconnectEvent");
   }
 
+  @Override
+  public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
+
+    registry.addHandler(new SocketHandler(), "/socket")
+        .setAllowedOrigins("*");
+  }
 }

src/main/java/oncoding/concoder/controller/VideoController.java

@@ -0,0 +1,133 @@
+package oncoding.concoder.controller;
+
+import java.text.ParseException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.UUID;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.json.simple.JSONObject;
+import org.json.simple.parser.JSONParser;
+import oncoding.concoder.dto.ChatDTO.SessionForTest;
+import org.springframework.boot.configurationprocessor.json.JSONException;
+import org.springframework.context.event.EventListener;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.messaging.handler.annotation.Header;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.messaging.handler.annotation.SendTo;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.client.RestTemplate;
+import org.springframework.web.socket.messaging.SessionConnectEvent;
+import org.springframework.web.socket.messaging.SessionDisconnectEvent;
+
+@Slf4j
+@Controller
+@RequiredArgsConstructor
+public class VideoController {
+
+  // 테스트용 세션 리스트.
+  private final ArrayList<SessionForTest> sessionIdList;
+  private final SimpMessagingTemplate template;
+
+  // 실시간으로 들어온 세션 감지하여 전체 세션 리스트 반환
+  @MessageMapping("/video/joined-room-info")
+  @SendTo("/sub/video/joined-room-info")
+  private ArrayList<SessionForTest> joinRoom(@Header("simpSessionId") String sessionId, JSONObject ob)
+      throws JSONException {
+
+    // 현재 들어온 세션 저장.
+    sessionIdList.add(new SessionForTest(UUID.fromString((String)ob.get("from")) , sessionId));
+
+    return sessionIdList;
+  }
+
+
+  // caller의 정보를 다른 callee들에게 쏴준다.
+  @MessageMapping("/video/caller-info")
+  @SendTo("/sub/video/caller-info")
+  private Map<String, Object> caller(JSONObject ob) throws JSONException {
+
+    log.info(ob.toString());
+
+    // caller의 정보를 소켓으로 쏴준다.
+    Map<String, Object> data = new HashMap<>();
+    data.put("toCall", ob.get("toCall"));
+    data.put("from", ob.get("from"));
+    data.put("signal", ob.get("signal"));
+
+    return data;
+  }
+
+  // caller와 callee의 signaling을 위해 callee 정보를 쏴준다.
+  @MessageMapping("/video/callee-info")
+  @SendTo("/sub/video/callee-info")
+  private Map<String, Object> answerCall(JSONObject ob) throws JSONException {
+
+    log.info(ob.toString());
+
+    // accepter의 정보를 소켓으로 쏴준다.
+    Map<String, Object> data = new HashMap<>();
+    data.put("signal", ob.get("signal"));
+    data.put("from", ob.get("from"));
+    data.put("to", ob.get("to"));
+
+    return data;
+  }
+
+  @MessageMapping("/video/audio-sentiment")
+  @SendTo("/sub/video/audio-sentiment")
+  public Map<String, Object> getAudioSentiment(@RequestBody Map<String, String> map)
+      throws ParseException, org.json.simple.parser.ParseException {
+
+    HttpHeaders headers = new HttpHeaders();
+    RestTemplate restTemplate = new RestTemplate();
+    String resultMessage = restTemplate.postForObject(
+        "http://localhost:8080" + "/audio-sentiment", new HttpEntity<>(map, headers), String.class);
+
+    JSONParser parser = new JSONParser();
+    Object obj = parser.parse(resultMessage);
+    JSONObject jsonObj = (JSONObject) obj;
+
+    // {from : senderId, }
+    Map<String, Object> returnData = new HashMap<>();
+    returnData.put("from", map.get("from"));
+    returnData.put("resultOfAudioSentiment", jsonObj);
+    return returnData;
+  }
+
+  @MessageMapping("/video/chat")
+  @SendTo("/sub/video/chat")
+  public Map<String, String> listenAndSendChat(@RequestBody Map<String, String> map) throws ParseException {
+
+    return map;
+  }
+
+  @EventListener
+  private void handleSessionConnected(SessionConnectEvent event) {
+
+  }
+
+  @EventListener
+  private void handleSessionDisconnect(SessionDisconnectEvent event) {
+
+    String removedID = "";
+
+    // close된 세션의 id 저장.
+    for (SessionForTest session : sessionIdList) {
+      if (session.getSessionId().equals(event.getSessionId())) {
+        removedID = String.valueOf(session.getId());
+        sessionIdList.remove(session);
+        break;
+      }
+    }
+
+    //종료 세션 id 전달.
+    template.convertAndSend("/sub/video/close-session", removedID);
+
+  }
+
+}

src/main/java/oncoding/concoder/dto/ChatDTO.java

@@ -81,6 +81,19 @@ public static RoomResponse from(final Room room) {
       }
     }
 
+
+  @Setter
+  @Getter
+  @AllArgsConstructor
+  @NoArgsConstructor
+  public static class SessionForTest {
+
+
+    private UUID id;
+    private String sessionId;
+
+  }
+
     @Setter
     @Getter
     @AllArgsConstructor