-
Notifications
You must be signed in to change notification settings - Fork 195
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(torii): add support for erc1155 (#2955)
* feat(torii): add support for erc1155
* add erc1155 processors
* processors & uri
* uri token id
* erc1155 {id} substitution from spec
* fmt
* show in debug
* debug import
* token uri in warn
* cleanup and comment
* fmt
* fmt
* fix batch
* fix no token uri- Loading branch information
Showing
13 changed files
with
549 additions
and
372 deletions.
There are no files selected for viewing
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
113 changes: 113 additions & 0 deletions
113
crates/torii/indexer/src/processors/erc1155_transfer_batch.rs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,113 @@ | ||
| use anyhow::Error; | ||
| use async_trait::async_trait; | ||
| use cainome::cairo_serde::{CairoSerde, U256 as U256Cainome}; | ||
| use dojo_world::contracts::world::WorldContractReader; | ||
| use starknet::core::types::{Event, U256}; | ||
| use starknet::providers::Provider; | ||
| use torii_sqlite::Sql; | ||
| use tracing::debug; | ||
|
|
||
| use super::{EventProcessor, EventProcessorConfig}; | ||
| use crate::task_manager::{self, TaskId, TaskPriority}; | ||
|
|
||
| pub(crate) const LOG_TARGET: &str = "torii_indexer::processors::erc1155_transfer_batch"; | ||
|
|
||
| #[derive(Default, Debug)] | ||
| pub struct Erc1155TransferBatchProcessor; | ||
|
|
||
| #[async_trait] | ||
| impl<P> EventProcessor<P> for Erc1155TransferBatchProcessor | ||
| where | ||
| P: Provider + Send + Sync + std::fmt::Debug, | ||
| { | ||
| fn event_key(&self) -> String { | ||
| "TransferBatch".to_string() | ||
| } | ||
|
|
||
| fn validate(&self, event: &Event) -> bool { | ||
| // key: [hash(TransferBatch), operator, from, to] | ||
| // data: [ids_len, ids[0].low, ids[0].high, ..., values_len, values[0].low, values[0].high, | ||
| // ...] | ||
| event.keys.len() == 4 && !event.data.is_empty() | ||
| } | ||
|
|
||
| fn task_priority(&self) -> TaskPriority { | ||
| 1 | ||
| } | ||
|
|
||
| fn task_identifier(&self, _event: &Event) -> TaskId { | ||
| task_manager::TASK_ID_SEQUENTIAL | ||
| } | ||
|
|
||
| async fn process( | ||
| &self, | ||
| _world: &WorldContractReader<P>, | ||
| db: &mut Sql, | ||
| block_number: u64, | ||
| block_timestamp: u64, | ||
| event_id: &str, | ||
| event: &Event, | ||
| _config: &EventProcessorConfig, | ||
| ) -> Result<(), Error> { | ||
| let token_address = event.from_address; | ||
| let from = event.keys[2]; | ||
| let to = event.keys[3]; | ||
|
|
||
| // ERC1155 TransferBatch event data format: | ||
| // - ids_len: felt (first element) | ||
| // - ids: U256[] (each element stored as 2 felts: [low, high]) | ||
| // - values_len: felt | ||
| // - values: U256[] (each element stored as 2 felts: [low, high]) | ||
| // Spec reference: https://eips.ethereum.org/EIPS/eip-1155#transferbatch | ||
| let ids_len = event.data[0].try_into().unwrap_or(0u64) as usize; | ||
| let mut current_idx = 1; | ||
|
|
||
| // First pass: read all token IDs | ||
| let mut token_ids = Vec::with_capacity(ids_len); | ||
| for _ in 0..ids_len { | ||
| if current_idx + 1 >= event.data.len() { | ||
| break; | ||
| } | ||
| let token_id = U256Cainome::cairo_deserialize(&event.data, current_idx)?; | ||
| token_ids.push(U256::from_words(token_id.low, token_id.high)); | ||
| current_idx += 2; | ||
| } | ||
|
|
||
| // Move index to values array | ||
| let values_len = event.data[current_idx].try_into().unwrap_or(0u64) as usize; | ||
| current_idx += 1; | ||
|
|
||
| // Second pass: read and process amounts | ||
| for (idx, token_id) in token_ids.iter().enumerate() { | ||
| if idx >= values_len || current_idx + (idx * 2) + 1 >= event.data.len() { | ||
| break; | ||
| } | ||
|
|
||
| let amount = U256Cainome::cairo_deserialize(&event.data, current_idx + (idx * 2))?; | ||
| let amount = U256::from_words(amount.low, amount.high); | ||
|
|
||
| db.handle_nft_transfer( | ||
| token_address, | ||
| from, | ||
| to, | ||
| *token_id, | ||
| amount, | ||
| block_timestamp, | ||
| event_id, | ||
| block_number, | ||
| ) | ||
| .await?; | ||
|
|
||
| debug!( | ||
| target: LOG_TARGET, | ||
| from = ?from, | ||
| to = ?to, | ||
| token_id = ?token_id, | ||
| amount = ?amount, | ||
| "ERC1155 TransferBatch" | ||
| ); | ||
| } | ||
|
|
||
| Ok(()) | ||
| } | ||
| } |
76 changes: 76 additions & 0 deletions
76
crates/torii/indexer/src/processors/erc1155_transfer_single.rs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,76 @@ | ||
| use anyhow::Error; | ||
| use async_trait::async_trait; | ||
| use cainome::cairo_serde::{CairoSerde, U256 as U256Cainome}; | ||
| use dojo_world::contracts::world::WorldContractReader; | ||
| use starknet::core::types::{Event, U256}; | ||
| use starknet::providers::Provider; | ||
| use torii_sqlite::Sql; | ||
| use tracing::debug; | ||
|
|
||
| use super::{EventProcessor, EventProcessorConfig}; | ||
| use crate::task_manager::{self, TaskId, TaskPriority}; | ||
|
|
||
| pub(crate) const LOG_TARGET: &str = "torii_indexer::processors::erc1155_transfer_single"; | ||
|
|
||
| #[derive(Default, Debug)] | ||
| pub struct Erc1155TransferSingleProcessor; | ||
|
|
||
| #[async_trait] | ||
| impl<P> EventProcessor<P> for Erc1155TransferSingleProcessor | ||
| where | ||
| P: Provider + Send + Sync + std::fmt::Debug, | ||
| { | ||
| fn event_key(&self) -> String { | ||
| "TransferSingle".to_string() | ||
| } | ||
|
|
||
| fn validate(&self, event: &Event) -> bool { | ||
| // key: [hash(TransferSingle), operator, from, to] | ||
| // data: [id.low, id.high, value.low, value.high] | ||
| event.keys.len() == 4 && event.data.len() == 4 | ||
| } | ||
|
|
||
| fn task_priority(&self) -> TaskPriority { | ||
| 1 | ||
| } | ||
|
|
||
| fn task_identifier(&self, _event: &Event) -> TaskId { | ||
| task_manager::TASK_ID_SEQUENTIAL | ||
| } | ||
|
|
||
| async fn process( | ||
| &self, | ||
| _world: &WorldContractReader<P>, | ||
| db: &mut Sql, | ||
| block_number: u64, | ||
| block_timestamp: u64, | ||
| event_id: &str, | ||
| event: &Event, | ||
| _config: &EventProcessorConfig, | ||
| ) -> Result<(), Error> { | ||
| let token_address = event.from_address; | ||
| let from = event.keys[2]; | ||
| let to = event.keys[3]; | ||
|
|
||
| let token_id = U256Cainome::cairo_deserialize(&event.data, 0)?; | ||
| let token_id = U256::from_words(token_id.low, token_id.high); | ||
|
|
||
| let amount = U256Cainome::cairo_deserialize(&event.data, 2)?; | ||
| let amount = U256::from_words(amount.low, amount.high); | ||
|
|
||
| db.handle_nft_transfer( | ||
| token_address, | ||
| from, | ||
| to, | ||
| token_id, | ||
| amount, | ||
| block_timestamp, | ||
| event_id, | ||
| block_number, | ||
| ) | ||
| .await?; | ||
| debug!(target: LOG_TARGET, from = ?from, to = ?to, token_id = ?token_id, amount = ?amount, "ERC1155 TransferSingle"); | ||
|
|
||
| Ok(()) | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2 changes: 2 additions & 0 deletions
2
crates/torii/migrations/20250212025607_transfers_event_id.sql
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,2 @@ | ||
| ALTER TABLE token_transfers | ||
| ADD COLUMN event_id TEXT; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.