Fix not loading snapshot(must have been using deduplication)

gnosisguild · Nov 5, 2024 · b971db7 · b971db7
1 parent b4475bb
commit b971db7
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 4 deletions.
diff --git a/packages/ciphernode/enclave_node/src/aggregator.rs b/packages/ciphernode/enclave_node/src/aggregator.rs
@@ -49,7 +49,7 @@ pub async fn setup_aggregator(
         let read_provider = create_readonly_provider(&ensure_ws_rpc(rpc_url)).await?;
         let write_provider =
             create_provider_with_signer(&ensure_http_rpc(rpc_url), &signer).await?;
-            
+
         EnclaveSol::attach(
             &bus,
             &read_provider,
@@ -59,7 +59,12 @@ pub async fn setup_aggregator(
             chain.contracts.enclave.deploy_block(),
         )
         .await?;
-        RegistryFilterSol::attach(&bus, &write_provider, &chain.contracts.filter_registry.address()).await?;
+        RegistryFilterSol::attach(
+            &bus,
+            &write_provider,
+            &chain.contracts.filter_registry.address(),
+        )
+        .await?;
         CiphernodeRegistrySol::attach(
             &bus,
             &read_provider,

diff --git a/packages/ciphernode/enclave_node/src/ciphernode.rs b/packages/ciphernode/enclave_node/src/ciphernode.rs
@@ -58,7 +58,7 @@ pub async fn setup_ciphernode(
             &read_provider,
             &chain.contracts.ciphernode_registry.address(),
             &repositories.ciphernode_registry_reader(read_provider.get_chain_id()),
-            chain.contracts.ciphernode_registry.deploy_block()
+            chain.contracts.ciphernode_registry.deploy_block(),
         )
         .await?;
     }

diff --git a/packages/ciphernode/evm/src/event_reader.rs b/packages/ciphernode/evm/src/event_reader.rs
@@ -74,7 +74,9 @@ where
     start_block: Option<u64>,
     /// Event bus for error propagation
     bus: Addr<EventBus>,
+    /// The in memory state of the event reader
     state: EvmEventReaderState,
+    /// Repository to save the state of the event reader
     repository: Repository<EvmEventReaderState>,
 }
 
@@ -122,7 +124,7 @@ where
             bus: bus.clone(),
             repository: repository.clone(),
         };
-        let addr = EvmEventReader::new(params).start();
+        let addr = EvmEventReader::load(params).await?.start();
 
         bus.do_send(Subscribe::new("Shutdown", addr.clone().into()));