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/gemini.go | |
| parent | 0441fc93496ac64670f3357d8f13b17c6380baae (diff) | |
Refactor fetch functions to use new FullData.Insert{Feed,Page} funcs
Diffstat (limited to 'fetch/gemini.go')
| -rw-r--r-- | fetch/gemini.go | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/fetch/gemini.go b/fetch/gemini.go index 516358a..3c81eaa 100644 --- a/fetch/gemini.go +++ b/fetch/gemini.go @@ -29,7 +29,7 @@ import ( // fetchGemini will make a request for a gemini resource func fetchGemini(remote *url.URL) (*gemini.Response, error) { client := &gemini.Client{} - resp, err := client.Get(context.Background(), remoteURL.String()) + resp, err := client.Get(context.Background(), remote.String()) if err != nil { return nil, err } @@ -94,7 +94,7 @@ func geminiFeed(data *core.FullData, remote *url.URL, title string) error { feed.Items = append(feed.Items, item) } } - InsertFeed(data, &feed, remote) + data.InsertFeed(&feed, remote) return nil case "text/xml", "application/rss+xml", @@ -109,7 +109,7 @@ func geminiFeed(data *core.FullData, remote *url.URL, title string) error { if err != nil { return err } - InsertFeed(data, feed, remote) + data.InsertFeed(feed, remote) return nil default: return fmt.Errorf("Cannot interpret %s as a feed", resp.Meta) @@ -119,7 +119,7 @@ func geminiFeed(data *core.FullData, remote *url.URL, title string) error { // geminiPage will fetch and insert a new core.Page into a core.FullData given // a gemini url (or update if it's preexisting) func geminiPage(data *core.FullData, remote *url.URL, title string) error { - resp, err := fetchGemini(p.Link) + resp, err := fetchGemini(remote) if err != nil { return err } @@ -135,11 +135,9 @@ func geminiPage(data *core.FullData, remote *url.URL, title string) error { return err } newHash := fmt.Sprintf("%x", h.Sum(nil)) - if newHash != p.Hash { - page.Hash = newHash - page.Updated = time.Now() - } + page.Hash = newHash + page.Updated = time.Now() - InsertPage(data, &page, remote) + data.InsertPage(&page, remote) return nil } |
