diff --git a/src/poll.rs b/src/poll.rs index 341a1d3..7c3d3bf 100644 --- a/src/poll.rs +++ b/src/poll.rs @@ -106,15 +106,15 @@ pub async fn poll_feed( let now = Utc::now(); let last_checked = now - feed.last_checked_time; info!("Feed {} last checked: {}", feed_id, last_checked); - let entries = if last_checked < POLLING_INTERVAL { - info!("Reading entries from database for feed {}", feed_id); - read_entries(&feed_id, &mut **db).await? - } else { + + if last_checked > POLLING_INTERVAL { info!("Fetching new entries for feed {}", feed_id); let entries = crate::poll_utils::fetch_new_entries(&url).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 unread_count = entries.iter().filter(|e| e.marked_read.is_none()).count();