diff options
| author | nytpu <alex@nytpu.com> | 2021-03-18 10:33:58 -0600 |
|---|---|---|
| committer | nytpu <alex@nytpu.com> | 2021-03-18 10:33:58 -0600 |
| commit | a3a427b9eed52b5e173191cb4d2c871db3d8148a (patch) | |
| tree | 58f5908cbfe7da5df8d76c5598d50a69660e194d /fetch/fetch.go | |
| parent | 0441fc93496ac64670f3357d8f13b17c6380baae (diff) | |
Refactor fetch functions to use new FullData.Insert{Feed,Page} funcs
Diffstat (limited to 'fetch/fetch.go')
| -rw-r--r-- | fetch/fetch.go | 27 |
1 files changed, 0 insertions, 27 deletions
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() - } -} |
