From a3a427b9eed52b5e173191cb4d2c871db3d8148a Mon Sep 17 00:00:00 2001 From: nytpu Date: Thu, 18 Mar 2021 10:33:58 -0600 Subject: Refactor fetch functions to use new FullData.Insert{Feed,Page} funcs --- fetch/fetch.go | 27 --------------------------- 1 file changed, 27 deletions(-) (limited to 'fetch/fetch.go') diff --git a/fetch/fetch.go b/fetch/fetch.go index 231c7dc..6e9e7a0 100644 --- a/fetch/fetch.go +++ b/fetch/fetch.go @@ -9,7 +9,6 @@ package fetch import ( "fmt" "net/url" - "reflect" "golang.nytpu.com/comitium/core" ) @@ -43,29 +42,3 @@ func Page(data *core.FullData, remote *url.URL, title string) error { return fmt.Errorf("Unsupported protocol '%s'", remote.Scheme) } } - -// InsertFeed will insert or update a core.Feed in a core.FullData -func InsertFeed(data *core.FullData, new *core.Feed, remote *url.URL) { - data.FeedsMu.Lock() - oldFeed, ok := data.Feeds[*remote] - if !ok || !reflect.DeepEqual(new, oldFeed) { - // Feeds are different, or there was never an old one - data.Feeds[*remote] = new - data.FeedsMu.Unlock() - } else { - data.FeedsMu.Unlock() - } -} - -// InsertFeed will insert or update a core.Page in a core.FullData -func InsertPage(data *core.FullData, new *core.Page, remote *url.URL) { - data.PagesMu.Lock() - _, ok := data.Pages[*remote] - if !ok || data.Pages[*remote].Hash != new.Hash { - // pages are different, or there was never an old one - data.Pages[*remote] = new - data.PagesMu.Unlock() - } else { - data.PagesMu.Unlock() - } -} -- cgit v1.2.3