feat: verifies new MMR = old MMR + all incremental headers

synapseweb3 · Jul 19, 2023 · 0f9febb · 0f9febb
1 parent 28d102f
commit 0f9febb
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 5 deletions.
diff --git a/verification/Cargo.toml b/verification/Cargo.toml
@@ -10,7 +10,7 @@ repository = "https://github.com/synapseweb3/eth-light-client-in-ckb"
 
 [dependencies]
 molecule         = { version = "=0.7.5", default-features = false }
-ckb-mmr          = { version = "0.5.2", default-features = false, package = "ckb-merkle-mountain-range" }
+ckb-mmr          = { version = "0.6.0", default-features = false, package = "ckb-merkle-mountain-range" }
 rlp              = { version = "0.5.2", default-features = false }
 ethereum-types   = { version = "0.14.1", default-features = false  }
 tiny-keccak      = { version = "2.0.2", features = ["keccak"] }

diff --git a/verification/src/types/extension/core.rs b/verification/src/types/extension/core.rs
@@ -297,7 +297,7 @@ impl core::ClientUpdate {
         let mut prev_cached_header: mmr::HeaderWithCache;
         let mut curr_tip_valid_header_root: core::Hash;
         let mut header_mmr_index: u64;
-        let mut digests_with_positions = Vec::with_capacity(headers_count);
+        let mut digests = Vec::with_capacity(headers_count);
 
         // Check First Header with the Old Client
         {
@@ -333,7 +333,7 @@ impl core::ClientUpdate {
                 curr_cached_header.inner.slot
             );
             let digest = curr_cached_header.packed_digest();
-            digests_with_positions.push((position, digest));
+            digests.push(digest);
 
             header_mmr_index += 1;
             prev_cached_header = curr_cached_header;
@@ -374,7 +374,7 @@ impl core::ClientUpdate {
                 curr_cached_header.inner.slot
             );
             let digest = curr_cached_header.packed_digest();
-            digests_with_positions.push((position, digest));
+            digests.push(digest);
 
             header_mmr_index += 1;
             prev_cached_header = curr_cached_header;
@@ -397,7 +397,11 @@ impl core::ClientUpdate {
                 mmr::MMRProof::new(mmr_size, proof)
             };
             let result = proof
-                .verify(new_client.headers_mmr_root.pack(), digests_with_positions)
+                .verify_incremental(
+                    new_client.headers_mmr_root.pack(),
+                    client.headers_mmr_root.pack(),
+                    digests,
+                )
                 .map_err(|_| ClientUpdateError::MmrError)?;
             if !result {
                 warn!(