gavindiaz/solana-streamer
1
0
Fork 0
mirror of https://github.com/0xfnzero/solana-streamer.git synced 2026-08-17 10:58:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: upgrade to v0.4.4

Browse Source
This commit is contained in:
ysq
2025-09-10 10:50:33 +08:00
parent 0c07c4d9ee
commit e3b763f0ca
3 changed files with 37 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/streaming/event_parser/core/account_event_parser.rs
+34 -25
View File
@@ -288,32 +288,41 @@ impl AccountEventParser {
) -> Option<Box<dyn UnifiedEvent>> {
use solana_program::program_pack::Pack;
use spl_token::state::Mint;
if let Ok(mint) = Mint::unpack_from_slice(&account.data) {
let mut event = TokenInfoEvent {
metadata,
pubkey: account.pubkey,
executable: account.executable,
lamports: account.lamports,
owner: account.owner,
rent_epoch: account.rent_epoch,
supply: mint.supply,
decimals: mint.decimals,
};
event.set_handle_us(elapsed_micros_since(account.recv_us));
return Some(Box::new(event));
match Mint::unpack_from_slice(&account.data) {
Ok(mint) => {
let mut event = TokenInfoEvent {
metadata,
pubkey: account.pubkey,
executable: account.executable,
lamports: account.lamports,
owner: account.owner,
rent_epoch: account.rent_epoch,
supply: mint.supply,
decimals: mint.decimals,
};
event.set_handle_us(elapsed_micros_since(account.recv_us));
return Some(Box::new(event));
}
Err(_) => {
let mut event = TokenAccountEvent {
metadata,
pubkey: account.pubkey,
executable: account.executable,
lamports: account.lamports,
owner: account.owner,
rent_epoch: account.rent_epoch,
amount: None,
};
match Account::unpack(&account.data) {
Ok(info) => {
event.amount = Some(info.amount);
}
Err(_) => {}
}
event.set_handle_us(elapsed_micros_since(account.recv_us));
return Some(Box::new(event));
}
}
let info = Account::unpack(&account.data);
let mut event = TokenAccountEvent {
metadata,
pubkey: account.pubkey,
executable: account.executable,
lamports: account.lamports,
owner: account.owner,
rent_epoch: account.rent_epoch,
amount: if let Ok(info) = info { Some(info.amount) } else { None },
};
event.set_handle_us(elapsed_micros_since(account.recv_us));
return Some(Box::new(event));
}
pub fn parse_nonce_account_event(