feat: add back reqwest and hyper features

Author: leruaa

Cargo.toml

@@ -12,6 +12,7 @@ description = """
 Easily send transaction bundles using Alloy.
 """
 
+
 [dependencies]
 alloy = { version = "1.0.30", features = [
     "rpc",
@@ -24,7 +25,8 @@ alloy = { version = "1.0.30", features = [
     "transports",
     "transport-http",
     "signers",
-] }
+], default-features = false }
+cfg-if = "1.0.3"
 futures = "0.3"
 pin-project = "1.1"
 url = "2.5"
@@ -41,6 +43,11 @@ alloy = { version = "1.0.30", features = [
     "signer-local",
 ] }
 
+[features]
+default = ["reqwest"]
+reqwest = ["alloy/reqwest"]
+hyper = ["alloy/hyper"]
+
 [package.metadata.docs.rs]
 cargo-args = ["-Zunstable-options", "-Zrustdoc-scrape-examples"]
 

src/eth/broadcastable_call.rs

@@ -3,14 +3,16 @@ use std::{fmt::Debug, future::IntoFuture, marker::PhantomData, pin::Pin};
 use alloy::{
     providers::ext::MevBuilder,
     rpc::{
-        client::{RpcCall, RpcClient},
+        client::RpcCall,
         json_rpc::{Request, RpcObject},
     },
     transports::{BoxFuture, TransportResult},
 };
 use futures::{future::join_all, Future, FutureExt};
 use pin_project::pin_project;
 
+use crate::utils::build_rpc_client;
+
 use super::Endpoints;
 
 /// Allows to broadcast a request to many RPC endpoints.
@@ -31,7 +33,7 @@ where
         let calls = endpoints
             .iter()
             .map(|e| {
-                let client = RpcClient::new_http(e.url.clone());
+                let client = build_rpc_client(e.url.clone());
                 let rpc_call = RpcCall::new(request.clone(), client.transport().clone());
                 let mut mev = MevBuilder::new_rpc(rpc_call);
                 if let Some(signer) = &e.signer {

src/lib.rs

@@ -16,3 +16,5 @@ pub use eth::{
 
 mod mev_share;
 pub use mev_share::{MevShareBundleBuilder, MevShareProviderExt};
+
+mod utils;

src/mev_share/provider_ext.rs

@@ -1,16 +1,16 @@
 use alloy::{
     network::Network,
     providers::{ext::MevBuilder, Provider},
-    rpc::{
-        client::RpcClient,
-        types::mev::{EthBundleHash, MevSendBundle, SimBundleOverrides, SimBundleResponse},
-    },
+    rpc::types::mev::{EthBundleHash, MevSendBundle, SimBundleOverrides, SimBundleResponse},
     signers::Signer,
     transports::TransportResult,
 };
 use async_trait::async_trait;
 
-use crate::mev_share::{MevShareBundleBuilder, FLASHBOTS_RELAY_RPC_URL};
+use crate::{
+    mev_share::{MevShareBundleBuilder, FLASHBOTS_RELAY_RPC_URL},
+    utils::build_rpc_client,
+};
 
 /// Extension trait for sending and simulate MEV-Share bundles.
 #[async_trait]
@@ -62,7 +62,7 @@ where
     where
         S: Signer + Clone + Send + Sync + 'static,
     {
-        let client = RpcClient::new_http(FLASHBOTS_RELAY_RPC_URL.parse().unwrap());
+        let client = build_rpc_client(FLASHBOTS_RELAY_RPC_URL.parse().unwrap());
         let request = client.request("mev_sendBundle", (bundle,));
 
         MevBuilder::new_rpc(request).with_auth(signer).await
@@ -77,7 +77,7 @@ where
     where
         S: Signer + Clone + Send + Sync + 'static,
     {
-        let client = RpcClient::new_http(FLASHBOTS_RELAY_RPC_URL.parse().unwrap());
+        let client = build_rpc_client(FLASHBOTS_RELAY_RPC_URL.parse().unwrap());
         let request = client.request("mev_simBundle", (bundle, sim_overrides));
 
         MevBuilder::new_rpc(request).with_auth(signer).await

src/utils.rs

@@ -0,0 +1,14 @@
+use alloy::rpc::client::RpcClient;
+use url::Url;
+
+pub(crate) fn build_rpc_client(url: Url) -> RpcClient {
+    cfg_if::cfg_if! {
+        if #[cfg(feature = "reqwest")] {
+            RpcClient::new_http(url)
+        } else if #[cfg(feature = "hyper")] {
+            RpcClient::builder().new_hyper(url)
+        } else {
+            panic!("One of 'reqwest' or 'hyper' features must be enabled")
+        }
+    }
+}