Rename ExecutionLayerConsolidationRequest->ConsolidationRequest

Author: prestonvanloon

specs/electra/beacon-chain.md

@@ -28,7 +28,7 @@
     - [`PendingBalanceDeposit`](#pendingbalancedeposit)
     - [`PendingPartialWithdrawal`](#pendingpartialwithdrawal)
     - [`WithdrawalRequest`](#executionlayerwithdrawalrequest)
-    - [`ExecutionLayerConsolidationRequest`](#executionlayerconsolidationrequest)
+    - [`ConsolidationRequest`](#executionlayerconsolidationrequest)
     - [`PendingConsolidation`](#pendingconsolidation)
   - [Modified Containers](#modified-containers)
     - [`AttesterSlashing`](#attesterslashing)
@@ -95,7 +95,7 @@
       - [Deposit requests](#deposit-requests)
         - [New `process_deposit_request`](#new-process_deposit_request)
       - [Execution layer consolidation requests](#execution-layer-consolidation-requests)
-        - [New `process_execution_layer_consolidation_request`](#new-process_execution_layer_consolidation_request)
+        - [New `process_consolidation_request`](#new-process_consolidation_request)
 - [Testing](#testing)
 
 <!-- END doctoc generated TOC please keep comment here to allow auto update -->
@@ -238,12 +238,12 @@ class WithdrawalRequest(Container):
     amount: Gwei
 ```
 
-#### `ExecutionLayerConsolidationRequest`
+#### `ConsolidationRequest`
 
 *Note*: The container is new in EIP7251.
 
 ```python
-class ExecutionLayerConsolidationRequest(Container):
+class ConsolidationRequest(Container):
     source_address: ExecutionAddress
     source_pubkey: BLSPubkey
     target_pubkey: BLSPubkey
@@ -338,7 +338,7 @@ class ExecutionPayload(Container):
     # [New in Electra:EIP7002:EIP7251]
     withdrawal_requests: List[WithdrawalRequest, MAX_WITHDRAWAL_REQUESTS_PER_PAYLOAD]
     # [New in Electra:EIP7251]
-    consolidation_requests: List[ExecutionLayerConsolidationRequest, MAX_CONSOLIDATION_REQUESTS_PER_PAYLOAD]
+    consolidation_requests: List[ConsolidationRequest, MAX_CONSOLIDATION_REQUESTS_PER_PAYLOAD]
 ```
 
 #### `ExecutionPayloadHeader`
@@ -1077,7 +1077,7 @@ def process_operations(state: BeaconState, body: BeaconBlockBody) -> None:
     # [New in Electra:EIP7002:EIP7251]
     for_ops(body.execution_payload.withdrawal_requests, process_withdrawal_request)
     # [New in Electra:EIP7251]
-    for_ops(body.execution_payload.consolidation_requests, process_execution_layer_consolidation_request)
+    for_ops(body.execution_payload.consolidation_requests, process_consolidation_request)
 ```
 
 ##### Attestations
@@ -1326,12 +1326,12 @@ def process_deposit_request(state: BeaconState, deposit_request: DepositRequest)
 
 ##### Execution layer consolidation requests
 
-###### New `process_execution_layer_consolidation_request`
+###### New `process_consolidation_request`
 
 ```python
-def process_execution_layer_consolidation_request(
+def process_consolidation_request(
     state: BeaconState,
-    execution_layer_consolidation_request: ExecutionLayerConsolidationRequest
+    consolidation_request: ConsolidationRequest
 ) -> None:
     # If the pending consolidations queue is full, consolidation requests are ignored
     if len(state.pending_consolidations) == PENDING_CONSOLIDATIONS_LIMIT:
@@ -1342,8 +1342,8 @@ def process_execution_layer_consolidation_request(
 
     validator_pubkeys = [v.pubkey for v in state.validators]
     # Verify pubkeys exists
-    request_source_pubkey = execution_layer_consolidation_request.source_pubkey
-    request_target_pubkey = execution_layer_consolidation_request.target_pubkey
+    request_source_pubkey = consolidation_request.source_pubkey
+    request_target_pubkey = consolidation_request.target_pubkey
     if request_source_pubkey not in validator_pubkeys:
         return
     if request_target_pubkey not in validator_pubkeys:
@@ -1360,7 +1360,7 @@ def process_execution_layer_consolidation_request(
     # Verify source withdrawal credentials
     has_correct_credential = has_execution_withdrawal_credential(source_validator)
     is_correct_source_address = (
-        source_validator.withdrawal_credentials[12:] == execution_layer_consolidation_request.source_address
+        source_validator.withdrawal_credentials[12:] == consolidation_request.source_address
     )
     if not (has_correct_credential and is_correct_source_address):
         return

tests/core/pyspec/eth2spec/test/electra/block_processing/test_process_execution_layer_consolidation_request.py

@@ -39,7 +39,7 @@ def test_basic_consolidation_in_current_consolidation_epoch(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation with source address
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -88,7 +88,7 @@ def test_basic_consolidation_in_new_consolidation_epoch(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation with source address
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -131,7 +131,7 @@ def test_basic_consolidation_with_preexisting_churn(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation with source address
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -178,7 +178,7 @@ def test_basic_consolidation_with_insufficient_preexisting_churn(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation with source address
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -229,7 +229,7 @@ def test_basic_consolidation_with_compounding_credentials(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation with source address
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -274,7 +274,7 @@ def test_consolidation_churn_limit_balance(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation with source address
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -322,7 +322,7 @@ def test_consolidation_balance_larger_than_churn_limit(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation with source address
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -369,7 +369,7 @@ def test_consolidation_balance_through_two_churn_epochs(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation with source address
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -415,7 +415,7 @@ def test_incorrect_source_equals_target(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation from source to source
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[source_index].pubkey,
@@ -447,7 +447,7 @@ def test_incorrect_exceed_pending_consolidations_limit(spec, state):
     set_eth1_withdrawal_credential_with_balance(
         spec, state, source_index, address=source_address
     )
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -476,7 +476,7 @@ def test_incorrect_not_enough_consolidation_churn_available(spec, state):
     set_eth1_withdrawal_credential_with_balance(
         spec, state, source_index, address=source_address
     )
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -504,7 +504,7 @@ def test_incorrect_exited_source(spec, state):
     set_eth1_withdrawal_credential_with_balance(
         spec, state, source_index, address=source_address
     )
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -536,7 +536,7 @@ def test_incorrect_exited_target(spec, state):
     set_eth1_withdrawal_credential_with_balance(
         spec, state, source_index, address=source_address
     )
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -566,7 +566,7 @@ def test_incorrect_inactive_source(spec, state):
     set_eth1_withdrawal_credential_with_balance(
         spec, state, source_index, address=source_address
     )
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -598,7 +598,7 @@ def test_incorrect_inactive_target(spec, state):
     set_eth1_withdrawal_credential_with_balance(
         spec, state, source_index, address=source_address
     )
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -627,7 +627,7 @@ def test_incorrect_no_source_execution_withdrawal_credential(spec, state):
     source_index = spec.get_active_validator_indices(state, current_epoch)[0]
     target_index = spec.get_active_validator_indices(state, current_epoch)[1]
     source_address = b"\x22" * 20
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -656,7 +656,7 @@ def test_incorrect_no_target_execution_withdrawal_credential(spec, state):
     set_eth1_withdrawal_credential_with_balance(
         spec, state, source_index, address=source_address
     )
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -684,7 +684,7 @@ def test_incorrect_incorrect_source_address(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation with different source address
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=b"\x33" * 20,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=state.validators[target_index].pubkey,
@@ -714,7 +714,7 @@ def test_incorrect_unknown_source_pubkey(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation with different source pubkey
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=source_address,
         source_pubkey=b"\x00" * 48,
         target_pubkey=state.validators[target_index].pubkey,
@@ -744,7 +744,7 @@ def test_incorrect_unknown_target_pubkey(spec, state):
         spec, state, source_index, address=source_address
     )
     # Make consolidation with different target pubkey
-    consolidation = spec.ExecutionLayerConsolidationRequest(
+    consolidation = spec.ConsolidationRequest(
         source_address=b"\x33" * 20,
         source_pubkey=state.validators[source_index].pubkey,
         target_pubkey=b"\x00" * 48,
@@ -760,7 +760,7 @@ def run_consolidation_processing(spec, state, consolidation, success=True):
     """
     Run ``process_consolidation``, yielding:
       - pre-state ('pre')
-      - execution_layer_consolidation_request ('execution_layer_consolidation_request')
+      - consolidation_request ('consolidation_request')
       - post-state ('post').
     If ``valid == False``, run expecting ``AssertionError``
     """
@@ -778,9 +778,9 @@ def run_consolidation_processing(spec, state, consolidation, success=True):
         pre_state = state.copy()
 
     yield 'pre', state
-    yield 'execution_layer_consolidation_request', consolidation
+    yield 'consolidation_request', consolidation
 
-    spec.process_execution_layer_consolidation_request(state, consolidation)
+    spec.process_consolidation_request(state, consolidation)
 
     yield 'post', state
 

tests/formats/operations/README.md

@@ -47,7 +47,7 @@ Operations:
 | `bls_to_execution_change` | `SignedBLSToExecutionChange` | `address_change`    | `process_bls_to_execution_change(state, address_change)` (new in Capella) |
 | `deposit_request`         | `DepositRequest`             | `deposit_request`   | `process_deposit_request(state, deposit_request)` (new in Electra)               |
 | `withdrawal_request`      | `WithdrawalRequest`          | `withdrawal_request` | `process_withdrawal_request(state, withdrawal_request)` (new in Electra) |
-| `execution_layer_consolidation_request`                   | `ExecutionLayerConsolidationRequest`         | `execution_layer_consolidation_request` | `process_execution_layer_consolidation_request(state, execution_layer_consolidation_request)` (new in Electra) |
+| `consolidation_request`   | `ConsolidationRequest`        | `consolidation_request` | `process_consolidation_request(state, consolidation_request)` (new in Electra) |
 
 Note that `block_header` is not strictly an operation (and is a full `Block`), but processed in the same manner, and hence included here.
 

tests/generators/operations/main.py

@@ -45,7 +45,7 @@
 
     _new_electra_mods = {key: 'eth2spec.test.electra.block_processing.test_process_' + key for key in [
         'attestation',
-        'execution_layer_consolidation_request',
+        'consolidation_request',
         'deposit_request',
         'withdrawal_request',
         'voluntary_exit'