Add DependencyManager #120

* Implement a dependency manager
* Add a snashot storer as a dependency
* Use snapshot storer dependency in server routes

Author: jpraynaud

mithril-network/mithril-aggregator/Makefile

@@ -1,4 +1,4 @@
-.PHONY: all build test debug run help doc
+.PHONY: all build test check debug run help doc
 
 CARGO = cargo
 
@@ -17,6 +17,10 @@ debug:
 test:
 	${CARGO} test
 
+check:
+	${CARGO} check --all-targets
+	${CARGO} clippy --all-targets
+
 help:
 	@${CARGO} run -- -h
 

mithril-network/mithril-aggregator/config/dev.json

@@ -0,0 +1,4 @@
+{
+    "network": "testnet",
+    "url_snapshot_manifest": "https://storage.googleapis.com/cardano-testnet/snapshots.json"
+}

mithril-network/mithril-aggregator/src/dependency.rs

@@ -0,0 +1,29 @@
+use std::sync::Arc;
+use tokio::sync::RwLock;
+
+use crate::entities::*;
+use crate::snapshot_store::SnapshotStorer;
+
+pub struct DependencyManager {
+    pub config: Config,
+    pub snapshot_storer: Option<Arc<RwLock<dyn SnapshotStorer + Sync + Send>>>,
+}
+
+impl DependencyManager {
+    /// DependencyManager factory
+    pub fn new(config: Config) -> Self {
+        Self {
+            config,
+            snapshot_storer: None,
+        }
+    }
+
+    /// With SnapshotStorer
+    pub fn with_snapshot_storer(
+        &mut self,
+        snapshot_storer: Arc<RwLock<dyn SnapshotStorer + Sync + Send>>,
+    ) -> &mut Self {
+        self.snapshot_storer = Some(snapshot_storer);
+        self
+    }
+}

mithril-network/mithril-aggregator/src/entities.rs

@@ -5,6 +5,16 @@
 
 use serde::{Deserialize, Serialize};
 
+/// Aggregator configuration
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct Config {
+    /// Cardano network
+    pub network: String,
+
+    /// Snapshots manifest location
+    pub url_snapshot_manifest: String,
+}
+
 /// Beacon represents a point in the Cardano chain at which a Mithril certificate should be produced
 #[derive(Clone, Debug, PartialEq, Default, Serialize, Deserialize)]
 pub struct Beacon {
@@ -141,7 +151,7 @@ impl Certificate {
 pub struct Error {
     /// error code
     #[serde(rename = "code")]
-    pub code: Option<serde_json::Value>,
+    pub code: String,
 
     /// error message
     #[serde(rename = "message")]
@@ -150,7 +160,7 @@ pub struct Error {
 
 impl Error {
     /// Error factory
-    pub fn new(code: Option<serde_json::Value>, message: String) -> Error {
+    pub fn new(code: String, message: String) -> Error {
         Error { code, message }
     }
 }

mithril-network/mithril-aggregator/src/errors.rs

@@ -0,0 +1,3 @@
+pub const OPEN_CONFIG_FILE: &str = "impossible to open config file";
+
+pub const PARSE_CONFIG_FILE: &str = "impossible to parse config file";