From 194c428e44886ced17a5b07eb843c5108654631b Mon Sep 17 00:00:00 2001
From: Corto <adrena.corto@gmail.com>
Date: Tue, 8 Oct 2024 19:23:08 +0800
Subject: [PATCH] Logs

---
 plugin/src/plugin.rs | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/plugin/src/plugin.rs b/plugin/src/plugin.rs
index 26cf45db..f1203ba7 100644
--- a/plugin/src/plugin.rs
+++ b/plugin/src/plugin.rs
@@ -53,7 +53,7 @@ impl GeyserPlugin for SablierPlugin {
             env!("GEYSER_INTERFACE_VERSION"),
             env!("RUSTC_VERSION")
         );
-        info!("Loading snapshot... 8----");
+        info!("Loading snapshot...");
         let config = PluginConfig::read_from(config_file)?;
         *self = SablierPlugin::new_from_config(config);
 
@@ -83,6 +83,7 @@ impl GeyserPlugin for SablierPlugin {
                     .get_program_accounts_with_config(&program_id, config)
                     .await
                     .map_err(PluginError::from)?;
+                info!("  - Fetched {} Thread PDAs", thread_pdas.len());
 
                 let versioned_thread_pdas: Vec<(Pubkey, VersionedThread)> = thread_pdas
                     .into_iter()
@@ -92,8 +93,9 @@ impl GeyserPlugin for SablierPlugin {
                             .map(|thread| (pubkey, thread))
                     })
                     .collect();
+                info!("  - after deserialization: {} Thread PDAs left", versioned_thread_pdas.len());
 
-                info!("Add fetched Thread pdas to observers...");
+                info!("Adding {} fetched Thread pdas to observers...", versioned_thread_pdas.len());
                 for (pubkey, thread) in versioned_thread_pdas {
                     observers
                         .thread