@@ -8,14 +8,14 @@ use std::convert::TryInto;
8
8
use std:: sync:: atomic:: { AtomicUsize , Ordering } ;
9
9
10
10
/// A simple RPC client for calling methods using HTTP `POST`.
11
- pub struct RPCClient {
11
+ pub struct RpcClient {
12
12
basic_auth : String ,
13
13
endpoint : HttpEndpoint ,
14
14
client : HttpClient ,
15
15
id : AtomicUsize ,
16
16
}
17
17
18
- impl RPCClient {
18
+ impl RpcClient {
19
19
pub fn new ( user_auth : & str , endpoint : HttpEndpoint ) -> std:: io:: Result < Self > {
20
20
let client = HttpClient :: connect ( & endpoint) ?;
21
21
Ok ( Self {
@@ -79,7 +79,7 @@ mod tests {
79
79
#[ tokio:: test]
80
80
async fn call_method_returning_unknown_response ( ) {
81
81
let server = HttpServer :: responding_with_not_found ( ) ;
82
- let mut client = RPCClient :: new ( "credentials" , server. endpoint ( ) ) . unwrap ( ) ;
82
+ let mut client = RpcClient :: new ( "credentials" , server. endpoint ( ) ) . unwrap ( ) ;
83
83
84
84
match client. call_method :: < u64 > ( "getblockcount" , & [ ] ) . await {
85
85
Err ( e) => assert_eq ! ( e. kind( ) , std:: io:: ErrorKind :: NotFound ) ,
@@ -91,7 +91,7 @@ mod tests {
91
91
async fn call_method_returning_malfomred_response ( ) {
92
92
let response = serde_json:: json!( "foo" ) ;
93
93
let server = HttpServer :: responding_with_ok ( MessageBody :: Content ( response) ) ;
94
- let mut client = RPCClient :: new ( "credentials" , server. endpoint ( ) ) . unwrap ( ) ;
94
+ let mut client = RpcClient :: new ( "credentials" , server. endpoint ( ) ) . unwrap ( ) ;
95
95
96
96
match client. call_method :: < u64 > ( "getblockcount" , & [ ] ) . await {
97
97
Err ( e) => {
@@ -108,7 +108,7 @@ mod tests {
108
108
"error" : { "code" : -8 , "message" : "invalid parameter" } ,
109
109
} ) ;
110
110
let server = HttpServer :: responding_with_ok ( MessageBody :: Content ( response) ) ;
111
- let mut client = RPCClient :: new ( "credentials" , server. endpoint ( ) ) . unwrap ( ) ;
111
+ let mut client = RpcClient :: new ( "credentials" , server. endpoint ( ) ) . unwrap ( ) ;
112
112
113
113
let invalid_block_hash = serde_json:: json!( "foo" ) ;
114
114
match client. call_method :: < u64 > ( "getblock" , & [ invalid_block_hash] ) . await {
@@ -124,7 +124,7 @@ mod tests {
124
124
async fn call_method_returning_missing_result ( ) {
125
125
let response = serde_json:: json!( { "result" : null } ) ;
126
126
let server = HttpServer :: responding_with_ok ( MessageBody :: Content ( response) ) ;
127
- let mut client = RPCClient :: new ( "credentials" , server. endpoint ( ) ) . unwrap ( ) ;
127
+ let mut client = RpcClient :: new ( "credentials" , server. endpoint ( ) ) . unwrap ( ) ;
128
128
129
129
match client. call_method :: < u64 > ( "getblockcount" , & [ ] ) . await {
130
130
Err ( e) => {
@@ -139,7 +139,7 @@ mod tests {
139
139
async fn call_method_returning_valid_result ( ) {
140
140
let response = serde_json:: json!( { "result" : 654470 } ) ;
141
141
let server = HttpServer :: responding_with_ok ( MessageBody :: Content ( response) ) ;
142
- let mut client = RPCClient :: new ( "credentials" , server. endpoint ( ) ) . unwrap ( ) ;
142
+ let mut client = RpcClient :: new ( "credentials" , server. endpoint ( ) ) . unwrap ( ) ;
143
143
144
144
match client. call_method :: < u64 > ( "getblockcount" , & [ ] ) . await {
145
145
Err ( e) => panic ! ( "Unexpected error: {:?}" , e) ,
0 commit comments