diff --git a/internal/backends/scrobblerlog/scrobblerlog.go b/internal/backends/scrobblerlog/scrobblerlog.go index 19ed30b..7955c15 100644 --- a/internal/backends/scrobblerlog/scrobblerlog.go +++ b/internal/backends/scrobblerlog/scrobblerlog.go @@ -151,9 +151,12 @@ func (b *ScrobblerLogBackend) ExportListens(oldestTimestamp time.Time, results c listens := make(models.ListensList, 0, len(b.log.Records)) client := strings.Split(b.log.Client, " ")[0] for _, record := range b.log.Records { - listens = append(listens, recordToListen(record, client)) + listen := recordToListen(record, client) + if listen.ListenedAt.After(oldestTimestamp) { + listens = append(listens, recordToListen(record, client)) + } } - sort.Sort(listens.NewerThan(oldestTimestamp)) + sort.Sort(listens) progress <- models.Progress{Total: int64(len(listens))}.Complete() results <- models.ListensResult{Items: listens} }