fix: ambiguous elided lifetimes

Author: jpraynaud

internal/mithril-dmq/src/consumer/pallas.rs

@@ -51,7 +51,7 @@ impl<M: TryFromBytes + Debug> DmqConsumerPallas<M> {
     }
 
     /// Gets the cached `DmqClient`, creating a new one if it does not exist.
-    async fn get_client(&self) -> StdResult<MutexGuard<Option<DmqClient>>> {
+    async fn get_client(&self) -> StdResult<MutexGuard<'_, Option<DmqClient>>> {
         {
             // Run this in a separate block to avoid dead lock on the Mutex
             let client_lock = self.client.lock().await;

internal/mithril-persistence/src/database/version_checker.rs

@@ -317,7 +317,7 @@ mod tests {
             .read::<i64, _>(0)
     }
 
-    fn create_db_checker(connection: &ConnectionThreadSafe) -> DatabaseVersionChecker {
+    fn create_db_checker(connection: &ConnectionThreadSafe) -> DatabaseVersionChecker<'_> {
         DatabaseVersionChecker::new(
             discard_logger(),
             ApplicationNodeType::Aggregator,

internal/mithril-persistence/src/sqlite/connection_extensions.rs

@@ -8,7 +8,7 @@ use crate::sqlite::{EntityCursor, Query, SqliteConnection, Transaction};
 /// Extension trait for the [SqliteConnection] type.
 pub trait ConnectionExtensions {
     /// Begin a transaction on the connection.
-    fn begin_transaction(&self) -> StdResult<Transaction>;
+    fn begin_transaction(&self) -> StdResult<Transaction<'_>>;
 
     /// Execute the given sql query and return the value of the first cell read.
     fn query_single_cell<Q: AsRef<str>, T: ReadableWithIndex>(
@@ -18,7 +18,7 @@ pub trait ConnectionExtensions {
     ) -> StdResult<T>;
 
     /// Fetch entities from the database using the given query.
-    fn fetch<Q: Query>(&self, query: Q) -> StdResult<EntityCursor<Q::Entity>>;
+    fn fetch<Q: Query>(&self, query: Q) -> StdResult<EntityCursor<'_, Q::Entity>>;
 
     /// Fetch the first entity from the database returned using the given query.
     fn fetch_first<Q: Query>(&self, query: Q) -> StdResult<Option<Q::Entity>> {
@@ -39,7 +39,7 @@ pub trait ConnectionExtensions {
 }
 
 impl ConnectionExtensions for SqliteConnection {
-    fn begin_transaction(&self) -> StdResult<Transaction> {
+    fn begin_transaction(&self) -> StdResult<Transaction<'_>> {
         Ok(Transaction::begin(self)?)
     }
 
@@ -54,7 +54,7 @@ impl ConnectionExtensions for SqliteConnection {
         statement.read::<T, _>(0).with_context(|| "Read query error")
     }
 
-    fn fetch<Q: Query>(&self, query: Q) -> StdResult<EntityCursor<Q::Entity>> {
+    fn fetch<Q: Query>(&self, query: Q) -> StdResult<EntityCursor<'_, Q::Entity>> {
         let (condition, params) = query.filters().expand();
         let sql = query.get_definition(&condition);
         let cursor = prepare_statement(self, &sql)?.into_iter().bind(&params[..])?;

internal/mithril-persistence/src/sqlite/connection_pool.rs

@@ -47,7 +47,7 @@ impl SqliteConnectionPool {
     }
 
     /// Get a connection from the pool
-    pub fn connection(&self) -> StdResult<ResourcePoolItem<SqlitePooledConnection>> {
+    pub fn connection(&self) -> StdResult<ResourcePoolItem<'_, SqlitePooledConnection>> {
         let timeout = Duration::from_millis(1000);
         let connection = self.connection_pool.acquire_resource(timeout)?;
 

mithril-aggregator/src/services/stake_distribution.rs

@@ -118,7 +118,7 @@ impl Default for UpdateToken {
 }
 
 impl UpdateToken {
-    pub fn update(&self, epoch: Epoch) -> StdResult<MutexGuard<()>> {
+    pub fn update(&self, epoch: Epoch) -> StdResult<MutexGuard<'_, ()>> {
         let update_semaphore = self.is_busy.try_lock().map_err(|_| {
             let last_updated_epoch = self.busy_on_epoch.read().unwrap();