diff options
| -rw-r--r-- | reader/processor/processor.go | 2 | ||||
| -rw-r--r-- | storage/entry.go | 6 |
2 files changed, 4 insertions, 4 deletions
diff --git a/reader/processor/processor.go b/reader/processor/processor.go index faceccc..5fab442 100644 --- a/reader/processor/processor.go +++ b/reader/processor/processor.go @@ -17,7 +17,7 @@ import ( func ProcessFeedEntries(store *storage.Storage, feed *model.Feed) { for _, entry := range feed.Entries { if feed.Crawler { - if !store.EntryURLExists(feed.UserID, entry.URL) { + if !store.EntryURLExists(feed.ID, entry.URL) { content, err := scraper.Fetch(entry.URL, feed.ScraperRules, feed.UserAgent) if err != nil { logger.Error(`[Filter] Unable to crawl this entry: %q => %v`, entry.URL, err) diff --git a/storage/entry.go b/storage/entry.go index ec31843..811a207 100644 --- a/storage/entry.go +++ b/storage/entry.go @@ -316,9 +316,9 @@ func (s *Storage) MarkCategoryAsRead(userID, categoryID int64, before time.Time) } // EntryURLExists returns true if an entry with this URL already exists. -func (s *Storage) EntryURLExists(userID int64, entryURL string) bool { +func (s *Storage) EntryURLExists(feedID int64, entryURL string) bool { var result int - query := `SELECT count(*) as c FROM entries WHERE user_id=$1 AND url=$2` - s.db.QueryRow(query, userID, entryURL).Scan(&result) + query := `SELECT count(*) as c FROM entries WHERE feed_id=$1 AND url=$2` + s.db.QueryRow(query, feedID, entryURL).Scan(&result) return result >= 1 } |