feat(rpc): v0.8.0 getMessagesStatus method

.db-versions.yml

@@ -1,5 +1,7 @@
-current_version: 1
+current_version: 2
 versions:
+  - version: 2
+    pr: 388
   - version: 1
     pr: 450
   - version: 0

CHANGELOG.md

@@ -2,6 +2,7 @@
 
 ## Next release
 
+- feat(rpc): added `getMessagesStatus` method
 - fix(primitives): limit legacy class sizes
 - fix(block_production): dynamic block closing now adds special address with prev block hash
 - fix(rpc): call, simulate, estimate rpcs executed on top of the block, not at the start of it

crates/madara/client/db/Cargo.toml

@@ -36,6 +36,7 @@ starknet-types-rpc = { workspace = true }
 starknet_api = { workspace = true }
 
 # Other
+alloy = { workspace = true }
 anyhow.workspace = true
 bincode = { workspace = true }
 librocksdb-sys = { workspace = true }

crates/madara/client/db/src/l1_db.rs

@@ -1,9 +1,10 @@
+use crate::error::DbError;
+use crate::{Column, DatabaseExt, MadaraBackend, MadaraStorageError};
+use alloy::primitives::TxHash;
 use rocksdb::{IteratorMode, WriteOptions};
 use serde::{Deserialize, Serialize};
 use starknet_api::core::Nonce;
-
-use crate::error::DbError;
-use crate::{Column, DatabaseExt, MadaraBackend, MadaraStorageError};
+use starknet_types_core::felt::Felt;
 
 type Result<T, E = MadaraStorageError> = std::result::Result<T, E>;
 
@@ -129,6 +130,34 @@ impl MadaraBackend {
         Ok(())
     }
 
+    pub fn get_l1_handler_tx_hashes(&self, l1_tx_hash: TxHash) -> Result<Vec<Felt>, DbError> {
+        let l1_l2_mappings_column = self.db.get_column(Column::L1MessagingHandlerTxHashes);
+        let l1_handler_tx_hashes = self
+            .db
+            .prefix_iterator_cf(&l1_l2_mappings_column, l1_tx_hash.as_slice())
+            .map(|kv_bytes| Ok(Felt::from_bytes_be_slice(&kv_bytes?.1)))
+            .collect::<Result<_, rocksdb::Error>>()?;
+        Ok(l1_handler_tx_hashes)
+    }
+
+    /// Store mapping from L1 transaction to L1 handler transaction (on the L2). A unique order
+    /// value is required to ensure the handler transactions are retreived in the correct order.
+    pub fn add_l1_handler_tx_hash_mapping(
+        &self,
+        l1_tx_hash: TxHash,
+        l1_handler_tx_hash: Felt,
+        order: u64,
+    ) -> Result<(), DbError> {
+        let l1_l2_mappings_column = self.db.get_column(Column::L1MessagingHandlerTxHashes);
+        let mut key = [0u8; 40];
+        key[..32].copy_from_slice(l1_tx_hash.as_slice());
+        key[32..].copy_from_slice(&order.to_be_bytes()); // BE is important for the lexographic sorting
+        let mut writeopts = WriteOptions::default();
+        writeopts.disable_wal(true);
+        self.db.put_cf_opt(&l1_l2_mappings_column, key, l1_handler_tx_hash.to_bytes_be(), &writeopts)?;
+        Ok(())
+    }
+
     /// Retrieve the latest L1 messaging [Nonce] if one is available, otherwise
     /// returns [None].
     pub fn get_l1_messaging_nonce_latest(&self) -> Result<Option<Nonce>, MadaraStorageError> {

crates/madara/client/db/src/lib.rs

@@ -149,6 +149,7 @@ pub enum Column {
 
     L1Messaging,
     L1MessagingNonce,
+    L1MessagingHandlerTxHashes,
 
     /// Devnet: stores the private keys for the devnet predeployed contracts
     Devnet,
@@ -196,6 +197,7 @@ impl Column {
             BonsaiClassesLog,
             L1Messaging,
             L1MessagingNonce,
+            L1MessagingHandlerTxHashes,
             PendingContractToClassHashes,
             PendingContractToNonces,
             PendingContractStorage,
@@ -232,6 +234,7 @@ impl Column {
             ContractStorage => "contract_storage",
             L1Messaging => "l1_messaging",
             L1MessagingNonce => "l1_messaging_nonce",
+            L1MessagingHandlerTxHashes => "l1_messaging_handler_tx_hashes",
             PendingContractToClassHashes => "pending_contract_to_class_hashes",
             PendingContractToNonces => "pending_contract_to_nonces",
             PendingContractStorage => "pending_contract_storage",

crates/madara/client/db/src/rocksdb_options.rs

@@ -2,6 +2,8 @@
 #![allow(non_upper_case_globals)] // allow KiB/MiB/GiB names
 
 use crate::{contract_db, Column};
+use alloy::primitives::private::alloy_rlp::MaxEncodedLenAssoc;
+use alloy::primitives::TxHash;
 use anyhow::{Context, Result};
 use rocksdb::{DBCompressionType, Env, Options, SliceTransform};
 
@@ -56,6 +58,9 @@ impl Column {
                     contract_db::CONTRACT_NONCES_PREFIX_EXTRACTOR,
                 ));
             }
+            Column::L1MessagingHandlerTxHashes => {
+                options.set_prefix_extractor(SliceTransform::create_fixed_prefix(TxHash::LEN));
+            }
             _ => {}
         }
 

crates/madara/client/eth/Cargo.toml

@@ -28,6 +28,7 @@ mp-transactions.workspace = true
 mp-utils.workspace = true
 
 # Starknet
+blockifier.workspace = true
 starknet-types-core.workspace = true
 starknet_api.workspace = true