From 40dd2f57790198eda6443f714f9b73c10a8887bb Mon Sep 17 00:00:00 2001
From: Maksym Pavlenko <pavlenko.maksym@gmail.com>
Date: Thu, 16 Apr 2020 13:54:45 -0700
Subject: [PATCH] Respect page_size parameter when downloading episodes

---
 cmd/podsync/updater.go | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/cmd/podsync/updater.go b/cmd/podsync/updater.go
index aaad9b4..772cd7c 100644
--- a/cmd/podsync/updater.go
+++ b/cmd/podsync/updater.go
@@ -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 {