fix: edge case when requests processed out of order

Ludo Galabru · Ludo Galabru · commit a6651b851f54 · 2023-08-24T10:01:58.000+02:00
diff --git a/components/ordhook-core/src/core/pipeline/mod.rs b/components/ordhook-core/src/core/pipeline/mod.rs
@@ -169,7 +169,6 @@ pub async fn download_and_pipeline_blocks(
                 while let Ok(message) = block_compressed_rx.try_recv() {
                     match message {
                         Some((block_height, block, compacted_block)) => {
-                            blocks_processed += 1;
                             new_blocks.push((block_height, block, compacted_block));
                             // Max batch size: 10_000 blocks
                             if new_blocks.len() >= 10_000 {
@@ -216,6 +215,7 @@ pub async fn download_and_pipeline_blocks(
                             vec![],
                         ));
                     }
+                    blocks_processed += 1;
                     continue;
                 }
 
@@ -235,6 +235,7 @@ pub async fn download_and_pipeline_blocks(
                             blocks,
                         ));
                     }
+                    blocks_processed += 1;
                 }
             }
             ()

Original file line number	Diff line number	Diff line change
`@@ -169,7 +169,6 @@ pub async fn download_and_pipeline_blocks(`
`169`	`169`	`while let Ok(message) = block_compressed_rx.try_recv() {`
`170`	`170`	`match message {`
`171`	`171`	`Some((block_height, block, compacted_block)) => {`
`172`		`- blocks_processed += 1;`
`173`	`172`	`new_blocks.push((block_height, block, compacted_block));`
`174`	`173`	`// Max batch size: 10_000 blocks`
`175`	`174`	`if new_blocks.len() >= 10_000 {`
`@@ -216,6 +215,7 @@ pub async fn download_and_pipeline_blocks(`
`216`	`215`	`vec![],`
`217`	`216`	`));`
`218`	`217`	`}`
	`218`	`+ blocks_processed += 1;`
`219`	`219`	`continue;`
`220`	`220`	`}`
`221`	`221`
`@@ -235,6 +235,7 @@ pub async fn download_and_pipeline_blocks(`
`235`	`235`	`blocks,`
`236`	`236`	`));`
`237`	`237`	`}`
	`238`	`+ blocks_processed += 1;`
`238`	`239`	`}`
`239`	`240`	`}`
`240`	`241`	`()`