Skip to content

Commit

Permalink
Update logs
Browse files Browse the repository at this point in the history
  • Loading branch information
Adrena-Corto committed Oct 9, 2024
1 parent bacf5ae commit e366982
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions plugin/src/plugin.rs
Original file line number Diff line number Diff line change
Expand Up @@ -63,13 +63,12 @@ impl GeyserPlugin for SablierPlugin {
let observers = self.inner.observers.clone();
self.inner.clone().spawn(|inner| async move {
info!("Fetch existing Thread pdas...");
let rpc_client = &inner.executors.client;
let client = inner.executors.client.clone();
let program_id = sablier_thread_program::ID;

// Filter to retrieve only Thread PDAs
let account_type_filter =
RpcFilterType::Memcmp(Memcmp::new_base58_encoded(0, &Thread::discriminator()));
info!("here");
let config = RpcProgramAccountsConfig {
filters: Some([vec![account_type_filter]].concat()),
account_config: RpcAccountInfoConfig {
Expand All @@ -78,9 +77,9 @@ impl GeyserPlugin for SablierPlugin {
},
..RpcProgramAccountsConfig::default()
};
info!("here2");

// Fetch Thread pdas
let thread_pdas = rpc_client
let thread_pdas = client
.get_program_accounts_with_config(&program_id, config)
.await
.map_err(|err| {
Expand Down

0 comments on commit e366982

Please sign in to comment.