@@ -222,14 +222,14 @@ impl LSPSMessage {
222
222
match self {
223
223
LSPSMessage :: LSPS0 ( LSPS0Message :: Request ( request_id, request) ) => {
224
224
Some ( ( RequestId ( request_id. 0 . clone ( ) ) , request. into ( ) ) )
225
- }
225
+ } ,
226
226
#[ cfg( lsps1) ]
227
227
LSPSMessage :: LSPS1 ( LSPS1Message :: Request ( request_id, request) ) => {
228
228
Some ( ( RequestId ( request_id. 0 . clone ( ) ) , request. into ( ) ) )
229
- }
229
+ } ,
230
230
LSPSMessage :: LSPS2 ( LSPS2Message :: Request ( request_id, request) ) => {
231
231
Some ( ( RequestId ( request_id. 0 . clone ( ) ) , request. into ( ) ) )
232
- }
232
+ } ,
233
233
_ => None ,
234
234
}
235
235
}
@@ -254,21 +254,21 @@ impl Serialize for LSPSMessage {
254
254
match request {
255
255
LSPS0Request :: ListProtocols ( params) => {
256
256
jsonrpc_object. serialize_field ( JSONRPC_PARAMS_FIELD_KEY , params) ?
257
- }
257
+ } ,
258
258
} ;
259
- }
259
+ } ,
260
260
LSPSMessage :: LSPS0 ( LSPS0Message :: Response ( request_id, response) ) => {
261
261
jsonrpc_object. serialize_field ( JSONRPC_ID_FIELD_KEY , & request_id. 0 ) ?;
262
262
263
263
match response {
264
264
LSPS0Response :: ListProtocols ( result) => {
265
265
jsonrpc_object. serialize_field ( JSONRPC_RESULT_FIELD_KEY , result) ?;
266
- }
266
+ } ,
267
267
LSPS0Response :: ListProtocolsError ( error) => {
268
268
jsonrpc_object. serialize_field ( JSONRPC_ERROR_FIELD_KEY , error) ?;
269
- }
269
+ } ,
270
270
}
271
- }
271
+ } ,
272
272
#[ cfg( lsps1) ]
273
273
LSPSMessage :: LSPS1 ( LSPS1Message :: Request ( request_id, request) ) => {
274
274
jsonrpc_object. serialize_field ( JSONRPC_ID_FIELD_KEY , & request_id. 0 ) ?;
@@ -278,40 +278,40 @@ impl Serialize for LSPSMessage {
278
278
match request {
279
279
LSPS1Request :: GetInfo ( params) => {
280
280
jsonrpc_object. serialize_field ( JSONRPC_PARAMS_FIELD_KEY , params) ?
281
- }
281
+ } ,
282
282
LSPS1Request :: CreateOrder ( params) => {
283
283
jsonrpc_object. serialize_field ( JSONRPC_PARAMS_FIELD_KEY , params) ?
284
- }
284
+ } ,
285
285
LSPS1Request :: GetOrder ( params) => {
286
286
jsonrpc_object. serialize_field ( JSONRPC_PARAMS_FIELD_KEY , params) ?
287
- }
287
+ } ,
288
288
}
289
- }
289
+ } ,
290
290
#[ cfg( lsps1) ]
291
291
LSPSMessage :: LSPS1 ( LSPS1Message :: Response ( request_id, response) ) => {
292
292
jsonrpc_object. serialize_field ( JSONRPC_ID_FIELD_KEY , & request_id. 0 ) ?;
293
293
294
294
match response {
295
295
LSPS1Response :: GetInfo ( result) => {
296
296
jsonrpc_object. serialize_field ( JSONRPC_RESULT_FIELD_KEY , result) ?
297
- }
297
+ } ,
298
298
LSPS1Response :: GetInfoError ( error) => {
299
299
jsonrpc_object. serialize_field ( JSONRPC_ERROR_FIELD_KEY , error) ?
300
- }
300
+ } ,
301
301
LSPS1Response :: CreateOrder ( result) => {
302
302
jsonrpc_object. serialize_field ( JSONRPC_RESULT_FIELD_KEY , result) ?
303
- }
303
+ } ,
304
304
LSPS1Response :: CreateOrderError ( error) => {
305
305
jsonrpc_object. serialize_field ( JSONRPC_ERROR_FIELD_KEY , error) ?
306
- }
306
+ } ,
307
307
LSPS1Response :: GetOrder ( result) => {
308
308
jsonrpc_object. serialize_field ( JSONRPC_RESULT_FIELD_KEY , result) ?
309
- }
309
+ } ,
310
310
LSPS1Response :: GetOrderError ( error) => {
311
311
jsonrpc_object. serialize_field ( JSONRPC_ERROR_FIELD_KEY , error) ?
312
- }
312
+ } ,
313
313
}
314
- }
314
+ } ,
315
315
LSPSMessage :: LSPS2 ( LSPS2Message :: Request ( request_id, request) ) => {
316
316
jsonrpc_object. serialize_field ( JSONRPC_ID_FIELD_KEY , & request_id. 0 ) ?;
317
317
jsonrpc_object
@@ -320,34 +320,34 @@ impl Serialize for LSPSMessage {
320
320
match request {
321
321
LSPS2Request :: GetInfo ( params) => {
322
322
jsonrpc_object. serialize_field ( JSONRPC_PARAMS_FIELD_KEY , params) ?
323
- }
323
+ } ,
324
324
LSPS2Request :: Buy ( params) => {
325
325
jsonrpc_object. serialize_field ( JSONRPC_PARAMS_FIELD_KEY , params) ?
326
- }
326
+ } ,
327
327
}
328
- }
328
+ } ,
329
329
LSPSMessage :: LSPS2 ( LSPS2Message :: Response ( request_id, response) ) => {
330
330
jsonrpc_object. serialize_field ( JSONRPC_ID_FIELD_KEY , & request_id. 0 ) ?;
331
331
332
332
match response {
333
333
LSPS2Response :: GetInfo ( result) => {
334
334
jsonrpc_object. serialize_field ( JSONRPC_RESULT_FIELD_KEY , result) ?
335
- }
335
+ } ,
336
336
LSPS2Response :: GetInfoError ( error) => {
337
337
jsonrpc_object. serialize_field ( JSONRPC_ERROR_FIELD_KEY , error) ?
338
- }
338
+ } ,
339
339
LSPS2Response :: Buy ( result) => {
340
340
jsonrpc_object. serialize_field ( JSONRPC_RESULT_FIELD_KEY , result) ?
341
- }
341
+ } ,
342
342
LSPS2Response :: BuyError ( error) => {
343
343
jsonrpc_object. serialize_field ( JSONRPC_ERROR_FIELD_KEY , error) ?
344
- }
344
+ } ,
345
345
}
346
- }
346
+ } ,
347
347
LSPSMessage :: Invalid ( error) => {
348
348
jsonrpc_object. serialize_field ( JSONRPC_ID_FIELD_KEY , & serde_json:: Value :: Null ) ?;
349
349
jsonrpc_object. serialize_field ( JSONRPC_ERROR_FIELD_KEY , & error) ?;
350
- }
350
+ } ,
351
351
}
352
352
353
353
jsonrpc_object. end ( )
@@ -379,22 +379,22 @@ impl<'de, 'a> Visitor<'de> for LSPSMessageVisitor<'a> {
379
379
match key {
380
380
"id" => {
381
381
id = map. next_value ( ) ?;
382
- }
382
+ } ,
383
383
"method" => {
384
384
method = Some ( map. next_value ( ) ?) ;
385
- }
385
+ } ,
386
386
"params" => {
387
387
params = Some ( map. next_value ( ) ?) ;
388
- }
388
+ } ,
389
389
"result" => {
390
390
result = Some ( map. next_value ( ) ?) ;
391
- }
391
+ } ,
392
392
"error" => {
393
393
error = Some ( map. next_value ( ) ?) ;
394
- }
394
+ } ,
395
395
_ => {
396
396
let _: serde_json:: Value = map. next_value ( ) ?;
397
- }
397
+ } ,
398
398
}
399
399
}
400
400
@@ -415,7 +415,7 @@ impl<'de, 'a> Visitor<'de> for LSPSMessageVisitor<'a> {
415
415
416
416
return Err ( de:: Error :: custom ( "Received unknown error message" ) ) ;
417
417
}
418
- }
418
+ } ,
419
419
} ;
420
420
421
421
match method {
@@ -432,7 +432,7 @@ impl<'de, 'a> Visitor<'de> for LSPSMessageVisitor<'a> {
432
432
id,
433
433
LSPS1Request :: GetInfo ( request) ,
434
434
) ) )
435
- }
435
+ } ,
436
436
#[ cfg( lsps1) ]
437
437
LSPSMethod :: LSPS1CreateOrder => {
438
438
let request = serde_json:: from_value ( params. unwrap_or ( json ! ( { } ) ) )
@@ -441,7 +441,7 @@ impl<'de, 'a> Visitor<'de> for LSPSMessageVisitor<'a> {
441
441
id,
442
442
LSPS1Request :: CreateOrder ( request) ,
443
443
) ) )
444
- }
444
+ } ,
445
445
#[ cfg( lsps1) ]
446
446
LSPSMethod :: LSPS1GetOrder => {
447
447
let request = serde_json:: from_value ( params. unwrap_or ( json ! ( { } ) ) )
@@ -450,20 +450,20 @@ impl<'de, 'a> Visitor<'de> for LSPSMessageVisitor<'a> {
450
450
id,
451
451
LSPS1Request :: GetOrder ( request) ,
452
452
) ) )
453
- }
453
+ } ,
454
454
LSPSMethod :: LSPS2GetInfo => {
455
455
let request = serde_json:: from_value ( params. unwrap_or ( json ! ( { } ) ) )
456
456
. map_err ( de:: Error :: custom) ?;
457
457
Ok ( LSPSMessage :: LSPS2 ( LSPS2Message :: Request (
458
458
id,
459
459
LSPS2Request :: GetInfo ( request) ,
460
460
) ) )
461
- }
461
+ } ,
462
462
LSPSMethod :: LSPS2Buy => {
463
463
let request = serde_json:: from_value ( params. unwrap_or ( json ! ( { } ) ) )
464
464
. map_err ( de:: Error :: custom) ?;
465
465
Ok ( LSPSMessage :: LSPS2 ( LSPS2Message :: Request ( id, LSPS2Request :: Buy ( request) ) ) )
466
- }
466
+ } ,
467
467
} ,
468
468
None => match self . request_id_to_method_map . remove ( & id) {
469
469
Some ( method) => match method {
@@ -483,7 +483,7 @@ impl<'de, 'a> Visitor<'de> for LSPSMessageVisitor<'a> {
483
483
} else {
484
484
Err ( de:: Error :: custom ( "Received invalid JSON-RPC object: one of method, result, or error required" ) )
485
485
}
486
- }
486
+ } ,
487
487
#[ cfg( lsps1) ]
488
488
LSPSMethod :: LSPS1GetInfo => {
489
489
if let Some ( error) = error {
@@ -501,7 +501,7 @@ impl<'de, 'a> Visitor<'de> for LSPSMessageVisitor<'a> {
501
501
} else {
502
502
Err ( de:: Error :: custom ( "Received invalid JSON-RPC object: one of method, result, or error required" ) )
503
503
}
504
- }
504
+ } ,
505
505
#[ cfg( lsps1) ]
506
506
LSPSMethod :: LSPS1CreateOrder => {
507
507
if let Some ( error) = error {
@@ -519,7 +519,7 @@ impl<'de, 'a> Visitor<'de> for LSPSMessageVisitor<'a> {
519
519
} else {
520
520
Err ( de:: Error :: custom ( "Received invalid JSON-RPC object: one of method, result, or error required" ) )
521
521
}
522
- }
522
+ } ,
523
523
#[ cfg( lsps1) ]
524
524
LSPSMethod :: LSPS1GetOrder => {
525
525
if let Some ( error) = error {
@@ -537,7 +537,7 @@ impl<'de, 'a> Visitor<'de> for LSPSMessageVisitor<'a> {
537
537
} else {
538
538
Err ( de:: Error :: custom ( "Received invalid JSON-RPC object: one of method, result, or error required" ) )
539
539
}
540
- }
540
+ } ,
541
541
LSPSMethod :: LSPS2GetInfo => {
542
542
if let Some ( error) = error {
543
543
Ok ( LSPSMessage :: LSPS2 ( LSPS2Message :: Response (
@@ -554,7 +554,7 @@ impl<'de, 'a> Visitor<'de> for LSPSMessageVisitor<'a> {
554
554
} else {
555
555
Err ( de:: Error :: custom ( "Received invalid JSON-RPC object: one of method, result, or error required" ) )
556
556
}
557
- }
557
+ } ,
558
558
LSPSMethod :: LSPS2Buy => {
559
559
if let Some ( error) = error {
560
560
Ok ( LSPSMessage :: LSPS2 ( LSPS2Message :: Response (
@@ -571,7 +571,7 @@ impl<'de, 'a> Visitor<'de> for LSPSMessageVisitor<'a> {
571
571
} else {
572
572
Err ( de:: Error :: custom ( "Received invalid JSON-RPC object: one of method, result, or error required" ) )
573
573
}
574
- }
574
+ } ,
575
575
} ,
576
576
None => Err ( de:: Error :: custom ( format ! (
577
577
"Received response for unknown request id: {}" ,
0 commit comments