Merge pull request #2009 from input-output-hk/djo/1981/rework-aggregator-log-msgs

Rework & harmonize aggregator log messages

Author: Alenar

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "mithril-aggregator"
-version = "0.5.82"
+version = "0.5.83"
 description = "A Mithril Aggregator server"
 authors = { workspace = true }
 edition = { workspace = true }

mithril-aggregator/Cargo.toml

@@ -60,10 +60,7 @@ impl CardanoImmutableFilesFullArtifactBuilder {
         beacon: &CardanoDbBeacon,
         snapshot_digest: &str,
     ) -> StdResult<OngoingSnapshot> {
-        debug!(
-            self.logger,
-            "CardanoImmutableFilesFullArtifactBuilder: create snapshot archive"
-        );
+        debug!(self.logger, ">> create_snapshot_archive");
 
         let snapshotter = self.snapshotter.clone();
         let snapshot_name = format!(
@@ -81,7 +78,7 @@ impl CardanoImmutableFilesFullArtifactBuilder {
             })
             .await??;
 
-        debug!(self.logger, " > snapshot created: '{ongoing_snapshot:?}'");
+        debug!(self.logger, " > Snapshot created: '{ongoing_snapshot:?}'");
 
         Ok(ongoing_snapshot)
     }
@@ -90,19 +87,16 @@ impl CardanoImmutableFilesFullArtifactBuilder {
         &self,
         ongoing_snapshot: &OngoingSnapshot,
     ) -> StdResult<Vec<SnapshotLocation>> {
-        debug!(
-            self.logger,
-            "CardanoImmutableFilesFullArtifactBuilder: upload snapshot archive"
-        );
+        debug!(self.logger, ">> upload_snapshot_archive");
         let location = self
             .snapshot_uploader
             .upload_snapshot(ongoing_snapshot.get_file_path())
             .await;
 
         if let Err(error) = tokio::fs::remove_file(ongoing_snapshot.get_file_path()).await {
             warn!(
-                self.logger,
-                " > Post upload ongoing snapshot file removal failure: {error}"
+                self.logger, " > Post upload ongoing snapshot file removal failure";
+                "error" => error
             );
         }
 
@@ -116,10 +110,7 @@ impl CardanoImmutableFilesFullArtifactBuilder {
         snapshot_digest: String,
         remote_locations: Vec<String>,
     ) -> StdResult<Snapshot> {
-        debug!(
-            self.logger,
-            "CardanoImmutableFilesFullArtifactBuilder: create snapshot"
-        );
+        debug!(self.logger, ">> create_snapshot");
 
         let snapshot = Snapshot::new(
             snapshot_digest,

mithril-aggregator/src/artifact_builder/cardano_immutable_files_full.rs

@@ -177,10 +177,9 @@ impl ServeCommand {
                 }
                 Err(error) => {
                     warn!(
-                        root_logger,
-                        "Failed to build the `SignersImporter`:\n url to import `{}`\n Error: {:?}",
-                        cexplorer_pools_url,
-                        error
+                        root_logger, "Failed to build the `SignersImporter`";
+                        "url_to_import" => cexplorer_pools_url,
+                        "error" => ?error
                     );
                 }
             }
@@ -190,7 +189,7 @@ impl ServeCommand {
         dependencies_builder.vanish().await;
 
         if let Err(e) = join_set.join_next().await.unwrap()? {
-            crit!(root_logger, "A critical error occurred: {e}");
+            crit!(root_logger, "A critical error occurred"; "error" => e);
         }
 
         // stop servers

mithril-aggregator/src/commands/serve_command.rs

@@ -599,7 +599,8 @@ impl DependenciesBuilder {
         let epoch_settings_configuration = self.get_epoch_settings_configuration()?;
         debug!(
             logger,
-            "Handle discrepancies at startup of epoch settings store, will record epoch settings from the configuration for epoch {current_epoch}: {epoch_settings_configuration:?}"
+            "Handle discrepancies at startup of epoch settings store, will record epoch settings from the configuration for epoch {current_epoch}";
+            "epoch_settings_configuration" => ?epoch_settings_configuration,
         );
         epoch_settings_store
             .handle_discrepancies_at_startup(current_epoch, &epoch_settings_configuration)

mithril-aggregator/src/dependency_injection/builder.rs

@@ -37,15 +37,15 @@ impl EventStore {
         let persister = EventPersister::new(connection);
         info!(
             self.logger,
-            "monitoring: starting event loop to log messages."
+            "Starting monitoring event loop to log messages."
         );
         loop {
             if let Some(message) = self.receiver.recv().await {
-                debug!(self.logger, "Event received: {message:?}");
+                debug!(self.logger, "Event received"; "event" => ?message);
                 let event = persister
                     .persist(message)
                     .with_context(|| "event persist failure")?;
-                debug!(self.logger, "event ID={} created", event.event_id);
+                debug!(self.logger, "Event ID={} created", event.event_id);
             } else {
                 info!(self.logger, "No more events to proceed, quitting…");
                 break;

mithril-aggregator/src/event_store/runner.rs

@@ -52,7 +52,7 @@ impl TransmitterService<EventMessage> {
     {
         let content = serde_json::to_string(content).map_err(|e| {
             let error_msg = format!("Serialization error while forging event message: {e}");
-            warn!(self.logger, "Event message error => «{error_msg}»");
+            warn!(self.logger, "Event message error"; "error" => &error_msg);
 
             error_msg
         })?;
@@ -68,7 +68,7 @@ impl TransmitterService<EventMessage> {
         self.get_transmitter().send(message.clone()).map_err(|e| {
             let error_msg =
                 format!("An error occurred when sending message {message:?} to monitoring: '{e}'.");
-            warn!(self.logger, "Event message error => «{error_msg}»");
+            warn!(self.logger, "Event message error"; "error" => &error_msg);
 
             error_msg
         })

mithril-aggregator/src/event_store/transmitter_service.rs

@@ -52,7 +52,7 @@ pub mod handlers {
     use crate::services::MessageService;
 
     use mithril_common::entities::Epoch;
-    use slog::{debug, warn, Logger};
+    use slog::{warn, Logger};
     use std::convert::Infallible;
     use std::sync::Arc;
     use warp::http::StatusCode;
@@ -64,15 +64,13 @@ pub mod handlers {
         logger: Logger,
         http_message_service: Arc<dyn MessageService>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!(logger, "⇄ HTTP SERVER: artifacts");
-
         match http_message_service
             .get_cardano_stake_distribution_list_message(LIST_MAX_ITEMS)
             .await
         {
             Ok(message) => Ok(reply::json(&message, StatusCode::OK)),
             Err(err) => {
-                warn!(logger, "list_artifacts_cardano_stake_distribution"; "error" => ?err);
+                warn!(logger, "get_cardano_stake_distribution_list::error"; "error" => ?err);
                 Ok(reply::server_error(err))
             }
         }
@@ -84,8 +82,6 @@ pub mod handlers {
         logger: Logger,
         http_message_service: Arc<dyn MessageService>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!(logger, "⇄ HTTP SERVER: artifact/{signed_entity_id}");
-
         match http_message_service
             .get_cardano_stake_distribution_message(&signed_entity_id)
             .await
@@ -108,8 +104,6 @@ pub mod handlers {
         logger: Logger,
         http_message_service: Arc<dyn MessageService>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!(logger, "⇄ HTTP SERVER: artifact/epoch/{epoch}");
-
         let artifact_epoch = match epoch.parse::<u64>() {
             Ok(epoch) => Epoch(epoch),
             Err(err) => {

mithril-aggregator/src/http_server/routes/artifact_routes/cardano_stake_distribution.rs

@@ -35,7 +35,7 @@ pub mod handlers {
     use crate::http_server::routes::reply;
     use crate::services::MessageService;
 
-    use slog::{debug, warn, Logger};
+    use slog::{warn, Logger};
     use std::convert::Infallible;
     use std::sync::Arc;
     use warp::http::StatusCode;
@@ -47,8 +47,6 @@ pub mod handlers {
         logger: Logger,
         http_message_service: Arc<dyn MessageService>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!(logger, "⇄ HTTP SERVER: artifacts");
-
         match http_message_service
             .get_cardano_transaction_list_message(LIST_MAX_ITEMS)
             .await
@@ -68,8 +66,6 @@ pub mod handlers {
         logger: Logger,
         http_message_service: Arc<dyn MessageService>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!(logger, "⇄ HTTP SERVER: artifact/{signed_entity_id}");
-
         match http_message_service
             .get_cardano_transaction_message(&signed_entity_id)
             .await

mithril-aggregator/src/http_server/routes/artifact_routes/cardano_transaction.rs

@@ -36,7 +36,7 @@ pub mod handlers {
     use crate::http_server::routes::reply;
     use crate::services::MessageService;
 
-    use slog::{debug, warn, Logger};
+    use slog::{warn, Logger};
     use std::convert::Infallible;
     use std::sync::Arc;
     use warp::http::StatusCode;
@@ -48,8 +48,6 @@ pub mod handlers {
         logger: Logger,
         http_message_service: Arc<dyn MessageService>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!(logger, "⇄ HTTP SERVER: artifacts");
-
         match http_message_service
             .get_mithril_stake_distribution_list_message(LIST_MAX_ITEMS)
             .await
@@ -68,8 +66,6 @@ pub mod handlers {
         logger: Logger,
         http_message_service: Arc<dyn MessageService>,
     ) -> Result<impl warp::Reply, Infallible> {
-        debug!(logger, "⇄ HTTP SERVER: artifact/{signed_entity_id}");
-
         match http_message_service
             .get_mithril_stake_distribution_message(&signed_entity_id)
             .await