Fix block polling bug (#238)

helius-labs · Nov 1, 2024 · a4dd65c · a4dd65c
1 parent 6145d77
commit a4dd65c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/ingester/fetchers/grpc.rs b/src/ingester/fetchers/grpc.rs
@@ -78,6 +78,10 @@ pub fn get_grpc_stream_with_rpc_fallback(
                             panic!("gRPC stream ended unexpectedly");
                         }
                         Either::Right((Some(rpc_blocks), _)) => {
+                            let rpc_blocks: Vec<BlockInfo> = rpc_blocks
+                                .into_iter()
+                                .filter(|b| b.metadata.slot > last_indexed_slot)
+                                .collect();
                             let blocks_len = rpc_blocks.len();
                             let parent_slot = rpc_blocks.first().unwrap().metadata.parent_slot;
                             let last_slot = rpc_blocks.last().unwrap().metadata.slot;