From 822e6491832c5bd8ef3d55e2a57d3835acde3c4c Mon Sep 17 00:00:00 2001
From: g11tech <develop@g11tech.io>
Date: Thu, 9 May 2024 22:29:39 +0530
Subject: [PATCH] feat: apply some fixes and hacks to get the single node
 devnet working with fork transition (#6754)

---
 .../chain/produceBlock/produceBlockBody.ts    |  5 ++
 .../src/slot/upgradeStateToElectra.ts         | 74 +++++++++++++++++++
 2 files changed, 79 insertions(+)

diff --git a/packages/beacon-node/src/chain/produceBlock/produceBlockBody.ts b/packages/beacon-node/src/chain/produceBlock/produceBlockBody.ts
index c66aa29ef58..05b6cb5e7d8 100644
--- a/packages/beacon-node/src/chain/produceBlock/produceBlockBody.ts
+++ b/packages/beacon-node/src/chain/produceBlock/produceBlockBody.ts
@@ -17,6 +17,7 @@ import {
   BlindedBeaconBlockBody,
   BlindedBeaconBlock,
   sszTypesFor,
+  electra,
 } from "@lodestar/types";
 import {
   CachedBeaconStateAllForks,
@@ -342,6 +343,10 @@ export async function produceBlockBody<T extends BlockType>(
     }
   }
 
+  if (ForkSeq[fork] >= ForkSeq.electra) {
+    (blockBody as electra.BeaconBlockBody).consolidations = [];
+  }
+
   Object.assign(logMeta, {executionPayloadValue});
   this.logger.verbose("Produced beacon block body", logMeta);
 
diff --git a/packages/state-transition/src/slot/upgradeStateToElectra.ts b/packages/state-transition/src/slot/upgradeStateToElectra.ts
index a6bc6c331e1..121425265b5 100644
--- a/packages/state-transition/src/slot/upgradeStateToElectra.ts
+++ b/packages/state-transition/src/slot/upgradeStateToElectra.ts
@@ -14,6 +14,80 @@ import {
 export function upgradeStateToElectra(stateDeneb: CachedBeaconStateDeneb): CachedBeaconStateElectra {
   const {config} = stateDeneb;
 
+  ssz.deneb.BeaconState.commitViewDU(stateDeneb);
+  const stateElectraCloned = stateDeneb;
+
+  const stateElectraView = ssz.electra.BeaconState.defaultViewDU();
+  stateElectraView.genesisTime = stateElectraCloned.genesisTime;
+  stateElectraView.genesisValidatorsRoot = stateElectraCloned.genesisValidatorsRoot;
+  stateElectraView.slot = stateElectraCloned.slot;
+  stateElectraView.fork = ssz.phase0.Fork.toViewDU({
+    previousVersion: stateDeneb.fork.currentVersion,
+    currentVersion: config.ELECTRA_FORK_VERSION,
+    epoch: stateDeneb.epochCtx.epoch,
+  });
+  stateElectraView.latestBlockHeader = stateElectraCloned.latestBlockHeader;
+  stateElectraView.blockRoots = stateElectraCloned.blockRoots;
+  stateElectraView.stateRoots = stateElectraCloned.stateRoots;
+  stateElectraView.historicalRoots = stateElectraCloned.historicalRoots;
+  stateElectraView.eth1Data = stateElectraCloned.eth1Data;
+  stateElectraView.eth1DataVotes = stateElectraCloned.eth1DataVotes;
+  stateElectraView.eth1DepositIndex = stateElectraCloned.eth1DepositIndex;
+  stateElectraView.validators = stateElectraCloned.validators;
+  stateElectraView.balances = stateElectraCloned.balances;
+  stateElectraView.randaoMixes = stateElectraCloned.randaoMixes;
+  stateElectraView.slashings = stateElectraCloned.slashings;
+  stateElectraView.previousEpochParticipation = stateElectraCloned.previousEpochParticipation;
+  stateElectraView.currentEpochParticipation = stateElectraCloned.currentEpochParticipation;
+  stateElectraView.justificationBits = stateElectraCloned.justificationBits;
+  stateElectraView.previousJustifiedCheckpoint = stateElectraCloned.previousJustifiedCheckpoint;
+  stateElectraView.currentJustifiedCheckpoint = stateElectraCloned.currentJustifiedCheckpoint;
+  stateElectraView.finalizedCheckpoint = stateElectraCloned.finalizedCheckpoint;
+  stateElectraView.inactivityScores = stateElectraCloned.inactivityScores;
+  stateElectraView.currentSyncCommittee = stateElectraCloned.currentSyncCommittee;
+  stateElectraView.nextSyncCommittee = stateElectraCloned.nextSyncCommittee;
+  stateElectraView.latestExecutionPayloadHeader = ssz.electra.BeaconState.fields.latestExecutionPayloadHeader.toViewDU({
+    ...stateElectraCloned.latestExecutionPayloadHeader.toValue(),
+    depositRequestsRoot: ssz.Root.defaultValue(),
+    withdrawalRequestsRoot: ssz.Root.defaultValue(),
+  });
+  stateElectraView.nextWithdrawalIndex = stateDeneb.nextWithdrawalIndex;
+  stateElectraView.nextWithdrawalValidatorIndex = stateDeneb.nextWithdrawalValidatorIndex;
+  stateElectraView.historicalSummaries = stateElectraCloned.historicalSummaries;
+
+  // latestExecutionPayloadHeader's depositRequestsRoot and withdrawalRequestsRoot set to zeros by default
+  // default value of depositRequestsStartIndex is UNSET_DEPOSIT_RECEIPTS_START_INDEX
+  stateElectraView.depositRequestsStartIndex = UNSET_DEPOSIT_RECEIPTS_START_INDEX;
+
+  const validatorsArr = stateElectraView.validators.getAllReadonly();
+
+  for (let i = 0; i < validatorsArr.length; i++) {
+    const validator = validatorsArr[i];
+
+    // [EIP-7251]: add validators that are not yet active to pending balance deposits
+    if (validator.activationEligibilityEpoch === FAR_FUTURE_EPOCH) {
+      queueEntireBalanceAndResetValidator(stateElectraView as CachedBeaconStateElectra, i);
+    }
+
+    // [EIP-7251]: Ensure early adopters of compounding credentials go through the activation churn
+    const withdrawalCredential = validator.withdrawalCredentials;
+    if (hasCompoundingWithdrawalCredential(withdrawalCredential)) {
+      queueExcessActiveBalance(stateElectraView as CachedBeaconStateElectra, i);
+    }
+  }
+
+  const stateElectra = getCachedBeaconState(stateElectraView, stateDeneb);
+  // Commit new added fields ViewDU to the root node
+  stateElectra.commit();
+  // Clear cache to ensure the cache of deneb fields is not used by new ELECTRA fields
+  stateElectra["clearCache"]();
+
+  return stateElectra;
+}
+
+export function upgradeStateToElectraOriginal(stateDeneb: CachedBeaconStateDeneb): CachedBeaconStateElectra {
+  const {config} = stateDeneb;
+
   const stateElectraNode = ssz.deneb.BeaconState.commitViewDU(stateDeneb);
   const stateElectraView = ssz.electra.BeaconState.getViewDU(stateElectraNode);