refactor: Controller에서 Redis 의존 제거

Author: heygeeji

src/main/java/com/back/web7_9_codecrete_be/domain/chats/controller/ChatMessageController.java

@@ -1,19 +1,14 @@
 package com.back.web7_9_codecrete_be.domain.chats.controller;
 
 import java.security.Principal;
-import java.time.Duration;
 import java.util.Map;
 
-import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.messaging.handler.annotation.MessageMapping;
 import org.springframework.messaging.handler.annotation.Payload;
-import org.springframework.security.core.Authentication;
 import org.springframework.stereotype.Controller;
 
 import com.back.web7_9_codecrete_be.domain.chats.dto.request.ChatMessageRequest;
 import com.back.web7_9_codecrete_be.domain.chats.service.ChatMessageService;
-import com.back.web7_9_codecrete_be.global.security.CustomUserDetail;
-import com.back.web7_9_codecrete_be.global.websocket.ServerInstanceId;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -24,7 +19,6 @@
 public class ChatMessageController {
 
 	private final ChatMessageService chatMessageService;
-	private final RedisTemplate<String, Object> redisTemplate;
 
 	@MessageMapping("/chat/send")
 	public void send(ChatMessageRequest message, Principal principal) {
@@ -33,17 +27,7 @@ public void send(ChatMessageRequest message, Principal principal) {
 			throw new IllegalStateException("Unauthenticated WebSocket access");
 		}
 
-		CustomUserDetail userDetail = (CustomUserDetail)
-			((Authentication) principal).getPrincipal();
-
-		Long userId = userDetail.getUser().getId();
-
-		String sessionSetKey =
-			"chat:server:" + ServerInstanceId.ID + ":user:" + userId + ":sessionIds";
-
-		redisTemplate.expire(sessionSetKey, Duration.ofHours(2));
-
-		chatMessageService.sendMessage(message, principal);
+		chatMessageService.handleSend(message, principal);
 	}
 
 	@MessageMapping("/chat/status")

src/main/java/com/back/web7_9_codecrete_be/domain/chats/service/ChatMessageService.java

@@ -1,17 +1,21 @@
 package com.back.web7_9_codecrete_be.domain.chats.service;
 
 import java.security.Principal;
+import java.time.Duration;
 import java.time.LocalDateTime;
 
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.messaging.simp.SimpMessagingTemplate;
+import org.springframework.security.core.Authentication;
 import org.springframework.stereotype.Service;
 
 import com.back.web7_9_codecrete_be.domain.chats.dto.request.ChatMessageRequest;
 import com.back.web7_9_codecrete_be.domain.chats.dto.response.ChatMessageResponse;
 import com.back.web7_9_codecrete_be.domain.chats.dto.response.ChatUserCache;
 import com.back.web7_9_codecrete_be.domain.chats.repository.ChatStreamRepository;
+import com.back.web7_9_codecrete_be.global.security.CustomUserDetail;
 import com.back.web7_9_codecrete_be.global.websocket.ChatCountBroadcaster;
+import com.back.web7_9_codecrete_be.global.websocket.ServerInstanceId;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -28,9 +32,29 @@ public class ChatMessageService {
 	private final RedisTemplate<String, Object> redisTemplate;
 	private final ChatCountBroadcaster chatCountBroadcaster;
 
-	public void sendMessage(ChatMessageRequest request, Principal principal) {
+	/**
+	 * 채팅 메시지 전송 + 세션 TTL 갱신
+	 */
+	public void handleSend(ChatMessageRequest request, Principal principal) {
 
-		String email = principal.getName();
+		if (!(principal instanceof Authentication authentication)) {
+			throw new IllegalStateException("Unauthenticated WebSocket access");
+		}
+
+		CustomUserDetail userDetail =
+			(CustomUserDetail) authentication.getPrincipal();
+
+		Long userId = userDetail.getUser().getId();
+
+		extendUserSessionTtl(userId);
+
+		sendMessage(request, userDetail.getUsername());
+	}
+
+	/**
+	 * 실제 메시지 저장 + 브로드캐스트
+	 */
+	private void sendMessage(ChatMessageRequest request, String email) {
 
 		ChatUserCache chatUser = chatUserCacheService.getChatUser(email);
 
@@ -42,8 +66,10 @@ public void sendMessage(ChatMessageRequest request, Principal principal) {
 			LocalDateTime.now()
 		);
 
-		log.info("[SEND MESSAGE] From User ID: {}, Content: {}", chatUser.getUserId(), request.getContent());
+		log.info("[SEND MESSAGE] From User ID: {}, Content: {}",
+			chatUser.getUserId(), request.getContent());
 
+		// Redis Stream 저장
 		chatStreamRepository.save(response);
 
 		// WebSocket 브로드캐스트
@@ -53,6 +79,23 @@ public void sendMessage(ChatMessageRequest request, Principal principal) {
 		);
 	}
 
+	/**
+	 * 유저 세션 TTL 연장
+	 */
+	private void extendUserSessionTtl(Long userId) {
+
+		String sessionSetKey =
+			"chat:server:" + ServerInstanceId.ID + ":user:" + userId + ":sessionIds";
+
+		redisTemplate.expire(sessionSetKey, Duration.ofHours(2));
+
+		log.debug("[CHAT TTL] session TTL extended: userId={}, key={}", userId, sessionSetKey);
+	}
+
+
+	/**
+	 * 채팅방 접속자 수 브로드캐스트
+	 */
 	public void broadcastUserCount(Long concertId) {
 
 		String key = "chat:concert:" + concertId + ":users";