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

chore(op): Use tokio::sync::OnceCell to set SequencerClient (#10885)

Browse Source
This commit is contained in:
Emilia Hane
2024-09-13 18:03:37 +02:00
committed by GitHub
parent 47d188cb8e
commit 9c4cf3d720
3 changed files with 16 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
crates/optimism/bin/src/main.rs
View File

@ -38,7 +38,7 @@ fn main() {
if let Some(sequencer_http) = sequencer_http_arg {
ctx.registry
.eth_api()
.set_sequencer_client(SequencerClient::new(sequencer_http));
.set_sequencer_client(SequencerClient::new(sequencer_http))?;
}
Ok(())
@ -62,7 +62,7 @@ fn main() {
if let Some(sequencer_http) = sequencer_http_arg {
ctx.registry
.eth_api()
.set_sequencer_client(SequencerClient::new(sequencer_http));
.set_sequencer_client(SequencerClient::new(sequencer_http))?;
}
Ok(())

8
crates/optimism/rpc/src/eth/mod.rs
View File

@ -36,6 +36,7 @@ use reth_tasks::{
TaskSpawner,
};
use reth_transaction_pool::TransactionPool;
use tokio::sync::OnceCell;
use crate::{OpEthApiError, SequencerClient};
@ -59,8 +60,11 @@ pub type EthApiNodeBackend<N> = EthApiInner<
/// all the `Eth` helper traits and prerequisite traits.
#[derive(Clone)]
pub struct OpEthApi<N: FullNodeComponents> {
/// Gateway to node's core components.
inner: Arc<EthApiNodeBackend<N>>,
sequencer_client: Arc<parking_lot::RwLock<Option<SequencerClient>>>,
/// Sequencer client, configured to forward submitted transactions to sequencer of given OP
/// network.
sequencer_client: OnceCell<SequencerClient>,
}
impl<N> OpEthApi<N>
@ -90,7 +94,7 @@ where
ctx.config.proof_permits,
);
Self { inner: Arc::new(inner), sequencer_client: Arc::new(parking_lot::RwLock::new(None)) }
Self { inner: Arc::new(inner), sequencer_client: OnceCell::new() }
}
}

13
crates/optimism/rpc/src/eth/transaction.rs
View File

@ -76,13 +76,16 @@ impl<N> OpEthApi<N>
where
N: FullNodeComponents,
{
/// Sets a `SequencerClient` for `eth_sendRawTransaction` to forward transactions to.
pub fn set_sequencer_client(&self, sequencer_client: SequencerClient) {
*self.sequencer_client.write() = Some(sequencer_client);
/// Sets a [`SequencerClient`] for `eth_sendRawTransaction` to forward transactions to.
pub fn set_sequencer_client(
&self,
sequencer_client: SequencerClient,
) -> Result<(), tokio::sync::SetError<SequencerClient>> {
self.sequencer_client.set(sequencer_client)
}
/// Returns the `SequencerClient` if one is set.
/// Returns the [`SequencerClient`] if one is set.
pub fn raw_tx_forwarder(&self) -> Option<SequencerClient> {
self.sequencer_client.read().clone()
self.sequencer_client.get().cloned()
}
}