feat/#58 채팅방 생성 후 채팅 없이 5분 경과 시 채팅방 삭제

src/main/java/com/example/SucceSS/SucceSsApplication.java

@@ -3,8 +3,10 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @EnableJpaAuditing
+@EnableScheduling
 @SpringBootApplication
 public class SucceSsApplication {
 

src/main/java/com/example/SucceSS/config/chat/SchedulerConfig.java

@@ -0,0 +1,17 @@
+package com.example.SucceSS.config.chat;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+
+@Configuration
+public class SchedulerConfig {
+    @Bean
+    public ThreadPoolTaskScheduler taskScheduler() {
+        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
+        scheduler.setPoolSize(10);
+        scheduler.setThreadNamePrefix("ChatRoomDeletingScheduler-");
+        scheduler.initialize();
+        return scheduler;
+    }
+}

src/main/java/com/example/SucceSS/service/ChatService/ChatRoomService.java

@@ -12,15 +12,25 @@
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.domain.Sort;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.time.Instant;
+import java.util.Date;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ScheduledFuture;
+import java.util.concurrent.TimeUnit;
+
 @Service
 @RequiredArgsConstructor
 public class ChatRoomService {
 
     private final ChatRoomRepository chatRoomRepository;
     private final ChatRepository chatRepository;
+    private final ConcurrentHashMap<Long, ScheduledFuture<?>> scheduledTasks = new ConcurrentHashMap<>();
+    private final ThreadPoolTaskScheduler taskScheduler;
+
 
     @Transactional
     public ChatRoomResponseDto createChatRoom(Member member) {
@@ -29,9 +39,8 @@ public ChatRoomResponseDto createChatRoom(Member member) {
                 .title("New Chat")
                 .build();
 
-        chatRoomRepository.save(chatRoom);
-
-        //sendFirstMessage(chatRoom);
+        chatRoom = chatRoomRepository.save(chatRoom);
+        scheduleDeletion(chatRoom.getChatRoomId());
         return chatRoom.toResponse();
     }
 
@@ -47,15 +56,6 @@ public Page<ChatResponseDto> getChatPages(Long chatRoomId, Pageable pageable) {
                 .map(ChatResponseDto::fromWithoutLocation);
     }
 
-    /*
-    private void sendFirstMessage(ChatRoom chatRoom) {
-        ChatDto dto = ChatDto.toChatDto(chatRoom.getChatRoomId(),chatRoom.getMemberId(), "New Chat", "CHAT");
-        producer.sendMessageToUser(dto);
-
-        chatRepository.save(Chat.of(dto));
-    }
-     */
-
     @Transactional(readOnly = true)
     public Page<ChatRoomResponseDto> getChatRoomPages(Member member, Pageable pageable) {
         return chatRoomRepository.getPagesByMemberId(member.getId()
@@ -67,4 +67,22 @@ private Pageable getChatRoomPageableWithSort(Pageable pageable) {
                 , Sort.by(Sort.Direction.DESC,"updatedAt"));
     }
 
+    public void scheduleDeletion(Long chatRoomId) {
+        ScheduledFuture<?> future = taskScheduler.schedule(
+                () -> deleteChatRoom(chatRoomId),
+                Instant.now().plusSeconds(5*60)
+        );
+        scheduledTasks.put(chatRoomId, future);
+    }
+
+    public void cancelScheduledDeletion(Long chatRoomId) {
+        ScheduledFuture<?> future = scheduledTasks.get(chatRoomId);
+        if (future != null && !future.isDone()) {
+            future.cancel(false);
+        }
+        scheduledTasks.remove(chatRoomId);
+    }
+
+
+
 }

src/main/java/com/example/SucceSS/service/ChatService/ChatService.java

@@ -33,6 +33,7 @@ public class ChatService {
     private final ChatRoomRepository chatRoomRepository;
     private static final String USER = "user";
     private static final String LUMI = "lumi";
+    private final ChatRoomService chatRoomService;
 
     @Value("${spring.huggingface.api.url}")
     private String API_URL;
@@ -160,5 +161,8 @@ public void updateChatRoomInfos(ChatRoom chatRoom, ChatRequestDto chatDto) {
             chatRoom.updateChatRoomTitle(chatDto.getText());
         }
         chatRoom.setUpdatedDate(LocalDateTime.now());
+
+        // 삭제 스케줄링 취소
+        chatRoomService.cancelScheduledDeletion(chatRoom.getChatRoomId());
     }
 }