aisil 0.3.2

A lightweight framework to define APIs as types
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

//! Call API as JsonRPC.

use crate::{HasMethod, ImplsMethod, IsApi, combinator::WithErr};
use core::marker::PhantomData;
use reqwest::{Client, Error, Method, Url};
use serde::{Deserialize, Serialize};

/// Wrapper over [`reqwest::Client`] with fixed base URL.
pub struct JsonRpcClient<API> {
  method: Method,
  base_url: Url,
  client: Client,
  api_marker: PhantomData<API>,
}

impl<API> Clone for JsonRpcClient<API> {
  fn clone(&self) -> Self {
    JsonRpcClient {
      method: self.method.clone(),
      base_url: self.base_url.clone(),
      client: self.client.clone(),
      api_marker: PhantomData,
    }
  }
}

impl<API, Req, Res> ImplsMethod<WithErr<Error, API>, Req> for JsonRpcClient<API>
where
  API: IsApi + HasMethod<Req, Res = Res> + Send + Sync,
  Req: serde::Serialize + Send,
  Res: serde::de::DeserializeOwned,
{
  async fn call_api(&self, req: Req) -> Result<Res, Error> {
    Ok(
      self
        .client
        .request(self.method.clone(), self.base_url.clone())
        .json(&JsonRpcRequest {
          method: API::METHOD_NAME,
          params: SingleParam { payload: req },
          jsonrpc: "2.0",
        })
        .send()
        .await?
        .error_for_status()?
        .json::<JsonRpcResponse<Res>>()
        .await?
        .result,
    )
  }
}

impl<API> JsonRpcClient<API> {
  pub fn new(method: Method, base_url: Url, client: Client) -> Self {
    Self { method, base_url, client, api_marker: PhantomData }
  }
}

#[derive(Debug, Clone, Serialize)]
struct SingleParam<P> {
  payload: P,
}

#[derive(Debug, Clone, Serialize)]
struct JsonRpcRequest<'a, P> {
  method: &'a str,
  params: SingleParam<P>,
  jsonrpc: &'static str,
}

#[derive(Debug, Clone, Deserialize)]
struct JsonRpcResponse<X> {
  result: X,
}