gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-06-15 09:48:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

adding PayloadAttestationMessage to RejectedPayloadAttestation

Browse Source
This commit is contained in:
hopinheimer
2026-04-18 01:13:00 -04:00
parent e0b9802569
commit ec111259c1
3 changed files with 15 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
beacon_node/beacon_chain/src/payload_attestation_verification.rs
View File

@@ -218,6 +218,8 @@ impl<E: EthSpec> VerifiedPayloadAttestationMessage<E> {
payload_attestation_message: PayloadAttestationMessage,
chain: &BeaconChain<T>,
) -> Result<Self, Error> {
// TODO(manas): i think we can have a shuffling cache. but this an interim solution
// can be discussed.
let head_snapshot = chain.head_snapshot();
let head_state = &head_snapshot.beacon_state;

23
beacon_node/network/src/network_beacon_processor/gossip_methods.rs
View File

@@ -134,8 +134,8 @@ struct RejectedAggregate<E: EthSpec> {
}
struct RejectedPayloadAttestation {
payload_attestation_message: Box<PayloadAttestationMessage>,
error: PayloadAttestationError,
message_slot: Slot,
}
/// Data for an aggregated or unaggregated attestation that failed verification.
@@ -3669,17 +3669,18 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
self: &Arc<Self>,
message_id: MessageId,
peer_id: PeerId,
payload_attestation_message: PayloadAttestationMessage,
payload_attestation_message: Box<PayloadAttestationMessage>,
) {
let message_slot = payload_attestation_message.data.slot;
let result = self
let result = match self
.chain
.verify_payload_attestation_message_for_gossip(payload_attestation_message)
.map_err(|error| RejectedPayloadAttestation {
.verify_payload_attestation_message_for_gossip(*payload_attestation_message.clone())
{
Ok(verified) => Ok(verified),
Err(error) => Err(RejectedPayloadAttestation {
payload_attestation_message: payload_attestation_message.clone(),
error,
message_slot,
});
}),
};
self.process_gossip_payload_attestation_result(result, message_id, peer_id);
}
@@ -3717,14 +3718,14 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
}
}
Err(RejectedPayloadAttestation {
payload_attestation_message,
error,
message_slot,
}) => {
self.handle_payload_attestation_verification_failure(
peer_id,
message_id,
error,
message_slot,
payload_attestation_message.data.slot,
);
}
}

2
beacon_node/network/src/network_beacon_processor/mod.rs
View File

@@ -485,7 +485,7 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
processor.process_gossip_payload_attestation(
message_id,
peer_id,
*payload_attestation_message,
payload_attestation_message,
)
};