Fixed Deezer listen export count

internal/backends/deezer/deezer.go

@@ -83,10 +83,14 @@ func (b *DeezerApiBackend) ExportListens(oldestTimestamp time.Time, results chan
 	offset := math.MaxInt32
 	perPage := MaxItemsPerGet
 
+	startTime := time.Now()
+	minTime := oldestTimestamp
+
+	totalDuration := startTime.Sub(oldestTimestamp)
+
 	defer close(results)
 
-	p := models.Progress{Total: int64(perPage)}
+	p := models.Progress{Total: int64(totalDuration.Seconds())}
-	var totalCount int
 
 out:
 	for {
@@ -101,7 +105,6 @@ out:
 		// and continue.
 		if offset >= result.Total {
 			p.Total = int64(result.Total)
-			totalCount = result.Total
 			offset = result.Total - perPage
 			if offset < 0 {
 				offset = 0
@@ -120,15 +123,19 @@ out:
 			if listen.ListenedAt.Unix() > oldestTimestamp.Unix() {
 				listens = append(listens, listen)
 			} else {
-				totalCount -= 1
 				break
 			}
 		}
 
 		sort.Sort(listens)
-		results <- models.ListensResult{Items: listens, Total: totalCount}
+		if len(listens) > 0 {
-		p.Elapsed += int64(count)
+			minTime = listens[0].ListenedAt
+		}
+
+		remainingTime := startTime.Sub(minTime)
+		p.Elapsed = int64(totalDuration.Seconds() - remainingTime.Seconds())
 		progress <- p
+		results <- models.ListensResult{Items: listens, OldestTimestamp: minTime}
 
 		if offset <= 0 {
 			// This was the last request, no further results
@@ -141,6 +148,7 @@ out:
 		}
 	}
 
+	results <- models.ListensResult{OldestTimestamp: minTime}
 	progress <- p.Complete()
 }