diff --git a/src/lib.rs b/src/lib.rs index a65d4fc..95556bc 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -1,7 +1,4 @@ -use std::{ - //sync::{Arc, OnceLock}, - time::Duration, -}; +use std::time::Duration; use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt}; pub mod server; @@ -82,8 +79,23 @@ impl BlogdorTheAggregator { } } -async fn check_feeds(_db: &SqlitePool, _client: &Client) { +async fn check_feeds(db: &SqlitePool, _client: &Client) { tracing::debug!("checking feeds"); + let feeds = match sqlx::query!("select id, url from feeds where active = true") + .fetch_all(db) + .await + { + Ok(feeds) => feeds, + Err(e) => { + tracing::error!("got error fetching feeds from db: {e}"); + return; + } + }; + + for feed in feeds { + let id = feed.id; + let url = feed.url; + } } async fn get_db_pool() -> SqlitePool {