Do not crawl existing entry URLs

1 files changed, 8 insertions, 0 deletions

diff --git a/storage/entry.go b/storage/entry.go
index c6058d0..d1e8798 100644
--- a/storage/entry.go
+++ b/storage/entry.go
@@ -226,3 +226,11 @@ func (s *Storage) MarkAllAsRead(userID int64) error {
 
 	return nil
 }
+
+// EntryURLExists returns true if an entry with this URL already exists.
+func (s *Storage) EntryURLExists(userID 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)
+	return result >= 1
+}