From 431a8ddb0c18b0781cba1d01eda3645b361f1b94 Mon Sep 17 00:00:00 2001 From: René 'Necoro' Neumann Date: Sun, 19 Apr 2020 23:46:08 +0200 Subject: Restructure --- internal/feed/parse.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'internal/feed/parse.go') diff --git a/internal/feed/parse.go b/internal/feed/parse.go index 53ceb00..a38be92 100644 --- a/internal/feed/parse.go +++ b/internal/feed/parse.go @@ -8,7 +8,6 @@ import ( "github.com/mmcdole/gofeed" - "github.com/Necoro/feed2imap-go/internal/config" "github.com/Necoro/feed2imap-go/internal/log" ) @@ -16,7 +15,7 @@ func context() (ctxt.Context, ctxt.CancelFunc) { return ctxt.WithTimeout(ctxt.Background(), 60*time.Second) } -func parseFeed(feed *config.Feed) error { +func parseFeed(feed *Feed) error { ctx, cancel := context() defer cancel() fp := gofeed.NewParser() @@ -27,7 +26,7 @@ func parseFeed(feed *config.Feed) error { return nil } -func handleFeed(feed *config.Feed, wg *sync.WaitGroup) { +func handleFeed(feed *Feed, wg *sync.WaitGroup) { defer wg.Done() log.Printf("Fetching %s from %s", feed.Name, feed.Url) @@ -36,7 +35,7 @@ func handleFeed(feed *config.Feed, wg *sync.WaitGroup) { } } -func Parse(feeds config.Feeds) { +func Parse(feeds Feeds) { var wg sync.WaitGroup wg.Add(len(feeds)) -- cgit v1.2.3-70-g09d2