jsonrpc_client 0.7.1

An async, macro-driven JSON-RPC client with pluggable backends.
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

use crate::{Response, SendRequest, Url};
use isahc::{
    http::{
        header::{HeaderValue, CONTENT_TYPE},
        Request,
    },
    ResponseExt,
};
use serde::de::DeserializeOwned;

#[async_trait::async_trait]
impl SendRequest for isahc::HttpClient {
    type Error = isahc::Error;

    async fn send_request<P>(&self, endpoint: Url, body: String) -> Result<Response<P>, Self::Error>
    where
        P: DeserializeOwned,
    {
        let mut request = Request::post(endpoint.to_string()).body(body)?;
        request
            .headers_mut()
            .insert(CONTENT_TYPE, HeaderValue::from_static("application/json"));

        let response = self
            .send_async(request)
            .await?
            .json()
            .map_err(|e| isahc::Error::ResponseBodyError(Some(e.to_string())))?;

        Ok(response)
    }
}

impl From<isahc::Error> for crate::Error<isahc::Error> {
    fn from(inner: isahc::Error) -> Self {
        crate::Error::Client(inner)
    }
}