Skip to content

Commit f863ffb

Browse files
committed
Use RawValue for RPC params
1 parent 8985c8c commit f863ffb

File tree

6 files changed

+157
-184
lines changed

6 files changed

+157
-184
lines changed

monad-rpc/benches/deserialize.rs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -31,23 +31,23 @@ fn deserialize<const DESERIALIZE_TO_T: bool, T>(
3131
where
3232
T: DeserializeOwned,
3333
{
34-
let request: RequestWrapper<Value> = serde_json::from_slice(body).unwrap();
34+
let request = RequestWrapper::from_body_bytes(body).unwrap();
3535

3636
match request {
3737
RequestWrapper::Single(json_request) => {
38-
let request = serde_json::from_value::<Request>(json_request.clone())
38+
let request = serde_json::from_str::<Request>(json_request.get())
3939
.map_err(|_| JsonRpcError::parse_error())?;
4040

41-
let params = request.params.clone();
41+
let id = request.id.clone();
4242

4343
if DESERIALIZE_TO_T {
44-
let parsed_params: T = serde_json::from_value(params).invalid_params()?;
44+
let parsed_params: T =
45+
serde_json::from_str(request.params.get()).invalid_params()?;
4546

4647
black_box(parsed_params);
47-
} else {
48-
black_box(params);
4948
}
5049

50+
black_box(id);
5151
black_box(request);
5252
black_box(json_request);
5353

@@ -57,7 +57,7 @@ where
5757
json_batch_request
5858
.into_iter()
5959
.map(|json_request| {
60-
let request = serde_json::from_value::<Request>(json_request).unwrap();
60+
let request = serde_json::from_str::<Request>(json_request.get()).unwrap();
6161

6262
black_box(request);
6363
})

monad-rpc/src/handlers/eth/call.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -88,10 +88,10 @@ pub struct EthCallStatsTracker {
8888
}
8989

9090
impl EthCallStatsTracker {
91-
pub async fn record_request_start(&self, request_id: &RequestId) {
91+
pub async fn record_request_start(&self, request_id: RequestId) {
9292
let mut requests = self.active_requests.lock().await;
9393
requests.insert(
94-
request_id.clone(),
94+
request_id,
9595
EthCallRequestStats {
9696
entry_time: Instant::now(),
9797
},

0 commit comments

Comments
 (0)