From 7edbd927803485f19049052707bf3f66297ecc50 Mon Sep 17 00:00:00 2001
From: Joe <Joe>
Date: Tue, 23 Dec 2025 09:38:11 -0800
Subject: [PATCH] actually add feeds

---
 src/server.rs | 16 ++++++++++++----
 1 file changed, 12 insertions(+), 4 deletions(-)

diff --git a/src/server.rs b/src/server.rs
index 0b924c7..2cbdc36 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -161,17 +161,25 @@ async fn remove_feed(db: &SqlitePool, user: u32, feed: &str) -> Result<(), Strin
 
 async fn add_feed(db: &SqlitePool, user: u32, feed: &str) -> Result<(), String> {
     add_user(db, user).await?;
-    if sqlx::query!(
+    sqlx::query!(
         "update feeds set active = true where url = ? and added_by = ?",
         feed,
         user
     )
     .execute(db)
     .await
-    .is_err()
+    .map_err(|e| format!("Got error adding feed: {e}"))?;
+
+    if sqlx::query!(
+        "select * from feeds where added_by = ? and url = ? and active = true",
+        user,
+        feed
+    )
+    .fetch_optional(db)
+    .await
+    .map_err(|e| format!("{e}"))?
+    .is_some()
     {
-        tracing::debug!("{feed} is new, adding new row");
-    } else {
         return Ok(());
     }