From a793a5e1757d94b7997549418856633e987720ef Mon Sep 17 00:00:00 2001
From: Enrique Ortiz <hi@enriqueortiz.dev>
Date: Thu, 23 Nov 2023 16:37:25 -0400
Subject: [PATCH 1/2] feat(): raw_request

---
 crates/providers/src/provider.rs | 54 ++++++++++++++++++++++++++++++--
 1 file changed, 52 insertions(+), 2 deletions(-)

diff --git a/crates/providers/src/provider.rs b/crates/providers/src/provider.rs
index 6aee89ac599..806076cca3a 100644
--- a/crates/providers/src/provider.rs
+++ b/crates/providers/src/provider.rs
@@ -13,7 +13,7 @@ use alloy_transport::{BoxTransport, Transport, TransportErrorKind, TransportResu
 use alloy_transport_http::Http;
 use auto_impl::auto_impl;
 use reqwest::Client;
-use serde::{Deserialize, Serialize};
+use serde::{Deserialize, Serialize, de::DeserializeOwned};
 use thiserror::Error;
 
 #[derive(Debug, Error, Serialize, Deserialize)]
@@ -238,6 +238,16 @@ pub trait TempProvider: Send + Sync {
     ) -> TransportResult<Vec<LocalizedTransactionTrace>>
     where
         Self: Sync;
+
+    async fn raw_request<P, R>(
+        &self,
+        method: &'static str,
+        params: P,
+    ) -> TransportResult<R>
+    where
+        P: Serialize + Send + Sync + Clone,
+        R: Serialize + DeserializeOwned + Send + Sync + Unpin + 'static,
+        Self: Sync;
 }
 
 impl<T: Transport + Clone + Send + Sync> Provider<T> {
@@ -663,6 +673,26 @@ impl<T: Transport + Clone + Send + Sync> TempProvider for Provider<T> {
         self.inner.prepare("trace_block", block).await
     }
 
+    /// Sends a raw request with the methods and params specified to the internal connection,
+    /// and returns the result.
+    async fn raw_request<P, R>(
+        &self,
+        method: &'static str,
+        params: P,
+    ) -> TransportResult<R>
+    where
+        P: Serialize + Send + Sync + Clone,
+        R: Serialize + DeserializeOwned + Send + Sync + Unpin + 'static,
+        Self: Sync
+    {
+        let res = async move {
+            let res: R = self.inner.prepare(method, &params).await?;
+            Ok(res)
+        }.await;
+
+        res
+    }
+
     #[cfg(feature = "anvil")]
     async fn set_code(&self, address: Address, code: &'static str) -> TransportResult<()>
     where
@@ -708,7 +738,7 @@ mod providers_test {
         utils,
     };
     use alloy_primitives::{address, b256, U256, U64};
-    use alloy_rpc_types::{BlockNumberOrTag, Filter};
+    use alloy_rpc_types::{BlockNumberOrTag, Filter, Block};
     use ethers_core::utils::Anvil;
 
     #[tokio::test]
@@ -719,6 +749,14 @@ mod providers_test {
         assert_eq!(0, num)
     }
 
+    #[tokio::test]
+    async fn gets_block_number_with_raw_req() {
+        let anvil = Anvil::new().spawn();
+        let provider = Provider::try_from(&anvil.endpoint()).unwrap();
+        let num: U64 = provider.raw_request("eth_blockNumber", ()).await.unwrap();
+        assert_eq!(0, num.to::<u64>())
+    }
+
     #[tokio::test]
     async fn gets_transaction_count() {
         let anvil = Anvil::new().spawn();
@@ -745,6 +783,18 @@ mod providers_test {
         assert_eq!(block.header.hash.unwrap(), hash);
     }
 
+    #[tokio::test]
+    async fn gets_block_by_hash_with_raw_req() {
+        let anvil = Anvil::new().spawn();
+        let provider = Provider::try_from(&anvil.endpoint()).unwrap();
+        let num = 0;
+        let tag: BlockNumberOrTag = num.into();
+        let block = provider.get_block_by_number(tag, true).await.unwrap().unwrap();
+        let hash = block.header.hash.unwrap();
+        let block: Block = provider.raw_request::<(alloy_primitives::FixedBytes<32>, bool), Block>("eth_getBlockByHash", (hash, true)).await.unwrap();
+        assert_eq!(block.header.hash.unwrap(), hash);
+    }
+
     #[tokio::test]
     async fn gets_block_by_number_full() {
         let anvil = Anvil::new().spawn();

From 50f86ff7716f2f75f345018f4073b1a1fb457b96 Mon Sep 17 00:00:00 2001
From: Enrique Ortiz <hi@enriqueortiz.dev>
Date: Thu, 23 Nov 2023 16:45:21 -0400
Subject: [PATCH 2/2] chore: remove unneeded async block

---
 crates/providers/src/provider.rs | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git a/crates/providers/src/provider.rs b/crates/providers/src/provider.rs
index 806076cca3a..8ab5ad2df65 100644
--- a/crates/providers/src/provider.rs
+++ b/crates/providers/src/provider.rs
@@ -685,12 +685,8 @@ impl<T: Transport + Clone + Send + Sync> TempProvider for Provider<T> {
         R: Serialize + DeserializeOwned + Send + Sync + Unpin + 'static,
         Self: Sync
     {
-        let res = async move {
-            let res: R = self.inner.prepare(method, &params).await?;
-            Ok(res)
-        }.await;
-
-        res
+        let res: R = self.inner.prepare(method, &params).await?;
+        Ok(res)
     }
 
     #[cfg(feature = "anvil")]