Adds contract_address to context

stakelens · Jun 28, 2024 · ecc19b3 · ecc19b3
1 parent ba36304
commit ecc19b3
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 3 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/ghost-crab/src/handler.rs b/ghost-crab/src/handler.rs
@@ -1,5 +1,6 @@
 use crate::indexer::TemplateManager;
 use crate::process_logs::ExecutionMode;
+use alloy::primitives::Address;
 use alloy::providers::RootProvider;
 use alloy::rpc::types::eth::Log;
 use alloy::transports::http::{Client, Http};
@@ -10,6 +11,7 @@ pub struct Context {
     pub log: Log,
     pub provider: RootProvider<Http<Client>>,
     pub templates: TemplateManager,
+    pub contract_address: Address
 }
 
 pub type HandleInstance = Arc<Box<(dyn Handler + Send + Sync)>>;

diff --git a/ghost-crab/src/prelude.rs b/ghost-crab/src/prelude.rs
@@ -18,3 +18,4 @@ pub use crate::indexer;
 pub use crate::indexer::Template;
 pub use crate::process_logs;
 pub use alloy::providers::Provider;
+pub use alloy::primitives::Address;
diff --git a/ghost-crab/src/process_logs.rs b/ghost-crab/src/process_logs.rs
@@ -50,7 +50,7 @@ pub async fn process_logs(
         );
 
         let filter = Filter::new()
-            .address(address)
+            .address(address.clone())
             .event(&event_signature)
             .from_block(current_block)
             .to_block(end_block);
@@ -70,6 +70,7 @@ pub async fn process_logs(
                                 log,
                                 provider,
                                 templates,
+                                contract_address: address
                             })
                             .await;
                     });
@@ -86,6 +87,7 @@ pub async fn process_logs(
                             log,
                             provider,
                             templates,
+                            contract_address: address
                         })
                         .await;
                 }