jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: add rpc-api trait for call bundle (#5449)

Browse Source
This commit is contained in:
Matthias Seitz
2023-11-15 22:16:26 +01:00
committed by GitHub
parent f9725a4f88
commit 5e605d20a4
3 changed files with 35 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
crates/rpc/rpc-api/src/bundle.rs
View File

@ -1,15 +1,28 @@
//! Additional `eth_` functions for bundles
//!
//! See also <https://docs.flashbots.net/flashbots-auction/searchers/advanced/rpc-endpoint>
use jsonrpsee::proc_macros::rpc;
use reth_primitives::{Bytes, B256};
use reth_rpc_types::{
CancelBundleRequest, CancelPrivateTransactionRequest, EthBundleHash, EthCallBundleResponse,
EthCallBundleTransactionResult, EthSendBundle, PrivateTransactionRequest,
CancelBundleRequest, CancelPrivateTransactionRequest, EthBundleHash, EthCallBundle,
EthCallBundleResponse, EthSendBundle, PrivateTransactionRequest,
};
/// Eth bundle rpc interface.
///
/// See also <https://docs.flashbots.net/flashbots-auction/searchers/advanced/rpc-endpoint>
/// A subset of the [EthBundleApi] API interface that only supports `eth_callBundle`.
#[cfg_attr(not(feature = "client"), rpc(server, namespace = "eth"))]
#[cfg_attr(feature = "client", rpc(server, client, namespace = "eth"))]
#[async_trait::async_trait]
pub trait EthCallBundleApi {
/// `eth_callBundle` can be used to simulate a bundle against a specific block number,
/// including simulating a bundle at the top of the next block.
#[method(name = "callBundle")]
async fn call_bundle(
&self,
request: EthCallBundle,
) -> jsonrpsee::core::RpcResult<EthCallBundleResponse>;
}
/// Eth bundle rpc interface.
/// The __full__ Eth bundle rpc interface.
///
/// See also <https://docs.flashbots.net/flashbots-auction/searchers/advanced/rpc-endpoint>
#[cfg_attr(not(feature = "client"), rpc(server, namespace = "eth"))]
@ -26,8 +39,8 @@ pub trait EthBundleApi {
#[method(name = "callBundle")]
async fn call_bundle(
&self,
request: EthCallBundleResponse,
) -> jsonrpsee::core::RpcResult<EthCallBundleTransactionResult>;
request: EthCallBundle,
) -> jsonrpsee::core::RpcResult<EthCallBundleResponse>;
/// `eth_cancelBundle` is used to prevent a submitted bundle from being included on-chain. See [bundle cancellations](https://docs.flashbots.net/flashbots-auction/searchers/advanced/bundle-cancellations) for more information.
#[method(name = "cancelBundle")]

4
crates/rpc/rpc-api/src/lib.rs
View File

@ -38,7 +38,7 @@ pub use servers::*;
pub mod servers {
pub use crate::{
admin::AdminApiServer,
bundle::EthBundleApiServer,
bundle::{EthBundleApiServer, EthCallBundleApiServer},
debug::DebugApiServer,
engine::{EngineApiServer, EngineEthApiServer},
eth::EthApiServer,
@ -64,7 +64,7 @@ pub use clients::*;
pub mod clients {
pub use crate::{
admin::AdminApiClient,
bundle::EthBundleApiClient,
bundle::{EthBundleApiClient, EthCallBundleApiClient},
debug::DebugApiClient,
engine::{EngineApiClient, EngineEthApiClient},
eth::EthApiClient,

12
crates/rpc/rpc/src/eth/bundle.rs
View File

@ -9,12 +9,14 @@ use crate::{
},
BlockingTaskGuard,
};
use jsonrpsee::core::RpcResult;
use reth_primitives::{
keccak256,
revm_primitives::db::{DatabaseCommit, DatabaseRef},
U256,
};
use reth_revm::database::StateProviderDatabase;
use reth_rpc_api::EthCallBundleApiServer;
use reth_rpc_types::{EthCallBundle, EthCallBundleResponse, EthCallBundleTransactionResult};
use revm::{
db::CacheDB,
@ -175,6 +177,16 @@ where
}
}
#[async_trait::async_trait]
impl<Eth> EthCallBundleApiServer for EthBundle<Eth>
where
Eth: EthTransactions + 'static,
{
async fn call_bundle(&self, request: EthCallBundle) -> RpcResult<EthCallBundleResponse> {
Ok(EthBundle::call_bundle(self, request).await?)
}
}
/// Container type for `EthBundle` internals
#[derive(Debug)]
struct EthBundleInner<Eth> {