greg/rss-reader
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Tweak

Browse Source
This commit is contained in:
Greg Shuflin 2025-02-06 00:10:31 -08:00
parent d7882b0291
commit 93c9cba831
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/poll.rs
View File

@ -106,15 +106,15 @@ pub async fn poll_feed(
let now = Utc::now(); let now = Utc::now();
let last_checked = now - feed.last_checked_time; let last_checked = now - feed.last_checked_time;
info!("Feed {} last checked: {}", feed_id, last_checked); info!("Feed {} last checked: {}", feed_id, last_checked);
let entries = if last_checked < POLLING_INTERVAL {
info!("Reading entries from database for feed {}", feed_id); if last_checked > POLLING_INTERVAL {
read_entries(&feed_id, &mut **db).await?
} else {
info!("Fetching new entries for feed {}", feed_id); info!("Fetching new entries for feed {}", feed_id);
let entries = crate::poll_utils::fetch_new_entries(&url).await?; let entries = crate::poll_utils::fetch_new_entries(&url).await?;
update_entry_db(&entries, &feed_id, &mut **db).await?; update_entry_db(&entries, &feed_id, &mut **db).await?;
entries }
};
info!("Reading entries from database for feed {}", feed_id);
let entries = read_entries(&feed_id, &mut db).await?;
let count = entries.len(); let count = entries.len();
let unread_count = entries.iter().filter(|e| e.marked_read.is_none()).count(); let unread_count = entries.iter().filter(|e| e.marked_read.is_none()).count();