Merge branch 'refactor-syncer' into integrate-cert

consensus-shipyard · Nov 28, 2024 · 427bfe5 · 427bfe5
2 parents 6094356 + 7434eba
commit 427bfe5
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 12 deletions.
diff --git a/fendermint/vm/topdown/src/observation.rs b/fendermint/vm/topdown/src/observation.rs
@@ -231,7 +231,7 @@ impl LinearizedParentBlockView {
             self.cumulative_effects_comm.as_slice(),
             to_append.as_slice(),
         ]
-        .concat();
+            .concat();
         let cid = Cid::new_v1(DAG_CBOR, Code::Blake2b256.digest(&bytes));
         self.cumulative_effects_comm = cid.to_bytes();
     }
@@ -264,4 +264,4 @@ impl LinearizedParentBlockView {
             self.cumulative_effects_comm,
         ))
     }
-}
+}
diff --git a/fendermint/vm/topdown/src/syncer/poll.rs b/fendermint/vm/topdown/src/syncer/poll.rs
@@ -28,9 +28,9 @@ pub struct ParentPoll<P, S> {
 
 #[async_trait]
 impl<P, S> ParentPoller for ParentPoll<P, S>
-where
-    S: ParentViewStore + Send + Sync + 'static + Clone,
-    P: Send + Sync + 'static + ParentQueryProxy,
+    where
+        S: ParentViewStore + Send + Sync + 'static + Clone,
+        P: Send + Sync + 'static + ParentQueryProxy,
 {
     type Store = S;
 
@@ -118,9 +118,9 @@ where
 }
 
 impl<P, S> ParentPoll<P, S>
-where
-    S: ParentViewStore + Send + Sync + 'static,
-    P: Send + Sync + 'static + ParentQueryProxy,
+    where
+        S: ParentViewStore + Send + Sync + 'static,
+        P: Send + Sync + 'static + ParentQueryProxy,
 {
     pub fn new(config: ParentSyncerConfig, proxy: P, store: S, last_finalized: Checkpoint) -> Self {
         let (tx, _) = broadcast::channel(config.broadcast_channel_size);
@@ -273,8 +273,8 @@ async fn fetch_data<P>(
     height: BlockHeight,
     block_hash: BlockHash,
 ) -> Result<ParentBlockView, Error>
-where
-    P: ParentQueryProxy + Send + Sync + 'static,
+    where
+        P: ParentQueryProxy + Send + Sync + 'static,
 {
     let changes_res = parent_proxy
         .get_validator_changes(height)
@@ -313,4 +313,4 @@ where
         topdown_msgs_res.value,
         changes_res.value,
     ))
-}
+}
diff --git a/fendermint/vm/topdown/src/syncer/store.rs b/fendermint/vm/topdown/src/syncer/store.rs
@@ -69,4 +69,4 @@ impl ParentViewStore for InMemoryParentViewStore {
         let inner = self.inner.read().unwrap();
         Ok(inner.upper_bound())
     }
-}
+}
-Original file line number
+Diff line change
@@ Expand Up / @@ -69,4 +69,4 @@ impl ParentViewStore for InMemoryParentViewStore { @@
             let inner = self.inner.read().unwrap();
             Ok(inner.upper_bound())
         }
-    }
+    }