feat(ethexe-rpc): Metrics middleware for RPC methods

Cargo.toml

@@ -228,6 +228,7 @@ tap = "1.0.1"
 ntest = "0.9.3"
 dashmap = "5.5.3"
 delegate = "0.13.5"
+bon = "3.9.1"
 
 # metrics
 metrics = "0.24.0"

core/src/rpc.rs

@@ -20,11 +20,14 @@
 
 use alloc::vec::Vec;
 use gear_core_errors::ReplyCode;
+use gprimitives::H256;
 use parity_scale_codec::{Decode, Encode};
 use scale_decode::DecodeAsType;
 use scale_encode::EncodeAsType;
 use scale_info::TypeInfo;
 
+use crate::utils;
+
 /// Pre-calculated gas consumption estimate for a message.
 ///
 /// Intended to be used as a result in `calculateGasFor*` RPC calls.
@@ -65,6 +68,25 @@ pub struct ReplyInfo {
     pub code: ReplyCode,
 }
 
+impl ReplyInfo {
+    /// Calculates `blake2b` hash from [`ReplyInfo`].
+    pub fn to_hash(&self) -> H256 {
+        let ReplyInfo {
+            payload,
+            value,
+            code,
+        } = self;
+
+        let bytes = [
+            payload.as_ref(),
+            value.to_be_bytes().as_ref(),
+            code.to_bytes().as_ref(),
+        ]
+        .concat();
+        utils::hash(&bytes).into()
+    }
+}
+
 /// Serializer and deserializer for ReplyCode as 0x-prefixed hex string.
 #[cfg(feature = "std")]
 pub(crate) mod serialize_reply_code {

ethexe/common/Cargo.toml

@@ -28,6 +28,7 @@ gsigner = { workspace = true, default-features = false, features = [
 sha3.workspace = true
 k256 = { version = "0.13.4", features = ["ecdsa"], default-features = false }
 nonempty.workspace = true
+thiserror.workspace = true
 
 # mock deps
 itertools = { workspace = true, optional = true }

ethexe/common/src/db.rs

@@ -23,7 +23,7 @@ use crate::{
     Schedule, SimpleBlockData, ValidatorsVec,
     events::BlockEvent,
     gear::StateTransition,
-    injected::{InjectedTransaction, SignedInjectedTransaction},
+    injected::{InjectedTransaction, Promise, SignedCompactPromise, SignedInjectedTransaction},
 };
 use alloc::{
     collections::{BTreeSet, VecDeque},
@@ -133,11 +133,21 @@ pub trait InjectedStorageRO {
         &self,
         hash: HashOf<InjectedTransaction>,
     ) -> Option<SignedInjectedTransaction>;
+
+    /// Returns the promise by its transaction hash.
+    fn promise(&self, hash: HashOf<InjectedTransaction>) -> Option<Promise>;
+
+    /// Returns the compact promise by its transaction hash.
+    fn compact_promise(&self, hash: HashOf<InjectedTransaction>) -> Option<SignedCompactPromise>;
 }
 
 #[auto_impl::auto_impl(&)]
 pub trait InjectedStorageRW: InjectedStorageRO {
     fn set_injected_transaction(&self, tx: SignedInjectedTransaction);
+
+    fn set_promise(&self, promise: &Promise);
+
+    fn set_compact_promise(&self, promise: &SignedCompactPromise);
 }
 
 #[derive(Debug, Clone, Default, Encode, Decode, TypeInfo, PartialEq, Eq, Hash)]