Merge pull request #36 from aws-cloud-clubs/hotfix/follow-list-redis

hotfix: RedisTemplate<String, Object> -> <String, Long>

src/main/java/com/goormy/hackathon/repository/Redis/FollowListRedisRepository.java

@@ -2,80 +2,61 @@
 
 import com.goormy.hackathon.entity.Follow;
 import com.goormy.hackathon.repository.JPA.FollowRepository;
-import org.springframework.beans.factory.annotation.Autowired;
+import jakarta.annotation.PostConstruct;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.core.ListOperations;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Repository;
 
 import java.util.ArrayList;
 import java.util.List;
-import java.util.Objects;
 import java.util.Set;
-import java.util.stream.Collectors;
 
 @Repository
+@RequiredArgsConstructor
 public class FollowListRedisRepository {
 
-    @Autowired
-    RedisTemplate<String, Object> redisTemplate;
+    private final RedisTemplate<String, Long> redisTemplate;
+    private final FollowRepository followRepository;
 
-    @Autowired
-    FollowRepository followRepository;
+    private static final String FEED_USER_SORTED_KEY = "hashtagId:";
+
+    private ListOperations<String, Long> listOperations;
+
+    @PostConstruct
+    private void init() {
+        listOperations = redisTemplate.opsForList();
+    }
 
     public void set(Long hashtagId, Long userId) {
-        String key = "hashtagId:" + hashtagId.toString();
-        redisTemplate.opsForList().rightPush(key, userId.toString());
+        listOperations.leftPush(FEED_USER_SORTED_KEY + hashtagId, userId);
     }
 
     public void delete(Long hashtagId, Long userId) {
-        String key = "hashtagId:" + hashtagId.toString();
-        redisTemplate.opsForList().remove(key, 0, userId);
+        listOperations.trim(FEED_USER_SORTED_KEY + hashtagId, 0, -1);
     }
 
     public List<Follow> getAllFollows() {
-        // Redis에서 데이터를 가져와 RDBMS로 마이그레이션
-        List<Follow> follows = new ArrayList<>();
-
-        // 모든 키 가져오기
         Set<String> keys = redisTemplate.keys("hashtagId:*");
-
+        List<Follow> follows = new ArrayList<>();
         if (keys != null) {
             for (String key : keys) {
-                List<Long> userIds = (List<Long>) (List<?>) redisTemplate.opsForList().range(key, 0, -1);
+                List<Long> userIds = listOperations.range(key, 0, -1);
                 if (userIds != null) {
                     for (Long userId : userIds) {
                         Long hashtagId = Long.parseLong(key.split(":")[1]);
-                        Follow follow = followRepository.findByUserIdAndHashTagId(userId,hashtagId)
+                        Follow follow = followRepository.findByUserIdAndHashTagId(userId, hashtagId)
                                 .orElseThrow(() -> new RuntimeException("존재하지 않는 팔로우입니다. userId: " + userId + " hashtagId: " + hashtagId));
                         follows.add(follow);
                     }
                 }
             }
         }
-
         return follows;
     }
 
-    // TODO: 수정 필요 - save 하는 쪽이 어떤 식으로 저장하느냐에 따라 호출 구현이 다를 듯
     public List<Long> findUserIdListByHashtagId(Long hashtagId) {
-        String key = "hashtagId:" + hashtagId;
-        List<Object> objects = redisTemplate.opsForList().range(key, 0, -1);
-
-        List<Long> longList = objects.stream()
-                .map(obj -> {
-                    try {
-                        return ((Number) obj).longValue();
-                    } catch (ClassCastException e) {
-                        // 예외 처리 로직 작성
-                        System.out.println(">>>" + obj);
-                        return null;
-                    }
-                })
-                .filter(Objects::nonNull)
-                .toList();
-        return longList;
+            return listOperations.range(FEED_USER_SORTED_KEY + hashtagId, 0, -1);
     }
 
-
-
-
 }