Initial commit for eip-7732 on fulu

beacon_chain/beacon_chain_db_immutable.nim

@@ -1,5 +1,5 @@
 # beacon_chain
-# Copyright (c) 2021-2024 Status Research & Development GmbH
+# Copyright (c) 2021-2025 Status Research & Development GmbH
 # Licensed and distributed under either of
 #   * MIT license (license terms in the root directory or at https://opensource.org/licenses/MIT).
 #   * Apache v2 license (license terms in the root directory or at https://www.apache.org/licenses/LICENSE-2.0).
@@ -427,78 +427,47 @@ type
     genesis_validators_root*: Eth2Digest
     slot*: Slot
     fork*: Fork
-
-    # History
     latest_block_header*: BeaconBlockHeader
-      ## `latest_block_header.state_root == ZERO_HASH` temporarily
-
     block_roots*: HashArray[Limit SLOTS_PER_HISTORICAL_ROOT, Eth2Digest]
-      ## Needed to process attestations, older to newer
-
     state_roots*: HashArray[Limit SLOTS_PER_HISTORICAL_ROOT, Eth2Digest]
     historical_roots*: HashList[Eth2Digest, Limit HISTORICAL_ROOTS_LIMIT]
-      ## Frozen in Capella, replaced by historical_summaries
-
-    # Eth1
     eth1_data*: Eth1Data
     eth1_data_votes*:
       HashList[Eth1Data, Limit(EPOCHS_PER_ETH1_VOTING_PERIOD * SLOTS_PER_EPOCH)]
     eth1_deposit_index*: uint64
-
-    # Registry
-    validators*:
-      HashList[ValidatorStatusCapella, Limit VALIDATOR_REGISTRY_LIMIT]
+    validators*: HashList[Validator, Limit VALIDATOR_REGISTRY_LIMIT]
     balances*: HashList[Gwei, Limit VALIDATOR_REGISTRY_LIMIT]
-
-    # Randomness
     randao_mixes*: HashArray[Limit EPOCHS_PER_HISTORICAL_VECTOR, Eth2Digest]
-
-    # Slashings
     slashings*: HashArray[Limit EPOCHS_PER_SLASHINGS_VECTOR, Gwei]
-      ## Per-epoch sums of slashed effective balances
-
-    # Participation
     previous_epoch_participation*: EpochParticipationFlags
     current_epoch_participation*: EpochParticipationFlags
-
-    # Finality
     justification_bits*: JustificationBits
-      ## Bit set for every recent justified epoch
-
     previous_justified_checkpoint*: Checkpoint
     current_justified_checkpoint*: Checkpoint
     finalized_checkpoint*: Checkpoint
-
-    # Inactivity
-    inactivity_scores*: HashList[uint64, Limit VALIDATOR_REGISTRY_LIMIT]
-
-    # Light client sync committees
+    inactivity_scores*: InactivityScores
     current_sync_committee*: SyncCommittee
     next_sync_committee*: SyncCommittee
-
-    # Execution
     latest_execution_payload_header*: fulu.ExecutionPayloadHeader
-
-    # Withdrawals
     next_withdrawal_index*: WithdrawalIndex
     next_withdrawal_validator_index*: uint64
-
-    # Deep history valid from Capella onwards
     historical_summaries*:
       HashList[HistoricalSummary, Limit HISTORICAL_ROOTS_LIMIT]
 
-    deposit_requests_start_index*: uint64  # [New in Electra:EIP6110]
-    deposit_balance_to_consume*: Gwei  # [New in Electra:EIP7251]
-    exit_balance_to_consume*: Gwei  # [New in Electra:EIP7251]
-    earliest_exit_epoch*: Epoch  # [New in Electra:EIP7251]
-    consolidation_balance_to_consume*: Gwei  # [New in Electra:EIP7251]
-    earliest_consolidation_epoch*: Epoch  # [New in Electra:EIP7251]
-    pending_deposits*: HashList[PendingDeposit, Limit PENDING_DEPOSITS_LIMIT]
-      ## [New in Electra:EIP7251]
-
-    # [New in Electra:EIP7251]
+    deposit_requests_start_index*: uint64
+    deposit_balance_to_consume*: Gwei
+    exit_balance_to_consume*: Gwei
+    earliest_exit_epoch*: Epoch
+    consolidation_balance_to_consume*: Gwei
+    earliest_consolidation_epoch*: Epoch 
+    pending_deposits*: 
+      HashList[PendingDeposit, Limit PENDING_DEPOSITS_LIMIT]
     pending_partial_withdrawals*:
       HashList[PendingPartialWithdrawal, Limit PENDING_PARTIAL_WITHDRAWALS_LIMIT]
     pending_consolidations*:
       HashList[PendingConsolidation, Limit PENDING_CONSOLIDATIONS_LIMIT]
-      ## [New in Electra:EIP7251]
+
+    # [New in ePBS:eip7732]
+    latest_block_hash*: Eth2Digest
+    latest_full_slot*: Slot
+    latest_withdrawals_root*: Eth2Digest

beacon_chain/beacon_node_light_client.nim

@@ -1,5 +1,5 @@
 # beacon_chain
-# Copyright (c) 2022-2024 Status Research & Development GmbH
+# Copyright (c) 2022-2025 Status Research & Development GmbH
 # Licensed and distributed under either of
 #   * MIT license (license terms in the root directory or at https://opensource.org/licenses/MIT).
 #   * Apache v2 license (license terms in the root directory or at https://www.apache.org/licenses/LICENSE-2.0).
@@ -42,7 +42,7 @@ proc initLightClient*(
         signedBlock: ForkedSignedBeaconBlock
     ): Future[void] {.async: (raises: [CancelledError]).} =
       withBlck(signedBlock):
-        when consensusFork >= ConsensusFork.Bellatrix:
+        when consensusFork >= ConsensusFork.Bellatrix and consensusFork != ConsensusFork.Fulu:
           if forkyBlck.message.is_execution_block:
             template payload(): auto = forkyBlck.message.body.execution_payload
             if not payload.block_hash.isZero:

beacon_chain/consensus_object_pools/blob_quarantine.nim

@@ -1,5 +1,5 @@
 # beacon_chain
-# Copyright (c) 2018-2024 Status Research & Development GmbH
+# Copyright (c) 2018-2025 Status Research & Development GmbH
 # Licensed and distributed under either of
 #   * MIT license (license terms in the root directory or at https://opensource.org/licenses/MIT).
 #   * Apache v2 license (license terms in the root directory or at https://www.apache.org/licenses/LICENSE-2.0).
@@ -73,35 +73,46 @@ func hasBlob*(
 func popBlobs*(
     quarantine: var BlobQuarantine, digest: Eth2Digest,
     blck: deneb.SignedBeaconBlock | electra.SignedBeaconBlock |
-          fulu.SignedBeaconBlock):
-    seq[ref BlobSidecar] =
+          fulu.SignedBeaconBlock): seq[ref BlobSidecar] =
   var r: seq[ref BlobSidecar] = @[]
-  for idx, kzg_commitment in blck.message.body.blob_kzg_commitments:
-    var b: ref BlobSidecar
-    if quarantine.blobs.pop((digest, BlobIndex idx, kzg_commitment), b):
-      r.add(b)
+
+  # skip processing blobs for fulu
+  when typeof(blck).kind == ConsensusFork.Fulu:
+    return r
+  else:
+    for idx, kzg_commitment in blck.message.body.blob_kzg_commitments:
+      var b: ref BlobSidecar
+      if quarantine.blobs.pop((digest, BlobIndex idx, kzg_commitment), b):
+        r.add(b)
   r
 
 func hasBlobs*(quarantine: BlobQuarantine,
     blck: deneb.SignedBeaconBlock | electra.SignedBeaconBlock |
           fulu.SignedBeaconBlock): bool =
     # Having a fulu SignedBeaconBlock is incorrect atm, but
     # shall be fixed once data columns are rebased to fulu
-  for idx, kzg_commitment in blck.message.body.blob_kzg_commitments:
-    if (blck.root, BlobIndex idx, kzg_commitment) notin quarantine.blobs:
-      return false
+  when typeof(blck).kind == ConsensusFork.Fulu:
+    return false
+  else:
+    for idx, kzg_commitment in blck.message.body.blob_kzg_commitments:
+      if (blck.root, BlobIndex idx, kzg_commitment) notin quarantine.blobs:
+        return false
   true
 
 func blobFetchRecord*(quarantine: BlobQuarantine,
     blck: deneb.SignedBeaconBlock | electra.SignedBeaconBlock |
           fulu.SignedBeaconBlock): BlobFetchRecord =
-  var indices: seq[BlobIndex]
-  for i in 0..<len(blck.message.body.blob_kzg_commitments):
-    let idx = BlobIndex(i)
-    if not quarantine.blobs.hasKey(
-        (blck.root, idx, blck.message.body.blob_kzg_commitments[i])):
-      indices.add(idx)
-  BlobFetchRecord(block_root: blck.root, indices: indices)
+  # Skip blob fetching logic for the Fulu fork
+  when typeof(blck).kind == ConsensusFork.Fulu:
+    return BlobFetchRecord(block_root: blck.root, indices: @[])  # Empty record
+  else:
+    var indices: seq[BlobIndex]
+    for i in 0..<len(blck.message.body.blob_kzg_commitments):
+      let idx = BlobIndex(i)
+      if not quarantine.blobs.hasKey(
+          (blck.root, idx, blck.message.body.blob_kzg_commitments[i])):
+        indices.add(idx)
+    BlobFetchRecord(block_root: blck.root, indices: indices)
 
 func init*(
     T: type BlobQuarantine, onBlobSidecarCallback: OnBlobSidecarCallback): T =

beacon_chain/consensus_object_pools/block_dag.nim

@@ -1,5 +1,5 @@
 # beacon_chain
-# Copyright (c) 2018-2024 Status Research & Development GmbH
+# Copyright (c) 2018-2025 Status Research & Development GmbH
 # Licensed and distributed under either of
 #   * MIT license (license terms in the root directory or at https://opensource.org/licenses/MIT).
 #   * Apache v2 license (license terms in the root directory or at https://www.apache.org/licenses/LICENSE-2.0).
@@ -72,11 +72,18 @@ func init*(
           deneb.SomeBeaconBlock | deneb.TrustedBeaconBlock |
           electra.SomeBeaconBlock | electra.TrustedBeaconBlock |
           fulu.SomeBeaconBlock | fulu.TrustedBeaconBlock): BlockRef =
-  BlockRef.init(
-    root, Opt.some blck.body.execution_payload.block_hash,
-    executionValid =
-      executionValid or blck.body.execution_payload.block_hash == ZERO_HASH,
-    blck.slot)
+  when typeof(blck).kind < ConsensusFork.Fulu:
+    BlockRef.init(
+      root, Opt.some blck.body.execution_payload.block_hash,
+      executionValid =
+        executionValid or blck.body.execution_payload.block_hash == ZERO_HASH,
+      blck.slot)
+  else:
+    BlockRef.init(
+      root, 
+      Opt.none(Eth2Digest),
+      executionValid = true,
+      blck.slot)
 
 func parent*(bs: BlockSlot): BlockSlot =
   ## Return a blockslot representing the previous slot, using the parent block

beacon_chain/consensus_object_pools/blockchain_dag.nim

@@ -1,5 +1,5 @@
 # beacon_chain
-# Copyright (c) 2018-2024 Status Research & Development GmbH
+# Copyright (c) 2018-2025 Status Research & Development GmbH
 # Licensed and distributed under either of
 #   * MIT license (license terms in the root directory or at https://opensource.org/licenses/MIT).
 #   * Apache v2 license (license terms in the root directory or at https://www.apache.org/licenses/LICENSE-2.0).
@@ -1461,7 +1461,9 @@ proc computeRandaoMix(
     bdata: ForkedTrustedSignedBeaconBlock): Opt[Eth2Digest] =
   ## Compute the requested RANDAO mix for `bdata` without `state`, if possible.
   withBlck(bdata):
-    when consensusFork >= ConsensusFork.Bellatrix:
+    when consensusFork >= ConsensusFork.Fulu:
+      return Opt.none(Eth2Digest)
+    elif consensusFork >= ConsensusFork.Bellatrix:
       if forkyBlck.message.is_execution_block:
         var mix = eth2digest(forkyBlck.message.body.randao_reveal.toRaw())
         mix.data.mxor forkyBlck.message.body.execution_payload.prev_randao.data
@@ -2311,7 +2313,9 @@ proc loadExecutionBlockHash*(
     return Opt.none(Eth2Digest)
 
   withBlck(blockData):
-    when consensusFork >= ConsensusFork.Bellatrix:
+    when consensusFork >= ConsensusFork.Fulu:
+      Opt.some ZERO_HASH
+    elif consensusFork >= ConsensusFork.Bellatrix:
       Opt.some forkyBlck.message.body.execution_payload.block_hash
     else:
       Opt.some ZERO_HASH

beacon_chain/consensus_object_pools/blockchain_list.nim

@@ -1,5 +1,5 @@
 # beacon_chain
-# Copyright (c) 2018-2024 Status Research & Development GmbH
+# Copyright (c) 2018-2025 Status Research & Development GmbH
 # Licensed and distributed under either of
 #   * MIT license (license terms in the root directory or at https://opensource.org/licenses/MIT).
 #   * Apache v2 license (license terms in the root directory or at https://www.apache.org/licenses/LICENSE-2.0).
@@ -142,7 +142,8 @@ proc store*(clist: ChainListRef, signedBlock: ForkedSignedBeaconBlock,
 proc checkBlobs(signedBlock: ForkedSignedBeaconBlock,
                 blobsOpt: Opt[BlobSidecars]): Result[void, VerifierError] =
   withBlck(signedBlock):
-    when consensusFork >= ConsensusFork.Deneb:
+    when consensusFork >= ConsensusFork.Deneb and 
+      consensusFork != ConsensusFork.Fulu:
       if blobsOpt.isSome():
         let blobs = blobsOpt.get()
 

beacon_chain/consensus_object_pools/data_column_quarantine.nim

@@ -1,5 +1,5 @@
 # beacon_chain
-# Copyright (c) 2018-2024 Status Research & Development GmbH
+# Copyright (c) 2018-2025 Status Research & Development GmbH
 # Licensed and distributed under either of
 #   * MIT license (license terms in the root directory or at https://opensource.org/licenses/MIT).
 #   * Apache v2 license (license terms in the root directory or at https://www.apache.org/licenses/LICENSE-2.0).
@@ -37,8 +37,8 @@ type
 func init*(T: type DataColumnQuarantine): T =
   T()
 
-func shortLog*(x: seq[DataColumnFetchRecord]): string =
-  "[" & x.mapIt(shortLog(it.block_root) & shortLog(it.indices)).join(", ") & "]"
+# func shortLog*(x: seq[DataColumnFetchRecord]): string =
+#   "[" & x.mapIt(shortLog(it.block_root) & shortLog(it.indices.mapIt($it).join(", "))).join(", ") & "]"
 
 func put*(quarantine: var DataColumnQuarantine,
           dataColumnSidecar: ref DataColumnSidecar) =

beacon_chain/el/el_manager.nim

@@ -1,5 +1,5 @@
 # beacon_chain
-# Copyright (c) 2018-2024 Status Research & Development GmbH
+# Copyright (c) 2018-2025 Status Research & Development GmbH
 # Licensed and distributed under either of
 #   * MIT license (license terms in the root directory or at https://opensource.org/licenses/MIT).
 #   * Apache v2 license (license terms in the root directory or at https://www.apache.org/licenses/LICENSE-2.0).
@@ -993,7 +993,12 @@ proc sendNewPayload*(
       let
         requests = m.elConnections.mapIt:
           let req =
-            when typeof(blck).kind >= ConsensusFork.Electra:
+            when typeof(blck).kind == ConsensusFork.Fulu:
+                let versioned_hashes: seq[VersionedHash] = @[]
+                sendNewPayloadToSingleEL(
+                  it, payload, versioned_hashes,
+                  FixedBytes[32] blck.parent_root.data)
+            elif typeof(blck).kind >= ConsensusFork.Electra:
               # https://github.com/ethereum/execution-apis/blob/4140e528360fea53c34a766d86a000c6c039100e/src/engine/prague.md#engine_newpayloadv4
               let versioned_hashes = mapIt(
                 blck.body.blob_kzg_commitments,