[DDING-81] 동영상 Converting 상태 검증 쿼리 작성 (#225)

(cherry picked from commit 6142d78)

Author: KoSeonJe

src/main/java/ddingdong/ddingdongBE/domain/feed/repository/FeedRepository.java

@@ -9,14 +9,29 @@
 public interface FeedRepository extends JpaRepository<Feed, Long> {
 
     @Query(value = """
-        select *
-          from feed f
-          where (:currentCursorId = -1 or id < :currentCursorId)
-          and f.club_id = :clubId
-          and deleted_at is null
-          order by f.id DESC
-          limit :size
-        """, nativeQuery = true)
+            select *
+              from feed f
+              where (:currentCursorId = -1 or id < :currentCursorId)
+              and f.club_id = :clubId
+              and deleted_at is null
+              and (
+                    f.feed_type != 'VIDEO'
+                    or exists (
+                         select 1
+                            from (
+                                select id
+                                    from file_meta_data
+                                    where entity_id = f.id
+                                    and domain_type = 'FEED_VIDEO'
+                            ) filtered_fm
+                            join vod_processing_job vpj
+                            on filtered_fm.id = vpj.file_meta_data_id
+                            where vpj.convert_job_status = 'COMPLETE'
+                            )
+                    )
+              order by f.id DESC
+              limit :size
+            """, nativeQuery = true)
     Slice<Feed> findPageByClubIdOrderById(
         @Param("clubId") Long clubId,
         @Param("size") int size,
@@ -29,6 +44,21 @@ Slice<Feed> findPageByClubIdOrderById(
         (select max(id)
         from feed
         where deleted_at is null
+        and (
+            f.feed_type != 'VIDEO'
+            or exists (
+                 select 1
+                    from (
+                        select id
+                            from file_meta_data
+                            where entity_id = f.id
+                            and domain_type = 'FEED_VIDEO'
+                    ) filtered_fm
+                    join vod_processing_job vpj
+                    on filtered_fm.id = vpj.file_meta_data_id
+                    where vpj.convert_job_status = 'COMPLETE'
+                    )
+            )
         GROUP BY club_id)
         and (:currentCursorId = -1 or id < :currentCursorId)
         ORDER BY id DESC

src/main/java/ddingdong/ddingdongBE/domain/feed/service/GeneralFeedService.java

@@ -3,12 +3,9 @@
 import ddingdong.ddingdongBE.common.exception.PersistenceException.ResourceNotFound;
 import ddingdong.ddingdongBE.domain.feed.entity.Feed;
 import ddingdong.ddingdongBE.domain.feed.repository.FeedRepository;
-import ddingdong.ddingdongBE.domain.vodprocessing.entity.VodProcessingJob;
-import ddingdong.ddingdongBE.domain.vodprocessing.service.VodProcessingJobService;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Optional;
-import java.util.stream.Collectors;
 import lombok.RequiredArgsConstructor;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Slice;
@@ -22,7 +19,6 @@
 public class GeneralFeedService implements FeedService {
 
     private final FeedRepository feedRepository;
-    private final VodProcessingJobService vodProcessingJobService;
 
     @Override
     public Slice<Feed> getFeedPageByClubId(Long clubId, int size, Long currentCursorId) {
@@ -61,9 +57,7 @@ public void delete(Feed feed) {
     }
 
     private Slice<Feed> buildSlice(Slice<Feed> originalSlice, int size) {
-        List<Feed> content = new ArrayList<>(originalSlice.getContent()).stream()
-                .filter(this::isComplete)
-                .collect(Collectors.toList());
+        List<Feed> content = new ArrayList<>(originalSlice.getContent());
         if (content.isEmpty()) {
             return null;
         }
@@ -76,16 +70,4 @@ private Slice<Feed> buildSlice(Slice<Feed> originalSlice, int size) {
 
         return new SliceImpl<>(content, PageRequest.of(originalSlice.getNumber(), size), hasNext);
     }
-
-    private boolean isComplete(Feed feed) {
-        if (feed.isImage()) {
-            return true;
-        }
-
-        VodProcessingJob vodProcessingJob = vodProcessingJobService.findByVideoFeedId(feed.getId());
-        if (vodProcessingJob == null) {
-            return false;
-        }
-        return vodProcessingJob.isCompleted();
-    }
 }