Merge pull request #571 from input-output-hk/greg/562/database_migration

application version stored in database

Author: ghubertpalo

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "mithril-aggregator"
-version = "0.1.1"
+version = "0.1.2"
 description = "A Mithril Aggregator server"
 authors = { workspace = true }
 edition = { workspace = true }
@@ -26,6 +26,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"
 tar = "0.4.38"
 thiserror = "1.0.31"
 tokio = { version = "1.17.0", features = ["full"] }

mithril-aggregator/Cargo.toml

@@ -12,6 +12,7 @@ use tokio::time::Duration;
 use mithril_common::certificate_chain::MithrilCertificateVerifier;
 use mithril_common::chain_observer::{CardanoCliRunner, ChainObserver};
 use mithril_common::crypto_helper::ProtocolGenesisVerifier;
+use mithril_common::database::{ApplicationNodeType, ApplicationVersionChecker};
 use mithril_common::digesters::{CardanoImmutableDigester, ImmutableFileSystemObserver};
 use mithril_common::entities::{Epoch, HexEncodedGenesisSecretKey};
 use mithril_common::store::adapter::SQLiteAdapter;
@@ -36,6 +37,13 @@ fn setup_genesis_dependencies(
     config: &GenesisConfiguration,
 ) -> Result<GenesisToolsDependency, Box<dyn std::error::Error>> {
     let sqlite_db_path = Some(config.get_sqlite_file());
+    ApplicationVersionChecker::new(
+        slog_scope::logger(),
+        ApplicationNodeType::Aggregator,
+        config.get_sqlite_file(),
+    )
+    .check(env!("CARGO_PKG_VERSION"))?;
+
     let chain_observer = Arc::new(
         mithril_common::chain_observer::CardanoCliChainObserver::new(Box::new(
             CardanoCliRunner::new(
@@ -295,12 +303,18 @@ 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());
+        ApplicationVersionChecker::new(
+            slog_scope::logger(),
+            ApplicationNodeType::Aggregator,
+            config.get_sqlite_file(),
+        )
+        .check(env!("CARGO_PKG_VERSION"))?;
+
         // Init dependencies
         let snapshot_store = config.build_snapshot_store()?;
         let snapshot_uploader = config.build_snapshot_uploader()?;
 
-        let sqlite_db_path = Some(config.get_sqlite_file());
-
         let certificate_pending_store = Arc::new(CertificatePendingStore::new(Box::new(
             SQLiteAdapter::new("pending_certificate", sqlite_db_path.clone())?,
         )));

mithril-aggregator/src/command_args.rs

@@ -26,7 +26,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
     let result = args.execute().await;
 
     if result.is_err() {
-        eprintln!("ERROR: application ends abnormaly.");
+        eprintln!("ERROR: application ends abnormaly: {:?}", result);
     }
 
     result

mithril-aggregator/src/main.rs

@@ -1,6 +1,6 @@
 [package]
 name = "mithril-common"
-version = "0.1.1"
+version = "0.1.2"
 authors = { workspace = true }
 edition = { workspace = true }
 documentation = { workspace = true }
@@ -28,14 +28,15 @@ nom = "7.1"
 rand-chacha-dalek-compat = { package = "rand_chacha", version = "0.2" }
 rand_chacha = "0.3.1"
 rand_core   = "0.6.3"
+semver = "1.0"
 serde = { version = "1.0", features = ["derive"] }
 serde_bytes = "0.11.7"
 serde_cbor = "0.11.2"
 serde_json = "1.0"
 serde_yaml = "0.9.10"
 sha2 = "0.10.2"
 slog = { version = "2.7.0", features = ["max_level_trace", "release_max_level_debug"] }
-sqlite = "0.27.0"
+sqlite = "0.28"
 thiserror = "1.0.31"
 tokio = { version = "1.17.0", features = ["full"] }
 walkdir = "2"