refactor(torii-indexer): add token contract address to task identifier (

#2985)
dojoengine · Feb 5, 2025 · b751c50 · b751c50
1 parent 1d2381c
commit b751c50
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git a/crates/torii/indexer/src/processors/erc20_legacy_transfer.rs b/crates/torii/indexer/src/processors/erc20_legacy_transfer.rs
@@ -43,8 +43,8 @@ where
 
     fn task_identifier(&self, event: &Event) -> TaskId {
         let mut hasher = DefaultHasher::new();
-        // Hash the event key (Transfer)
-        event.keys[0].hash(&mut hasher);
+        // Hash the contract address
+        event.from_address.hash(&mut hasher);
 
         // Take the max of from/to addresses to get a canonical representation
         // This ensures transfers between the same pair of addresses are grouped together

diff --git a/crates/torii/indexer/src/processors/erc20_transfer.rs b/crates/torii/indexer/src/processors/erc20_transfer.rs
@@ -43,8 +43,8 @@ where
 
     fn task_identifier(&self, event: &Event) -> TaskId {
         let mut hasher = DefaultHasher::new();
-        // Hash the event key (Transfer)
-        event.keys[0].hash(&mut hasher);
+        // Hash the contract address
+        event.from_address.hash(&mut hasher);
 
         // Take the max of from/to addresses to get a canonical representation
         // This ensures transfers between the same pair of addresses are grouped together

diff --git a/crates/torii/indexer/src/processors/erc721_legacy_transfer.rs b/crates/torii/indexer/src/processors/erc721_legacy_transfer.rs
@@ -43,8 +43,8 @@ where
 
     fn task_identifier(&self, event: &Event) -> TaskId {
         let mut hasher = DefaultHasher::new();
-        // Hash the event key (Transfer)
-        event.keys[0].hash(&mut hasher);
+        // Hash the contract address
+        event.from_address.hash(&mut hasher);
 
         // Take the max of from/to addresses to get a canonical representation
         // This ensures transfers between the same pair of addresses are grouped together

diff --git a/crates/torii/indexer/src/processors/erc721_transfer.rs b/crates/torii/indexer/src/processors/erc721_transfer.rs
@@ -43,8 +43,8 @@ where
 
     fn task_identifier(&self, event: &Event) -> TaskId {
         let mut hasher = DefaultHasher::new();
-        // Hash the event key (Transfer)
-        event.keys[0].hash(&mut hasher);
+        // Hash the contract address
+        event.from_address.hash(&mut hasher);
 
         // Take the max of from/to addresses to get a canonical representation
         // This ensures transfers between the same pair of addresses are grouped together