Add missed exit checks to consolidation processing

Consensys · Dec 5, 2024 · afe7063 · afe7063
1 parent 410b739
commit afe7063
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/.../main/java/tech/pegasys/teku/spec/logic/versions/electra/block/BlockProcessorElectra.java b/.../main/java/tech/pegasys/teku/spec/logic/versions/electra/block/BlockProcessorElectra.java
@@ -520,6 +520,20 @@ private void processConsolidationRequest(
       return;
     }
 
+    // Verify the source has been active long enough
+    if (currentEpoch.isLessThan(
+        sourceValidator.getActivationEpoch().plus(specConfig.getShardCommitteePeriod()))) {
+      LOG.debug("process_consolidation_request: source has not been active long enough");
+      return;
+    }
+    // Verify the source has no pending withdrawals in the queue
+    if (beaconStateAccessorsElectra
+        .getPendingBalanceToWithdraw(state, sourceValidatorIndex)
+        .isGreaterThan(ZERO)) {
+      LOG.debug("process_consolidation_request: source has pending withdrawals in the queue");
+      return;
+    }
+
     // Initiate source validator exit and append pending consolidation
     final UInt64 exitEpoch =
         beaconStateMutatorsElectra.computeConsolidationEpochAndUpdateChurn(