fix(chain-storage): fetch_chain_headers should return empty vec if qu…

…ery is out of range

applications/tari_base_node/src/grpc/base_node_grpc_server.rs

@@ -1945,6 +1945,10 @@ impl tari_rpc::base_node_server::BaseNode for BaseNodeGrpcServer {
                     }
                 }
 
+                if headers.len() < BATCH_SIZE {
+                    break;
+                }
+
                 current_height += BATCH_SIZE + 1;
             }
         });

base_layer/core/src/chain_storage/blockchain_database.rs

@@ -1372,9 +1372,19 @@ pub fn fetch_chain_headers<T: BlockchainBackend>(
         ));
     }
 
-    (start..=end_inclusive)
-        .map(|h| db.fetch_chain_header_by_height(h))
-        .collect()
+    #[allow(clippy::cast_possible_truncation)]
+    let mut headers = Vec::with_capacity((end_inclusive - start) as usize);
+    for h in start..=end_inclusive {
+        match db.fetch_chain_header_by_height(h) {
+            Ok(header) => {
+                headers.push(header);
+            },
+            Err(ChainStorageError::ValueNotFound { .. }) => break,
+            Err(e) => return Err(e),
+        }
+    }
+
+    Ok(headers)
 }
 
 fn insert_headers<T: BlockchainBackend>(db: &mut T, headers: Vec<ChainHeader>) -> Result<(), ChainStorageError> {