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

Merge pull request #2 from cgrdavies/main

Browse Source 
Plumb Account Required for Yellowstone GRPC Subscription
This commit is contained in:
sgxiang
2025-07-24 19:24:38 +08:00
committed by GitHub
parent 7615102fd6 690b9751c3
commit a5269bb1ff
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/streaming/yellowstone_grpc.rs
+4 -1
View File
@@ -168,6 +168,7 @@ impl YellowstoneGrpc {
bot_wallet: Option<Pubkey>, bot_wallet: Option<Pubkey>,
account_include: Option<Vec<String>>, account_include: Option<Vec<String>>,
account_exclude: Option<Vec<String>>, account_exclude: Option<Vec<String>>,
account_required: Option<Vec<String>>,
callback: F, callback: F,
) -> AnyResult<()> ) -> AnyResult<()>
where where
@@ -182,10 +183,12 @@ impl YellowstoneGrpc {
.collect::<Vec<String>>(); .collect::<Vec<String>>();
let mut account_include = account_include.unwrap_or_default(); let mut account_include = account_include.unwrap_or_default();
let account_exclude = account_exclude.unwrap_or_default(); let account_exclude = account_exclude.unwrap_or_default();
let account_required = account_required.unwrap_or_default();
account_include.extend(protocol_accounts.clone()); account_include.extend(protocol_accounts.clone());
let transactions = let transactions =
self.get_subscribe_request_filter(account_include, account_exclude, vec![]); self.get_subscribe_request_filter(account_include, account_exclude, account_required);
// 订阅事件 // 订阅事件
let (mut subscribe_tx, mut stream) = self.subscribe_with_request(transactions).await?; let (mut subscribe_tx, mut stream) = self.subscribe_with_request(transactions).await?;