Fix miscounting blocks

Zilliqa · Oct 31, 2023 · 353be67 · 353be67
1 parent 82520c8
commit 353be67
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/products/pdt/pdtlisten/src/importer.rs b/products/pdt/pdtlisten/src/importer.rs
@@ -53,7 +53,7 @@ impl BatchedImporter {
                     if block.block < range.start {
                         self.range = Some(block.block..range.end)
                     } else if block.block > range.end {
-                        self.range = Some(range.start..block.block)
+                        self.range = Some(range.start..block.block + 1) // range end not inclusive
                     }
                 } else {
                     self.range = Some(block.block..(block.block + 1))

diff --git a/products/pdt/pdtlisten/src/listener.rs b/products/pdt/pdtlisten/src/listener.rs
@@ -86,7 +86,11 @@ async fn get_block(
     let mut blocks: Vec<(Block<Transaction>, Vec<ZILTransactionBody>)> = Vec::new();
     for _block_number in last_seen_block_number_unwrap.as_u64() + 1..=block_number.as_u64() {
         let block = get_block_by_number(_block_number.into(), provider).await?;
-        let txn_bodies = get_zil_transaction_bodies_from_block(block_number, provider).await?;
+        let txn_bodies = if block.transactions.is_empty() {
+            Vec::default()
+        } else {
+            get_zil_transaction_bodies_from_block(block_number, provider).await?
+        };
         blocks.push((block, txn_bodies));
     }