Skip to content

Commit e8d30c6

Browse files
committed
Move into_json and log_response to crate root
These will both be used by the async client. Move them out of sync client in preparation. Edit the logging function so it doesn't panic.
1 parent fe8c087 commit e8d30c6

2 files changed

Lines changed: 39 additions & 33 deletions

File tree

client/src/client_sync/mod.rs

Lines changed: 1 addition & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@ use std::io::{BufRead, BufReader};
2424
use std::path::PathBuf;
2525

2626
pub use crate::client_sync::error::Error;
27+
pub(crate) use crate::{into_json, log_response};
2728

2829
/// Crate-specific Result type.
2930
///
@@ -156,36 +157,3 @@ macro_rules! impl_client_check_expected_server_version {
156157
}
157158
};
158159
}
159-
160-
/// Shorthand for converting a variable into a `serde_json::Value`.
161-
fn into_json<T>(val: T) -> Result<serde_json::Value>
162-
where
163-
T: serde::ser::Serialize,
164-
{
165-
Ok(serde_json::to_value(val)?)
166-
}
167-
168-
/// Helper to log an RPC response.
169-
fn log_response(method: &str, resp: &Result<jsonrpc::Response>) {
170-
use log::Level::{Debug, Trace, Warn};
171-
172-
if log::log_enabled!(Warn) || log::log_enabled!(Debug) || log::log_enabled!(Trace) {
173-
match resp {
174-
Err(ref e) =>
175-
if log::log_enabled!(Debug) {
176-
log::debug!(target: "corepc", "error: {}: {:?}", method, e);
177-
},
178-
Ok(ref resp) =>
179-
if let Some(ref e) = resp.error {
180-
if log::log_enabled!(Debug) {
181-
log::debug!(target: "corepc", "response error for {}: {:?}", method, e);
182-
}
183-
} else if log::log_enabled!(Trace) {
184-
let def =
185-
serde_json::value::to_raw_value(&serde_json::value::Value::Null).unwrap();
186-
let result = resp.result.as_ref().unwrap_or(&def);
187-
log::trace!(target: "corepc", "response for {}: {}", method, result);
188-
},
189-
}
190-
}
191-
}

client/src/lib.rs

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,3 +11,41 @@ pub extern crate types;
1111
#[cfg(feature = "client-sync")]
1212
#[macro_use]
1313
pub mod client_sync;
14+
15+
#[cfg(feature = "client-sync")]
16+
use crate::client_sync::Result;
17+
18+
/// Shorthand for converting a variable into a `serde_json::Value`.
19+
#[cfg(feature = "client-sync")]
20+
fn into_json<T>(val: T) -> Result<serde_json::Value>
21+
where
22+
T: serde::ser::Serialize,
23+
{
24+
Ok(serde_json::to_value(val)?)
25+
}
26+
27+
/// Helper to log an RPC response.
28+
#[cfg(feature = "client-sync")]
29+
fn log_response(method: &str, resp: &Result<jsonrpc::Response>) {
30+
use log::Level::{Debug, Trace, Warn};
31+
32+
if log::log_enabled!(Warn) || log::log_enabled!(Debug) || log::log_enabled!(Trace) {
33+
match resp {
34+
Err(ref e) =>
35+
if log::log_enabled!(Debug) {
36+
log::debug!(target: "corepc", "error: {}: {:?}", method, e);
37+
},
38+
Ok(ref resp) =>
39+
if let Some(ref e) = resp.error {
40+
if log::log_enabled!(Debug) {
41+
log::debug!(target: "corepc", "response error for {}: {:?}", method, e);
42+
}
43+
} else if log::log_enabled!(Trace) {
44+
let def =
45+
serde_json::value::to_raw_value(&serde_json::value::Value::Null).unwrap();
46+
let result = resp.result.as_ref().unwrap_or(&def);
47+
log::trace!(target: "corepc", "response for {}: {}", method, result);
48+
},
49+
}
50+
}
51+
}

0 commit comments

Comments
 (0)