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

track phoenix orderbook

This commit is contained in:
GroovieGermanikus 2024-05-07 17:34:58 +02:00
parent 1b5d4f458d
commit 087625de3f
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
examples/stream_token_accounts.rs
View File

@ -71,7 +71,8 @@ pub async fn main() {
Some(UpdateOneof::Account(update)) => { Some(UpdateOneof::Account(update)) => {
let account = update.account.unwrap(); let account = update.account.unwrap();
let account_pk = Pubkey::try_from(account.pubkey).unwrap(); let account_pk = Pubkey::try_from(account.pubkey).unwrap();
trace!("got account update (green)!!! {} - {:?} - {} bytes", let size = account.data.len();
info!("got account update (green)!!! {} - {:?} - {} bytes",
update.slot, account_pk, account.data.len()); update.slot, account_pk, account.data.len());
if ENABLE_TIMESTAMP_TAGGING { if ENABLE_TIMESTAMP_TAGGING {
@ -79,6 +80,7 @@ pub async fn main() {
info!("got account update: write_version={};timestamp_us={};slot={}", account.write_version, since_the_epoch.as_micros(), update.slot); info!("got account update: write_version={};timestamp_us={};slot={}", account.write_version, since_the_epoch.as_micros(), update.slot);
} }
match parse_token(&account.data, Some(6)) { match parse_token(&account.data, Some(6)) {
Ok(TokenAccountType::Account(account_ui)) => { Ok(TokenAccountType::Account(account_ui)) => {
// UiTokenAccount { // UiTokenAccount {
@ -110,6 +112,10 @@ pub async fn main() {
if account_ui.owner.starts_with("66fEFnKy") { if account_ui.owner.starts_with("66fEFnKy") {
info!("update balance for mint {} of owner {}: {}", mint, owner, amount); info!("update balance for mint {} of owner {}: {}", mint, owner, amount);
} }
// if pubkey.starts_with(b"JUP") {
// info!("update balance for mint {} of owner {}: {}", mint, owner, amount);
// }
token_account_by_ownermint.entry(owner) token_account_by_ownermint.entry(owner)
.or_insert_with(DashMap::new) .or_insert_with(DashMap::new)
.insert(mint, account_ui); .insert(mint, account_ui);
@ -167,9 +173,9 @@ pub fn token_accounts() -> SubscribeRequest {
accounts_subs.insert( accounts_subs.insert(
"client".to_string(), "client".to_string(),
SubscribeRequestFilterAccounts { SubscribeRequestFilterAccounts {
account: vec![], account: vec!["4DoNfFBfF7UokCC2FQzriy7yHK6DY6NVdYpuekQ5pRgg".to_string()],
owner: owner: vec![],
spl_token_ids().iter().map(|pubkey| pubkey.to_string()).collect(), // spl_token_ids().iter().map(|pubkey| pubkey.to_string()).collect(),
filters: vec![], filters: vec![],
}, },
); );