blockworks-foundation
/
solana-rpc-v2
mirror of https://github.com/blockworks-foundation/solana-rpc-v2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use nodeid for schedule and not vote account

This commit is contained in:
musitdev 2023-10-09 16:20:23 +02:00
parent 78008a6255
commit a5317d082c
2 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
stake_aggregate/src/leader_schedule.rs
View File

@ -369,7 +369,13 @@ fn calculate_epoch_stakes(
let delegated_stake = delegated_stakes
.get(&vote_account.pubkey)
.copied()
.unwrap_or_default();
.unwrap_or_else(|| {
log::info!(
"calculate_epoch_stakes stake with no vote account:{}",
vote_account.pubkey
);
Default::default()
});
(vote_account.pubkey, (delegated_stake, vote_account.clone()))
})
.collect();
@ -458,7 +464,9 @@ fn calculate_leader_schedule(
) -> HashMap<String, Vec<usize>> {
let mut stakes: Vec<(Pubkey, u64)> = stake_vote_map
.iter()
.filter_map(|(pk, (stake, _))| (*stake > 0).then_some((*pk, *stake)))
.filter_map(|(_, (stake, vote_account))| {
(*stake > 0).then_some((vote_account.vote_data.node_pubkey, *stake))
})
.collect();
let mut seed = [0u8; 32];

6
stake_aggregate/src/main.rs
View File

@ -2,7 +2,7 @@
//RUST_BACKTRACE=1 RUST_LOG=stake_aggregate=info cargo run --release --bin stake_aggregate &> stake_logs.txt &
/*
RPC calls;
curl http://localhost:3000 -X POST -H "Content-Type: application/json" -d '
curl http://localhost:3001 -X POST -H "Content-Type: application/json" -d '
{
"jsonrpc": "2.0",
"id" : 1,
@ -11,7 +11,7 @@
}
'
curl http://localhost:3000 -X POST -H "Content-Type: application/json" -d '
curl http://localhost:3001 -X POST -H "Content-Type: application/json" -d '
{
"jsonrpc": "2.0",
"id" : 1,
@ -21,7 +21,7 @@ curl http://localhost:3000 -X POST -H "Content-Type: application/json" -d '
' -o extract_stake_533_3.json
curl http://localhost:3000 -X POST -H "Content-Type: application/json" -d '
curl http://localhost:3001 -X POST -H "Content-Type: application/json" -d '
{
"jsonrpc": "2.0",
"id" : 1,