tornadocontrib/ web3-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix one syntax error

This commit is contained in:
Bryan Stitt 2023-09-02 10:38:26 -07:00
parent 5ce1b5bace
commit 2cf688cc68
2 changed files with 17 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
web3_proxy/src/app/mod.rs
View File

@ -1340,20 +1340,20 @@ impl Web3ProxyApp {
| "eth_supportedEntryPoints" | "eth_supportedEntryPoints"
| "web3_bundlerVersion") => match self.bundler_4337_rpcs.as_ref() { | "web3_bundlerVersion") => match self.bundler_4337_rpcs.as_ref() {
Some(bundler_4337_rpcs) => { Some(bundler_4337_rpcs) => {
let x = bundler_4337_rpcs // let x = bundler_4337_rpcs
.try_send_all_synced_connections::<Box<RawValue>>( // .try_send_all_synced_connections::<Box<RawValue>>(
method, // method,
params, // params,
Some(request_metadata), // Some(request_metadata),
None, // None,
None, // None,
Some(Duration::from_secs(30)), // Some(Duration::from_secs(30)),
Some(Level::DEBUG.into()), // Some(Level::DEBUG.into()),
Some(1), // Some(1),
) // )
.await?; // .await?;
// x.into()
x.into() todo!("wip");
} }
None => { None => {
// TODO: stats even when we error! // TODO: stats even when we error!

4
web3_proxy/src/rpcs/many.rs
View File

@ -32,7 +32,7 @@ use std::sync::Arc;
use tokio::select; use tokio::select;
use tokio::sync::{mpsc, watch}; use tokio::sync::{mpsc, watch};
use tokio::task::yield_now; use tokio::task::yield_now;
use tokio::time::{sleep, sleep_until, timeout, Duration, Instant}; use tokio::time::{sleep_until, timeout, Duration, Instant};
use tracing::{debug, error, info, instrument, trace, warn}; use tracing::{debug, error, info, instrument, trace, warn};
/// A collection of web3 connections. Sends requests either the current best server or all servers. /// A collection of web3 connections. Sends requests either the current best server or all servers.
@ -366,6 +366,8 @@ impl Web3Rpcs {
.name("noop") .name("noop")
.spawn(async move { .spawn(async move {
futures::future::pending::<()>().await; futures::future::pending::<()>().await;
Ok(())
})?; })?;
futures.push(flatten_handle(handle)); futures.push(flatten_handle(handle));