Ensure that snapshotting is fallable and prepare for persistable cont…

…ainer

packages/ciphernode/Cargo.toml

@@ -40,6 +40,7 @@ cipher = { path = "./cipher" }
 compile-time = "0.2.0"
 dirs = "5.0.1"
 data = { path = "./data" }
+enclave-core = { path = "./core" }
 shellexpand = "3.1.0"
 figment = { version = "0.10.19", features = ["yaml", "test"] }
 fhe_rs = { package = "fhe", git = "https://github.com/gnosisguild/fhe.rs", version = "0.1.0-beta.7" }

packages/ciphernode/aggregator/src/plaintext_aggregator.rs

@@ -221,8 +221,8 @@ impl Handler<Die> for PlaintextAggregator {
 impl Snapshot for PlaintextAggregator {
     type Snapshot = PlaintextAggregatorState;
 
-    fn snapshot(&self) -> Self::Snapshot {
-        self.state.clone()
+    fn snapshot(&self) -> Result<Self::Snapshot> {
+        Ok(self.state.clone())
     }
 }
 

packages/ciphernode/aggregator/src/publickey_aggregator.rs

@@ -246,8 +246,8 @@ impl Handler<Die> for PublicKeyAggregator {
 impl Snapshot for PublicKeyAggregator {
     type Snapshot = PublicKeyAggregatorState;
 
-    fn snapshot(&self) -> Self::Snapshot {
-        self.state.clone()
+    fn snapshot(&self) -> Result<Self::Snapshot> {
+        Ok(self.state.clone())
     }
 }
 

packages/ciphernode/config/Cargo.toml

@@ -11,6 +11,7 @@ figment = { workspace = true }
 alloy = { workspace = true }
 shellexpand = { workspace = true }
 url = { workspace = true }
+enclave-core = { workspace = true }
 
 [dev-dependencies]
 tempfile = { workspace = true }

packages/ciphernode/config/src/lib.rs

@@ -1,3 +1,5 @@
 mod app_config;
 mod yaml;
+mod store_keys;
+
 pub use app_config::*;

packages/ciphernode/config/src/store_keys.rs

@@ -0,0 +1,53 @@
+use enclave_core::E3id;
+
+pub struct StoreKeys;
+
+impl StoreKeys {
+    pub fn keyshare(e3_id: &E3id) -> String {
+        format!("//keyshare/{e3_id}")
+    }
+
+    pub fn plaintext(e3_id: &E3id) -> String {
+        format!("//plaintext/{e3_id}")
+    }
+
+    pub fn publickey(e3_id: &E3id) -> String {
+        format!("//publickey/{e3_id}")
+    }
+
+    pub fn fhe(e3_id: &E3id) -> String {
+        format!("//fhe/{e3_id}")
+    }
+
+    pub fn meta(e3_id: &E3id) -> String {
+        format!("//meta/{e3_id}")
+    }
+
+    pub fn context(e3_id: &E3id) -> String {
+        format!("//context/{e3_id}")
+    }
+
+    pub fn router() -> String {
+        String::from("//router")
+    }
+
+    pub fn sortition() -> String {
+        String::from("//sortition")
+    }
+
+    pub fn eth_private_key() -> String {
+        String::from("//eth_private_key")
+    }
+
+    pub fn libp2p_keypair() -> String {
+        String::from("//libp2p/keypair")
+    }
+
+    pub fn enclave_sol_reader(chain_id: u64) -> String {
+        format!("//evm_readers/enclave/{chain_id}")
+    }
+
+    pub fn ciphernode_registry_reader(chain_id: u64) -> String {
+        format!("//evm_readers/ciphernode_registry/{chain_id}")
+    }
+}

packages/ciphernode/data/src/lib.rs

@@ -4,6 +4,7 @@ mod into_key;
 mod repository;
 mod sled_store;
 mod snapshot;
+mod persistable;
 
 pub use data_store::*;
 pub use in_mem::*;