Use feed ID instead of user ID to check entry URLs presence

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
 }