mirror of
https://github.com/hl-archive-node/nanoreth.git
synced 2025-12-06 10:59:55 +00:00
chore: use more payload conversion fns (#13625)
This commit is contained in:
@ -1108,6 +1108,7 @@ mod tests {
|
|||||||
// tests covering `engine_getPayloadBodiesByRange` and `engine_getPayloadBodiesByHash`
|
// tests covering `engine_getPayloadBodiesByRange` and `engine_getPayloadBodiesByHash`
|
||||||
mod get_payload_bodies {
|
mod get_payload_bodies {
|
||||||
use super::*;
|
use super::*;
|
||||||
|
use alloy_rpc_types_engine::ExecutionPayloadBodyV1;
|
||||||
use reth_testing_utils::generators::{self, random_block_range, BlockRangeParams};
|
use reth_testing_utils::generators::{self, random_block_range, BlockRangeParams};
|
||||||
|
|
||||||
#[tokio::test]
|
#[tokio::test]
|
||||||
@ -1153,7 +1154,7 @@ mod tests {
|
|||||||
let expected = blocks
|
let expected = blocks
|
||||||
.iter()
|
.iter()
|
||||||
.cloned()
|
.cloned()
|
||||||
.map(|b| Some(convert_to_payload_body_v1(b.unseal::<Block>())))
|
.map(|b| Some(ExecutionPayloadBodyV1::from_block(b.unseal::<Block>())))
|
||||||
.collect::<Vec<_>>();
|
.collect::<Vec<_>>();
|
||||||
|
|
||||||
let res = api.get_payload_bodies_by_range_v1(start, count).await.unwrap();
|
let res = api.get_payload_bodies_by_range_v1(start, count).await.unwrap();
|
||||||
@ -1195,7 +1196,7 @@ mod tests {
|
|||||||
if first_missing_range.contains(&b.number) {
|
if first_missing_range.contains(&b.number) {
|
||||||
None
|
None
|
||||||
} else {
|
} else {
|
||||||
Some(convert_to_payload_body_v1(b.unseal::<Block>()))
|
Some(ExecutionPayloadBodyV1::from_block(b.unseal::<Block>()))
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
.collect::<Vec<_>>();
|
.collect::<Vec<_>>();
|
||||||
@ -1214,7 +1215,7 @@ mod tests {
|
|||||||
{
|
{
|
||||||
None
|
None
|
||||||
} else {
|
} else {
|
||||||
Some(convert_to_payload_body_v1(b.unseal::<Block>()))
|
Some(ExecutionPayloadBodyV1::from_block(b.unseal::<Block>()))
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
.collect::<Vec<_>>();
|
.collect::<Vec<_>>();
|
||||||
|
|||||||
@ -9,9 +9,7 @@ use alloy_rpc_types_engine::{
|
|||||||
};
|
};
|
||||||
use assert_matches::assert_matches;
|
use assert_matches::assert_matches;
|
||||||
use reth_primitives::{proofs, Block, SealedBlock, SealedHeader, TransactionSigned};
|
use reth_primitives::{proofs, Block, SealedBlock, SealedHeader, TransactionSigned};
|
||||||
use reth_rpc_types_compat::engine::payload::{
|
use reth_rpc_types_compat::engine::payload::{block_to_payload, block_to_payload_v1};
|
||||||
block_to_payload, block_to_payload_v1, convert_to_payload_body_v1,
|
|
||||||
};
|
|
||||||
use reth_testing_utils::generators::{
|
use reth_testing_utils::generators::{
|
||||||
self, random_block, random_block_range, BlockParams, BlockRangeParams, Rng,
|
self, random_block, random_block_range, BlockParams, BlockRangeParams, Rng,
|
||||||
};
|
};
|
||||||
@ -38,8 +36,8 @@ fn payload_body_roundtrip() {
|
|||||||
0..=99,
|
0..=99,
|
||||||
BlockRangeParams { tx_count: 0..2, ..Default::default() },
|
BlockRangeParams { tx_count: 0..2, ..Default::default() },
|
||||||
) {
|
) {
|
||||||
let unsealed = block.clone().unseal::<Block>();
|
let payload_body: ExecutionPayloadBodyV1 =
|
||||||
let payload_body: ExecutionPayloadBodyV1 = convert_to_payload_body_v1(unsealed);
|
ExecutionPayloadBodyV1::from_block(block.clone().unseal::<Block>());
|
||||||
|
|
||||||
assert_eq!(
|
assert_eq!(
|
||||||
Ok(block.body.transactions),
|
Ok(block.body.transactions),
|
||||||
|
|||||||
Reference in New Issue
Block a user