Merge pull request #166 from dnd-side-project/refactor/first-sprint

feat(Chat,Playlist): Playlist 삭제 시 채팅 삭제 이벤트 발행

Author: gzhan0226

chat-server/src/main/java/com/example/demo/dto/PlaylistDeleteEvent.java

@@ -0,0 +1,7 @@
+package com.example.demo.dto;
+
+import lombok.Builder;
+
+@Builder
+public record PlaylistDeleteEvent(String playlistId) {
+}

chat-server/src/main/java/com/example/demo/entity/repository/ChatRepository.java

@@ -8,16 +8,10 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Repository;
 import software.amazon.awssdk.enhanced.dynamodb.*;
-import software.amazon.awssdk.enhanced.dynamodb.model.Page;
-import software.amazon.awssdk.enhanced.dynamodb.model.PageIterable;
-import software.amazon.awssdk.enhanced.dynamodb.model.QueryConditional;
-import software.amazon.awssdk.enhanced.dynamodb.model.QueryEnhancedRequest;
+import software.amazon.awssdk.enhanced.dynamodb.model.*;
 import software.amazon.awssdk.services.dynamodb.model.AttributeValue;
 
-import java.util.Base64;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
+import java.util.*;
 
 @Repository
 @RequiredArgsConstructor
@@ -140,4 +134,48 @@ public int countByRoomId(String roomId) {
 
         return total;
     }
+
+    public void deleteAllByRoomId(String roomId) {
+        DynamoDbTable<Chat> t = table();
+
+        Map<String, AttributeValue> lek = null;
+        do {
+            QueryEnhancedRequest req = QueryEnhancedRequest.builder()
+                    .queryConditional(QueryConditional.keyEqualTo(
+                            Key.builder().partitionValue(roomId).build()))
+                    .attributesToProject("roomId", "sentAt")
+                    .limit(1000)
+                    .exclusiveStartKey(lek)
+                    .build();
+
+            Page<Chat> page = t.query(req).stream().findFirst().orElse(null);
+            if (page == null) break;
+
+            List<Chat> chats = page.items();
+            for (int i = 0; i < chats.size(); i += 25) {
+                int end = Math.min(i + 25, chats.size());
+
+                WriteBatch.Builder<Chat> wb = WriteBatch.builder(Chat.class)
+                        .mappedTableResource(t);
+
+                for (int j = i; j < end; j++) {
+                    Chat c = chats.get(j);
+                    wb.addDeleteItem(b -> b.key(
+                            Key.builder()
+                                    .partitionValue(c.getRoomId())
+                                    .sortValue(c.getSentAt())
+                                    .build()
+                    ));
+                }
+
+                BatchWriteItemEnhancedRequest batchReq = BatchWriteItemEnhancedRequest.builder()
+                        .writeBatches(wb.build())
+                        .build();
+
+                enhancedClient.batchWriteItem(batchReq);
+            }
+
+            lek = page.lastEvaluatedKey();
+        } while (lek != null && !lek.isEmpty());
+    }
 }

chat-server/src/main/java/com/example/demo/global/redis/ChatRedisSubscriber.java

@@ -1,6 +1,8 @@
 package com.example.demo.global.redis;
 
 import com.example.demo.dto.ChatOutbound;
+import com.example.demo.dto.PlaylistDeleteEvent;
+import com.example.demo.service.ChatService;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.RequiredArgsConstructor;
 import org.springframework.beans.factory.annotation.Value;
@@ -15,18 +17,33 @@ public class ChatRedisSubscriber implements MessageListener {
 
     private final SimpMessagingTemplate messagingTemplate;
     private final ObjectMapper objectMapper;
+    private final ChatService chatService;
+
+    @Value("${chat.redis.topic-prefix:chat.}")
+    private String topicPrefix;
 
     //Redis Pub/Sub으로 메시지를 받았을 때 실행됨
+    @Override
     public void onMessage(Message message, byte[] pattern) {
         try {
-            // Redis에서 전달받은 payload
+            String channel = new String(message.getChannel());
             String body = new String(message.getBody());
 
-            ChatOutbound chatOutbound = objectMapper.readValue(body, ChatOutbound.class);
-
-            // STOMP 구독자에게 브로드캐스트 (/chat/topic/rooms/{roomId})
-            String destination = "/chat/topic/rooms/" + chatOutbound.getRoomId();
-            messagingTemplate.convertAndSend(destination, chatOutbound);
+            if (channel.equals("chat.playlist.deleted")) {
+                PlaylistDeleteEvent playlistDeleteEvent = objectMapper.readValue(body, PlaylistDeleteEvent.class);
+                String roomId = playlistDeleteEvent.playlistId();   // == roomId
+                if (roomId != null && !roomId.isBlank()) {
+                    chatService.deleteAllByRoomId(roomId);
+                }
+                return;
+            }
+
+            // 실시간 메시지 브로드캐스트 (예: chat.room.*)
+            if (channel.startsWith(topicPrefix +"room.")) {
+                ChatOutbound chatOutbound = objectMapper.readValue(body, ChatOutbound.class);
+                String destination = "/chat/topic/rooms/" + chatOutbound.getRoomId();
+                messagingTemplate.convertAndSend(destination, chatOutbound);
+            }
 
         } catch (Exception e) {
             e.printStackTrace();

chat-server/src/main/java/com/example/demo/global/redis/RedisConfig.java

@@ -32,13 +32,11 @@ public class RedisConfig {
 
     @Bean
     public RedisConnectionFactory redisConnectionFactory() {
-        // Standalone 설정 (클러스터/리플리카 셋업이 아니면 보통 이걸로 충분)
         RedisStandaloneConfiguration standalone = new RedisStandaloneConfiguration(redisHost, redisPort);
         if (redisPassword != null && !redisPassword.isEmpty()) {
             standalone.setPassword(RedisPassword.of(redisPassword));
         }
 
-        // Lettuce 클라이언트 옵션 + SSL 여부
         LettuceClientConfiguration.LettuceClientConfigurationBuilder clientBuilder =
                 LettuceClientConfiguration.builder();
 
@@ -55,7 +53,6 @@ public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory cf) {
         return new StringRedisTemplate(cf);
     }
 
-    // 모든 room 채널을 패턴 구독
     @Bean
     public RedisMessageListenerContainer redisMessageListenerContainer(
             RedisConnectionFactory cf,
@@ -68,7 +65,6 @@ public RedisMessageListenerContainer redisMessageListenerContainer(
         return container;
     }
 
-    // Redis 수신 메시지를 처리할 리스너 어댑터 (ChatRedisSubscriber.onMessage 호출)
     @Bean
     public MessageListenerAdapter chatMessageListenerAdapter(ChatRedisSubscriber subscriber) {
         // 리플렉션으로 subscriber.onMessage(Message, byte[]) 호출

chat-server/src/main/java/com/example/demo/service/ChatService.java

@@ -50,7 +50,7 @@ public void handleInbound(String roomId, ChatInbound chatInbound) {
 
         // 2) Redis Pub/Sub 발행 (모든 인스턴스가 수신)
         try {
-            String channel = topicPrefix + roomId;     // ex) chat.room.room-1
+            String channel = topicPrefix + "room." + roomId;     // ex) chat.room.room-1
             String payload = objectMapper.writeValueAsString(chatOutbound);
             stringRedisTemplate.convertAndSend(channel, payload);
         } catch (Exception e) {
@@ -108,4 +108,9 @@ public void deleteMessage(String roomId, String messageId, String userId) {
     public int countByRoomId(String roomId) {
         return chatRepository.countByRoomId(roomId);
     }
+
+    public void deleteAllByRoomId(String roomId) {
+        // 멱등성: 존재하지 않아도 예외 없이 통과
+        chatRepository.deleteAllByRoomId(roomId);
+    }
 }

main-server/src/main/java/com/example/demo/domain/playlist/event/PlaylistDeleteEvent.java

@@ -0,0 +1,7 @@
+package com.example.demo.domain.playlist.event;
+
+import lombok.Builder;
+
+@Builder
+public record PlaylistDeleteEvent(String playlistId) {
+}

main-server/src/main/java/com/example/demo/domain/playlist/event/PlaylistEventHandler.java

@@ -0,0 +1,19 @@
+package com.example.demo.domain.playlist.event;
+
+import com.example.demo.global.redis.PlaylistEventPublisher;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+@Component
+@RequiredArgsConstructor
+public class PlaylistEventHandler {
+
+    private final PlaylistEventPublisher playlistEventPublisher;
+
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void handlePlaylistDeletedEvent(PlaylistDeleteEvent event) {
+        playlistEventPublisher.publishPlaylistDelete(event.playlistId());
+    }
+}

main-server/src/main/java/com/example/demo/domain/playlist/service/PlaylistServiceImpl.java

@@ -12,6 +12,7 @@
 import com.example.demo.domain.playlist.dto.playlistdto.PlaylistCreateRequest;
 import com.example.demo.domain.playlist.dto.playlistdto.PlaylistWithSongsResponse;
 import com.example.demo.domain.playlist.entity.Playlist;
+import com.example.demo.domain.playlist.event.PlaylistDeleteEvent;
 import com.example.demo.domain.playlist.repository.PlaylistRepository;
 import com.example.demo.domain.recommendation.entity.UserPlaylistHistory;
 import com.example.demo.domain.recommendation.repository.UserPlaylistHistoryRepository;
@@ -23,6 +24,7 @@
 import java.util.*;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -38,6 +40,7 @@ public class PlaylistServiceImpl implements PlaylistService {
     private final SongRepository songRepository;
     private final CdService cdService;
     private final CdRepository cdRepository;
+    private final ApplicationEventPublisher applicationEventPublisher;
 
     @Override
     @Transactional
@@ -108,22 +111,15 @@ public void deletePlaylist(String userId, Long playlistId) {
                         PlaylistErrorCode.PLAYLIST_NOT_FOUND
                 ));
 
-        // 2. 유저가 가진 플리 개수 확인
-        long totalCount = playlistRepository.countByUserIdNative(userId);
-        if (totalCount <= 1) {
-            throw new PlaylistException(
-                    "플레이리스트는 최소 1개 이상 존재해야 합니다.",
-                    PlaylistErrorCode.PLAYLIST_NOT_FOUND
-            );
-        }
-
-        //  4. 참조 테이블 순차 삭제 (중요!)
+        //  2. 참조 테이블 순차 삭제 (중요!)
         cdRepository.deleteByPlaylistId(playlistId); // CD 테이블
         songRepository.deleteByPlaylistId(playlistId); // 곡
         userPlaylistHistoryRepository.deleteByPlaylistId(playlistId); // 재생기록
 
-        // 5. 플레이리스트 삭제
+        // 3. 플레이리스트 삭제
         playlistRepository.delete(toDelete);
+
+        applicationEventPublisher.publishEvent(new PlaylistDeleteEvent(String.valueOf(playlistId)));
     }
 
 }

main-server/src/main/java/com/example/demo/global/redis/PlaylistEventPublisher.java

@@ -0,0 +1,33 @@
+package com.example.demo.global.redis;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Component
+@RequiredArgsConstructor
+public class PlaylistEventPublisher {
+
+    private final StringRedisTemplate redisTemplate;
+    private final ObjectMapper objectMapper = new ObjectMapper();
+
+    @Value("${chat.redis.topic-playlist-deleted:chat.playlist.deleted}")
+    private String playlistDeletedTopic;
+
+    public void publishPlaylistDelete(String playlistId) {
+        try {
+            Map<String, Object> payload = new HashMap<>();
+            payload.put("playlistId", playlistId);
+
+            String message = objectMapper.writeValueAsString(payload);
+            redisTemplate.convertAndSend(playlistDeletedTopic, message);
+        } catch (Exception e) {
+            //
+        }
+    }
+}

main-server/src/main/java/com/example/demo/global/redis/RedisConfig.java

@@ -1,14 +1,33 @@
 package com.example.demo.global.redis;
 
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.RedisPassword;
+import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
+import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
 import org.springframework.data.redis.core.StringRedisTemplate;
 
 
 @Configuration
 public class RedisConfig {
 
+    @Value("${spring.data.redis.host}") private String redisHost;
+    @Value("${spring.data.redis.port}") private int redisPort;
+    @Value("${spring.data.redis.password:}") private String redisPassword;
+    @Bean
+    public RedisConnectionFactory redisConnectionFactory() {
+        RedisStandaloneConfiguration standalone = new RedisStandaloneConfiguration(redisHost, redisPort);
+        if (redisPassword != null && !redisPassword.isEmpty()) {
+            standalone.setPassword(RedisPassword.of(redisPassword));
+        }
+        LettuceClientConfiguration.LettuceClientConfigurationBuilder clientBuilder =
+                LettuceClientConfiguration.builder();
+        return new LettuceConnectionFactory(standalone, clientBuilder.build());
+    }
+
     @Bean
     public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory cf) {
         return new StringRedisTemplate(cf);