diff --git a/scrapper/src/main.rs b/scrapper/src/main.rs index d700775..abe0491 100644 --- a/scrapper/src/main.rs +++ b/scrapper/src/main.rs @@ -97,6 +97,7 @@ async fn main() -> Result<(), anyhow::Error> { info!("Received post {:?}", news_post); if news_post.is_complete() { let title = news_post.title.clone().unwrap(); + // TODO: add stream name in the flag key if !redis_service.is_key_flagged(&title).await { let published = redis_service .publish(&args.redis_stream_name, &news_post)