opt(torii): parallalize event processing

commit-id:b4b488fe
dojoengine · Sep 5, 2024 · 8a10542 · 8a10542
1 parent 37887c9
commit 8a10542
Show file tree

Hide file tree

Showing 13 changed files with 634 additions and 265 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -206,6 +206,7 @@ tower = "0.4.13"
 tower-http = "0.4.4"
 tracing = "0.1.34"
 tracing-subscriber = { version = "0.3.16", features = [ "env-filter", "json" ] }
+tracing-test = "0.1"
 url = { version = "2.4.0", features = [ "serde" ] }
 
 # server

diff --git a/bin/torii/src/main.rs b/bin/torii/src/main.rs
@@ -170,7 +170,7 @@ async fn main() -> anyhow::Result<()> {
     let provider: Arc<_> = JsonRpcClient::new(HttpTransport::new(args.rpc)).into();
 
     // Get world address
-    let world = WorldContractReader::new(args.world_address, &provider);
+    let world = WorldContractReader::new(args.world_address, Arc::clone(&provider));
 
     let db = Sql::new(pool.clone(), args.world_address).await?;
 
@@ -193,7 +193,7 @@ async fn main() -> anyhow::Result<()> {
     let mut engine = Engine::new(
         world,
         db.clone(),
-        &provider,
+        Arc::clone(&provider),
         processors,
         EngineConfig {
             start_block: args.start_block,
@@ -217,7 +217,7 @@ async fn main() -> anyhow::Result<()> {
 
     let mut libp2p_relay_server = torii_relay::server::Relay::new(
         db,
-        provider.clone(),
+        Arc::clone(&provider),
         args.relay_port,
         args.relay_webrtc_port,
         args.relay_websocket_port,

diff --git a/crates/torii/core/Cargo.toml b/crates/torii/core/Cargo.toml
@@ -38,6 +38,7 @@ thiserror.workspace = true
 tokio = { version = "1.32.0", features = [ "sync" ], default-features = true }
 tokio-stream = "0.1.11"
 tokio-util = "0.7.7"
+tracing-test.workspace = true
 tracing.workspace = true
 
 [dev-dependencies]