Method execute

crates/execution/cli/src/commands/base_proofs/unwind.rs:51–92

Execute [`UnwindCommand`].

(
        self,
        runtime: reth_tasks::Runtime,
    )

impl<C: ChainSpecParser<ChainSpec = BaseChainSpec>> UnwindCommand<C> {
    /// Execute [`UnwindCommand`].
    pub async fn execute<N: CliNodeTypes<ChainSpec = C::ChainSpec, Primitives = BasePrimitives>>(
        self,
        runtime: reth_tasks::Runtime,
    ) -> eyre::Result<()> {
        let Self { env, storage_path, proofs_history_db, proofs_history_rocksdb, target } = self;

        info!(target: "reth::cli", version = %version_metadata().short_version, "reth starting");
        info!(
            target: "reth::cli",
            path = ?storage_path,
            backend = ?proofs_history_db,
            "Unwinding Base proofs storage"
        );
        proofs_history_db.ensure_storage_path_matches(&storage_path)?;

        // Initialize the environment with read-only access
        let Environment { provider_factory, .. } = env.init::<N>(AccessRights::RO, runtime)?;

        match proofs_history_db {
            ProofsHistoryDbBackend::Rocksdb => {
                let storage: BaseProofsStorage<Arc<RocksdbProofsStorage>> = Arc::new(
                    RocksdbProofsStorage::new_with_options(
                        &storage_path,
                        proofs_history_rocksdb.storage_options()?,
                    )
                    .map_err(|e| eyre::eyre!("Failed to create RocksdbProofsStorage: {e}"))?,
                )
                .into();
                Self::unwind_storage(target, &provider_factory, storage)?;
            }
            ProofsHistoryDbBackend::Mdbx => {
                let storage: BaseProofsStorage<Arc<MdbxProofsStorage>> = Arc::new(
                    MdbxProofsStorage::new(&storage_path)
                        .map_err(|e| eyre::eyre!("Failed to create MdbxProofsStorage: {e}"))?,
                )
                .into();
                Self::unwind_storage(target, &provider_factory, storage)?;
            }
        }

        Ok(())
    }

    fn unwind_storage<S, P>(
        target: u64,