add sqlite connection to signer

Author: ghubertpalo

Cargo.lock

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

mithril-aggregator/Cargo.toml

@@ -344,13 +344,11 @@ impl ServeCommand {
             .try_deserialize()
             .map_err(|e| format!("configuration deserialize error: {e}"))?;
         debug!("SERVE command"; "config" => format!("{config:?}"));
-        let sqlite_db_path = Some(config.get_sqlite_file());
         check_database_migration(config.get_sqlite_file())?;
 
         // Init dependencies
-        let sqlite_connection = Arc::new(Mutex::new(Connection::open(
-            sqlite_db_path.clone().unwrap(),
-        )?));
+        let sqlite_db_path = config.get_sqlite_file();
+        let sqlite_connection = Arc::new(Mutex::new(Connection::open(sqlite_db_path)?));
         let snapshot_store = Arc::new(LocalSnapshotStore::new(
             Box::new(SQLiteAdapter::new("snapshot", sqlite_connection.clone())?),
             LIST_SNAPSHOTS_MAX_ITEMS,

mithril-aggregator/src/command_args.rs

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

mithril-common/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "mithril-signer"
-version = "0.2.22"
+version = "0.2.23"
 description = "A Mithril Signer"
 authors = { workspace = true }
 edition = { workspace = true }
@@ -24,6 +24,7 @@ slog = { version = "2.7.0", features = ["max_level_trace", "release_max_level_de
 slog-async = "2.7.0"
 slog-bunyan = "2.4.0"
 slog-scope = "4.4.0"
+sqlite = "0.28"
 thiserror = "1.0.31"
 tokio = { version = "1.17.0", features = ["full"] }
 

mithril-signer/Cargo.toml

@@ -1,13 +1,17 @@
 use async_trait::async_trait;
-use std::{fs, sync::Arc};
-
-use mithril_common::digesters::{
-    cache::{ImmutableFileDigestCacheProvider, JsonImmutableFileDigestCacheProviderBuilder},
-    ImmutableFileObserver,
+use sqlite::Connection;
+use std::{
+    fs,
+    sync::{Arc, Mutex},
 };
+
 use mithril_common::{
     chain_observer::{CardanoCliChainObserver, CardanoCliRunner, ChainObserver},
     crypto_helper::{OpCert, ProtocolPartyId, SerDeShelleyFileFormat},
+    digesters::{
+        cache::{ImmutableFileDigestCacheProvider, JsonImmutableFileDigestCacheProviderBuilder},
+        ImmutableFileObserver,
+    },
     digesters::{CardanoImmutableDigester, ImmutableDigester, ImmutableFileSystemObserver},
     era::{EraChecker, EraReader},
     store::{adapter::SQLiteAdapter, StakeStore},
@@ -138,11 +142,12 @@ impl<'a> ServiceBuilder for ProductionServiceBuilder<'a> {
                 .map_err(|e| format!("Could not create data stores directory: {e:?}"))?;
         }
 
-        let sqlite_db_path = Some(self.config.get_sqlite_file());
+        let sqlite_db_path = self.config.get_sqlite_file();
+        let sqlite_connection = Arc::new(Mutex::new(Connection::open(sqlite_db_path)?));
         let protocol_initializer_store = Arc::new(ProtocolInitializerStore::new(
             Box::new(SQLiteAdapter::new(
                 "protocol_initializer",
-                sqlite_db_path.clone(),
+                sqlite_connection.clone(),
             )?),
             self.config.store_retention_limit,
         ));
@@ -156,7 +161,7 @@ impl<'a> ServiceBuilder for ProductionServiceBuilder<'a> {
             slog_scope::logger(),
         ));
         let stake_store = Arc::new(StakeStore::new(
-            Box::new(SQLiteAdapter::new("stake", sqlite_db_path)?),
+            Box::new(SQLiteAdapter::new("stake", sqlite_connection)?),
             self.config.store_retention_limit,
         ));
         let chain_observer = {