From 4434a31c09bc6306548743e9e47027bf6f2d2d1d Mon Sep 17 00:00:00 2001
From: joe <nonya>
Date: Sat, 13 Dec 2025 15:25:46 -0800
Subject: [PATCH] rename runs to successful_runs

---
 migrations/0002_runs.up.sql |  3 +--
 src/lib.rs                  | 15 ++++++++-------
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/migrations/0002_runs.up.sql b/migrations/0002_runs.up.sql
index 0123c79..79281dd 100644
--- a/migrations/0002_runs.up.sql
+++ b/migrations/0002_runs.up.sql
@@ -1,7 +1,6 @@
-CREATE TABLE IF NOT EXISTS runs (
+CREATE TABLE IF NOT EXISTS successful_runs (
  id INTEGER PRIMARY KEY,
  date_time DATETIME NOT NULL DEFAULT current_timestamp,
- succeeded BOOLEAN NOT NULL DEFAULT FALSE,
  feed INTEGER NOT NULL,
  FOREIGN KEY (feed) REFERENCES feeds(id)
 );
diff --git a/src/lib.rs b/src/lib.rs
index 998a620..6f6a206 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -167,12 +167,10 @@ async fn check_feeds(db: &SqlitePool, client: &reqwest::Client) {
                     tokio::time::sleep(Duration::from_millis(200)).await;
                 }
                 if success
-                    && let Err(e) = sqlx::query!(
-                        "insert into runs (feed, succeeded) values (?, true)",
-                        feed_id
-                    )
-                    .execute(db)
-                    .await
+                    && let Err(e) =
+                        sqlx::query!("insert into successful_runs (feed) values (?)", feed_id)
+                            .execute(db)
+                            .await
                 {
                     tracing::error!("could not insert run for {feed_id}, got {e}");
                 }
@@ -188,13 +186,14 @@ async fn check_feed(
     url: String,
 ) -> Result<Option<Vec<FeedEntry>>, String> {
     let rec = sqlx::query!(
-        "select date_time from runs where succeeded = true and feed = ? order by id desc limit 1",
+        "select date_time from successful_runs where feed = ? order by id desc limit 1",
         feed_id
     )
     .fetch_optional(&db)
     .await
     .map_err(|e| format!("Could not fetch runs for {url} from DB, got {e}"))?;
 
+    tracing::debug!("checking {url}");
     let last_fetched = rec.map(|d| d.date_time.and_utc()).unwrap_or(LAST_FETCHED);
     let now = Utc::now();
     let mut out = Vec::new();
@@ -241,8 +240,10 @@ async fn check_feed(
     }
 
     if out.is_empty() {
+        tracing::debug!("no new items from {url}");
         Ok(None)
     } else {
+        tracing::debug!("found {} new items from {url}", out.len());
         Ok(Some(out))
     }
 }