feat: metrics for the send_transaction wallet method

Cargo.toml

@@ -195,6 +195,10 @@ reth-network = { git = "https://github.com/paradigmxyz/reth.git", rev = "75dda1c
 reth-network-types = { git = "https://github.com/paradigmxyz/reth.git", rev = "75dda1c" }
 reth-chain-state = { git = "https://github.com/paradigmxyz/reth.git", rev = "75dda1c" }
 
+# metrics
+metrics = "0.23.0"
+metrics-derive = "0.1.0"
+
 # rpc
 jsonrpsee = "0.24"
 

crates/wallet/Cargo.toml

@@ -25,6 +25,9 @@ thiserror.workspace = true
 tracing.workspace = true
 tokio = { workspace = true, features = ["sync"] }
 
+metrics.workspace = true
+metrics-derive.workspace = true
+
 [dev-dependencies]
 serde_json.workspace = true
 jsonrpsee = { workspace = true, features = ["server", "client", "macros"] }

crates/wallet/src/lib.rs

@@ -26,6 +26,8 @@ use jsonrpsee::{
     core::{async_trait, RpcResult},
     proc_macros::rpc,
 };
+use metrics::Counter;
+use metrics_derive::Metrics;
 use reth_primitives::{revm_primitives::Bytecode, BlockId};
 use reth_rpc_eth_api::helpers::{EthCall, EthState, EthTransactions, FullEthApi, LoadFee};
 use reth_storage_api::{StateProvider, StateProviderFactory};
@@ -186,6 +188,7 @@ impl<Provider, Eth> OdysseyWallet<Provider, Eth> {
                 Capabilities { delegation: DelegationCapability { addresses: valid_designations } },
             )])),
             permit: Default::default(),
+            metrics: WalletMetrics::default(),
         };
         Self { inner: Arc::new(inner) }
     }
@@ -210,7 +213,15 @@ where
         trace!(target: "rpc::wallet", ?request, "Serving wallet_sendTransaction");
 
         // validate fields common to eip-7702 and eip-1559
-        validate_tx_request(&request)?;
+        match validate_tx_request(&request) {
+            Ok(_) => {
+                self.inner.metrics.valid_send_transaction_calls.increment(1);
+            }
+            Err(err) => {
+                self.inner.metrics.invalid_send_transaction_calls.increment(1);
+                return Err(err.into());
+            }
+        }
 
         let valid_delegations: &[Address] = self
             .inner
@@ -322,6 +333,8 @@ struct OdysseyWalletInner<Provider, Eth> {
     capabilities: WalletCapabilities,
     /// Used to guard tx signing
     permit: Mutex<()>,
+    /// Metrics for a `wallet`.
+    metrics: WalletMetrics,
 }
 
 fn validate_tx_request(request: &TransactionRequest) -> Result<(), OdysseyWalletError> {
@@ -343,6 +356,16 @@ fn validate_tx_request(request: &TransactionRequest) -> Result<(), OdysseyWallet
     Ok(())
 }
 
+/// Metrics for a `wallet`.
+#[derive(Metrics)]
+#[metrics(scope = "wallet")]
+struct WalletMetrics {
+    /// Number of invalid calls to `wallet_sendTransaction`
+    invalid_send_transaction_calls: Counter,
+    /// Number of valid calls to `wallet_sendTransaction`
+    valid_send_transaction_calls: Counter,
+}
+
 #[cfg(test)]
 mod tests {
     use crate::{