feat: SSZ-REST Engine API transport

Dockerfile

@@ -33,7 +33,7 @@ VOLUME /nethermind/keystore
 VOLUME /nethermind/logs
 VOLUME /nethermind/nethermind_db
 
-EXPOSE 8545 8551 30303
+EXPOSE 8545 8551 8552 30303
 
 COPY --from=build /publish .
 

src/Nethermind/Nethermind.Merge.Plugin/IMergeConfig.cs

@@ -75,4 +75,5 @@ The number of requests to the garbage collector (GC) to release the process memo
 
     [ConfigItem(Description = "Delay, in milliseconds, between `newPayload` and GC trigger. If not set, defaults to 1/8th of `Blocks.SecondsPerSlot`.", DefaultValue = null, HiddenFromDocs = true)]
     int? PostBlockGcDelayMs { get; set; }
+
 }

src/Nethermind/Nethermind.Merge.Plugin/MergeConfig.cs

@@ -36,5 +36,6 @@ public class MergeConfig : IMergeConfig
 
         public bool SimulateBlockProduction { get; set; } = false;
         public int? PostBlockGcDelayMs { get; set; } = null;
+
     }
 }

src/Nethermind/Nethermind.Merge.Plugin/MergePlugin.cs

@@ -19,6 +19,7 @@
 using Nethermind.Consensus.Rewards;
 using Nethermind.Consensus.Validators;
 using Nethermind.Core;
+using Nethermind.Core.Authentication;
 using Nethermind.Core.Crypto;
 using Nethermind.Core.Exceptions;
 using Nethermind.Db;
@@ -33,6 +34,7 @@
 using Nethermind.Merge.Plugin.GC;
 using Nethermind.Merge.Plugin.Handlers;
 using Nethermind.Merge.Plugin.InvalidChainTracker;
+using Nethermind.Merge.Plugin.SszRest;
 using Nethermind.Merge.Plugin.Synchronization;
 using Nethermind.Network.Contract.P2P;
 using Nethermind.Serialization.Json;
@@ -225,11 +227,17 @@ public Task InitNetworkProtocol()
                 if (_logger.IsDebug) _logger.Debug("Delayed adding post-merge eth/* capabilities until terminal block reached");
                 _poSSwitcher.TerminalBlockReached += (_, _) => AddPostMergeNetworkProtocols();
             }
+
         }
 
         return Task.CompletedTask;
     }
 
+    public Task InitRpcModules()
+    {
+        return Task.CompletedTask;
+    }
+
     private void AddPostMergeNetworkProtocols()
     {
         if (_logger.IsInfo) _logger.Info("Adding eth/69 capability");
@@ -345,6 +353,24 @@ protected override void Load(ContainerBuilder builder)
                         ctx.Resolve<ILogManager>());
                 })
                 .AddSingleton<IHttpClient, DefaultHttpClient>()
+
+                // EIP-8161 SSZ-REST Engine API transport (served on engine port alongside JSON-RPC)
+                .AddSingleton<SszRestHandler>(ctx =>
+                {
+                    ILogManager logManager = ctx.Resolve<ILogManager>();
+
+                    return new SszRestHandler(
+                        ctx.Resolve<IAsyncHandler<ExecutionPayload, PayloadStatusV1>>(),
+                        ctx.Resolve<IForkchoiceUpdatedHandler>(),
+                        ctx.Resolve<IAsyncHandler<byte[], ExecutionPayload?>>(),
+                        ctx.Resolve<IAsyncHandler<byte[], GetPayloadV2Result?>>(),
+                        ctx.Resolve<IAsyncHandler<byte[], GetPayloadV3Result?>>(),
+                        ctx.Resolve<IAsyncHandler<byte[], GetPayloadV4Result?>>(),
+                        ctx.Resolve<IAsyncHandler<byte[], GetPayloadV5Result?>>(),
+                        ctx.Resolve<IHandler<IEnumerable<string>, IEnumerable<string>>>(),
+                        ctx.Resolve<IAsyncHandler<byte[][], IEnumerable<BlobAndProofV1?>>>(),
+                        logManager);
+                })
             ;
     }
 

src/Nethermind/Nethermind.Merge.Plugin/Nethermind.Merge.Plugin.csproj

@@ -7,6 +7,9 @@
 
   <ItemGroup>
     <ProjectReference Include="..\Nethermind.Api\Nethermind.Api.csproj" />
+    <ProjectReference Include="..\Nethermind.Merkleization\Nethermind.Merkleization.csproj" />
+    <ProjectReference Include="..\Nethermind.Serialization.SszGenerator\Nethermind.Serialization.SszGenerator.csproj" OutputItemType="Analyzer" ReferenceOutputAssembly="false" />
+    <ProjectReference Include="..\Nethermind.Serialization.Ssz\Nethermind.Serialization.Ssz.csproj" />
   </ItemGroup>
 
 </Project>