Small changes

This commit is contained in:
Eitan Seri-Levi
2026-01-02 08:55:48 -06:00
parent 07a2ea393c
commit b52236a81f
3 changed files with 4 additions and 6 deletions

View File

@@ -94,15 +94,13 @@ pub async fn get_valid_signed_inclusion_list<T: BeaconChainTypes>(
let fork = harness.chain.spec.fork_at_epoch(current_epoch); let fork = harness.chain.spec.fork_at_epoch(current_epoch);
let signed_inclusion_list = sign( sign(
&inclusion_list, &inclusion_list,
&keypair.sk, &keypair.sk,
&fork, &fork,
harness.chain.genesis_validators_root, harness.chain.genesis_validators_root,
&harness.chain.spec, &harness.chain.spec,
); )
signed_inclusion_list
} }
/// Signs `self`, setting the `committee_position`'th bit of `aggregation_bits` to `true`. /// Signs `self`, setting the `committee_position`'th bit of `aggregation_bits` to `true`.

View File

@@ -45,6 +45,8 @@ use crate::validator::post_validator_liveness_epoch;
use crate::validator::*; use crate::validator::*;
use crate::version::beacon_response; use crate::version::beacon_response;
use beacon::states; use beacon::states;
use warp_utils::reject::convert_rejection;
use beacon_chain::{BeaconChain, BeaconChainError, BeaconChainTypes, WhenSlotSkipped}; use beacon_chain::{BeaconChain, BeaconChainError, BeaconChainTypes, WhenSlotSkipped};
use beacon_processor::BeaconProcessorSend; use beacon_processor::BeaconProcessorSend;
pub use block_id::BlockId; pub use block_id::BlockId;

View File

@@ -2,7 +2,6 @@ use std::{sync::Arc, time::Duration};
use beacon_chain::inclusion_list_verification::GossipInclusionListError; use beacon_chain::inclusion_list_verification::GossipInclusionListError;
use beacon_chain::{BeaconChain, BeaconChainTypes, validator_monitor::timestamp_now}; use beacon_chain::{BeaconChain, BeaconChainTypes, validator_monitor::timestamp_now};
use beacon_processor::work_reprocessing_queue::ReprocessQueueMessage;
use eth2::types::Failure; use eth2::types::Failure;
use lighthouse_network::PubsubMessage; use lighthouse_network::PubsubMessage;
use network::NetworkMessage; use network::NetworkMessage;
@@ -35,7 +34,6 @@ pub async fn publish_inclusion_lists<T: BeaconChainTypes>(
chain: Arc<BeaconChain<T>>, chain: Arc<BeaconChain<T>>,
inclusion_lists: Vec<SignedInclusionList<T::EthSpec>>, inclusion_lists: Vec<SignedInclusionList<T::EthSpec>>,
network_tx: UnboundedSender<NetworkMessage<T::EthSpec>>, network_tx: UnboundedSender<NetworkMessage<T::EthSpec>>,
_reprocess_send: Option<Sender<ReprocessQueueMessage>>,
) -> Result<(), warp::Rejection> { ) -> Result<(), warp::Rejection> {
// Gossip validate and publish inclusion lists that can be immediately processed. // Gossip validate and publish inclusion lists that can be immediately processed.
let seen_timestamp = timestamp_now(); let seen_timestamp = timestamp_now();