Mirrors/audiobookshelf
Mirrors/audiobookshelf
1
0
Fork 0
mirror of https://github.com/advplyr/audiobookshelf.git synced 2025-01-08 00:08:14 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix check podcast episodes cronjob

Browse Source
This commit is contained in:
advplyr 2022-04-14 10:15:42 -05:00
parent 05dff2583a
commit 8bbeae4873
1 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
server/managers/PodcastManager.js
View File

@ -139,33 +139,32 @@ class PodcastManager {
} }
async checkForNewEpisodes() { async checkForNewEpisodes() {
var podcastsWithAutoDownload = this.db.libraryItems.find(li => li.mediaType === 'podcast' && li.media.autoDownloadEpisodes) var podcastsWithAutoDownload = this.db.libraryItems.filter(li => li.mediaType === 'podcast' && li.media.autoDownloadEpisodes)
if (!podcastsWithAutoDownload.length) { if (!podcastsWithAutoDownload.length) {
this.cancelCron() this.cancelCron()
return return
} }
for (const libraryItem of podcastsWithAutoDownload) { for (const libraryItem of podcastsWithAutoDownload) {
Logger.info(`[PodcastManager] checkForNewEpisodes Cron for "${libraryItem.media.metadata.title}"`) const lastEpisodeCheckDate = new Date(libraryItem.media.lastEpisodeCheck || 0)
Logger.info(`[PodcastManager] checkForNewEpisodes Cron for "${libraryItem.media.metadata.title}" - Last episode check: ${lastEpisodeCheckDate}`)
var newEpisodes = await this.checkPodcastForNewEpisodes(libraryItem) var newEpisodes = await this.checkPodcastForNewEpisodes(libraryItem)
var hasUpdates = false
if (!newEpisodes) { // Failed if (!newEpisodes) { // Failed
libraryItem.media.autoDownloadEpisodes = false libraryItem.media.autoDownloadEpisodes = false
hasUpdates = true
} else if (newEpisodes.length) { } else if (newEpisodes.length) {
Logger.info(`[PodcastManager] Found ${newEpisodes.length} new episodes for podcast "${libraryItem.media.metadata.title}" - starting download`) Logger.info(`[PodcastManager] Found ${newEpisodes.length} new episodes for podcast "${libraryItem.media.metadata.title}" - starting download`)
this.downloadPodcastEpisodes(libraryItem, newEpisodes) this.downloadPodcastEpisodes(libraryItem, newEpisodes)
hasUpdates = true } else {
Logger.debug(`[PodcastManager] No new episodes for "${libraryItem.media.metadata.title}"`)
} }
if (hasUpdates) {
libraryItem.media.lastEpisodeCheck = Date.now() libraryItem.media.lastEpisodeCheck = Date.now()
libraryItem.updatedAt = Date.now() libraryItem.updatedAt = Date.now()
await this.db.updateLibraryItem(libraryItem) await this.db.updateLibraryItem(libraryItem)
this.emitter('item_updated', libraryItem.toJSONExpanded()) this.emitter('item_updated', libraryItem.toJSONExpanded())
} }
} }
}
async checkPodcastForNewEpisodes(podcastLibraryItem) { async checkPodcastForNewEpisodes(podcastLibraryItem) {
if (!podcastLibraryItem.media.metadata.feedUrl) { if (!podcastLibraryItem.media.metadata.feedUrl) {