chore(tracing): updated tracing msg formatting

src/crawler/llm/mod.rs

@@ -85,7 +85,7 @@ impl CrawlerService for LlmCrawler {
         let html_str = response.text().await?;
         let html_str = match html_editor::parse(&html_str) {
             Err(err) => {
-                tracing::error!(err=err, "failed to parse html");
+                tracing::error!(err = err, "failed to parse html");
                 html_str
             }
             Ok(mut dom) => dom

src/feeds/rss_feeds/mod.rs

@@ -128,7 +128,7 @@ where
             let art_id = response.guid();
             if self.cacher().contains(art_id).await {
                 tracing::warn!(
-                    article=art_id,
+                    article = art_id,
                     "{topic}: news article has been already parsed"
                 );
                 continue;
@@ -143,7 +143,7 @@ where
             }
 
             tracing::info!(
-                article=art_id,
+                article = art_id,
                 "{topic}: article has been published successful"
             );
             self.cacher.set(art_id, &art).await;

src/publish/pgsql/mod.rs

@@ -30,7 +30,7 @@ impl ServiceConnect for PgsqlPublisher {
         let address = config.address();
 
         let url = format!("postgresql://{user}:{passwd}@{address}/{db}");
-        tracing::info!(db_url=url, "connecting to database");
+        tracing::info!(db_url = url, "connecting to database");
         let connection = PgPoolOptions::default()
             .max_connections(config.max_pool_size())
             .connect(&url)

src/server/routers.rs

@@ -182,7 +182,7 @@ where
 
     let worker_name = form.target_url();
     if let Some(worker) = workers_guard.get(worker_name) {
-        tracing::info!(worker=worker_name, "worker already exists");
+        tracing::info!(worker = worker_name, "worker already exists");
         if !worker.worker().is_finished() && !form.create_force() {
             let msg = format!("worker {worker_name} already launched");
             return Err(ServerError::Launched(msg));

src/storage/pgsql/mod.rs

@@ -29,7 +29,7 @@ impl ServiceConnect for PgsqlTopicStorage {
         let address = config.address();
 
         let url = format!("postgresql://{user}:{passwd}@{address}/{db}");
-        tracing::info!(url=url, "connecting to database");
+        tracing::info!(url = url, "connecting to database");
         let connection = PgPoolOptions::default()
             .max_connections(config.max_pool_size())
             .connect(&url)

tests/mocks/mock_rmq_publish.rs

@@ -23,7 +23,7 @@ impl Publisher for MockRabbitPublisher {
 
     async fn publish(&self, msg_body: &PublishNews) -> Result<(), Self::Error> {
         let id = msg_body.id();
-        tracing::info!(article=id, "rabbit confirm msg successful");
+        tracing::info!(article = id, "rabbit confirm msg successful");
         Ok(())
     }
 }