reth_storage_errors/
provider.rs

1use crate::{any::AnyError, db::DatabaseError};
2use alloc::{boxed::Box, string::String};
3use alloy_eips::{BlockHashOrNumber, HashOrNumber};
4use alloy_primitives::{Address, BlockHash, BlockNumber, TxNumber, B256};
5use derive_more::Display;
6use reth_codecs::DecompressError;
7use reth_primitives_traits::{transaction::signed::RecoveryError, GotExpected};
8use reth_prune_types::PruneSegmentError;
9use reth_static_file_types::StaticFileSegment;
10use revm::{
11    database_interface::{bal::EvmDatabaseError, DBErrorMarker},
12    state::bal::BalError,
13};
14
15/// Provider result type.
16pub type ProviderResult<Ok> = Result<Ok, ProviderError>;
17
18/// Bundled errors variants thrown by various providers.
19#[derive(Clone, Debug, thiserror::Error)]
20pub enum ProviderError {
21    /// Database error.
22    #[error(transparent)]
23    Database(#[from] DatabaseError),
24    /// BAL error.
25    #[error("BAL error:{_0}")]
26    Bal(BalError),
27    /// Pruning error.
28    #[error(transparent)]
29    Pruning(#[from] PruneSegmentError),
30    /// Static file writer error.
31    #[error(transparent)]
32    StaticFileWriter(#[from] StaticFileWriterError),
33    /// RLP error.
34    #[error("{_0}")]
35    Rlp(alloy_rlp::Error),
36    /// Trie witness error.
37    #[error("trie witness error: {_0}")]
38    TrieWitnessError(String),
39    /// Error when recovering the sender for a transaction
40    #[error("failed to recover sender for transaction")]
41    SenderRecoveryError,
42    /// The header number was not found for the given block hash.
43    #[error("block hash {_0} does not exist in Headers table")]
44    BlockHashNotFound(BlockHash),
45    /// A block body is missing.
46    #[error("block meta not found for block #{_0}")]
47    BlockBodyIndicesNotFound(BlockNumber),
48    /// The transition ID was found for the given address and storage key, but the changeset was
49    /// not found.
50    #[error(
51        "storage change set for address {address} and key {storage_key} at block #{block_number} does not exist"
52    )]
53    StorageChangesetNotFound {
54        /// The block number found for the address and storage key.
55        block_number: BlockNumber,
56        /// The account address.
57        address: Address,
58        /// The storage key.
59        // NOTE: This is a Box only because otherwise this variant is 16 bytes larger than the
60        // second largest (which uses `BlockHashOrNumber`).
61        storage_key: Box<B256>,
62    },
63    /// The block number was found for the given address, but the changeset was not found.
64    #[error("account change set for address {address} at block #{block_number} does not exist")]
65    AccountChangesetNotFound {
66        /// Block number found for the address.
67        block_number: BlockNumber,
68        /// The account address.
69        address: Address,
70    },
71    /// When required header related data was not found but was required.
72    #[error("no header found for {_0:?}")]
73    HeaderNotFound(BlockHashOrNumber),
74    /// The specific transaction identified by hash or id is missing.
75    #[error("no transaction found for {_0:?}")]
76    TransactionNotFound(HashOrNumber),
77    /// The specific receipt for a transaction identified by hash or id is missing
78    #[error("no receipt found for {_0:?}")]
79    ReceiptNotFound(HashOrNumber),
80    /// Unable to find the best block.
81    #[error("best block does not exist")]
82    BestBlockNotFound,
83    /// Unable to find the finalized block.
84    #[error("finalized block does not exist")]
85    FinalizedBlockNotFound,
86    /// Unable to find the safe block.
87    #[error("safe block does not exist")]
88    SafeBlockNotFound,
89    /// Thrown when we failed to lookup a block for the pending state.
90    #[error("unknown block {_0}")]
91    UnknownBlockHash(B256),
92    /// Thrown when we were unable to find a state for a block hash.
93    #[error("no state found for block {_0}")]
94    StateForHashNotFound(B256),
95    /// Thrown when we were unable to find a state for a block number.
96    #[error("no state found for block number {_0}")]
97    StateForNumberNotFound(u64),
98    /// Unable to find the block number for a given transaction index.
99    #[error("unable to find the block number for a given transaction index")]
100    BlockNumberForTransactionIndexNotFound,
101    /// Root mismatch.
102    #[error("merkle trie {_0}")]
103    StateRootMismatch(Box<RootMismatch>),
104    /// Root mismatch during unwind
105    #[error("unwind merkle trie {_0}")]
106    UnwindStateRootMismatch(Box<RootMismatch>),
107    /// State is not available for the given block number because it is pruned.
108    #[error("state at block #{_0} is pruned")]
109    StateAtBlockPruned(BlockNumber),
110    /// State is not available because the block has not been executed yet.
111    #[error("state at block #{requested} is not available, block has not been executed yet (latest executed: #{executed})")]
112    BlockNotExecuted {
113        /// The block number that was requested.
114        requested: BlockNumber,
115        /// The latest executed block number.
116        executed: BlockNumber,
117    },
118    /// Block data is not available because history has expired.
119    ///
120    /// The requested block number is below the earliest available block.
121    #[error("block #{requested} is not available, history has expired (earliest available: #{earliest_available})")]
122    BlockExpired {
123        /// The block number that was requested.
124        requested: BlockNumber,
125        /// The earliest available block number.
126        earliest_available: BlockNumber,
127    },
128    /// Provider does not support this particular request.
129    #[error("this provider does not support this request")]
130    UnsupportedProvider,
131    /// Static File is not found at specified path.
132    #[cfg(feature = "std")]
133    #[error("not able to find {_0} static file at {_1:?}")]
134    MissingStaticFileSegmentPath(StaticFileSegment, std::path::PathBuf),
135    /// Static File is not found at specified path.
136    #[cfg(feature = "std")]
137    #[error("not able to find static file at {_0:?}")]
138    MissingStaticFilePath(std::path::PathBuf),
139    /// Highest block is not found for static file block.
140    #[error("highest block is not found for {_0} static file")]
141    MissingHighestStaticFileBlock(StaticFileSegment),
142    /// Static File is not found for requested block.
143    #[error("not able to find {_0} static file for block number {_1}")]
144    MissingStaticFileBlock(StaticFileSegment, BlockNumber),
145    /// Static File is not found for requested transaction.
146    #[error("unable to find {_0} static file for transaction id {_1}")]
147    MissingStaticFileTx(StaticFileSegment, TxNumber),
148    /// Static File is finalized and cannot be written to.
149    #[error("unable to write block #{_1} to finalized static file {_0}")]
150    FinalizedStaticFile(StaticFileSegment, BlockNumber),
151    /// Trying to insert data from an unexpected block number.
152    #[error("trying to append data to {_0} as block #{_1} but expected block #{_2}")]
153    UnexpectedStaticFileBlockNumber(StaticFileSegment, BlockNumber, BlockNumber),
154    /// Trying to insert data from an unexpected block number.
155    #[error("trying to append row to {_0} at index #{_1} but expected index #{_2}")]
156    UnexpectedStaticFileTxNumber(StaticFileSegment, TxNumber, TxNumber),
157    /// Changeset static file is corrupted, and does not have offsets for changesets in each block
158    #[error("changeset static file is corrupted, missing offsets for changesets in each block")]
159    CorruptedChangeSetStaticFile,
160    /// Error when constructing hashed post state reverts
161    #[error("Unbounded start is unsupported in from_reverts")]
162    UnboundedStartUnsupported,
163    /// Static File Provider was initialized as read-only.
164    #[error("cannot get a writer on a read-only environment.")]
165    ReadOnlyStaticFileAccess,
166    /// Consistent view error.
167    #[error("failed to initialize consistent view: {_0}")]
168    ConsistentView(Box<ConsistentViewError>),
169    /// Received invalid output from configured storage implementation.
170    #[error("received invalid output from storage")]
171    InvalidStorageOutput,
172    /// Missing trie updates.
173    #[error("missing trie updates for block {0}")]
174    MissingTrieUpdates(B256),
175    /// Insufficient changesets to revert to the requested block.
176    #[error("insufficient changesets to revert to block #{requested}. Available changeset range: {available:?}")]
177    InsufficientChangesets {
178        /// The block number requested for reversion
179        requested: BlockNumber,
180        /// The available range of blocks with changesets
181        available: core::ops::RangeInclusive<BlockNumber>,
182    },
183    /// Inconsistency detected between static files/rocksdb and the DB during
184    /// `ProviderFactory::check_consistency`. The database must be unwound to
185    /// the specified block number to restore consistency.
186    #[error("consistency check failed for {data_source}. Db must be unwound to {unwind_to}")]
187    MustUnwind {
188        /// The inconsistent data source(s).
189        data_source: &'static str,
190        /// The block number to which the database must be unwound.
191        unwind_to: BlockNumber,
192    },
193    /// A persisted snap attempt record this build cannot read.
194    #[error(
195        "snap attempt record version {found:?} is not supported, this build writes {supported}"
196    )]
197    UnsupportedSnapAttemptVersion {
198        /// Version found on disk, absent when the record carries no numeric version.
199        found: Option<u64>,
200        /// Version this build writes.
201        supported: u32,
202    },
203    /// Snap sync was selected on a database that predates the hashed state layout it downloads
204    /// into.
205    #[error("snap sync requires the hashed state layout, which this database predates")]
206    SnapStorageLayoutUnsupported,
207    /// State a snap attempt is still downloading was about to be marked complete.
208    #[error("snap attempt {attempt} has not verified the downloaded state")]
209    UnverifiedSnapState {
210        /// Attempt that owns the unverified state.
211        attempt: u64,
212    },
213    /// Any other error type wrapped into a cloneable [`AnyError`].
214    #[error(transparent)]
215    Other(#[from] AnyError),
216}
217
218impl ProviderError {
219    /// Creates a new [`ProviderError::Other`] variant by wrapping the given error into an
220    /// [`AnyError`]
221    pub fn other<E>(error: E) -> Self
222    where
223        E: core::error::Error + Send + Sync + 'static,
224    {
225        Self::Other(AnyError::new(error))
226    }
227
228    /// Returns the arbitrary error if it is [`ProviderError::Other`]
229    pub fn as_other(&self) -> Option<&(dyn core::error::Error + Send + Sync + 'static)> {
230        match self {
231            Self::Other(err) => Some(err.as_error()),
232            _ => None,
233        }
234    }
235
236    /// Returns a reference to the [`ProviderError::Other`] value if this type is a
237    /// [`ProviderError::Other`] and the [`AnyError`] wraps an error of that type. Returns None
238    /// otherwise.
239    pub fn downcast_other_ref<T: core::error::Error + 'static>(&self) -> Option<&T> {
240        let other = self.as_other()?;
241        other.downcast_ref()
242    }
243
244    /// Returns true if this type is a [`ProviderError::Other`] of that error
245    /// type. Returns false otherwise.
246    pub fn is_other<T: core::error::Error + 'static>(&self) -> bool {
247        self.as_other().map(|err| err.is::<T>()).unwrap_or(false)
248    }
249}
250
251impl DBErrorMarker for ProviderError {}
252
253impl From<alloy_rlp::Error> for ProviderError {
254    fn from(error: alloy_rlp::Error) -> Self {
255        Self::Rlp(error)
256    }
257}
258
259impl From<RecoveryError> for ProviderError {
260    fn from(_: RecoveryError) -> Self {
261        Self::SenderRecoveryError
262    }
263}
264
265impl From<ProviderError> for EvmDatabaseError<ProviderError> {
266    fn from(error: ProviderError) -> Self {
267        Self::Database(error)
268    }
269}
270
271impl From<DecompressError> for ProviderError {
272    fn from(error: DecompressError) -> Self {
273        Self::Database(error.into())
274    }
275}
276
277/// A root mismatch error at a given block height.
278#[derive(Clone, Debug, PartialEq, Eq, Display)]
279#[display("root mismatch at #{block_number} ({block_hash}): {root}")]
280pub struct RootMismatch {
281    /// The target block root diff.
282    pub root: GotExpected<B256>,
283    /// The target block number.
284    pub block_number: BlockNumber,
285    /// The target block hash.
286    pub block_hash: BlockHash,
287}
288
289/// A Static File Writer Error.
290#[derive(Clone, Debug, PartialEq, Eq, thiserror::Error)]
291pub enum StaticFileWriterError {
292    /// Cannot call `sync_all` or `finalize` when prune is queued.
293    #[error("cannot call sync_all or finalize when prune is queued, use commit() instead")]
294    FinalizeWithPruneQueued,
295    /// Thread panicked during execution.
296    #[error("thread panicked: {_0}")]
297    ThreadPanic(&'static str),
298    /// Other error with message.
299    #[error("{0}")]
300    Other(String),
301}
302
303impl StaticFileWriterError {
304    /// Creates a new [`StaticFileWriterError::Other`] with the given message.
305    pub fn new(message: impl Into<String>) -> Self {
306        Self::Other(message.into())
307    }
308}
309/// Consistent database view error.
310#[derive(Clone, Debug, PartialEq, Eq, Display)]
311pub enum ConsistentViewError {
312    /// Error thrown on attempt to initialize provider while node is still syncing.
313    #[display("node is syncing. best block: {best_block:?}")]
314    Syncing {
315        /// Best block diff.
316        best_block: GotExpected<BlockNumber>,
317    },
318    /// Error thrown on inconsistent database view.
319    #[display("inconsistent database state: {tip:?}")]
320    Inconsistent {
321        /// The tip diff.
322        tip: GotExpected<Option<B256>>,
323    },
324    /// Error thrown when the database does not contain a block from the previous database view.
325    #[display("database view no longer contains block: {block:?}")]
326    Reorged {
327        /// The previous block
328        block: B256,
329    },
330}
331
332impl From<ConsistentViewError> for ProviderError {
333    fn from(error: ConsistentViewError) -> Self {
334        Self::ConsistentView(Box::new(error))
335    }
336}
337
338#[cfg(test)]
339mod tests {
340    use super::*;
341
342    #[derive(thiserror::Error, Debug)]
343    #[error("E")]
344    struct E;
345
346    #[test]
347    fn other_err() {
348        let err = ProviderError::other(E);
349        assert!(err.is_other::<E>());
350        assert!(err.downcast_other_ref::<E>().is_some());
351    }
352}
reth_storage_errors/provider.rs

reth_storage_errors/
provider.rs
