[BE] 타이머 Websocket에 STOMP 적용

backend/src/main/java/site/coduo/sync/config/SchedulerConfig.java

@@ -2,12 +2,14 @@
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 
 @Configuration
 public class SchedulerConfig {
 
     @Bean
+    @Primary
     public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
         final ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
         scheduler.setPoolSize(100);

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

@@ -4,6 +4,7 @@
 import java.time.temporal.ChronoUnit;
 import java.util.concurrent.ScheduledFuture;
 
+import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.scheduling.Trigger;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 import org.springframework.scheduling.support.PeriodicTrigger;
@@ -14,9 +15,11 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import site.coduo.timer.domain.Timer;
+import site.coduo.timer.domain.TimerStatus;
 import site.coduo.timer.repository.TimerEntity;
 import site.coduo.timer.repository.TimerRepository;
 import site.coduo.timer.service.TimestampRegistry;
+import site.coduo.timer.service.dto.TimerResponse;
 import site.coduo.websocket.PairRoomWebSocketService;
 import site.coduo.websocket.message.EventAndDataMessage;
 
@@ -28,6 +31,7 @@ public class SchedulerService {
 
     public static final Duration DELAY_SECOND = Duration.of(1, ChronoUnit.SECONDS);
 
+    private final SimpMessagingTemplate messagingTemplate;
     private final PairRoomWebSocketService pairRoomWebSocketService;
     private final ThreadPoolTaskScheduler taskScheduler;
     private final SchedulerRegistry schedulerRegistry;
@@ -38,7 +42,10 @@ public void start(final String key) {
         if (schedulerRegistry.isActive(key)) {
             return;
         }
-        pairRoomWebSocketService.sendAllPairRoomSessions(key, new EventAndDataMessage("timer", "start"));
+        messagingTemplate.convertAndSend(
+                "/topic/" + key + "/timer/status",
+                new TimerResponse(TimerStatus.START.getName())
+        );
         if (isInitial(key)) {
             final Timer timer = timerRepository.fetchTimerByAccessCode(key)
                     .toDomain();
@@ -65,13 +72,16 @@ private void runTimer(final String key, final Timer timer) {
             stop(key, timer);
             return;
         }
-        if (pairRoomWebSocketService.hasNoConnections(key) && schedulerRegistry.has(key)) {
-            pauseTimer(key);
-            return;
-        }
+        // todo - STOMP에서 특정 topic을 구독하고 있는 사용자 수를 가져올 방법 생각
+//        if (pairRoomWebSocketService.hasNoConnections(key) && schedulerRegistry.has(key)) {
+//            pauseTimer(key);
+//            return;
+//        }
         timer.decreaseRemainingTime(DELAY_SECOND.toMillis());
-        pairRoomWebSocketService.sendAllPairRoomSessions(key,
-                new EventAndDataMessage("remaining-time", String.valueOf(timer.getRemainingTime())));
+        messagingTemplate.convertAndSend(
+                "/topic/" + key + "/timer",
+                new TimerResponse(timer.getRemainingTime())
+        );
     }
 
     private void pauseTimer(final String key) {
@@ -82,11 +92,15 @@ private void pauseTimer(final String key) {
 
     public void pause(final String key) {
         pauseTimer(key);
-        pairRoomWebSocketService.sendAllPairRoomSessions(key, new EventAndDataMessage("timer", "pause"));
+        messagingTemplate.convertAndSend(
+                "/topic/" + key + "/timer/status",
+                new TimerResponse(TimerStatus.PAUSE.getName()));
     }
 
     private void stop(final String key, final Timer timer) {
-        pairRoomWebSocketService.sendAllPairRoomSessions(key, new EventAndDataMessage("timer", "stop"));
+        messagingTemplate.convertAndSend(
+                "/topic/" + key + "/timer/status",
+                new TimerResponse(TimerStatus.PAUSE.getName()));
         schedulerRegistry.release(key);
         final Timer initalTimer = new Timer(timer.getAccessCode(), timer.getDuration(), timer.getDuration());
         timestampRegistry.register(key, initalTimer);
@@ -99,8 +113,10 @@ public void notifyTimerStatus(final WebSocketSession session, final String pairR
     }
 
     public void syncTimerWithDatabase(final String key) {
-        final Timer timer = timestampRegistry.get(key);
-        final TimerEntity timerEntity = timerRepository.fetchTimerByAccessCode(key);
-        timerEntity.updateTimer(timer);
+        if (timestampRegistry.has(key)) {
+            final Timer timer = timestampRegistry.get(key);
+            final TimerEntity timerEntity = timerRepository.fetchTimerByAccessCode(key);
+            timerEntity.updateTimer(timer);
+        }
     }
 }

backend/src/main/java/site/coduo/timer/controller/TimerController.java

@@ -14,15 +14,12 @@
 import site.coduo.timer.controller.docs.TimerDocs;
 import site.coduo.timer.service.TimerService;
 import site.coduo.timer.service.dto.TimerUpdateRequest;
-import site.coduo.websocket.PairRoomWebSocketService;
-import site.coduo.websocket.message.EventAndDataMessage;
 
 @Slf4j
 @RequiredArgsConstructor
 @RestController
 public class TimerController implements TimerDocs {
 
-    private final PairRoomWebSocketService pairRoomWebSocketService;
     private final TimerService timerService;
     private final SchedulerService schedulerService;
 
@@ -36,7 +33,6 @@ public ResponseEntity<Void> createTimerStart(@PathVariable("accessCode") final S
     @PatchMapping("/{accessCode}/timer/stop")
     public ResponseEntity<Void> createTimerStop(@PathVariable("accessCode") final String accessCode) {
         schedulerService.pause(accessCode);
-
         return ResponseEntity.noContent()
                 .build();
     }
@@ -47,8 +43,6 @@ public ResponseEntity<Void> updateTimer(
             @Valid @RequestBody final TimerUpdateRequest request
     ) {
         timerService.updateTimer(accessCode, request);
-        pairRoomWebSocketService.sendAllPairRoomSessions(accessCode, new EventAndDataMessage("timer", "update"));
-
         return ResponseEntity.noContent()
                 .build();
     }

backend/src/main/java/site/coduo/timer/domain/TimerStatus.java

@@ -0,0 +1,15 @@
+package site.coduo.timer.domain;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor
+public enum TimerStatus {
+
+    START("start"),
+    PAUSE("pause"),
+    UPDATE("update");
+
+    private final String name;
+}

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

@@ -1,5 +1,6 @@
 package site.coduo.timer.service;
 
+import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -8,15 +9,18 @@
 import site.coduo.pairroom.repository.PairRoomEntity;
 import site.coduo.pairroom.repository.PairRoomRepository;
 import site.coduo.timer.domain.Timer;
+import site.coduo.timer.domain.TimerStatus;
 import site.coduo.timer.repository.TimerEntity;
 import site.coduo.timer.repository.TimerRepository;
+import site.coduo.timer.service.dto.TimerResponse;
 import site.coduo.timer.service.dto.TimerUpdateRequest;
 
 @Transactional(readOnly = true)
 @RequiredArgsConstructor
 @Service
 public class TimerService {
 
+    private final SimpMessagingTemplate messagingTemplate;
     private final TimerRepository timerRepository;
     private final TimestampRegistry timestampRegistry;
     private final PairRoomRepository pairRoomRepository;
@@ -42,5 +46,9 @@ public void updateTimer(final String accessCode, final TimerUpdateRequest update
         );
         timerEntity.updateTimer(newTimer);
         timestampRegistry.register(accessCode, newTimer);
+        messagingTemplate.convertAndSend(
+                "/topic/" + accessCode + "/timer/status",
+                new TimerResponse(TimerStatus.UPDATE.getName())
+        );
     }
 }

backend/src/main/java/site/coduo/timer/service/dto/TimerResponse.java

@@ -0,0 +1,6 @@
+package site.coduo.timer.service.dto;
+
+public record TimerResponse(
+        Object data
+) {
+}

backend/src/test/java/site/coduo/config/TestConfig.java

@@ -3,7 +3,6 @@
 import org.springframework.boot.test.context.TestConfiguration;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Primary;
-import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 
 import site.coduo.fake.FakeGithubApiClient;
 import site.coduo.fake.FakeGithubOAuthClient;
@@ -40,10 +39,4 @@ public GithubOAuthClient fakeGithubOAuthClient() {
     public GithubApiClient fakeGithubApiClient() {
         return new FakeGithubApiClient();
     }
-
-    @Bean
-    @Primary
-    public ThreadPoolTaskScheduler testThreadPoolTaskScheduler() {
-        return new ThreadPoolTaskScheduler();
-    }
 }

backend/src/test/java/site/coduo/sync/service/SchedulerServiceTest.java

@@ -13,6 +13,7 @@
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 
 import site.coduo.pairroom.domain.accesscode.AccessCode;
@@ -29,8 +30,7 @@ class SchedulerServiceTest {
 
     @Autowired
     private PairRoomWebSocketService pairRoomWebSocketService;
-
-    @Autowired
+
     private ThreadPoolTaskScheduler taskScheduler;
 
     @Autowired
@@ -39,6 +39,7 @@ class SchedulerServiceTest {
     @Autowired
     private TimestampRegistry timestampRegistry;
 
+    private SimpMessagingTemplate messagingTemplate;
     private TimerRepository timerRepository;
     private SchedulerService schedulerService;
 
@@ -48,6 +49,7 @@ void setUp() {
         pairRoomWebSocketService = mock(PairRoomWebSocketService.class);
 
         schedulerService = new SchedulerService(
+                messagingTemplate,
                 pairRoomWebSocketService,
                 taskScheduler,
                 schedulerRegistry,