add publish log

scrapper/src/main.rs

@@ -87,7 +87,8 @@ async fn main() -> Result<(), anyhow::Error> {
         if news_post.is_complete() {
             let title = news_post.title.clone().unwrap();
             if redis_service.is_post_seen(&title).await {
-                redis_service.publish(news_post).await;
+                redis_service.publish(&news_post).await;
+                info!("Published {:?}", news_post);
                 redis_service.mark_post_seen(&title, 60 * 60 * 24 * 3).await;
             };
         }

scrapper/src/redis.rs

@@ -41,7 +41,7 @@ impl RedisService {
     }
 
     /// Publishes the post to the redis stream.
-    pub async fn publish(&mut self, post: NewsPost) {
+    pub async fn publish(&mut self, post: &NewsPost) {
         let serialized_post = serde_json::to_string(&post).unwrap();
         let result = redis::cmd("XADD")
             .arg(format!("posts:{}", self.stream_name))