groove/audiobookshelf
1
0
Fork 0
mirror of https://github.com/advplyr/audiobookshelf.git synced 2026-07-10 11:21:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Update the podcastmanager

Browse source
This commit is contained in:
mfcar 2023-10-03 12:33:46 +01:00
parent aefcc4490f
commit 309f5ef5e3
No known key found for this signature in database
1 changed files with 16 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

29
server/managers/PodcastManager.js
View file

@ -285,14 +285,14 @@ class PodcastManager {
Logger.error(`[PodcastManager] checkPodcastForNewEpisodes no feed url for ${podcastLibraryItem.media.metadata.title} (ID: ${podcastLibraryItem.id})`)
return false
}
var feed = await getPodcastFeed(podcastLibraryItem.media.metadata.feedUrl)
let feed = await getPodcastFeed(podcastLibraryItem.media.metadata.feedUrl)
if (!feed || !feed.episodes) {
Logger.error(`[PodcastManager] checkPodcastForNewEpisodes invalid feed payload for ${podcastLibraryItem.media.metadata.title} (ID: ${podcastLibraryItem.id}, URL: ${podcastLibraryItem.media.metadata.feedUrl})`, feed)
return false
}
// Filter new and not already has
var newEpisodes = feed.episodes.filter(ep => ep.publishedAt > dateToCheckForEpisodesAfter && !podcastLibraryItem.media.checkHasEpisodeByFeedUrl(ep.enclosure.url))
let newEpisodes = feed.episodes.filter(ep => ep.publishedAt > dateToCheckForEpisodesAfter && !podcastLibraryItem.media.checkHasEpisodeByFeedUrl(ep.enclosure.url))
if (maxNewEpisodes > 0) {
newEpisodes = newEpisodes.slice(0, maxNewEpisodes)
@ -326,13 +326,22 @@ class PodcastManager {
return newEpisodes
}
setFeedHealthStatus(libraryItem, isHealthy) {
libraryItem.media.metadata.feedHealthy = isHealthy
async setFeedHealthStatus(podcastId, isHealthy) {
const podcast = await Database.podcastModel.findByPk(podcastId)
if (!podcast) return
podcast.feedHealthy = isHealthy
if (isHealthy) {
libraryItem.media.lastSuccessfulFetchAt = Date.now()
podcast.lastSuccessfulFetchAt = Date.now()
}
libraryItem.updatedAt = Date.now()
Database.updateLibraryItem(libraryItem)
podcast.lastEpisodeCheck = Date.now()
podcast.updatedAt = Date.now()
await Database.podcastModel.update(podcast, {
where: { id: podcastId }
})
return {lastEpisodeCheck: podcast.lastEpisodeCheck, lastSuccessfulFetchAt: podcast.lastSuccessfulFetchAt, feedHealthy: podcast.feedHealthy}
}
async findEpisode(rssFeedUrl, searchTitle) {
@ -408,12 +417,6 @@ class PodcastManager {
queue: this.downloadQueue.filter(item => !libraryId || item.libraryId === libraryId).map(item => item.toJSONForClient())
}
}
async getPodcastsWithIncomingFeeds() {
const podcasts = await Database.models.podcast.getAllIncomingFeeds()
Logger.info(`[PodcastManager] Fetched ${podcasts.length} podcasts with incoming feeds`)
return podcasts
}
}
module.exports = PodcastManager