Taiko

src/Nethermind/Nethermind.Api/Extensions/PluginConfig.cs

@@ -5,5 +5,5 @@ namespace Nethermind.Api.Extensions;
 
 public class PluginConfig : IPluginConfig
 {
- public string[] PluginOrder { get; set; } = { "Clique", "Aura", "Ethash", "Optimism", "Shutter", "AuRaMerge", "Merge", "MEV", "HealthChecks", "Hive" };
+ public string[] PluginOrder { get; set; } = { "Clique", "Aura", "Ethash", "Optimism", "Shutter", "Taiko", "AuRaMerge", "Merge", "MEV", "HealthChecks", "Hive" };
 }

src/Nethermind/Nethermind.Consensus/AlwaysPoS.cs

@@ -15,7 +15,7 @@ private AlwaysPoS() { }
 
  public UInt256? TerminalTotalDifficulty => 0;
 
- public UInt256? FinalTotalDifficulty => null;
+ public UInt256? FinalTotalDifficulty => 0;
 
  public bool TransitionFinished => true;
 

src/Nethermind/Nethermind.Consensus/Processing/BlockExtensions.cs

@@ -14,13 +14,8 @@
 
 namespace Nethermind.Consensus.Processing
 {
- internal static class BlockExtensions
+ public static class BlockExtensions
  {
- public static Block CreateCopy(this Block block, BlockHeader header) =>
- block is BlockToProduce blockToProduce
- ? new BlockToProduce(header, blockToProduce.Transactions, blockToProduce.Uncles, blockToProduce.Withdrawals, blockToProduce.Requests)
- : new Block(header, block.Transactions, block.Uncles, block.Withdrawals, block.Requests);
-
  public static IEnumerable<Transaction> GetTransactions(this Block block) =>
  block is BlockToProduce blockToProduce
  ? blockToProduce.Transactions

src/Nethermind/Nethermind.Consensus/Processing/BlockProcessor.cs

@@ -399,7 +399,7 @@ private Block PrepareBlockForProcessing(Block suggestedBlock)
  headerForProcessing.StateRoot = bh.StateRoot;
  }
 
- return suggestedBlock.CreateCopy(headerForProcessing);
+ return suggestedBlock.WithReplacedHeader(headerForProcessing);
  }
 
  // TODO: block processor pipeline

src/Nethermind/Nethermind.Consensus/Processing/IReadOnlyTxProcessingEnvFactory.cs

@@ -0,0 +1,11 @@
+// SPDX-FileCopyrightText: 2022 Demerzel Solutions Limited
+// SPDX-License-Identifier: LGPL-3.0-only
+
+using Nethermind.Evm.TransactionProcessing;
+
+namespace Nethermind.Consensus.Processing;
+
+public interface IReadOnlyTxProcessingEnvFactory
+{
+ public IReadOnlyTxProcessorSource Create();
+}

src/Nethermind/Nethermind.Consensus/Processing/ReadOnlyTxProcessingEnvFactory.cs

@@ -3,6 +3,7 @@
 
 using Nethermind.Blockchain;
 using Nethermind.Core.Specs;
+using Nethermind.Evm.TransactionProcessing;
 using Nethermind.Logging;
 using Nethermind.State;
 
@@ -13,7 +14,7 @@ public class ReadOnlyTxProcessingEnvFactory(
  IReadOnlyBlockTree readOnlyBlockTree,
  ISpecProvider? specProvider,
  ILogManager? logManager,
- IWorldState? worldStateToWarmUp = null)
+ IWorldState? worldStateToWarmUp = null) : IReadOnlyTxProcessingEnvFactory
 {
  public ReadOnlyTxProcessingEnvFactory(
  IWorldStateManager worldStateManager,
@@ -25,5 +26,5 @@ public ReadOnlyTxProcessingEnvFactory(
  {
  }
 
- public ReadOnlyTxProcessingEnv Create() => new(worldStateManager, readOnlyBlockTree, specProvider, logManager, worldStateToWarmUp);
+ public IReadOnlyTxProcessorSource Create() => new ReadOnlyTxProcessingEnv(worldStateManager, readOnlyBlockTree, specProvider, logManager, worldStateToWarmUp);
 }

src/Nethermind/Nethermind.Consensus/Producers/BlockProductionPolicy.cs

@@ -24,6 +24,17 @@ public BlockProductionPolicy(
  public bool ShouldStartBlockProduction() => _miningConfig.Enabled;
 }
 
+public class NeverStartBlockProductionPolicy : IBlockProductionPolicy
+{
+ public bool ShouldStartBlockProduction() => false;
+
+ public static NeverStartBlockProductionPolicy Instance =>
+ LazyInitializer.EnsureInitialized(ref _instance, () => new());
+
+ private static NeverStartBlockProductionPolicy? _instance;
+ private NeverStartBlockProductionPolicy() { }
+}
+
 public class AlwaysStartBlockProductionPolicy : IBlockProductionPolicy
 {
  public bool ShouldStartBlockProduction() => true;

src/Nethermind/Nethermind.Consensus/Producers/BlockToProduce.cs

@@ -13,7 +13,7 @@
 
 namespace Nethermind.Consensus.Producers
 {
- internal class BlockToProduce : Block
+ public class BlockToProduce : Block
  {
  private IEnumerable<Transaction>? _transactions;
 
@@ -39,5 +39,7 @@ public BlockToProduce(BlockHeader blockHeader,
  {
  Transactions = transactions;
  }
+
+ public override Block WithReplacedHeader(BlockHeader newHeader) => new BlockToProduce(newHeader, Transactions, Uncles, Withdrawals, Requests);
  }
 }

src/Nethermind/Nethermind.Consensus/Producers/FailBlockProducer.cs

@@ -0,0 +1,23 @@
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using Nethermind.Core;
+using Nethermind.Evm.Tracing;
+
+namespace Nethermind.Consensus.Producers;
+
+/// <summary>
+/// A BlockProducer that always fails.
+/// It is used in tests or when the node is not supposed to produce blocks, and we want to detect block production being triggered.
+/// </summary>
+public class FailBlockProducer : IBlockProducer
+{
+ public Task<Block?> BuildBlock(
+ BlockHeader? parentHeader = null,
+ IBlockTracer? blockTracer = null,
+ PayloadAttributes? payloadAttributes = null,
+ CancellationToken? cancellationToken = null)
+ {
+ throw new InvalidOperationException("FailBlockProducer is not supposed to produce blocks.");
+ }
+}

src/Nethermind/Nethermind.Consensus/Transactions/ITxSource.cs

@@ -11,6 +11,4 @@ public interface ITxSource
  {
  IEnumerable<Transaction> GetTransactions(BlockHeader parent, long gasLimit, PayloadAttributes? payloadAttributes = null);
  }
-
-
 }

src/Nethermind/Nethermind.Consensus/Validators/BlockValidator.cs

@@ -342,7 +342,7 @@ public static bool ValidateRequestsOrder(Block block, out string? error)
  return true;
  }
 
- private bool ValidateTransactions(Block block, IReleaseSpec spec, out string? errorMessage)
+ protected virtual bool ValidateTransactions(Block block, IReleaseSpec spec, out string? errorMessage)
  {
  Transaction[] transactions = block.Transactions;
 
@@ -362,7 +362,7 @@ private bool ValidateTransactions(Block block, IReleaseSpec spec, out string? er
  return true;
  }
 
- private bool ValidateEip4844Fields(Block block, IReleaseSpec spec, out string? error)
+ protected virtual bool ValidateEip4844Fields(Block block, IReleaseSpec spec, out string? error)
  {
  if (!spec.IsEip4844Enabled)
  {

src/Nethermind/Nethermind.Consensus/Validators/HeaderValidator.cs

@@ -95,7 +95,7 @@ public virtual bool Validate(BlockHeader header, BlockHeader? parent, bool isUnc
  && ValidateBlobGasFields(header, parent, spec, ref error);
  }
 
- private bool Validate1559(BlockHeader header, BlockHeader parent, IReleaseSpec spec, ref string? error)
+ protected virtual bool Validate1559(BlockHeader header, BlockHeader parent, IReleaseSpec spec, ref string? error)
  {
  if (spec.IsEip1559Enabled)
  {
@@ -112,7 +112,7 @@ private bool Validate1559(BlockHeader header, BlockHeader parent, IReleaseSpec s
  return true;
  }
 
- private bool ValidateBlockNumber(BlockHeader header, BlockHeader parent, ref string? error)
+ protected virtual bool ValidateBlockNumber(BlockHeader header, BlockHeader parent, ref string? error)
  {
  if (header.Number != parent.Number + 1)
  {
@@ -124,7 +124,7 @@ private bool ValidateBlockNumber(BlockHeader header, BlockHeader parent, ref str
  return true;
  }
 
- private bool ValidateGasUsed(BlockHeader header, ref string? error)
+ protected virtual bool ValidateGasUsed(BlockHeader header, ref string? error)
  {
  if (header.GasUsed > header.GasLimit)
  {
@@ -136,7 +136,7 @@ private bool ValidateGasUsed(BlockHeader header, ref string? error)
  return true;
  }
 
- private bool ValidateParent(BlockHeader header, BlockHeader? parent, ref string? error)
+ protected virtual bool ValidateParent(BlockHeader header, BlockHeader? parent, ref string? error)
  {
  if (parent is null)
  {
@@ -159,7 +159,7 @@ private bool ValidateParent(BlockHeader header, BlockHeader? parent, ref string?
  return true;
  }
 
- private bool ValidateSeal(BlockHeader header, BlockHeader parent, bool isUncle, ref string? error)
+ protected virtual bool ValidateSeal(BlockHeader header, BlockHeader parent, bool isUncle, ref string? error)
  {
  bool result = _sealValidator.ValidateParams(parent, header, isUncle);
 
@@ -172,7 +172,7 @@ private bool ValidateSeal(BlockHeader header, BlockHeader parent, bool isUncle,
  return result;
  }
 
- private bool ValidateFieldLimit(BlockHeader blockHeader, ref string? error)
+ protected virtual bool ValidateFieldLimit(BlockHeader blockHeader, ref string? error)
  {
  // Note, these are out of spec. Technically, there could be a block with field with very high value that is
  // valid when using ulong, but wrapped to negative value when using long. However, switching to ulong
@@ -248,7 +248,7 @@ protected virtual bool ValidateGasLimitRange(BlockHeader header, BlockHeader par
  return gasLimitNotTooHigh && gasLimitNotTooLow;
  }
 
- private bool ValidateTimestamp(BlockHeader header, BlockHeader parent, ref string? error)
+ protected virtual bool ValidateTimestamp(BlockHeader header, BlockHeader parent, ref string? error)
  {
  bool timestampMoreThanAtParent = header.Timestamp > parent.Timestamp;
  if (!timestampMoreThanAtParent)
@@ -312,7 +312,7 @@ private bool ValidateGenesis(BlockHeader header) =>
  header.Bloom is not null &&
  header.ExtraData.Length <= _specProvider.GenesisSpec.MaximumExtraDataSize;
 
- private bool ValidateBlobGasFields(BlockHeader header, BlockHeader parentHeader, IReleaseSpec spec, ref string? error)
+ protected virtual bool ValidateBlobGasFields(BlockHeader header, BlockHeader parentHeader, IReleaseSpec spec, ref string? error)
  {
  if (spec.IsEip4844Enabled)
  {

src/Nethermind/Nethermind.Core.Test/Json/Base64ConverterTests.cs

@@ -0,0 +1,30 @@
+// SPDX-FileCopyrightText: 2022 Demerzel Solutions Limited
+// SPDX-License-Identifier: LGPL-3.0-only
+
+using Nethermind.Serialization.Json;
+using NUnit.Framework;
+using System.Linq;
+
+namespace Nethermind.Core.Test.Json;
+
+[TestFixture]
+public class Base64ConverterTests : ConverterTestBase<byte[]?>
+{
+ [TestCase(null)]
+ [TestCase(new byte[0])]
+ [TestCase(new byte[] { 1 })]
+ [TestCase(new byte[] { 0, 1 })]
+ [TestCase(new byte[] { 0, 0, 1 })]
+ [TestCase(new byte[] { 0, 0, 255 })]
+ [TestCase(new byte[] { 0, 0, 1, 0 })]
+ [TestCase(new byte[] { 0, 0, 1, 0, 0 })]
+ [TestCase(new byte[] { 0, 0, 1, 0, 127 })]
+ [TestCase(new byte[] { 0, 0, 1, 0, 255 })]
+ public void ValueWithAndWithoutLeadingZeros_are_equal(byte[]? value)
+ {
+ TestConverter(
+ value,
+ (before, after) => (before is null && after is null) || (before is not null && after is not null && before.SequenceEqual(after)),
+ new Base64Converter());
+ }
+}

src/Nethermind/Nethermind.Core/Block.cs

@@ -4,7 +4,6 @@
 using System;
 using System.Collections.Generic;
 using System.Diagnostics;
-using System.Diagnostics.CodeAnalysis;
 using System.Linq;
 using System.Text;
 using Nethermind.Core.ConsensusRequests;
@@ -46,7 +45,7 @@ public Block(BlockHeader header) : this(
  )
  { }
 
- public Block WithReplacedHeader(BlockHeader newHeader) => new(newHeader, Body);
+ public virtual Block WithReplacedHeader(BlockHeader newHeader) => new(newHeader, Body);
 
  public Block WithReplacedBody(BlockBody newBody) => new(Header, newBody);
 

src/Nethermind/Nethermind.Core/SealEngineType.cs

@@ -12,5 +12,6 @@ public static class SealEngineType
  public const string Ethash = nameof(Ethash);
  public const string BeaconChain = nameof(BeaconChain);
  public const string Optimism = nameof(Optimism);
+ public const string Taiko = nameof(Taiko);
  }
 }

src/Nethermind/Nethermind.Core/Specs/IReleaseSpec.cs

@@ -326,6 +326,9 @@ public interface IReleaseSpec : IEip1559Spec, IReceiptSpec
  /// OP Granite
  bool IsOpGraniteEnabled { get; }
 
+ /// Taiko Ontake
+ bool IsOntakeEnabled { get; }
+
  /// <summary>
  /// Should transactions be validated against chainId.
  /// </summary>

src/Nethermind/Nethermind.Core/Specs/ReleaseSpecDecorator.cs

@@ -80,8 +80,54 @@ public class ReleaseSpecDecorator(IReleaseSpec spec) : IReleaseSpec
  public bool IsEip7702Enabled => spec.IsEip7702Enabled;
  public virtual bool IsRip7212Enabled => spec.IsRip7212Enabled;
  public virtual bool IsOpGraniteEnabled => spec.IsOpGraniteEnabled;
+ public virtual bool IsOntakeEnabled => spec.IsOntakeEnabled;
  public virtual ulong WithdrawalTimestamp => spec.WithdrawalTimestamp;
  public virtual ulong Eip4844TransitionTimestamp => spec.Eip4844TransitionTimestamp;
  public virtual bool IsEip158IgnoredAccount(Address address) => spec.IsEip158IgnoredAccount(address);
  public bool IsEip4844FeeCollectorEnabled => spec.IsEip4844FeeCollectorEnabled;
+
+ public virtual long MaxInitCodeSize => spec.MaxInitCodeSize;
+ public virtual bool ValidateChainId => spec.ValidateChainId;
+ public virtual bool ClearEmptyAccountWhenTouched => spec.ClearEmptyAccountWhenTouched;
+ // VM
+ public virtual bool LimitCodeSize => spec.LimitCodeSize;
+ public virtual bool UseHotAndColdStorage => spec.UseHotAndColdStorage;
+ public virtual bool UseTxAccessLists => spec.UseTxAccessLists;
+ public virtual bool AddCoinbaseToTxAccessList => spec.AddCoinbaseToTxAccessList;
+ public virtual bool ModExpEnabled => spec.ModExpEnabled;
+ public virtual bool Bn128Enabled => spec.Bn128Enabled;
+ public virtual bool BlakeEnabled => spec.BlakeEnabled;
+ public virtual bool Bls381Enabled => spec.Bls381Enabled;
+ public virtual bool ChargeForTopLevelCreate => spec.ChargeForTopLevelCreate;
+ public virtual bool FailOnOutOfGasCodeDeposit => spec.FailOnOutOfGasCodeDeposit;
+ public virtual bool UseShanghaiDDosProtection => spec.UseShanghaiDDosProtection;
+ public virtual bool UseExpDDosProtection => spec.UseExpDDosProtection;
+ public virtual bool UseLargeStateDDosProtection => spec.UseLargeStateDDosProtection;
+ public virtual bool ReturnDataOpcodesEnabled => spec.ReturnDataOpcodesEnabled;
+ public virtual bool ChainIdOpcodeEnabled => spec.ChainIdOpcodeEnabled;
+ public virtual bool Create2OpcodeEnabled => spec.Create2OpcodeEnabled;
+ public virtual bool DelegateCallEnabled => spec.DelegateCallEnabled;
+ public virtual bool StaticCallEnabled => spec.StaticCallEnabled;
+ public virtual bool ShiftOpcodesEnabled => spec.ShiftOpcodesEnabled;
+ public virtual bool RevertOpcodeEnabled => spec.RevertOpcodeEnabled;
+ public virtual bool ExtCodeHashOpcodeEnabled => spec.ExtCodeHashOpcodeEnabled;
+ public virtual bool SelfBalanceOpcodeEnabled => spec.SelfBalanceOpcodeEnabled;
+ public virtual bool UseConstantinopleNetGasMetering => spec.UseConstantinopleNetGasMetering;
+ public virtual bool UseIstanbulNetGasMetering => spec.UseIstanbulNetGasMetering;
+ public virtual bool UseNetGasMetering => spec.UseNetGasMetering;
+ public virtual bool UseNetGasMeteringWithAStipendFix => spec.UseNetGasMeteringWithAStipendFix;
+ public virtual bool Use63Over64Rule => spec.Use63Over64Rule;
+ public virtual bool BaseFeeEnabled => spec.BaseFeeEnabled;
+ // EVM Related
+ public virtual bool IncludePush0Instruction => spec.IncludePush0Instruction;
+ public virtual bool TransientStorageEnabled => spec.TransientStorageEnabled;
+ public virtual bool WithdrawalsEnabled => spec.WithdrawalsEnabled;
+ public virtual bool SelfdestructOnlyOnSameTransaction => spec.SelfdestructOnlyOnSameTransaction;
+ public virtual bool IsBeaconBlockRootAvailable => spec.IsBeaconBlockRootAvailable;
+ public virtual bool IsBlockHashInStateAvailable => spec.IsBlockHashInStateAvailable;
+ public virtual bool MCopyIncluded => spec.MCopyIncluded;
+ public virtual bool BlobBaseFeeEnabled => spec.BlobBaseFeeEnabled;
+ public virtual Address? FeeCollector => spec.FeeCollector;
+ public virtual UInt256? Eip1559BaseFeeMinValue => spec.Eip1559BaseFeeMinValue;
+ public virtual bool ValidateReceipts => spec.ValidateReceipts;
 }

src/Nethermind/Nethermind.Core/Transaction.cs

@@ -31,6 +31,9 @@ public class Transaction
  /// </summary>
  public TxType Type { get; set; }
 
+ // Taiko Anchor transaction
+ public bool IsAnchorTx { get; set; }
+
  // Optimism deposit transaction fields
  // SourceHash uniquely identifies the source of the deposit
  public Hash256? SourceHash { get; set; }

src/Nethermind/Nethermind.Evm/TransactionProcessing/TransactionProcessor.cs

@@ -309,7 +309,7 @@ private static void UpdateMetrics(ExecutionOptions opts, UInt256 effectiveGasPri
  /// <param name="opts">Options (Flags) to use for execution</param>
  /// <param name="intrinsicGas">Calculated intrinsic gas</param>
  /// <returns></returns>
- protected TransactionResult ValidateStatic(
+ protected virtual TransactionResult ValidateStatic(
  Transaction tx,
  BlockHeader header,
  IReleaseSpec spec,
@@ -357,7 +357,7 @@ protected virtual TransactionResult ValidateGas(Transaction tx, BlockHeader head
  if (validate && tx.GasLimit > header.GasLimit - header.GasUsed)
  {
  TraceLogInvalidTx(tx, $"BLOCK_GAS_LIMIT_EXCEEDED {tx.GasLimit} > {header.GasLimit} - {header.GasUsed}");
- return "block gas limit exceeded";
+ return TransactionResult.BlockGasLimitExceeded;
  }
 
  return TransactionResult.Ok;
@@ -782,5 +782,7 @@ public readonly struct TransactionResult(string? error)
  public static implicit operator TransactionResult(string? error) => new(error);
  public static implicit operator bool(TransactionResult result) => result.Success;
  public override string ToString() => Error is not null ? $"Fail : {Error}" : "Success";
+
+ public const string BlockGasLimitExceeded = "block gas limit exceeded";
  }
 }