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

chore(op): Move imports in reth_optimism_rpc::sequencer to module prelude (#10886)

Browse Source
This commit is contained in:
Emilia Hane
2024-09-13 18:09:50 +02:00
committed by GitHub
parent 9c4cf3d720
commit 784154bcdb
1 changed files with 12 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
crates/optimism/rpc/src/sequencer.rs
View File

@ -1,8 +1,14 @@
//! Helpers for optimism specific RPC implementations. //! Helpers for optimism specific RPC implementations.
use std::sync::{atomic::AtomicUsize, Arc}; use std::sync::{
atomic::{self, AtomicUsize},
Arc,
};
use alloy_primitives::hex;
use reqwest::Client; use reqwest::Client;
use serde_json::json;
use tracing::warn;
use crate::SequencerClientError; use crate::SequencerClientError;
@ -41,19 +47,19 @@ impl SequencerClient {
/// Returns the next id for the request /// Returns the next id for the request
fn next_request_id(&self) -> usize { fn next_request_id(&self) -> usize {
self.inner.id.fetch_add(1, std::sync::atomic::Ordering::SeqCst) self.inner.id.fetch_add(1, atomic::Ordering::SeqCst)
} }
/// Forwards a transaction to the sequencer endpoint. /// Forwards a transaction to the sequencer endpoint.
pub async fn forward_raw_transaction(&self, tx: &[u8]) -> Result<(), SequencerClientError> { pub async fn forward_raw_transaction(&self, tx: &[u8]) -> Result<(), SequencerClientError> {
let body = serde_json::to_string(&serde_json::json!({ let body = serde_json::to_string(&json!({
"jsonrpc": "2.0", "jsonrpc": "2.0",
"method": "eth_sendRawTransaction", "method": "eth_sendRawTransaction",
"params": [format!("0x{}", alloy_primitives::hex::encode(tx))], "params": [format!("0x{}", hex::encode(tx))],
"id": self.next_request_id() "id": self.next_request_id()
})) }))
.map_err(|_| { .map_err(|_| {
tracing::warn!( warn!(
target = "rpc::eth", target = "rpc::eth",
"Failed to serialize transaction for forwarding to sequencer" "Failed to serialize transaction for forwarding to sequencer"
); );
@ -67,7 +73,7 @@ impl SequencerClient {
.send() .send()
.await .await
.inspect_err(|err| { .inspect_err(|err| {
tracing::warn!( warn!(
target = "rpc::eth", target = "rpc::eth",
%err, %err,
"Failed to forward transaction to sequencer", "Failed to forward transaction to sequencer",