53 lines
1.8 KiB
Rust
53 lines
1.8 KiB
Rust
use crate::{
|
|
bank::{Bank, TransactionResults},
|
|
genesis_utils::{self, GenesisConfigInfo, ValidatorVoteKeypairs},
|
|
vote_sender_types::ReplayVoteSender,
|
|
};
|
|
use solana_sdk::{pubkey::Pubkey, signature::Signer, transaction::Transaction};
|
|
use solana_vote_program::vote_transaction;
|
|
|
|
pub fn setup_bank_and_vote_pubkeys(num_vote_accounts: usize, stake: u64) -> (Bank, Vec<Pubkey>) {
|
|
// Create some voters at genesis
|
|
let validator_voting_keypairs: Vec<_> = (0..num_vote_accounts)
|
|
.map(|_| ValidatorVoteKeypairs::new_rand())
|
|
.collect();
|
|
|
|
let vote_pubkeys: Vec<_> = validator_voting_keypairs
|
|
.iter()
|
|
.map(|k| k.vote_keypair.pubkey())
|
|
.collect();
|
|
let GenesisConfigInfo { genesis_config, .. } =
|
|
genesis_utils::create_genesis_config_with_vote_accounts(
|
|
10_000,
|
|
&validator_voting_keypairs,
|
|
vec![stake; validator_voting_keypairs.len()],
|
|
);
|
|
let bank = Bank::new(&genesis_config);
|
|
(bank, vote_pubkeys)
|
|
}
|
|
|
|
pub fn find_and_send_votes(
|
|
txs: &[Transaction],
|
|
tx_results: &TransactionResults,
|
|
vote_sender: Option<&ReplayVoteSender>,
|
|
) {
|
|
let TransactionResults {
|
|
execution_results,
|
|
overwritten_vote_accounts,
|
|
..
|
|
} = tx_results;
|
|
if let Some(vote_sender) = vote_sender {
|
|
for old_account in overwritten_vote_accounts {
|
|
assert!(execution_results[old_account.transaction_result_index]
|
|
.0
|
|
.is_ok());
|
|
let transaction = &txs[old_account.transaction_index];
|
|
if let Some(parsed_vote) = vote_transaction::parse_vote_transaction(transaction) {
|
|
if parsed_vote.1.slots.last().is_some() {
|
|
let _ = vote_sender.send(parsed_vote);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|