mirror/mxpv-podsync
1
0
Fork 0
mirror of https://github.com/mxpv/podsync.git synced 2024-05-11 05:55:04 +00:00
Code Issues Releases Activity

Respect page_size parameter when downloading episodes

Browse Source
This commit is contained in:
Maksym Pavlenko
2020-04-16 13:54:45 -07:00
parent 174557ee4f
commit 40dd2f5779
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
cmd/podsync/updater.go
View File

@@ -105,8 +105,11 @@ func (u *Updater) downloadEpisodes(ctx context.Context, feedConfig *config.Feed)
var (
feedID = feedConfig.ID
downloadList []*model.Episode
pageSize = feedConfig.PageSize
)
log.WithField("page_size", pageSize).Info("downloading episodes")
// Build the list of files to download
if err := u.db.WalkEpisodes(ctx, feedID, func(episode *model.Episode) error {
if episode.Status != model.EpisodeNew && episode.Status != model.EpisodeError {
@@ -126,6 +129,13 @@ func (u *Updater) downloadEpisodes(ctx context.Context, feedConfig *config.Feed)
}
}
// Limit the number of episodes downloaded at once
pageSize--
if pageSize <= 0 {
return nil
}
log.Debugf("adding %s (%q) to the list", episode.ID, episode.Title)
downloadList = append(downloadList, episode)
return nil
}); err != nil {