@@ -14,7 +14,9 @@ pub enum Error {
14
14
ProtocolErr ( String ) ,
15
15
// Foreign errors
16
16
#[ error( "Error sending HTTP request: {0}" ) ]
17
- ClientErr ( #[ from] reqwest:: Error ) ,
17
+ SendErr ( #[ from] reqwest:: Error ) ,
18
+ #[ error( "Error receving HTTP response from testnet: {0}" ) ]
19
+ TestnetErr ( reqwest:: Error ) ,
18
20
#[ error( "Error altering URL scheme" ) ]
19
21
SchemeErr ( ( ) ) , // TODO: should be part of UrlError, see https://github.com/servo/rust-url/issues/299
20
22
#[ error( "Error parsing URL: {0}" ) ]
@@ -83,7 +85,7 @@ impl NodeClient<'_> {
83
85
. get ( & format ! ( "{}/accounts/{}/balance" , self . url, user) )
84
86
. bearer_auth ( auth)
85
87
. send ( )
86
- . map_err ( Error :: ClientErr )
88
+ . map_err ( Error :: SendErr )
87
89
}
88
90
89
91
// POST /accounts
@@ -94,7 +96,7 @@ impl NodeClient<'_> {
94
96
. bearer_auth ( auth)
95
97
. json ( & args)
96
98
. send ( )
97
- . map_err ( Error :: ClientErr )
99
+ . map_err ( Error :: SendErr )
98
100
}
99
101
100
102
// PUT /accounts/:username
@@ -105,7 +107,7 @@ impl NodeClient<'_> {
105
107
. bearer_auth ( auth)
106
108
. json ( & args)
107
109
. send ( )
108
- . map_err ( Error :: ClientErr )
110
+ . map_err ( Error :: SendErr )
109
111
}
110
112
111
113
// DELETE /accounts/:username
@@ -115,7 +117,7 @@ impl NodeClient<'_> {
115
117
. delete ( & format ! ( "{}/accounts/{}" , self . url, args[ "username" ] ) )
116
118
. bearer_auth ( auth)
117
119
. send ( )
118
- . map_err ( Error :: ClientErr )
120
+ . map_err ( Error :: SendErr )
119
121
}
120
122
121
123
// WebSocket /accounts/:username/payments/incoming
@@ -157,7 +159,7 @@ impl NodeClient<'_> {
157
159
. get ( & format ! ( "{}/accounts/{}" , self . url, args[ "username" ] ) )
158
160
. bearer_auth ( auth)
159
161
. send ( )
160
- . map_err ( Error :: ClientErr )
162
+ . map_err ( Error :: SendErr )
161
163
}
162
164
163
165
// GET /accounts
@@ -167,7 +169,7 @@ impl NodeClient<'_> {
167
169
. get ( & format ! ( "{}/accounts" , self . url) )
168
170
. bearer_auth ( auth)
169
171
. send ( )
170
- . map_err ( Error :: ClientErr )
172
+ . map_err ( Error :: SendErr )
171
173
}
172
174
173
175
// PUT /accounts/:username/settings
@@ -179,7 +181,7 @@ impl NodeClient<'_> {
179
181
. bearer_auth ( auth)
180
182
. json ( & args)
181
183
. send ( )
182
- . map_err ( Error :: ClientErr )
184
+ . map_err ( Error :: SendErr )
183
185
}
184
186
185
187
// POST /accounts/:username/payments
@@ -191,15 +193,15 @@ impl NodeClient<'_> {
191
193
. bearer_auth ( & format ! ( "{}:{}" , user, auth) )
192
194
. json ( & args)
193
195
. send ( )
194
- . map_err ( Error :: ClientErr )
196
+ . map_err ( Error :: SendErr )
195
197
}
196
198
197
199
// GET /rates
198
200
fn get_rates ( & self , _matches : & ArgMatches ) -> Result < Response , Error > {
199
201
self . client
200
202
. get ( & format ! ( "{}/rates" , self . url) )
201
203
. send ( )
202
- . map_err ( Error :: ClientErr )
204
+ . map_err ( Error :: SendErr )
203
205
}
204
206
205
207
// PUT /rates
@@ -210,15 +212,15 @@ impl NodeClient<'_> {
210
212
. bearer_auth ( auth)
211
213
. json ( & rate_pairs)
212
214
. send ( )
213
- . map_err ( Error :: ClientErr )
215
+ . map_err ( Error :: SendErr )
214
216
}
215
217
216
218
// GET /routes
217
219
fn get_routes ( & self , _matches : & ArgMatches ) -> Result < Response , Error > {
218
220
self . client
219
221
. get ( & format ! ( "{}/routes" , self . url) )
220
222
. send ( )
221
- . map_err ( Error :: ClientErr )
223
+ . map_err ( Error :: SendErr )
222
224
}
223
225
224
226
// PUT /routes/static/:prefix
@@ -229,7 +231,7 @@ impl NodeClient<'_> {
229
231
. bearer_auth ( auth)
230
232
. body ( args[ "destination" ] . to_string ( ) )
231
233
. send ( )
232
- . map_err ( Error :: ClientErr )
234
+ . map_err ( Error :: SendErr )
233
235
}
234
236
235
237
// PUT routes/static
@@ -240,7 +242,7 @@ impl NodeClient<'_> {
240
242
. bearer_auth ( auth)
241
243
. json ( & route_pairs)
242
244
. send ( )
243
- . map_err ( Error :: ClientErr )
245
+ . map_err ( Error :: SendErr )
244
246
}
245
247
246
248
// PUT /settlement/engines
@@ -251,15 +253,15 @@ impl NodeClient<'_> {
251
253
. bearer_auth ( auth)
252
254
. json ( & engine_pairs)
253
255
. send ( )
254
- . map_err ( Error :: ClientErr )
256
+ . map_err ( Error :: SendErr )
255
257
}
256
258
257
259
// GET /
258
260
fn get_root ( & self , _matches : & ArgMatches ) -> Result < Response , Error > {
259
261
self . client
260
262
. get ( & format ! ( "{}/" , self . url) )
261
263
. send ( )
262
- . map_err ( Error :: ClientErr )
264
+ . map_err ( Error :: SendErr )
263
265
}
264
266
265
267
/*
@@ -280,10 +282,9 @@ impl NodeClient<'_> {
280
282
let foreign_args: XpringResponse = self
281
283
. client
282
284
. get ( & format ! ( "https://xpring.io/api/accounts/{}" , asset) )
283
- . send ( )
284
- . map_err ( Error :: ClientErr ) ?
285
+ . send ( ) ?
285
286
. json ( )
286
- . map_err ( Error :: ClientErr ) ?;
287
+ . map_err ( Error :: TestnetErr ) ?;
287
288
let mut args = HashMap :: new ( ) ;
288
289
let token = format ! ( "{}:{}" , foreign_args. username, foreign_args. passkey) ;
289
290
args. insert ( "ilp_over_http_url" , foreign_args. http_endpoint ) ;
@@ -311,7 +312,7 @@ impl NodeClient<'_> {
311
312
http:: Response :: builder ( ) . body ( token) . unwrap ( ) , // infallible unwrap
312
313
) )
313
314
} else {
314
- result. map_err ( Error :: ClientErr )
315
+ result. map_err ( Error :: SendErr )
315
316
}
316
317
}
317
318
}
0 commit comments