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

Replace numEpisodesIncomplete subquery with cached user progress calculation

Browse Source
This commit is contained in:
mikiher 2025-02-16 09:22:06 +02:00
parent 707533df8f
commit cb9fc3e0d1
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
server/utils/queries/libraryItemsPodcastFilters.js
View File

@ -140,9 +140,6 @@ module.exports = {
} }
const podcastIncludes = [] const podcastIncludes = []
if (includeNumEpisodesIncomplete) {
podcastIncludes.push([Sequelize.literal(`(SELECT count(*) FROM podcastEpisodes pe LEFT OUTER JOIN mediaProgresses mp ON mp.mediaItemId = pe.id AND mp.userId = :userId WHERE pe.podcastId = podcast.id AND (mp.isFinished = 0 OR mp.isFinished IS NULL))`), 'numEpisodesIncomplete'])
}
let { mediaWhere, replacements } = this.getMediaGroupQuery(filterGroup, filterValue) let { mediaWhere, replacements } = this.getMediaGroupQuery(filterGroup, filterValue)
replacements.userId = user.id replacements.userId = user.id
@ -184,8 +181,15 @@ module.exports = {
if (libraryItem.feeds?.length) { if (libraryItem.feeds?.length) {
libraryItem.rssFeed = libraryItem.feeds[0] libraryItem.rssFeed = libraryItem.feeds[0]
} }
if (podcast.dataValues.numEpisodesIncomplete) {
libraryItem.numEpisodesIncomplete = podcast.dataValues.numEpisodesIncomplete if (includeNumEpisodesIncomplete) {
const numEpisodesComplete = user.mediaProgresses.reduce((acc, mp) => {
if (mp.podcastId === podcast.id && mp.isFinished) {
acc += 1
}
return acc
}, 0)
libraryItem.numEpisodesIncomplete = podcast.numEpisodes - numEpisodesComplete
} }
libraryItem.media = podcast libraryItem.media = podcast