update version

Author: ghubertpalo

Cargo.lock

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

mithril-aggregator/Cargo.toml

@@ -76,7 +76,7 @@ impl SqLiteEntity for EpochSettingRecord {
     }
 }
 
-/// Simple [EpochSetting] provider.
+/// Simple [EpochSettingRecord] provider.
 pub struct EpochSettingProvider<'client> {
     client: &'client Connection,
 }

mithril-aggregator/src/database/provider/epoch_setting.rs

@@ -440,10 +440,12 @@ mod tests {
                 ))
                 .unwrap();
 
-            cursor.next().expect(&format!(
-                "OpenMessage ID='{}' should exist in the database.",
-                open_message.open_message_id.to_string()
-            ))
+            cursor.next().unwrap_or_else(|| {
+                panic!(
+                    "OpenMessage ID='{}' should exist in the database.",
+                    open_message.open_message_id
+                )
+            })
         };
 
         assert_eq!(open_message.message, message.message);

mithril-aggregator/src/database/provider/open_message.rs

@@ -240,7 +240,7 @@ impl DependenciesBuilder {
         Ok(stake_pool_store)
     }
 
-    /// Return a [StakeStore]
+    /// Return a [StakePoolStore]
     pub async fn get_stake_store(&mut self) -> Result<Arc<StakePoolStore>> {
         if self.stake_store.is_none() {
             self.stake_store = Some(self.build_stake_store().await?);
@@ -547,7 +547,7 @@ impl DependenciesBuilder {
         Ok(chain_observer)
     }
 
-    /// Return a [ChaineObserver]
+    /// Return a [ChainObserver]
     pub async fn get_chain_observer(&mut self) -> Result<Arc<dyn ChainObserver>> {
         if self.chain_observer.is_none() {
             self.chain_observer = Some(self.build_chain_observer().await?);
@@ -629,7 +629,7 @@ impl DependenciesBuilder {
         Ok(Arc::new(cache_provider))
     }
 
-    /// Get an [ImmutableCacheProvider]
+    /// Get an [ImmutableFileDigestCacheProvider]
     pub async fn get_immutable_cache_provider(
         &mut self,
     ) -> Result<Arc<dyn ImmutableFileDigestCacheProvider>> {
@@ -900,7 +900,7 @@ impl DependenciesBuilder {
         Ok(event_transmitter)
     }
 
-    /// [EventTransmitter] service
+    /// [TransmitterService] service
     pub async fn get_event_transmitter(&mut self) -> Result<Arc<TransmitterService<EventMessage>>> {
         if self.event_transmitter.is_none() {
             self.event_transmitter = Some(self.build_event_transmitter().await?);
@@ -915,7 +915,7 @@ impl DependenciesBuilder {
         Ok(api_version_provider)
     }
 
-    /// [ApiVersionprovider] service
+    /// [APIVersionProvider] service
     pub async fn get_api_version_provider(&mut self) -> Result<Arc<APIVersionProvider>> {
         if self.api_version_provider.is_none() {
             self.api_version_provider = Some(self.build_api_version_provider().await?);

mithril-aggregator/src/dependency_injection/builder.rs

@@ -5,7 +5,7 @@ use std::{error::Error, fmt::Display};
 use config::ConfigError;
 use mithril_common::StdError;
 
-/// Result with the [DependencyBuilderError] error.
+/// Result with the [DependenciesBuilderError] error.
 pub type Result<T> = std::result::Result<T, DependenciesBuilderError>;
 
 /// Error that can occure during dependencies initialization process.

mithril-aggregator/src/dependency_injection/error.rs

@@ -1,6 +1,6 @@
 [package]
 name = "mithril-common"
-version = "0.2.35"
+version = "0.2.36"
 authors = { workspace = true }
 edition = { workspace = true }
 documentation = { workspace = true }

mithril-common/Cargo.toml

@@ -52,8 +52,8 @@ impl Projection {
     /// Create a Projection from a list of tuples `&[(name, definition, sql_type)]`.
     pub fn from(fields: &[(&str, &str, &str)]) -> Self {
         let field_defs: Vec<ProjectionField> = fields
-            .into_iter()
-            .map(|(name, definition, sql_type)| ProjectionField::new(name, definition, &sql_type))
+            .iter()
+            .map(|(name, definition, sql_type)| ProjectionField::new(name, definition, sql_type))
             .collect();
 
         Self::new(field_defs)

mithril-common/src/sqlite/projection.rs

@@ -2,6 +2,8 @@ use std::collections::{hash_map::Iter, HashMap};
 
 /// Handful tool to store SQL source aliases.
 /// ```
+/// use mithril_common::sqlite::SourceAlias;
+///
 /// let aliases = SourceAlias::new(&[("first", "one"), ("second", "two")]);
 /// ```
 #[derive(Debug, Default, Clone)]