feat(rpc): add eth_capabilities method for routing capability discovery

src/Nethermind/Nethermind.Blockchain.Test/FullPruning/FullPrunerTests.cs

@@ -244,6 +244,7 @@ public TestContext(
                     FullPruningCompletionBehavior = completionBehavior
                 },
                 BlockTree,
+                Substitute.For<IStateBoundary>(),
                 StateReader,
                 ProcessExitSource,
                 _chainEstimations,

src/Nethermind/Nethermind.Blockchain.Test/FullPruning/FullPruningDiskTest.cs

@@ -65,6 +65,7 @@ protected override async Task<TestBlockchain> Build(Action<ContainerBuilder>? co
                 PruningTrigger,
                 PruningConfig,
                 BlockTree,
+                Container.Resolve<IWorldStateManager>(),
                 StateReader,
                 ProcessExitSource,
                 DriveInfo,
@@ -115,14 +116,15 @@ public class FullTestPruner(
             IPruningTrigger pruningTrigger,
             IPruningConfig pruningConfig,
             IBlockTree blockTree,
+            IStateBoundary stateBoundary,
             IStateReader stateReader,
             IProcessExitSource processExitSource,
             IDriveInfo driveInfo,
             IPruningTrieStore trieStore,
             IChainEstimations chainEstimations,
             ILogManager logManager)
             : FullPruner(pruningDb, nodeStorageFactory, mainNodeStorage, pruningTrigger, pruningConfig, blockTree,
-                stateReader, processExitSource, chainEstimations, driveInfo, trieStore, logManager)
+                stateBoundary, stateReader, processExitSource, chainEstimations, driveInfo, trieStore, logManager)
         {
             public EventWaitHandle WaitHandle { get; } = new ManualResetEvent(false);
 

src/Nethermind/Nethermind.Blockchain/FullPruning/FullPruner.cs

@@ -29,6 +29,7 @@ public class FullPruner : IDisposable
         private readonly IPruningTrigger _pruningTrigger;
         private readonly IPruningConfig _pruningConfig;
         private readonly IBlockTree _blockTree;
+        private readonly IStateBoundary _stateBoundary;
         private readonly IStateReader _stateReader;
         private readonly IProcessExitSource _processExitSource;
         private readonly ILogManager _logManager;
@@ -46,6 +47,7 @@ public FullPruner(
             IPruningTrigger pruningTrigger,
             IPruningConfig pruningConfig,
             IBlockTree blockTree,
+            IStateBoundary stateBoundary,
             IStateReader stateReader,
             IProcessExitSource processExitSource,
             IChainEstimations chainEstimations,
@@ -59,6 +61,7 @@ public FullPruner(
             _pruningTrigger = pruningTrigger;
             _pruningConfig = pruningConfig;
             _blockTree = blockTree;
+            _stateBoundary = stateBoundary;
             _stateReader = stateReader;
             _processExitSource = processExitSource;
             _logManager = logManager;
@@ -178,7 +181,10 @@ await WaitForMainChainChange((e) =>
             }
 
             if (_logger.IsInfo) _logger.Info($"Full Pruning Ready to start: pruning garbage before state {stateToCopy} with root {header.StateRoot}");
-            await CopyTrie(pruningContext, header, cancellationToken);
+            if (CopyTrie(pruningContext, header, cancellationToken))
+            {
+                _stateBoundary.OldestStateBlock = stateToCopy;
+            }
         }
 
         private bool CanStartNewPruning() => _fullPruningDb.CanStartPruning;
@@ -218,10 +224,11 @@ private void HandlePruningFinished(object? sender, PruningEventArgs e)
             }
         }
 
-        private Task CopyTrie(IPruningContext pruning, BlockHeader? baseBlock, CancellationToken cancellationToken)
+        private bool CopyTrie(IPruningContext pruning, BlockHeader? baseBlock, CancellationToken cancellationToken)
         {
             INodeStorage.KeyScheme originalKeyScheme = _nodeStorage.Scheme;
             ICopyTreeVisitor visitor = null;
+            bool committed = false;
 
             try
             {
@@ -277,6 +284,7 @@ private Task CopyTrie(IPruningContext pruning, BlockHeader? baseBlock, Cancellat
 
                     _nodeStorage.Scheme = targetNodeStorage.Scheme;
                     _lastPruning = DateTime.UtcNow;
+                    committed = true;
                 }
             }
             catch (Exception e)
@@ -290,7 +298,7 @@ private Task CopyTrie(IPruningContext pruning, BlockHeader? baseBlock, Cancellat
                 visitor?.Dispose();
             }
 
-            return Task.CompletedTask;
+            return committed;
         }
 
         private ICopyTreeVisitor CopyTree<TContext>(

src/Nethermind/Nethermind.Blockchain/FullPruning/IFullPrunerFactory.cs

@@ -8,5 +8,5 @@ namespace Nethermind.Blockchain.FullPruning;
 
 public interface IFullPrunerFactory
 {
-    FullPruner? Create(IStateReader stateReader, IPruningTrieStore trieStore);
+    FullPruner? Create(IWorldStateManager worldStateManager, IPruningTrieStore trieStore);
 }

src/Nethermind/Nethermind.Blockchain/ReadOnlyBlockTree.cs

@@ -37,7 +37,6 @@ public long? BestPersistedState
             set => _wrapped.BestPersistedState = value;
         }
 
-
         public BlockHeader? LowestInsertedBeaconHeader
         {
             get => _wrapped.LowestInsertedBeaconHeader;

src/Nethermind/Nethermind.Core.Test/TestWorldStateFactory.cs

@@ -76,6 +76,6 @@ public static WorldStateManager CreateWorldStateManagerForTest(IDbProvider dbPro
         finalizedStateProvider.TrieStore = trieStore;
         TrieStoreScopeProvider worldState = new(trieStore, dbProvider.CodeDb, logManager);
 
-        return new WorldStateManager(worldState, trieStore, dbProvider, logManager);
+        return new WorldStateManager(worldState, trieStore, dbProvider, logManager, pruningConfig);
     }
 }

src/Nethermind/Nethermind.History/HistoryPruner.cs

@@ -33,6 +33,8 @@ public class HistoryPruner : IHistoryPruner
     private const int LockWaitTimeoutMs = 100;
     private const int SlotsPerEpoch = 32;
 
+    public long GetRetentionBlocks(long retentionEpochs) => retentionEpochs * SlotsPerEpoch;
+
     // only one pruning and one searching thread at a time
     private readonly object _pruneLock = new();
     private readonly object _searchLock = new();

src/Nethermind/Nethermind.History/IHistoryPruner.cs

@@ -15,4 +15,10 @@ public interface IHistoryPruner
     event EventHandler<OnNewOldestBlockArgs> NewOldestBlock;
 
     void SchedulePruneHistory();
+
+    /// <summary>
+    /// Converts a retention window expressed in epochs to a block count using this pruner's
+    /// slots-per-epoch constant. Keeps the epoch→blocks conversion co-located with the pruner.
+    /// </summary>
+    long GetRetentionBlocks(long retentionEpochs);
 }

src/Nethermind/Nethermind.Init/FullPrunerFactory.cs

@@ -36,7 +36,7 @@ ILogManager logManager
 {
     private readonly ILogger _logger = logManager.GetClassLogger<FullPrunerFactory>();
 
-    public FullPruner? Create(IStateReader stateReader, IPruningTrieStore trieStore)
+    public FullPruner? Create(IWorldStateManager worldStateManager, IPruningTrieStore trieStore)
     {
         IDb stateDb = dbProvider.StateDb;
 
@@ -60,7 +60,8 @@ ILogManager logManager
             compositePruningTrigger,
             pruningConfig,
             blockTree,
-            stateReader,
+            worldStateManager,
+            worldStateManager.GlobalStateReader,
             processExit,
             ChainSizes.CreateChainSizeInfo(chainSpec.ChainId),
             drive,

src/Nethermind/Nethermind.Init/Modules/RpcModules.cs

@@ -81,6 +81,7 @@ protected override void Load(ContainerBuilder builder)
                 .AddSingleton<IBlockchainBridgeFactory, BlockchainBridgeFactory>()
                 .AddScoped<IBlockchainBridge>((ctx) => ctx.Resolve<IBlockchainBridgeFactory>().CreateBlockchainBridge())
                     .AddSingleton<IFeeHistoryOracle, FeeHistoryOracle>()
+                    .AddSingleton<IEthCapabilitiesProvider, EthCapabilitiesProvider>()
                     .AddSingleton<FilterStore, ITimerFactory, IJsonRpcConfig>((timerFactory, rpcConfig) => new FilterStore(timerFactory, rpcConfig.FiltersTimeout))
                     .AddSingleton<FilterManager>()
                     .AddSingleton<IWitnessGeneratingBlockProcessingEnvFactory, WitnessGeneratingBlockProcessingEnvFactory>()

src/Nethermind/Nethermind.Init/PruningTrieStateFactory.cs

@@ -27,6 +27,7 @@ namespace Nethermind.Init;
 
 public class PruningTrieStateFactory(
     ISyncConfig syncConfig,
+    IPruningConfig pruningConfig,
     IDbProvider dbProvider,
     IBlockTree blockTree,
     MainPruningTrieStoreFactory mainPruningTrieStoreFactory,
@@ -71,6 +72,7 @@ public class PruningTrieStateFactory(
             trieStore,
             dbProvider,
             logManager,
+            pruningConfig,
             new LastNStateRootTracker(blockTree, syncConfig.SnapServingMaxDepth));
 
         // NOTE: Don't forget this! Very important!
@@ -80,7 +82,7 @@ public class PruningTrieStateFactory(
 
         disposeStack.Push(mainWorldTrieStore);
 
-        FullPruner? fullPruner = fullPrunerFactory.Create(stateManager.GlobalStateReader, trieStore);
+        FullPruner? fullPruner = fullPrunerFactory.Create(stateManager, trieStore);
         if (fullPruner is not null)
         {
             disposeStack.Push(fullPruner);

src/Nethermind/Nethermind.JsonRpc.Benchmark/EthModuleBenchmarks.cs

@@ -6,7 +6,11 @@
 using Nethermind.Blockchain;
 using Nethermind.Blockchain.Find;
 using Nethermind.Blockchain.Receipts;
+using Nethermind.Blockchain.Synchronization;
 using Nethermind.Blockchain.Tracing;
+using Nethermind.History;
+using Nethermind.Synchronization;
+using NSubstitute;
 using Nethermind.Consensus.Processing;
 using Nethermind.Core;
 using Nethermind.Core.Extensions;
@@ -86,7 +90,14 @@ public void GlobalSetup()
                 _container.Resolve<IForkInfo>(),
                 new LogIndexConfig(),
                 new BlocksConfig().SecondsPerSlot,
-                _headBlockSignal);
+                _headBlockSignal,
+                new EthCapabilitiesProvider(
+                    blockTree.AsReadOnly(),
+                    _container.Resolve<IWorldStateManager>(),
+                    _container.Resolve<ISyncConfig>(),
+                    Substitute.For<ISyncPointers>(),
+                    Substitute.For<IHistoryConfig>(),
+                    Substitute.For<IHistoryPruner>()));
         }
 
         [GlobalCleanup]

src/Nethermind/Nethermind.JsonRpc.Test/Modules/BoundedModulePoolTests.cs

@@ -2,11 +2,14 @@
 // SPDX-License-Identifier: LGPL-3.0-only
 
 using System.Threading.Tasks;
+using Nethermind.Blockchain;
 using Nethermind.Blockchain.Receipts;
+using Nethermind.Blockchain.Synchronization;
 using Nethermind.Config;
 using Nethermind.Core.Specs;
 using Nethermind.Core.Test.Builders;
 using Nethermind.Db.LogIndex;
+using Nethermind.History;
 using Nethermind.JsonRpc.Modules;
 using Nethermind.JsonRpc.Modules.Eth;
 using Nethermind.Logging;
@@ -17,6 +20,7 @@
 using Nethermind.JsonRpc.Modules.Eth.GasPrice;
 using Nethermind.Network;
 using Nethermind.State;
+using Nethermind.Synchronization;
 using Nethermind.TxPool;
 using Nethermind.Wallet;
 using NSubstitute;
@@ -58,7 +62,14 @@ public Task Initialize()
             Substitute.For<IProtocolsManager>(),
             new BlocksConfig(),
             Substitute.For<IForkInfo>(),
-            Substitute.For<ILogIndexConfig>()),
+            Substitute.For<ILogIndexConfig>(),
+            new EthCapabilitiesProvider(
+                blockTree.AsReadOnly(),
+                Substitute.For<IStateBoundary>(),
+                new SyncConfig(),
+                Substitute.For<ISyncPointers>(),
+                Substitute.For<IHistoryConfig>(),
+                Substitute.For<IHistoryPruner>())),
              1, 1000);
 
         return Task.CompletedTask;