Merge pull request #1183 from woowacourse-teams/BE/dev

[BE] 구독 요청한 세션에게만 타이머 상태를 전송하도록 변경한 내용 테스트 서버로 이동

Author: JiHyeonL

backend/src/main/java/site/coduo/timer/service/SchedulerService.java

@@ -87,9 +87,9 @@ private void reset(final String key, final Timer timer) {
         timestampRegistry.register(key, initalTimer);
     }
 
-    public void notifyTimerStatus(final String key) {
+    public void notifyTimerStatus(final String key, final String sessionId) {
         if (schedulerRegistry.isActive(key)) {
-            timerStompManager.sendStatus(key, TimerStatus.RUNNING);
+            timerStompManager.sendStatusToUser(sessionId, key, TimerStatus.RUNNING);
         }
     }
 

backend/src/main/java/site/coduo/timer/service/TimerStompManager.java

@@ -26,6 +26,14 @@ public void sendStatus(final String accessCode, final TimerStatus status) {
         );
     }
 
+    public void sendStatusToUser(final String sessionId, final String accessCode, final TimerStatus status) {
+        simpMessagingTemplate.convertAndSendToUser(
+                sessionId,
+                String.format(STATUS_DESTINATION, accessCode),
+                new TimerStatusResponse(status.getMessage(), null)
+        );
+    }
+
     public void sendTime(final String accessCode, final long time) {
         simpMessagingTemplate.convertAndSend(String.format(TIME_DESTINATION, accessCode), new TimerStartResponse(time));
     }

backend/src/main/java/site/coduo/websocket/WebSocketHandler.java

@@ -22,7 +22,6 @@ public class WebSocketHandler extends TextWebSocketHandler {
     public void afterConnectionEstablished(final WebSocketSession session) {
         final String pairRoomAccessCode = parsePairRoomAccessCode(session);
         pairRoomWebSocketSessionStore.addSession(pairRoomAccessCode, session);
-        schedulerService.notifyTimerStatus(pairRoomAccessCode);
         log.info("연결 성공 : {}", session.getId());
     }
 

backend/src/main/java/site/coduo/websocket/stomp/StompEventListener.java

@@ -31,7 +31,8 @@ public void onSubscription(final SessionSubscribeEvent event) {
         }
         final String key = parsePairRoomKey(destination);
         if (timerStompManager.isTimerStatusDestination(key, destination)) {
-            schedulerService.notifyTimerStatus(key);
+            final String sessionId = headerAccessor.getSessionId();
+            schedulerService.notifyTimerStatus(key, sessionId);
         }
     }