jsonrpc-client-core 0.5.0

A crate for generating transport agnostic, auto serializing, strongly typed JSON-RPC 2.0 clients
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

// Copyright 2017 Amagicom AB.
//
// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
// option. This file may not be copied, modified, or distributed
// except according to those terms.

use jsonrpc_core::types::{Id, Output, Version};
use serde;
use serde_json;
use {ErrorKind, Result, ResultExt};

/// Parses a binary response into json, extracts the "result" field and tries to deserialize that
/// to the desired type.
pub fn parse<R>(response_raw: &[u8], expected_id: &Id) -> Result<R>
where
    R: serde::de::DeserializeOwned,
{
    let response: Output = serde_json::from_slice(response_raw)
        .chain_err(|| ErrorKind::ResponseError("Not valid json"))?;
    ensure!(
        response.version() == Some(Version::V2),
        ErrorKind::ResponseError("Not JSON-RPC 2.0 compatible")
    );
    ensure!(
        response.id() == expected_id,
        ErrorKind::ResponseError("Response id not equal to request id")
    );
    match response {
        Output::Success(success) => {
            trace!("Received json result: {}", success.result);
            serde_json::from_value(success.result)
                .chain_err(|| ErrorKind::ResponseError("Not valid for target type"))
        }
        Output::Failure(failure) => bail!(ErrorKind::JsonRpcError(failure.error)),
    }
}