feat(ethexe-consensus): Limits for BatchCommitment abi encoding (#5214)

Author: ecol-master

.ethexe.example.local.toml

@@ -79,6 +79,10 @@ validator-session = "0x02ba5734d8f7091719471e7f7ed6b9df170dc70cc661ca05e688601ad
 # (optional, max block gas limit: 9_000_000_000_000, default: 4_000_000_000_000).
 # block-gas-limit = 4_000_000_000_000
 
+# Batch size limit for the node.
+# (optional, max batch size limit 122_880, default 102_400)
+# batch-size-limit = 102_400
+
 # Number of blocks that must pass before applying canonical (Ethereum) events.
 # NOTE: Customize this parameter only for development purposes. In production, your node
 #       may fail to reach consensus with other nodes if this value is changed.

.ethexe.example.toml

@@ -79,6 +79,10 @@
 # (optional, max block gas limit: 9_000_000_000_000, default: 4_000_000_000_000).
 # block-gas-limit = 4_000_000_000_000
 
+# Batch size limit for the node.
+# (optional, max batch size limit 122_880, default 102_400)
+# batch-size-limit = 102_400
+
 # Number of blocks that must pass before applying canonical (Ethereum) events.
 # NOTE: Customize this parameter only for development purposes. In production, your node
 #       may fail to reach consensus with other nodes if this value is changed.

Cargo.lock

@@ -22,7 +22,7 @@ use clap::Parser;
 use directories::ProjectDirs;
 use ethexe_common::{
     DEFAULT_BLOCK_GAS_LIMIT,
-    consensus::DEFAULT_CHAIN_DEEPNESS_THRESHOLD,
+    consensus::{DEFAULT_BATCH_SIZE_LIMIT, DEFAULT_CHAIN_DEEPNESS_THRESHOLD, MAX_BATCH_SIZE_LIMIT},
     gear::{CANONICAL_QUARANTINE, MAX_BLOCK_GAS_LIMIT},
 };
 use ethexe_processor::DEFAULT_CHUNK_SIZE;
@@ -91,6 +91,12 @@ pub struct NodeParams {
     #[serde(rename = "block-gas-limit")]
     pub block_gas_limit: Option<u64>,
 
+    /// Batch size limit for the node.
+    #[arg(long)]
+    #[serde(rename = "batch-size-limit")]
+    pub batch_size_limit: Option<u64>,
+
+    /// Quarantine for canonical (Ethereum) messages.
     #[arg(long)]
     #[serde(rename = "canonical-quarantine")]
     pub canonical_quarantine: Option<u8>,
@@ -137,6 +143,10 @@ impl NodeParams {
                 .block_gas_limit
                 .unwrap_or(DEFAULT_BLOCK_GAS_LIMIT)
                 .min(MAX_BLOCK_GAS_LIMIT),
+            batch_size_limit: self
+                .batch_size_limit
+                .unwrap_or(DEFAULT_BATCH_SIZE_LIMIT)
+                .min(MAX_BATCH_SIZE_LIMIT),
             canonical_quarantine: self.canonical_quarantine.unwrap_or(CANONICAL_QUARANTINE),
             dev: self.dev,
             pre_funded_accounts: self
@@ -216,6 +226,7 @@ impl MergeParams for NodeParams {
                 .or(with.chunk_processing_threads),
 
             block_gas_limit: self.block_gas_limit.or(with.block_gas_limit),
+            batch_size_limit: self.batch_size_limit.or(with.batch_size_limit),
             canonical_quarantine: self.canonical_quarantine.or(with.canonical_quarantine),
 
             fast_sync: self.fast_sync || with.fast_sync,

ethexe/cli/src/params/node.rs

@@ -27,6 +27,15 @@ use k256::sha2::Digest as _;
 use parity_scale_codec::{Decode, Encode};
 use sha3::Keccak256;
 
+/// The maximum batch size limit - 120 KB.
+pub const MAX_BATCH_SIZE_LIMIT: u64 = 120 * 1024;
+
+/// The default batch size - 100 KB.
+pub const DEFAULT_BATCH_SIZE_LIMIT: u64 = 100 * 1024;
+
+/// Default threshold for producer to submit commitment despite of no transitions
+pub const DEFAULT_CHAIN_DEEPNESS_THRESHOLD: u32 = 500;
+
 pub type VerifiedAnnounce = VerifiedData<Announce>;
 pub type VerifiedValidationRequest = VerifiedData<BatchCommitmentValidationRequest>;
 pub type VerifiedValidationReply = VerifiedData<BatchCommitmentValidationReply>;
@@ -104,6 +113,3 @@ impl ToDigest for BatchCommitmentValidationReply {
         hasher.update(signature.into_pre_eip155_bytes())
     }
 }
-
-/// Default threshold for producer to submit commitment despite of no transitions
-pub const DEFAULT_CHAIN_DEEPNESS_THRESHOLD: u32 = 500;

ethexe/common/src/consensus.rs

@@ -32,6 +32,7 @@ lru.workspace = true
 metrics.workspace = true
 metrics-derive.workspace = true
 gear-workspace-hack.workspace = true
+alloy.workspace = true
 
 [dev-dependencies]
 ethexe-common = { workspace = true, features = ["mock"] }