mirror of
https://github.com/hl-archive-node/nanoreth.git
synced 2025-12-06 02:49:55 +00:00
chore: fmt
This commit is contained in:
@ -1,5 +1,5 @@
|
|||||||
pub mod call_forwarder;
|
pub mod call_forwarder;
|
||||||
pub mod hl_node_compliance;
|
pub mod hl_node_compliance;
|
||||||
pub mod tx_forwarder;
|
|
||||||
pub mod subscribe_fixup;
|
pub mod subscribe_fixup;
|
||||||
|
pub mod tx_forwarder;
|
||||||
mod utils;
|
mod utils;
|
||||||
|
|||||||
@ -1,7 +1,10 @@
|
|||||||
pub mod hl;
|
pub mod hl;
|
||||||
pub mod parser;
|
pub mod parser;
|
||||||
|
|
||||||
use crate::{hardforks::HlHardforks, node::primitives::{header::HlHeaderExtras, HlHeader}};
|
use crate::{
|
||||||
|
hardforks::HlHardforks,
|
||||||
|
node::primitives::{HlHeader, header::HlHeaderExtras},
|
||||||
|
};
|
||||||
use alloy_eips::eip7840::BlobParams;
|
use alloy_eips::eip7840::BlobParams;
|
||||||
use alloy_genesis::Genesis;
|
use alloy_genesis::Genesis;
|
||||||
use alloy_primitives::{Address, B256, U256};
|
use alloy_primitives::{Address, B256, U256};
|
||||||
|
|||||||
@ -1,4 +1,8 @@
|
|||||||
use crate::{hardforks::HlHardforks, node::{primitives::HlHeader, HlNode}, HlBlock, HlBlockBody, HlPrimitives};
|
use crate::{
|
||||||
|
HlBlock, HlBlockBody, HlPrimitives,
|
||||||
|
hardforks::HlHardforks,
|
||||||
|
node::{HlNode, primitives::HlHeader},
|
||||||
|
};
|
||||||
use reth::{
|
use reth::{
|
||||||
api::{FullNodeTypes, NodeTypes},
|
api::{FullNodeTypes, NodeTypes},
|
||||||
beacon_consensus::EthBeaconConsensus,
|
beacon_consensus::EthBeaconConsensus,
|
||||||
|
|||||||
@ -1,5 +1,6 @@
|
|||||||
use crate::{
|
use crate::{
|
||||||
node::evm::config::{HlBlockExecutorFactory, HlEvmConfig}, HlBlock, HlHeader
|
HlBlock, HlHeader,
|
||||||
|
node::evm::config::{HlBlockExecutorFactory, HlEvmConfig},
|
||||||
};
|
};
|
||||||
use reth_evm::{
|
use reth_evm::{
|
||||||
block::BlockExecutionError,
|
block::BlockExecutionError,
|
||||||
|
|||||||
@ -270,8 +270,8 @@ impl<'a, N: HlNodeType> MigrateStaticFiles<'a, N> {
|
|||||||
let mut first = true;
|
let mut first = true;
|
||||||
|
|
||||||
for (block_range, _tx_ranges) in all_static_files {
|
for (block_range, _tx_ranges) in all_static_files {
|
||||||
let migration_needed = self.using_old_header(block_range.start())?
|
let migration_needed = self.using_old_header(block_range.start())? ||
|
||||||
|| self.using_old_header(block_range.end())?;
|
self.using_old_header(block_range.end())?;
|
||||||
if !migration_needed {
|
if !migration_needed {
|
||||||
// Create a placeholder symlink
|
// Create a placeholder symlink
|
||||||
self.create_placeholder(block_range)?;
|
self.create_placeholder(block_range)?;
|
||||||
|
|||||||
@ -179,7 +179,7 @@ where
|
|||||||
|
|
||||||
#[cfg(test)]
|
#[cfg(test)]
|
||||||
mod tests {
|
mod tests {
|
||||||
use crate::{chainspec::hl::hl_mainnet, HlHeader};
|
use crate::{HlHeader, chainspec::hl::hl_mainnet};
|
||||||
|
|
||||||
use super::*;
|
use super::*;
|
||||||
use alloy_primitives::{B256, U128};
|
use alloy_primitives::{B256, U128};
|
||||||
|
|||||||
@ -3,8 +3,13 @@ use alloy_primitives::Address;
|
|||||||
use reth_primitives_traits::{BlockBody as BlockBodyTrait, InMemorySize};
|
use reth_primitives_traits::{BlockBody as BlockBodyTrait, InMemorySize};
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
|
|
||||||
use crate::node::types::{ReadPrecompileCall, ReadPrecompileCalls};
|
use crate::{
|
||||||
use crate::{HlHeader, node::primitives::TransactionSigned};
|
HlHeader,
|
||||||
|
node::{
|
||||||
|
primitives::TransactionSigned,
|
||||||
|
types::{ReadPrecompileCall, ReadPrecompileCalls},
|
||||||
|
},
|
||||||
|
};
|
||||||
|
|
||||||
/// Block body for HL. It is equivalent to Ethereum [`BlockBody`] but additionally stores sidecars
|
/// Block body for HL. It is equivalent to Ethereum [`BlockBody`] but additionally stores sidecars
|
||||||
/// for blob transactions.
|
/// for blob transactions.
|
||||||
@ -33,13 +38,11 @@ pub type BlockBody = alloy_consensus::BlockBody<TransactionSigned, HlHeader>;
|
|||||||
|
|
||||||
impl InMemorySize for HlBlockBody {
|
impl InMemorySize for HlBlockBody {
|
||||||
fn size(&self) -> usize {
|
fn size(&self) -> usize {
|
||||||
self.inner.size()
|
self.inner.size() +
|
||||||
+ self
|
self.sidecars
|
||||||
.sidecars
|
|
||||||
.as_ref()
|
.as_ref()
|
||||||
.map_or(0, |s| s.capacity() * core::mem::size_of::<BlobTransactionSidecar>())
|
.map_or(0, |s| s.capacity() * core::mem::size_of::<BlobTransactionSidecar>()) +
|
||||||
+ self
|
self.read_precompile_calls
|
||||||
.read_precompile_calls
|
|
||||||
.as_ref()
|
.as_ref()
|
||||||
.map_or(0, |s| s.0.capacity() * core::mem::size_of::<ReadPrecompileCall>())
|
.map_or(0, |s| s.0.capacity() * core::mem::size_of::<ReadPrecompileCall>())
|
||||||
}
|
}
|
||||||
|
|||||||
@ -45,7 +45,11 @@ pub struct HlHeaderExtras {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl HlHeader {
|
impl HlHeader {
|
||||||
pub(crate) fn from_ethereum_header(header: Header, receipts: &[EthereumReceipt], system_tx_count: u64) -> HlHeader {
|
pub(crate) fn from_ethereum_header(
|
||||||
|
header: Header,
|
||||||
|
receipts: &[EthereumReceipt],
|
||||||
|
system_tx_count: u64,
|
||||||
|
) -> HlHeader {
|
||||||
let logs_bloom = logs_bloom(receipts.iter().flat_map(|r| &r.logs));
|
let logs_bloom = logs_bloom(receipts.iter().flat_map(|r| &r.logs));
|
||||||
HlHeader {
|
HlHeader {
|
||||||
inner: header,
|
inner: header,
|
||||||
@ -183,8 +187,9 @@ impl reth_codecs::Compact for HlHeader {
|
|||||||
// because Compact trait requires the Bytes field to be placed at the end of the struct.
|
// because Compact trait requires the Bytes field to be placed at the end of the struct.
|
||||||
// Bytes::from_compact just reads all trailing data as the Bytes field.
|
// Bytes::from_compact just reads all trailing data as the Bytes field.
|
||||||
//
|
//
|
||||||
// Hence we need to use other form of serialization, since extra headers are not Compact-compatible.
|
// Hence we need to use other form of serialization, since extra headers are not
|
||||||
// We just treat all header fields as rmp-serialized one `Bytes` field.
|
// Compact-compatible. We just treat all header fields as rmp-serialized one `Bytes`
|
||||||
|
// field.
|
||||||
let result: Bytes = rmp_serde::to_vec(&self).unwrap().into();
|
let result: Bytes = rmp_serde::to_vec(&self).unwrap().into();
|
||||||
result.to_compact(buf)
|
result.to_compact(buf)
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
#![allow(clippy::owned_cow)]
|
#![allow(clippy::owned_cow)]
|
||||||
use super::{HlBlock, HlBlockBody, TransactionSigned};
|
use super::{HlBlock, HlBlockBody, TransactionSigned};
|
||||||
use crate::{node::types::ReadPrecompileCalls, HlHeader};
|
use crate::{HlHeader, node::types::ReadPrecompileCalls};
|
||||||
use alloy_consensus::{BlobTransactionSidecar, BlockBody};
|
use alloy_consensus::{BlobTransactionSidecar, BlockBody};
|
||||||
use alloy_eips::eip4895::Withdrawals;
|
use alloy_eips::eip4895::Withdrawals;
|
||||||
use alloy_primitives::Address;
|
use alloy_primitives::Address;
|
||||||
|
|||||||
@ -6,7 +6,10 @@ use serde::{Deserialize, Serialize};
|
|||||||
use std::borrow::Cow;
|
use std::borrow::Cow;
|
||||||
|
|
||||||
use super::{HlBlock, HlBlockBody};
|
use super::{HlBlock, HlBlockBody};
|
||||||
use crate::{node::{primitives::BlockBody, types::ReadPrecompileCalls}, HlHeader};
|
use crate::{
|
||||||
|
HlHeader,
|
||||||
|
node::{primitives::BlockBody, types::ReadPrecompileCalls},
|
||||||
|
};
|
||||||
|
|
||||||
#[derive(Debug, Serialize, Deserialize)]
|
#[derive(Debug, Serialize, Deserialize)]
|
||||||
pub struct HlBlockBodyBincode<'a> {
|
pub struct HlBlockBodyBincode<'a> {
|
||||||
|
|||||||
@ -82,8 +82,8 @@ impl BlockPoller {
|
|||||||
.ok_or(eyre::eyre!("Failed to find latest block number"))?;
|
.ok_or(eyre::eyre!("Failed to find latest block number"))?;
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
if let Some(debug_cutoff_height) = debug_cutoff_height
|
if let Some(debug_cutoff_height) = debug_cutoff_height &&
|
||||||
&& next_block_number > debug_cutoff_height
|
next_block_number > debug_cutoff_height
|
||||||
{
|
{
|
||||||
next_block_number = debug_cutoff_height;
|
next_block_number = debug_cutoff_height;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user