github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-04-08 03:01:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

feat(alloy-provider): implement sealed_header method (#17455)

Browse Source
This commit is contained in:
cakevm
2025-07-17 15:56:21 +02:00
committed by GitHub
parent 0b1d950f67
commit 61a19c1bcb
1 changed files with 18 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
crates/alloy-provider/src/lib.rs
View File

@@ -301,20 +301,12 @@ where
}
fn header_by_number(&self, num: u64) -> ProviderResult<Option<Self::Header>> {
let block_response = self.block_on_async(async {
self.provider.get_block_by_number(num.into()).await.map_err(ProviderError::other)
})?;
let Some(block_response) = block_response else {
let Some(sealed_header) = self.sealed_header(num)? else {
// If the block was not found, return None
return Ok(None);
};
// Convert the network block response to primitive block
let block = <BlockTy<Node> as TryFromBlockResponse<N>>::from_block_response(block_response)
.map_err(ProviderError::other)?;
Ok(Some(block.into_header()))
Ok(Some(sealed_header.into_header()))
}
fn header_td(&self, _hash: &BlockHash) -> ProviderResult<Option<U256>> {
@@ -334,9 +326,23 @@ where
fn sealed_header(
&self,
_number: BlockNumber,
number: BlockNumber,
) -> ProviderResult<Option<SealedHeader<Self::Header>>> {
Err(ProviderError::UnsupportedProvider)
let block_response = self.block_on_async(async {
self.provider.get_block_by_number(number.into()).await.map_err(ProviderError::other)
})?;
let Some(block_response) = block_response else {
// If the block was not found, return None
return Ok(None);
};
let block_hash = block_response.header().hash();
// Convert the network block response to primitive block
let block = <BlockTy<Node> as TryFromBlockResponse<N>>::from_block_response(block_response)
.map_err(ProviderError::other)?;
Ok(Some(SealedHeader::new(block.into_header(), block_hash)))
}
fn sealed_headers_while(