check torrs empty output

lieranderl · Aug 25, 2023 · f625de5 · f625de5
1 parent b676f5b
commit f625de5
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/executor/executor.go b/executor/executor.go
@@ -177,8 +177,6 @@ func (p *TrackersPipeline) RunTrackersSearchPipilene(isMovie string) *TrackersPi
 	allTorrents := pipeline.Merge(ctx, torrentsResults1, torrentsResults2)
 	allErrors := pipeline.Merge(ctx, rutorErrors1, rutorErrors2)
 
-	log.Println("ALL len: ", len(allTorrents))
-
 	ts, err := torrents.MergeTorrentChannlesToSlice(ctx, cancel, allTorrents, allErrors)
 	log.Println("TS length before: ", len(ts))
 	ts = torrents.RemoveDuplicatesInPlace(ts)

diff --git a/internal/torrents/torrent.go b/internal/torrents/torrent.go
@@ -44,6 +44,11 @@ func MergeTorrentChannlesToSlice(ctx context.Context, cancelFunc context.CancelF
 		case res, ok := <-values:
 			if ok {
 				torrents = append(torrents, res...)
+				log.Print("Appending ", len(res), " torrents to slice. Total: ", len(torrents), " torrents")
+				if len(res) == 0 {
+					log.Print("Empty slice received")
+					return torrents, nil
+				}
 			} else {
 				log.Print("done")
 				return torrents, nil