feat(torii-indexer): add option for strict model reader block (#2954)

* feat(torii-indexer): add option for strict model reader block

* event processor config

crates/torii/cli/src/options.rs

@@ -170,6 +170,16 @@ pub struct IndexingOptions {
     )]
     #[serde(default)]
     pub world_block: u64,
+
+    /// Whether or not to read models from the block number they were registered in.
+    /// If false, models will be read from the latest block.
+    #[arg(
+        long = "indexing.strict_model_reader",
+        default_value_t = false,
+        help = "Whether or not to read models from the block number they were registered in."
+    )]
+    #[serde(default)]
+    pub strict_model_reader: bool,
 }
 
 impl Default for IndexingOptions {
@@ -184,6 +194,7 @@ impl Default for IndexingOptions {
             max_concurrent_tasks: DEFAULT_MAX_CONCURRENT_TASKS,
             namespaces: vec![],
             world_block: 0,
+            strict_model_reader: false,
         }
     }
 }
@@ -226,6 +237,10 @@ impl IndexingOptions {
             if self.world_block == 0 {
                 self.world_block = other.world_block;
             }
+
+            if !self.strict_model_reader {
+                self.strict_model_reader = other.strict_model_reader;
+            }
         }
     }
 }

crates/torii/indexer/src/processors/mod.rs

@@ -30,6 +30,7 @@ pub mod upgrade_model;
 pub struct EventProcessorConfig {
     pub historical_events: HashSet<String>,
     pub namespaces: HashSet<String>,
+    pub strict_model_reader: bool,
 }
 
 impl EventProcessorConfig {

crates/torii/indexer/src/processors/register_event.rs

@@ -5,7 +5,7 @@ use async_trait::async_trait;
 use dojo_world::contracts::abigen::world::Event as WorldEvent;
 use dojo_world::contracts::model::ModelReader;
 use dojo_world::contracts::world::WorldContractReader;
-use starknet::core::types::Event;
+use starknet::core::types::{BlockId, Event};
 use starknet::providers::Provider;
 use torii_sqlite::Sql;
 use tracing::{debug, info};
@@ -47,7 +47,7 @@ where
         &self,
         world: &WorldContractReader<P>,
         db: &mut Sql,
-        _block_number: u64,
+        block_number: u64,
         block_timestamp: u64,
         _event_id: &str,
         event: &Event,
@@ -79,7 +79,11 @@ where
 
         // Called model here by language, but it's an event. Torii rework will make clear
         // distinction.
-        let model = world.model_reader(&namespace, &name).await?;
+        let model = if config.strict_model_reader {
+            world.model_reader_with_block(&namespace, &name, BlockId::Number(block_number)).await?
+        } else {
+            world.model_reader(&namespace, &name).await?
+        };
         let schema = model.schema().await?;
         let layout = model.layout().await?;
 

crates/torii/indexer/src/processors/register_model.rs

@@ -5,7 +5,7 @@ use async_trait::async_trait;
 use dojo_world::contracts::abigen::world::Event as WorldEvent;
 use dojo_world::contracts::model::ModelReader;
 use dojo_world::contracts::world::WorldContractReader;
-use starknet::core::types::Event;
+use starknet::core::types::{BlockId, Event};
 use starknet::providers::Provider;
 use torii_sqlite::Sql;
 use tracing::{debug, info};
@@ -47,7 +47,7 @@ where
         &self,
         world: &WorldContractReader<P>,
         db: &mut Sql,
-        _block_number: u64,
+        block_number: u64,
         block_timestamp: u64,
         _event_id: &str,
         event: &Event,
@@ -77,7 +77,11 @@ where
             return Ok(());
         }
 
-        let model = world.model_reader(&namespace, &name).await?;
+        let model = if config.strict_model_reader {
+            world.model_reader_with_block(&namespace, &name, BlockId::Number(block_number)).await?
+        } else {
+            world.model_reader(&namespace, &name).await?
+        };
         let schema = model.schema().await?;
         let layout = model.layout().await?;
 

crates/torii/indexer/src/processors/upgrade_event.rs

@@ -5,7 +5,7 @@ use async_trait::async_trait;
 use dojo_world::contracts::abigen::world::Event as WorldEvent;
 use dojo_world::contracts::model::ModelReader;
 use dojo_world::contracts::world::WorldContractReader;
-use starknet::core::types::Event;
+use starknet::core::types::{BlockId, Event};
 use starknet::providers::Provider;
 use torii_sqlite::Sql;
 use tracing::{debug, info};
@@ -47,11 +47,11 @@ where
         &self,
         world: &WorldContractReader<P>,
         db: &mut Sql,
-        _block_number: u64,
+        block_number: u64,
         block_timestamp: u64,
         _event_id: &str,
         event: &Event,
-        _config: &EventProcessorConfig,
+        config: &EventProcessorConfig,
     ) -> Result<(), Error> {
         // Torii version is coupled to the world version, so we can expect the event to be well
         // formed.
@@ -88,7 +88,11 @@ where
         let namespace = model.namespace;
         let prev_schema = model.schema;
 
-        let model = world.model_reader(&namespace, &name).await?;
+        let model = if config.strict_model_reader {
+            world.model_reader_with_block(&namespace, &name, BlockId::Number(block_number)).await?
+        } else {
+            world.model_reader(&namespace, &name).await?
+        };
         let new_schema = model.schema().await?;
         let schema_diff = new_schema.diff(&prev_schema);
         // No changes to the schema. This can happen if torii is re-run with a fresh database.

crates/torii/indexer/src/processors/upgrade_model.rs

@@ -5,7 +5,7 @@ use async_trait::async_trait;
 use dojo_world::contracts::abigen::world::Event as WorldEvent;
 use dojo_world::contracts::model::ModelReader;
 use dojo_world::contracts::world::WorldContractReader;
-use starknet::core::types::Event;
+use starknet::core::types::{BlockId, Event};
 use starknet::providers::Provider;
 use torii_sqlite::Sql;
 use tracing::{debug, info};
@@ -47,11 +47,11 @@ where
         &self,
         world: &WorldContractReader<P>,
         db: &mut Sql,
-        _block_number: u64,
+        block_number: u64,
         block_timestamp: u64,
         _event_id: &str,
         event: &Event,
-        _config: &EventProcessorConfig,
+        config: &EventProcessorConfig,
     ) -> Result<(), Error> {
         // Torii version is coupled to the world version, so we can expect the event to be well
         // formed.
@@ -86,7 +86,11 @@ where
         let namespace = model.namespace;
         let prev_schema = model.schema;
 
-        let model = world.model_reader(&namespace, &name).await?;
+        let model = if config.strict_model_reader {
+            world.model_reader_with_block(&namespace, &name, BlockId::Number(block_number)).await?
+        } else {
+            world.model_reader(&namespace, &name).await?
+        };
         let new_schema = model.schema().await?;
         let schema_diff = new_schema.diff(&prev_schema);
         // No changes to the schema. This can happen if torii is re-run with a fresh database.

crates/torii/runner/src/lib.rs

@@ -177,6 +177,7 @@ impl Runner {
                 polling_interval: Duration::from_millis(self.args.indexing.polling_interval),
                 flags,
                 event_processor_config: EventProcessorConfig {
+                    strict_model_reader: self.args.indexing.strict_model_reader,
                     historical_events: self.args.events.historical.into_iter().collect(),
                     namespaces: self.args.indexing.namespaces.into_iter().collect(),
                 },