Merge pull request #1237 from input-output-hk/damien/798/implement-anyhow-context-for-aggregator-dependency-injection

Implement anyhow context: dependency_injection

Author: dlachaume

Cargo.lock

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

mithril-aggregator/Cargo.toml

@@ -73,7 +73,12 @@ impl ExportGenesisSubCommand {
             self.target_path.display()
         );
         let mut dependencies_builder = DependenciesBuilder::new(config.clone());
-        let dependencies = dependencies_builder.create_genesis_container().await?;
+        let dependencies = dependencies_builder
+            .create_genesis_container()
+            .await
+            .with_context(|| {
+                "Dependencies Builder can not create genesis command dependencies container"
+            })?;
 
         let genesis_tools = GenesisTools::from_dependencies(dependencies)
             .await
@@ -105,7 +110,12 @@ impl ImportGenesisSubCommand {
             self.signed_payload_path.to_string_lossy()
         );
         let mut dependencies_builder = DependenciesBuilder::new(config.clone());
-        let dependencies = dependencies_builder.create_genesis_container().await?;
+        let dependencies = dependencies_builder
+            .create_genesis_container()
+            .await
+            .with_context(|| {
+                "Dependencies Builder can not create genesis command dependencies container"
+            })?;
 
         let genesis_tools = GenesisTools::from_dependencies(dependencies)
             .await
@@ -170,7 +180,12 @@ impl BootstrapGenesisSubCommand {
         debug!("BOOTSTRAP GENESIS command"; "config" => format!("{config:?}"));
         println!("Genesis bootstrap for test only!");
         let mut dependencies_builder = DependenciesBuilder::new(config.clone());
-        let dependencies = dependencies_builder.create_genesis_container().await?;
+        let dependencies = dependencies_builder
+            .create_genesis_container()
+            .await
+            .with_context(|| {
+                "Dependencies Builder can not create genesis command dependencies container"
+            })?;
 
         let genesis_tools = GenesisTools::from_dependencies(dependencies)
             .await

mithril-aggregator/src/commands/genesis_command.rs

@@ -88,7 +88,10 @@ impl ServeCommand {
         println!("Press Ctrl+C to stop");
 
         // start the monitoring thread
-        let mut event_store = dependencies_builder.create_event_store().await?;
+        let mut event_store = dependencies_builder
+            .create_event_store()
+            .await
+            .with_context(|| "Dependencies Builder can not create event store")?;
         let event_store_config = config.clone();
         let event_store_thread = tokio::spawn(async move {
             event_store
@@ -102,13 +105,19 @@ impl ServeCommand {
         });
 
         // start the aggregator runtime
-        let mut runtime = dependencies_builder.create_aggregator_runner().await?;
+        let mut runtime = dependencies_builder
+            .create_aggregator_runner()
+            .await
+            .with_context(|| "Dependencies Builder can not create aggregator runner")?;
         let mut join_set = JoinSet::new();
         join_set.spawn(async move { runtime.run().await.map_err(|e| e.to_string()) });
 
         // start the HTTP server
         let (shutdown_tx, shutdown_rx) = oneshot::channel();
-        let routes = dependencies_builder.create_http_routes().await?;
+        let routes = dependencies_builder
+            .create_http_routes()
+            .await
+            .with_context(|| "Dependencies Builder can not create http routes")?;
         join_set.spawn(async move {
             let (_, server) = warp::serve(routes).bind_with_graceful_shutdown(
                 (

mithril-aggregator/src/commands/serve_command.rs

@@ -60,7 +60,10 @@ impl RecomputeCertificatesHashCommand {
         debug!("RECOMPUTE CERTIFICATES HASH command"; "config" => format!("{config:?}"));
         println!("Recomputing all certificate hash",);
         let mut dependencies_builder = DependenciesBuilder::new(config.clone());
-        let connection = dependencies_builder.get_sqlite_connection().await?;
+        let connection = dependencies_builder
+            .get_sqlite_connection()
+            .await
+            .with_context(|| "Dependencies Builder can not get sqlite connection")?;
         let migrator = CertificatesHashMigrator::new(
             CertificateRepository::new(connection.clone()),
             Arc::new(SignedEntityStoreAdapter::new(connection.clone())),