Sasedev/khadhroony-solana-project
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v0.2.7-pre.009-fix.001

Browse Source
This commit is contained in:
SinuS von SifriduS
2026-08-22 23:14:32 +02:00
parent d17161234a
commit f0f444bc86
4 changed files with 92 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crates/ksp-onchain-transport-lib/src/ws_accounts.rs
View File

@@ -1,5 +1,5 @@
// file: crates/ksp-onchain-transport-lib/src/ws_accounts.rs
// version: 1
// version: 2
const MAX_PROGRAM_SUBSCRIBE_FILTERS: usize = 4;
const MAX_PROGRAM_SUBSCRIBE_RAW_MEMCMP_BYTES: usize = 128;
@@ -163,7 +163,9 @@ impl crate::WsSession {
{
params.push(config.to_json_value());
}
return self.subscribe_typed(crate::WsSubscriptionKind::Account, params, |value| decode_account_notification("accountSubscribe", value)).await;
return self
.subscribe_typed(crate::WsSubscriptionKind::Account, params, |value| return decode_account_notification("accountSubscribe", value))
.await;
}
/// Subscribes to account changes owned by one Solana program through standard `programSubscribe`.
@@ -184,7 +186,9 @@ impl crate::WsSession {
{
params.push(config.to_json_value());
}
return self.subscribe_typed(crate::WsSubscriptionKind::Program, params, |value| decode_program_notification("programSubscribe", value)).await;
return self
.subscribe_typed(crate::WsSubscriptionKind::Program, params, |value| return decode_program_notification("programSubscribe", value))
.await;
}
}

4
crates/ksp-onchain-transport-lib/src/ws_transactions.rs
View File

@@ -1,5 +1,5 @@
// file: crates/ksp-onchain-transport-lib/src/ws_transactions.rs
// version: 1
// version: 2
/// Filter accepted by the standard Solana `logsSubscribe` WebSocket method.
#[derive(Clone, Debug, Eq, PartialEq)]
@@ -63,7 +63,7 @@ impl crate::WsSession {
{
params.push(config.to_json_value());
}
return self.subscribe_typed(crate::WsSubscriptionKind::Logs, params, |value| decode_logs_notification("logsSubscribe", value)).await;
return self.subscribe_typed(crate::WsSubscriptionKind::Logs, params, |value| return decode_logs_notification("logsSubscribe", value)).await;
}
}