Merge pull request #1856 from ethereum/hwwhww/verify_empty_shard_transition

Rework `Shard transition processing`

specs/phase1/beacon-chain.md

@@ -61,12 +61,14 @@
     - [Operations](#operations)
       - [New Attestation processing](#new-attestation-processing)
         - [`validate_attestation`](#validate_attestation)
+        - [Updated `process_attestation`](#updated-process_attestation)
+      - [Shard transition processing](#shard-transition-processing)
         - [`apply_shard_transition`](#apply_shard_transition)
         - [`process_crosslink_for_shard`](#process_crosslink_for_shard)
         - [`process_crosslinks`](#process_crosslinks)
-        - [`process_attestation`](#process_attestation)
+        - [`verify_empty_shard_transition`](#verify_empty_shard_transition)
+        - [`process_shard_transitions`](#process_shard_transitions)
       - [New Attester slashing processing](#new-attester-slashing-processing)
-    - [Verify empty shard transition](#verify-empty-shard-transition)
     - [Light client processing](#light-client-processing)
   - [Epoch transition](#epoch-transition)
     - [Custody game updates](#custody-game-updates)
@@ -673,7 +675,6 @@ def process_block(state: BeaconState, block: BeaconBlock) -> None:
     process_eth1_data(state, block.body)
     process_light_client_signatures(state, block.body)
     process_operations(state, block.body)
-    verify_empty_shard_transition(state, block.body)
 ```
 
 #### Operations
@@ -697,7 +698,7 @@ def process_operations(state: BeaconState, body: BeaconBlockBody) -> None:
     # See custody game spec.
     process_custody_game_operations(state, body)
 
-    process_crosslinks(state, body.shard_transitions, body.attestations)
+    process_shard_transitions(state, body.shard_transitions, body.attestations)
 
     # TODO process_operations(body.shard_receipt_proofs, process_shard_receipt_proofs)
 ```
@@ -744,6 +745,27 @@ def validate_attestation(state: BeaconState, attestation: Attestation) -> None:
     assert is_valid_indexed_attestation(state, get_indexed_attestation(state, attestation))
 ```
 
+###### Updated `process_attestation`
+
+```python
+def process_attestation(state: BeaconState, attestation: Attestation) -> None:
+    validate_attestation(state, attestation)
+    # Store pending attestation for epoch processing
+    pending_attestation = PendingAttestation(
+        aggregation_bits=attestation.aggregation_bits,
+        data=attestation.data,
+        inclusion_delay=state.slot - attestation.data.slot,
+        proposer_index=get_beacon_proposer_index(state),
+        crosslink_success=False,  # To be filled in during process_shard_transitions
+    )
+    if attestation.data.target.epoch == get_current_epoch(state):
+        state.current_epoch_attestations.append(pending_attestation)
+    else:
+        state.previous_epoch_attestations.append(pending_attestation)
+```
+
+##### Shard transition processing
+
 ###### `apply_shard_transition`
 
 ```python
@@ -885,23 +907,30 @@ def process_crosslinks(state: BeaconState,
                     pending_attestation.crosslink_success = True
 ```
 
-###### `process_attestation`
+###### `verify_empty_shard_transition`
 
 ```python
-def process_attestation(state: BeaconState, attestation: Attestation) -> None:
+def verify_empty_shard_transition(state: BeaconState, shard_transitions: Sequence[ShardTransition]) -> bool:
-    validate_attestation(state, attestation)
+    """
-    # Store pending attestation for epoch processing
+    Verify that a `shard_transition` in a block is empty if an attestation was not processed for it.
-    pending_attestation = PendingAttestation(
+    """
-        aggregation_bits=attestation.aggregation_bits,
+    for shard in range(get_active_shard_count(state)):
-        data=attestation.data,
+        if state.shard_states[shard].slot != compute_previous_slot(state.slot):
-        inclusion_delay=state.slot - attestation.data.slot,
+            if shard_transitions[shard] != ShardTransition():
-        proposer_index=get_beacon_proposer_index(state),
+                return False
-        crosslink_success=False,  # To be filled in during process_crosslinks
+    return True
-    )
+```
-    if attestation.data.target.epoch == get_current_epoch(state):
+
-        state.current_epoch_attestations.append(pending_attestation)
+###### `process_shard_transitions`
-    else:
+
-        state.previous_epoch_attestations.append(pending_attestation)
+```python
+def process_shard_transitions(state: BeaconState,
+                              shard_transitions: Sequence[ShardTransition],
+                              attestations: Sequence[Attestation]) -> None:
+    # Process crosslinks
+    process_crosslinks(state, shard_transitions, attestations)
+    # Verify the empty proposal shard states
+    assert verify_empty_shard_transition(state, shard_transitions)
 ```
 
 ##### New Attester slashing processing
@@ -946,18 +975,6 @@ def process_attester_slashing(state: BeaconState, attester_slashing: AttesterSla
     assert slashed_any
 ```
 
-#### Verify empty shard transition
-
-```python
-def verify_empty_shard_transition(state: BeaconState, block_body: BeaconBlockBody) -> None:
-    """
-    Verify that ``shard_transitions`` are empty if a crosslink was not formed for the associated shard in this slot.
-    """
-    for shard in range(get_active_shard_count(state)):
-        if state.shard_states[shard].slot != compute_previous_slot(state.slot):
-            assert block_body.shard_transitions[shard] == ShardTransition()
-```
-
 #### Light client processing
 
 ```python

tests/core/pyspec/eth2spec/test/helpers/shard_transitions.py

@@ -1,9 +1,9 @@
 from eth2spec.test.context import expect_assertion_error
 
 
-def run_crosslinks_processing(spec, state, shard_transitions, attestations, valid=True):
+def run_shard_transitions_processing(spec, state, shard_transitions, attestations, valid=True):
     """
-    Run ``process_attestation``, yielding:
+    Run ``process_shard_transitions``, yielding:
       - pre-state ('pre')
       - shard_transitions ('shard_transitions')
       - attestations ('attestations')
@@ -17,12 +17,12 @@ def run_crosslinks_processing(spec, state, shard_transitions, attestations, vali
 
     # If the attestation is invalid, processing is aborted, and there is no post-state.
     if not valid:
-        expect_assertion_error(lambda: spec.process_crosslinks(state, shard_transitions, attestations))
+        expect_assertion_error(lambda: spec.process_shard_transitions(state, shard_transitions, attestations))
         yield 'post', None
         return
 
     # process crosslinks
-    spec.process_crosslinks(state, shard_transitions, attestations)
+    spec.process_shard_transitions(state, shard_transitions, attestations)
 
     # yield post-state
     yield 'post', state

tests/core/pyspec/eth2spec/test/phase_1/block_processing/test_process_shard_transition.py

@@ -4,7 +4,7 @@ from eth2spec.test.context import (
     spec_state_test,
     always_bls,
 )
-from eth2spec.test.helpers.crosslinks import run_crosslinks_processing
+from eth2spec.test.helpers.shard_transitions import run_shard_transitions_processing
 from eth2spec.test.helpers.shard_block import (
     build_attestation_with_shard_transition,
     build_shard_block,
@@ -46,7 +46,7 @@ def run_basic_crosslink_tests(spec, state, target_len_offset_slot, valid=True):
     transition_to(spec, state, state.slot + target_len_offset_slot)
     pre_shard_state = state.shard_states[shard]
 
-    yield from run_crosslinks_processing(spec, state, shard_transitions, [attestation], valid=valid)
+    yield from run_shard_transitions_processing(spec, state, shard_transitions, [attestation], valid=valid)
 
     if valid:
         # After state transition,

tests/generators/README.md

@@ -184,7 +184,7 @@ def create_provider(handler_name: str, tests_src, config_name: str) -> gen_typin
 
 if __name__ == "__main__":
     gen_runner.run_generator("epoch_processing", [
-        create_provider('crosslinks', test_process_crosslinks, 'minimal'),
+        create_provider('final_updates', test_process_final_updates, 'minimal'),
         ...
     ])