From 8467dbb9bd9960191f16def3ba43dcbde0fdda14 Mon Sep 17 00:00:00 2001
From: René 'Necoro' Neumann <necoro@necoro.eu>
Date: Thu, 23 Apr 2020 23:48:09 +0200
Subject: Notify about the number of successfully fetched feeds.

---
 internal/feed/parse.go | 24 +++++++++++++++++++-----
 1 file changed, 19 insertions(+), 5 deletions(-)

(limited to 'internal')

diff --git a/internal/feed/parse.go b/internal/feed/parse.go
index 22d16f2..35a7596 100644
--- a/internal/feed/parse.go
+++ b/internal/feed/parse.go
@@ -32,22 +32,36 @@ func parseFeed(feed *Feed) error {
 	return nil
 }
 
-func handleFeed(feed *Feed, wg *sync.WaitGroup) {
-	defer wg.Done()
+func handleFeed(feed *Feed, group *sync.WaitGroup, success chan<- bool) {
+	defer group.Done()
 	log.Printf("Fetching %s from %s", feed.Name, feed.Url)
 
-	if err := parseFeed(feed); err != nil {
+	err := parseFeed(feed)
+	if err != nil {
 		log.Error(err)
 	}
+	success <- err == nil
 }
 
-func Parse(feeds Feeds) {
+func Parse(feeds Feeds) int {
 	var wg sync.WaitGroup
 	wg.Add(len(feeds))
 
+	success := make(chan bool, len(feeds))
+
 	for _, feed := range feeds {
-		go handleFeed(feed, &wg)
+		go handleFeed(feed, &wg, success)
 	}
 
 	wg.Wait()
+	close(success)
+
+	ctr := 0
+	for s := range success {
+		if s {
+			ctr++
+		}
+	}
+
+	return ctr
 }
-- 
cgit v1.2.3-54-g00ecf