#324 Refactor podcast episode retrieval and media file

handling
kagemomiji · Dec 10, 2023 · dbcfbe7 · dbcfbe7
1 parent cb4308f
commit dbcfbe7
Showing 1 changed file with 27 additions and 3 deletions.
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
@@ -365,7 +365,17 @@ public List<PodcastEpisode> getEpisodes(Integer channelId) {
             return podcastEpisodeRepository.findByChannel(channel).stream()
                 .filter(filterAllowed)
                 .map(ep -> {
-                    ep.getMediaFile();
+                    MediaFile mediaFile = ep.getMediaFile();
+                    if (mediaFile != null) {
+                        // Refresh media file to check if it still exists
+                        mediaFileService.refreshMediaFile(mediaFile);
+                        if (!mediaFile.isPresent() && ep.getStatus() != PodcastStatus.DELETED) {
+                            // If media file is not present anymore, set episode status to deleted
+                            ep.setStatus(PodcastStatus.DELETED);
+                            ep.setErrorMessage(null);
+                            podcastEpisodeRepository.save(ep);
+                        }
+                    }
                     return ep;
                 })
                 .sorted(Comparator.comparing(PodcastEpisode::getPublishDate, Comparator.nullsLast(Comparator.reverseOrder())))
@@ -400,8 +410,22 @@ public List<PodcastEpisode> getNewestEpisodes(int count) {
      */
     public PodcastEpisode getEpisode(int episodeId, boolean includeDeleted) {
         return podcastEpisodeRepository.findById(episodeId)
-           .filter(episode -> includeDeleted || episode.getStatus() != PodcastStatus.DELETED)
-           .orElse(null);
+                .map(ep -> {
+                    MediaFile mediaFile = ep.getMediaFile();
+                    if (mediaFile != null) {
+                        // Refresh media file to check if it still exists
+                        mediaFileService.refreshMediaFile(mediaFile);
+                        if (!mediaFile.isPresent() && ep.getStatus() != PodcastStatus.DELETED) {
+                            // If media file is not present anymore, set episode status to deleted
+                            ep.setStatus(PodcastStatus.DELETED);
+                            ep.setErrorMessage(null);
+                            podcastEpisodeRepository.save(ep);
+                        }
+                    }
+                    return ep;
+                })
+                .filter(episode -> includeDeleted || episode.getStatus() != PodcastStatus.DELETED)
+                .orElse(null);
     }
 
     /**