From d21881150c09986571a563eaf30bc1687787e63f Mon Sep 17 00:00:00 2001
From: René 'Necoro' Neumann <necoro@necoro.eu>
Date: Sat, 25 Apr 2020 11:27:34 +0200
Subject: Improved caching

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

(limited to 'internal/feed/parse.go')

diff --git a/internal/feed/parse.go b/internal/feed/parse.go
index 35a7596..6deebb2 100644
--- a/internal/feed/parse.go
+++ b/internal/feed/parse.go
@@ -32,7 +32,7 @@ func parseFeed(feed *Feed) error {
 	return nil
 }
 
-func handleFeed(feed *Feed, group *sync.WaitGroup, success chan<- bool) {
+func handleFeed(feed *Feed, group *sync.WaitGroup) {
 	defer group.Done()
 	log.Printf("Fetching %s from %s", feed.Name, feed.Url)
 
@@ -40,25 +40,17 @@ func handleFeed(feed *Feed, group *sync.WaitGroup, success chan<- bool) {
 	if err != nil {
 		log.Error(err)
 	}
-	success <- err == nil
 }
 
-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, success)
-	}
-
-	wg.Wait()
-	close(success)
+func (feeds Feeds) Parse() int {
+	feeds.ForeachGo(handleFeed)
 
 	ctr := 0
-	for s := range success {
-		if s {
+	for _, feed := range feeds.feeds {
+		success := feed.Success()
+		feed.cached.Checked(!success)
+
+		if success {
 			ctr++
 		}
 	}
-- 
cgit v1.2.3-70-g09d2