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

Fix feed ID

Browse Source
This commit is contained in:
Maksym Pavlenko
2019-12-01 16:01:36 -08:00
committed by Maksym Pavlenko
parent 8957f70b19
commit 4daecf4990
4 changed files with 32 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
cmd/podsync/updater.go
View File

@@ -89,7 +89,7 @@ func (u *Updater) updateFeed(ctx context.Context, feedConfig *config.Feed) error
log.Debugf("received %d episode(s) for %q", len(result.Episodes), result.Title)
if err := u.db.AddFeed(ctx, result); err != nil {
if err := u.db.AddFeed(ctx, feedConfig.ID, result); err != nil {
return err
}
@@ -121,7 +121,17 @@ func (u *Updater) downloadEpisodes(ctx context.Context, feedConfig *config.Feed,
return errors.Wrapf(err, "failed to build update list")
}
log.Debugf("update list: %+v", updateList)
var (
updateListLen = len(updateList)
downloaded = 0
)
if updateListLen > 0 {
log.Infof("update list size: %d", updateListLen)
} else {
log.Info("no episodes to download")
return nil
}
// Download pending episodes
for idx, episode := range updateList {
@@ -181,12 +191,15 @@ func (u *Updater) downloadEpisodes(ctx context.Context, feedConfig *config.Feed,
// Update file status in database
logger.Infof("successfully downloaded file %q", episode.ID)
if err := u.db.UpdateFile(feedID, episode.ID, func(file *model.File) error {
// Record file size of newly downloaded file
size, err := u.fileSize(episodePath)
if err != nil {
logger.WithError(err).Error("failed to get episode file size")
} else {
logger.Debugf("file size: %d bytes", file.Size)
file.Size = size
}
@@ -195,8 +208,11 @@ func (u *Updater) downloadEpisodes(ctx context.Context, feedConfig *config.Feed,
}); err != nil {
return err
}
downloaded++
}
log.Infof("downloaded %d episode(s)", downloaded)
return nil
}