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

chore: bump version to 1.1.4 and fix subscription filter keys

Browse Source
This commit is contained in:
ysq
2025-11-16 23:30:51 +08:00
parent 4b019e5e01
commit 329405e23f
4 changed files with 15 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/streaming/grpc/subscription.rs
+10 -10
View File
@@ -90,13 +90,13 @@ impl SubscriptionManager {
return None;
}
let mut accounts = HashMap::new();
for af in account_filter {
for (index, af) in account_filter.iter().enumerate() {
accounts.insert(
"".to_owned(),
format!("account_{}", index),
SubscribeRequestFilterAccounts {
account: af.account,
owner: af.owner,
filters: af.filters,
account: af.account.clone(),
owner: af.owner.clone(),
filters: af.filters.clone(),
nonempty_txn_signature: None,
},
);
@@ -114,16 +114,16 @@ impl SubscriptionManager {
return None;
}
let mut transactions = HashMap::new();
for tf in transaction_filter {
for (index, tf) in transaction_filter.iter().enumerate() {
transactions.insert(
"client".to_string(),
format!("transaction_{}", index),
SubscribeRequestFilterTransactions {
vote: Some(false),
failed: Some(false),
signature: None,
account_include: tf.account_include,
account_exclude: tf.account_exclude,
account_required: tf.account_required,
account_include: tf.account_include.clone(),
account_exclude: tf.account_exclude.clone(),
account_required: tf.account_required.clone(),
},
);
}