perf(katana-rpc): spawn blocking tasks

dojoengine · Jan 18, 2024 · d50bd68 · d50bd68
1 parent c1de18e
commit d50bd68
Show file tree

Hide file tree

Showing 6 changed files with 599 additions and 352 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/katana/core/src/sequencer.rs b/crates/katana/core/src/sequencer.rs
@@ -267,8 +267,9 @@ impl KatanaSequencer {
         self.backend.chain_id
     }
 
-    pub fn block_number(&self) -> BlockNumber {
-        BlockNumberProvider::latest_number(&self.backend.blockchain.provider()).unwrap()
+    pub fn block_number(&self) -> SequencerResult<BlockNumber> {
+        let num = BlockNumberProvider::latest_number(&self.backend.blockchain.provider())?;
+        Ok(num)
     }
 
     pub fn block_tx_count(&self, block_id: BlockIdOrTag) -> SequencerResult<Option<u64>> {
@@ -300,7 +301,7 @@ impl KatanaSequencer {
         Ok(count)
     }
 
-    pub async fn nonce_at(
+    pub fn nonce_at(
         &self,
         block_id: BlockIdOrTag,
         contract_address: ContractAddress,
@@ -352,7 +353,7 @@ impl KatanaSequencer {
         Ok(tx)
     }
 
-    pub async fn events(
+    pub fn events(
         &self,
         from_block: BlockIdOrTag,
         to_block: BlockIdOrTag,

diff --git a/crates/katana/rpc/Cargo.toml b/crates/katana/rpc/Cargo.toml
@@ -12,6 +12,7 @@ katana-primitives = { path = "../primitives" }
 katana-provider = { path = "../storage/provider" }
 katana-rpc-types = { path = "rpc-types" }
 katana-rpc-types-builder = { path = "rpc-types-builder" }
+katana-tasks = { path = "../tasks" }
 
 anyhow.workspace = true
 cairo-lang-starknet = "2.3.1"