Mainnet Sync - Snapshot

Makefile

@@ -37,6 +37,17 @@ clean-run-sepolia-verify: ## Clean .data and start Nethermind Arbitrum node (Sep
 	@$(MAKE) clean
 	@$(MAKE) run-sepolia-verify
 
+run-mainnet: ## Start Nethermind Arbitrum node (Mainnet) without cleaning .data
+	@echo "Starting Nethermind Arbitrum node (Mainnet) with metrics..."
+	cd $(BUILD_OUTPUT_DIR) && dotnet nethermind.dll -c arbitrum-mainnet-archive \
+		--data-dir $(ROOT_DIR)/.data \
+  	--Snapshot.Enabled true \
+  	--Snapshot.DownloadUrl "https://drive.usercontent.google.com/download?id=1Pf2jTRqgy41dZ-phpyDBvKHqrnQniKgJ&export=download&authuser=1&confirm=t&uuid=55e02503-d00b-4efa-8eb1-9cfaab8d49c8&at=AKSUxGMRmuAIU5MHSL33qOFtwc1q:1760799619104"
+
+clean-run-mainnet: ## Clean .data and start Nethermind Arbitrum node (Mainnet)
+	@$(MAKE) clean
+	@$(MAKE) run-mainnet
+
 run-sepolia-monitoring: ## Start monitoring stack and Nethermind Arbitrum node (Sepolia)
 	@echo "Starting monitoring stack..."
 	@./start-monitoring.sh

src/Nethermind.Arbitrum.Test/Execution/ArbitrumTransactionProcessorTests.cs

@@ -4,6 +4,7 @@
 using Nethermind.Arbitrum.Arbos;
 using Nethermind.Arbitrum.Arbos.Compression;
 using Nethermind.Arbitrum.Arbos.Storage;
+using Nethermind.Arbitrum.Config;
 using Nethermind.Arbitrum.Core;
 using Nethermind.Arbitrum.Data.Transactions;
 using Nethermind.Arbitrum.Evm;
@@ -1633,8 +1634,8 @@ public void ArbitrumTransaction_WithArbitrumBlockHeader_ProcessesCorrectly()
 
         genesis.Header.BaseFeePerGas = blockBaseFee;
 
-        // NEW: Create ArbitrumBlockHeader with original base fee stored
-        ArbitrumBlockHeader arbitrumHeader = new ArbitrumBlockHeader(genesis.Header, originalBaseFee);
+        ArbitrumChainSpecEngineParameters chainSpecParams = new() { GenesisBlockNum = 0 };
+        ArbitrumBlockHeader arbitrumHeader = new(genesis.Header, originalBaseFee, (long)chainSpecParams.GenesisBlockNum!);
         arbitrumHeader.BaseFeePerGas = 0; // Set to 0 for EVM execution (NoBaseFee behavior)
 
         BlockExecutionContext blCtx = new(arbitrumHeader, fullChainSimulationSpecProvider.GetSpec(arbitrumHeader));
@@ -1798,11 +1799,10 @@ public void ArbitrumTransaction_WithArbitrumBlockHeader_UsesOriginalBaseFeeForGa
             _logManager
         );
 
-        UInt256 blockBaseFee = (UInt256)1500;
         UInt256 originalBaseFee = (UInt256)3000;
 
-        // Create ArbitrumBlockHeader with original base fee stored
-        ArbitrumBlockHeader arbitrumHeader = new ArbitrumBlockHeader(genesis.Header, originalBaseFee);
+        ArbitrumChainSpecEngineParameters chainSpecParams = new() { GenesisBlockNum = 0 };
+        ArbitrumBlockHeader arbitrumHeader = new(genesis.Header, originalBaseFee, (long)chainSpecParams.GenesisBlockNum!);
         arbitrumHeader.BaseFeePerGas = 0; // Set to 0 for EVM execution (NoBaseFee behavior)
 
         BlockExecutionContext blCtx = new(arbitrumHeader, fullChainSimulationSpecProvider.GetSpec(arbitrumHeader));
@@ -1879,8 +1879,8 @@ public void ArbitrumBlockHeader_StoresOriginalBaseFeeCorrectly()
 
         genesis.Header.BaseFeePerGas = blockBaseFee;
 
-        // Create ArbitrumBlockHeader
-        ArbitrumBlockHeader arbitrumHeader = new(genesis.Header, originalBaseFee);
+        ArbitrumChainSpecEngineParameters chainSpecParams = new() { GenesisBlockNum = 0 };
+        ArbitrumBlockHeader arbitrumHeader = new(genesis.Header, originalBaseFee, (long)chainSpecParams.GenesisBlockNum!);
 
         // Verify it copies all properties correctly
         arbitrumHeader.ParentHash.Should().Be(genesis.Header.ParentHash);

src/Nethermind.Arbitrum.Test/Infrastructure/ArbitrumRpcTestBlockchain.cs

@@ -271,7 +271,8 @@ private static ArbitrumRpcTestBlockchain CreateInternal(ArbitrumRpcTestBlockchai
             chain.Container.Resolve<IFeeHistoryOracle>(),
             chain.Container.Resolve<IProtocolsManager>(),
             chain.Container.Resolve<IForkInfo>(),
-            chain.Container.Resolve<IBlocksConfig>().SecondsPerSlot
+            chain.Container.Resolve<IBlocksConfig>().SecondsPerSlot,
+            chain.Container.Resolve<ArbitrumChainSpecEngineParameters>()
         );
 
         return chain;

src/Nethermind.Arbitrum.Test/Rpc/ArbitrumRpcModuleTests.cs

@@ -130,7 +130,7 @@ public async Task ResultAtMessageIndex_BlockNotFound_ReturnsFailResult()
             Assert.Multiple(() =>
             {
                 Assert.That(result.Result.ResultType, Is.EqualTo(ResultType.Failure));
-                Assert.That(result.Result.Error, Does.Contain(ArbitrumRpcErrors.BlockNotFound));
+                Assert.That(result.Result.Error, Does.Contain(ArbitrumRpcErrors.BlockNotFound((long)blockNumber)));
             });
         }
 

src/Nethermind.Arbitrum/ArbitrumPlugin.cs

@@ -8,20 +8,28 @@
 using Nethermind.Api.Steps;
 using Nethermind.Arbitrum.Arbos;
 using Nethermind.Arbitrum.Config;
+using Nethermind.Arbitrum.Core;
 using Nethermind.Arbitrum.Evm;
 using Nethermind.Arbitrum.Execution;
 using Nethermind.Arbitrum.Execution.Transactions;
 using Nethermind.Arbitrum.Genesis;
+using Nethermind.Arbitrum.Init;
 using Nethermind.Arbitrum.Modules;
 using Nethermind.Arbitrum.Precompiles;
 using Nethermind.Arbitrum.Stylus;
+using Nethermind.Blockchain;
+using Nethermind.Blockchain.Blocks;
+using Nethermind.Blockchain.Headers;
+using Nethermind.Blockchain.Synchronization;
 using Nethermind.Config;
 using Nethermind.Consensus;
 using Nethermind.Consensus.Processing;
 using Nethermind.Consensus.Producers;
 using Nethermind.Core;
 using Nethermind.Core.Container;
 using Nethermind.Core.Specs;
+using Nethermind.Db;
+using Nethermind.Db.Blooms;
 using Nethermind.Db.Rocks.Config;
 using Nethermind.Evm;
 using Nethermind.Evm.State;
@@ -32,8 +40,10 @@
 using Nethermind.JsonRpc;
 using Nethermind.JsonRpc.Modules;
 using Nethermind.JsonRpc.Modules.Eth;
+using Nethermind.Logging;
 using Nethermind.Serialization.Rlp;
 using Nethermind.Specs.ChainSpecStyle;
+using Nethermind.State.Repositories;
 
 namespace Nethermind.Arbitrum;
 
@@ -174,6 +184,7 @@ protected override void Load(ContainerBuilder builder)
             .AddStep(typeof(ArbitrumInitializeBlockchain))
             .AddStep(typeof(ArbitrumInitializeWasmDb))
             .AddStep(typeof(ArbitrumInitializeStylusNative))
+            .AddStep(typeof(ArbitrumInitializeGenesis))
 
             .AddDatabase(WasmDb.DbName)
             .AddDecorator<IRocksDbConfigFactory, ArbitrumDbConfigFactory>()
@@ -186,6 +197,8 @@ protected override void Load(ContainerBuilder builder)
                 return new WasmStore(wasmDb, new StylusTargetConfig(), cacheTag: 1);
             })
 
+            .AddSingleton<IBlockTree, ArbitrumBlockTree>()
+
             .AddSingleton<ArbitrumBlockTreeInitializer>()
 
             .AddSingleton<IBlockValidationModule, ArbitrumBlockValidationModule>()

src/Nethermind.Arbitrum/Config/ArbitrumInitializeBlockchain.cs

@@ -3,9 +3,7 @@
 using Nethermind.TxPool;
 
 namespace Nethermind.Arbitrum.Config;
-
 public class ArbitrumInitializeBlockchain(ArbitrumNethermindApi api, IChainHeadInfoProvider chainHeadInfoProvider) : InitializeBlockchain(api, chainHeadInfoProvider)
 {
     protected override IBlockProductionPolicy CreateBlockProductionPolicy() => AlwaysStartBlockProductionPolicy.Instance;
-
 }

src/Nethermind.Arbitrum/Core/ArbitrumBlockHeader.cs

@@ -9,9 +9,11 @@ namespace Nethermind.Arbitrum.Core;
 
 public class ArbitrumBlockHeader : BlockHeader
 {
+    private readonly long _genesisBlockNumber;
+    public override long GenesisBlockNumber => _genesisBlockNumber;
     public UInt256 OriginalBaseFee { get; set; }
 
-    public ArbitrumBlockHeader(BlockHeader original, UInt256 originalBaseFee) : base(
+    public ArbitrumBlockHeader(BlockHeader original, UInt256 originalBaseFee, long genesisBlockNumber) : base(
         original.ParentHash ?? Hash256.Zero,
         original.UnclesHash ?? Hash256.Zero,
         original.Beneficiary ?? Address.Zero,
@@ -25,6 +27,7 @@ public ArbitrumBlockHeader(BlockHeader original, UInt256 originalBaseFee) : base
         original.ParentBeaconBlockRoot,
         original.RequestsHash)
     {
+        _genesisBlockNumber = genesisBlockNumber;
         OriginalBaseFee = originalBaseFee;
 
         Author = original.Author;

src/Nethermind.Arbitrum/Core/ArbitrumBlockTree.cs

@@ -0,0 +1,41 @@
+// SPDX-FileCopyrightText: 2025 Demerzel Solutions Limited
+// SPDX-License-Identifier: LGPL-3.0-only
+
+using Nethermind.Arbitrum.Config;
+using Nethermind.Blockchain;
+using Nethermind.Blockchain.Blocks;
+using Nethermind.Blockchain.Headers;
+using Nethermind.Blockchain.Synchronization;
+using Nethermind.Core.Specs;
+using Nethermind.Db;
+using Nethermind.Db.Blooms;
+using Nethermind.Logging;
+using Nethermind.State.Repositories;
+
+namespace Nethermind.Arbitrum.Core;
+
+public class ArbitrumBlockTree(
+    IBlockStore blockStore,
+    IHeaderStore headerStore,
+    IDbProvider dbProvider,
+    IBadBlockStore badBlockStore,
+    IChainLevelInfoRepository chainLevelInfoRepository,
+    ISpecProvider specProvider,
+    IBloomStorage bloomStorage,
+    ISyncConfig syncConfig,
+    ILogManager logManager,
+    ArbitrumChainSpecEngineParameters chainSpecParams)
+    : BlockTree(
+        blockStore,
+        headerStore,
+        dbProvider.BlockInfosDb,
+        dbProvider.MetadataDb,
+        badBlockStore,
+        chainLevelInfoRepository,
+        specProvider,
+        bloomStorage,
+        syncConfig,
+        logManager,
+        (long)chainSpecParams.GenesisBlockNum!)
+{
+}

src/Nethermind.Arbitrum/Genesis/ArbitrumInitializeGenesis.cs

@@ -0,0 +1,64 @@
+// SPDX-FileCopyrightText: 2025 Demerzel Solutions Limited
+// SPDX-License-Identifier: LGPL-3.0-only
+
+using Nethermind.Api.Steps;
+using Nethermind.Arbitrum.Config;
+using Nethermind.Blockchain;
+using Nethermind.Core;
+using Nethermind.Evm.State;
+using Nethermind.Init.Steps;
+using Nethermind.Logging;
+
+namespace Nethermind.Arbitrum.Init;
+
+[RunnerStepDependencies(typeof(InitDatabase))]
+public class ArbitrumInitializeGenesis : IStep
+{
+    private readonly ArbitrumNethermindApi _api;
+    private readonly IArbitrumSpecHelper _specHelper;
+    private readonly ILogger _logger;
+
+    public ArbitrumInitializeGenesis(ArbitrumNethermindApi api, IArbitrumSpecHelper specHelper)
+    {
+        _api = api;
+        _specHelper = specHelper;
+        _logger = _api.LogManager.GetClassLogger();
+    }
+
+    public Task Execute(CancellationToken cancellationToken)
+    {
+        if (!_specHelper.Enabled)
+            return Task.CompletedTask;
+
+        long arbitrumGenesisBlockNum = (long)_specHelper.GenesisBlockNum;
+
+        if (arbitrumGenesisBlockNum == 0)
+        {
+            _logger.Info("Arbitrum genesis block number is 0, skipping initialization");
+            return Task.CompletedTask;
+        }
+
+        Block? arbitrumGenesisBlock = _api.BlockTree!.FindBlock(arbitrumGenesisBlockNum, BlockTreeLookupOptions.None);
+
+        if (arbitrumGenesisBlock is null)
+        {
+            throw new InvalidOperationException(
+                $"Arbitrum genesis block {arbitrumGenesisBlockNum} not found in BlockTree. " +
+                "Ensure the snapshot was downloaded correctly before this step.");
+        }
+
+        _logger.Info($"Arbitrum genesis block {arbitrumGenesisBlockNum} already exists (hash: {arbitrumGenesisBlock.Hash})");
+
+        // Re-establish state registration by running the state initialization
+        _logger.Info("Re-initializing genesis state registration...");
+
+        IWorldState worldState = _api.WorldStateManager.GlobalWorldState;
+        using (worldState.BeginScope(IWorldState.PreGenesis))
+        {
+            worldState.CommitTree(arbitrumGenesisBlockNum);
+            _logger.Info($"State tree committed for genesis block {arbitrumGenesisBlockNum}");
+        }
+
+        return Task.CompletedTask;
+    }
+}