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

sort pubkeys

This commit is contained in:
Maximilian Schneider 2023-02-04 02:27:37 +09:00
parent 6287f1c344
commit 1c41e94e28
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
service-mango-crank/src/transaction_builder.rs
View File

@ -7,7 +7,7 @@ use solana_geyser_connector_lib::{
AccountWrite, SlotUpdate, AccountWrite, SlotUpdate,
}; };
use anchor_lang::{solana_program::pubkey, AccountDeserialize}; use anchor_lang::AccountDeserialize;
use log::*; use log::*;
use solana_sdk::{ use solana_sdk::{
account::{ReadableAccount, WritableAccount}, account::{ReadableAccount, WritableAccount},
@ -17,7 +17,7 @@ use solana_sdk::{
}; };
use std::{ use std::{
borrow::BorrowMut, borrow::BorrowMut,
collections::{HashMap, HashSet}, collections::{BTreeSet, HashMap, HashSet},
convert::TryFrom, convert::TryFrom,
str::FromStr, str::FromStr,
}; };
@ -112,7 +112,7 @@ pub fn init(
.unwrap(); .unwrap();
if !event_queue.empty() { if !event_queue.empty() {
let mango_accounts: HashSet<_> = event_queue let mango_accounts: BTreeSet<_> = event_queue
.iter() .iter()
.take(10) .take(10)
.flat_map(|e| { .flat_map(|e| {
@ -140,7 +140,6 @@ pub fn init(
}, },
None, None,
); );
ams.append( ams.append(
&mut mango_accounts &mut mango_accounts
.iter() .iter()
@ -156,7 +155,10 @@ pub fn init(
), ),
}; };
info!("mango perp evq={evq_b58} count={} limit=10", event_queue.iter().count()); info!(
"mango perp evq={evq_b58} count={} limit=10",
event_queue.iter().count()
);
instruction_sender.send(vec![ix]).await; instruction_sender.send(vec![ix]).await;
} }
} }
@ -195,7 +197,7 @@ pub fn init(
bytemuck::cast_slice::<u8, serum_dex::state::Event>(&rest[..end]); bytemuck::cast_slice::<u8, serum_dex::state::Event>(&rest[..end]);
let seq_num = header.seq_num; let seq_num = header.seq_num;
let oo_pks: HashSet<_> = (0..count) let oo_pks: BTreeSet<_> = (0..count)
.map(|i| { .map(|i| {
let offset = (seq_num - count + i) % events.len() as u64; let offset = (seq_num - count + i) % events.len() as u64;
let event: serum_dex::state::Event = events[offset as usize]; let event: serum_dex::state::Event = events[offset as usize];