From 733183cbd1cc920afd8e0f556755befab526fd23 Mon Sep 17 00:00:00 2001 From: DoTheBestToGetTheBest <146037313+DoTheBestToGetTheBest@users.noreply.github.com> Date: Tue, 31 Oct 2023 13:33:57 -0700 Subject: [PATCH 1/3] Update trace.rs --- crates/rpc/rpc-testing-util/src/trace.rs | 26 ++++++++++++++++++++++++ 1 file changed, 26 insertions(+) diff --git a/crates/rpc/rpc-testing-util/src/trace.rs b/crates/rpc/rpc-testing-util/src/trace.rs index acec06d9418c..8a32817cb5bb 100644 --- a/crates/rpc/rpc-testing-util/src/trace.rs +++ b/crates/rpc/rpc-testing-util/src/trace.rs @@ -270,6 +270,7 @@ mod tests { use super::*; use jsonrpsee::http_client::HttpClientBuilder; use reth_primitives::BlockNumberOrTag; + use std::collections::HashSet; fn assert_is_stream(_: &St) {} @@ -319,4 +320,29 @@ mod tests { println!("Total successes: {}", successes); println!("Total failures: {}", failures); } + + #[tokio::test] + async fn can_create_trace_call_many_stream() { + let client = HttpClientBuilder::default().build("http://localhost:8545").unwrap(); + + let call_request_1 = CallRequest { from: None, to: None, gas: None, ..Default::default() }; + let call_request_2 = CallRequest { from: None, to: None, gas: None, ..Default::default() }; + let trace_types = HashSet::from([TraceType::StateDiff, TraceType::VmTrace]); + let calls = vec![(call_request_1, trace_types.clone()), (call_request_2, trace_types)]; + + let mut stream = client.trace_call_many_stream(calls, None); + + assert_is_stream(&stream); + + while let Some(result) = stream.next().await { + match result { + Ok(trace_result) => { + println!("Success: {:?}", trace_result); + } + Err(error) => { + println!("Error: {:?}", error); + } + } + } + } } From 1c6985f559340b210390d1f0038391c822db49ac Mon Sep 17 00:00:00 2001 From: DoTheBestToGetTheBest <146037313+DoTheBestToGetTheBest@users.noreply.github.com> Date: Tue, 31 Oct 2023 14:23:13 -0700 Subject: [PATCH 2/3] Update crates/rpc/rpc-testing-util/src/trace.rs Co-authored-by: Matthias Seitz --- crates/rpc/rpc-testing-util/src/trace.rs | 1 + 1 file changed, 1 insertion(+) diff --git a/crates/rpc/rpc-testing-util/src/trace.rs b/crates/rpc/rpc-testing-util/src/trace.rs index 8a32817cb5bb..d21d78d01dc1 100644 --- a/crates/rpc/rpc-testing-util/src/trace.rs +++ b/crates/rpc/rpc-testing-util/src/trace.rs @@ -322,6 +322,7 @@ mod tests { } #[tokio::test] + #[ignore] async fn can_create_trace_call_many_stream() { let client = HttpClientBuilder::default().build("http://localhost:8545").unwrap(); From 66304a41ba8f3f06bf4c14e05f09be4c17cb09e9 Mon Sep 17 00:00:00 2001 From: DoTheBestToGetTheBest <146037313+DoTheBestToGetTheBest@users.noreply.github.com> Date: Tue, 31 Oct 2023 14:25:01 -0700 Subject: [PATCH 3/3] Update trace.rs --- crates/rpc/rpc-testing-util/src/trace.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/crates/rpc/rpc-testing-util/src/trace.rs b/crates/rpc/rpc-testing-util/src/trace.rs index d21d78d01dc1..c3c1f3904922 100644 --- a/crates/rpc/rpc-testing-util/src/trace.rs +++ b/crates/rpc/rpc-testing-util/src/trace.rs @@ -326,8 +326,8 @@ mod tests { async fn can_create_trace_call_many_stream() { let client = HttpClientBuilder::default().build("http://localhost:8545").unwrap(); - let call_request_1 = CallRequest { from: None, to: None, gas: None, ..Default::default() }; - let call_request_2 = CallRequest { from: None, to: None, gas: None, ..Default::default() }; + let call_request_1 = CallRequest::default(); + let call_request_2 = CallRequest::default(); let trace_types = HashSet::from([TraceType::StateDiff, TraceType::VmTrace]); let calls = vec![(call_request_1, trace_types.clone()), (call_request_2, trace_types)];