#336 refactored initialize podcast episodes

kagemomiji · Dec 21, 2023 · 1d5ed32 · 1d5ed32
1 parent 5233db4
commit 1d5ed32
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/airsonic-main/src/main/java/org/airsonic/player/repository/PodcastEpisodeRepository.java b/airsonic-main/src/main/java/org/airsonic/player/repository/PodcastEpisodeRepository.java
@@ -23,7 +23,9 @@ public Optional<PodcastEpisode> findByChannelAndTitleAndPublishDate(PodcastChann
 
     public List<PodcastEpisode> findByChannel(PodcastChannel channel);
 
+    public List<PodcastEpisode> findByChannelAndStatus(PodcastChannel channel, PodcastStatus status);
+
     public List<PodcastEpisode> findByStatusAndPublishDateNotNullAndMediaFilePresentTrueOrderByPublishDateDesc(
-            PodcastStatus status);
+                    PodcastStatus status);
 
 }
diff --git a/airsonic-main/src/main/java/org/airsonic/player/service/PodcastPersistenceService.java b/airsonic-main/src/main/java/org/airsonic/player/service/PodcastPersistenceService.java
@@ -106,11 +106,9 @@ public PodcastPersistenceService(
      */
     public void cleanDownloadingEpisodes() {
         podcastChannelRepository.findAll()
-            .parallelStream()
-            .map(PodcastChannel::getId)
-            .map(this::getEpisodes)
-            .flatMap(List::parallelStream)
-            .filter(e -> e.getStatus() == PodcastStatus.DOWNLOADING)
+            .stream()
+            .flatMap(c -> podcastEpisodeRepository.findByChannelAndStatus(c, PodcastStatus.DOWNLOADING).stream())
+            .filter(filterAllowed)
             .forEach(e -> {
                 deleteEpisode(e, false);
                 LOG.info("Deleted Podcast episode '{}' since download was interrupted.", e.getTitle());