gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Minor cli fixes (bp #8061) (#8065)

Browse Source 
automerge
This commit is contained in:
mergify[bot]
2020-01-31 12:36:35 -08:00
committed by GitHub
parent aa8c9f6a98
commit 57d490c84f
3 changed files with 14 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
client/src/rpc_client.rs
View File

@@ -177,7 +177,7 @@ impl RpcClient {
serde_json::from_value(response).map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("GetVoteAccounts parse failure: {}", err),
format!("GetVoteAccounts parse failure: {:?}", err),
)
})
}
@@ -196,7 +196,7 @@ impl RpcClient {
serde_json::from_value(response).map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("GetClusterNodes parse failure: {}", err),
format!("GetClusterNodes parse failure: {:?}", err),
)
})
}
@@ -215,7 +215,7 @@ impl RpcClient {
serde_json::from_value(response).map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("GetConfirmedBlock parse failure: {}", err),
format!("GetConfirmedBlock parse failure: {:?}", err),
)
})
}
@@ -242,7 +242,7 @@ impl RpcClient {
serde_json::from_value(response).map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("GetConfirmedBlocks parse failure: {}", err),
format!("GetConfirmedBlocks parse failure: {:?}", err),
)
})
}
@@ -293,7 +293,7 @@ impl RpcClient {
serde_json::from_value(response).map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("GetEpochInfo parse failure: {}", err),
format!("GetEpochInfo parse failure: {:?}", err),
)
})
}
@@ -324,7 +324,7 @@ impl RpcClient {
serde_json::from_value(response).map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("GetLeaderSchedule failure: {}", err),
format!("GetLeaderSchedule failure: {:?}", err),
)
})
}
@@ -343,7 +343,7 @@ impl RpcClient {
serde_json::from_value(response).map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("GetEpochSchedule parse failure: {}", err),
format!("GetEpochSchedule parse failure: {:?}", err),
)
})
}
@@ -381,7 +381,7 @@ impl RpcClient {
serde_json::from_value(response).map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("GetVersion parse failure: {}", err),
format!("GetVersion parse failure: {:?}", err),
)
})
}
@@ -400,7 +400,7 @@ impl RpcClient {
serde_json::from_value(response).map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("MinimumLedgerSlot parse failure: {}", err),
format!("MinimumLedgerSlot parse failure: {:?}", err),
)
})
}
@@ -612,7 +612,7 @@ impl RpcClient {
.map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("AccountNotFound: pubkey={}: {}", pubkey, err),
format!("AccountNotFound: pubkey={}: {:?}", pubkey, err),
)
})?
}
@@ -698,7 +698,7 @@ impl RpcClient {
.map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("AccountNotFound: pubkey={}: {}", pubkey, err),
format!("AccountNotFound: pubkey={}: {:?}", pubkey, err),
)
})?;
@@ -749,7 +749,7 @@ impl RpcClient {
serde_json::from_value(response).map_err(|err| {
io::Error::new(
io::ErrorKind::Other,
format!("GetTransactionCount parse failure: {}", err),
format!("GetTransactionCount parse failure: {:?}", err),
)
})
}

5
client/src/rpc_client_request.rs
View File

@@ -15,10 +15,7 @@ pub struct RpcClientRequest {
impl RpcClientRequest {
pub fn new(url: String) -> Self {
Self {
client: reqwest::blocking::Client::new(),
url,
}
Self::new_with_timeout(url, Duration::from_secs(20))
}
pub fn new_with_timeout(url: String, timeout: Duration) -> Self {