melwallet-client 0.7.3

melwalletd client library
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

use std::net::SocketAddr;

use async_trait::async_trait;
use http_types::{Method, Request, Response, Url};
use nanorpc::{JrpcRequest, JrpcResponse, RpcTransport};
use smol::net::TcpStream;

use anyhow::anyhow;

/// A client to a particular wallet daemon.
#[derive(Clone, Debug)]
pub struct DaemonClient {
    endpoint: SocketAddr,
}

#[async_trait]
impl RpcTransport for DaemonClient {
    type Error = anyhow::Error;

    async fn call_raw(&self, req: JrpcRequest) -> Result<JrpcResponse, Self::Error> {
        let to_send = serde_json::to_string(&req).unwrap();
        let mut res = http_post(self.endpoint, "", &to_send)
            .await
            .map_err(|_| anyhow!("failed to POST to melwalletd"))?;
        let result: JrpcResponse = res
            .body_json()
            .await
            .map_err(|_| anyhow!("Unable to deserialize response"))?;
        return Ok(result);
    }
}
impl DaemonClient {
    /// Creates a new client.
    pub fn new(endpoint: SocketAddr) -> Self {
        Self { endpoint }
    }
}

async fn http_post(endpoint: SocketAddr, _path: &str, body: &str) -> http_types::Result<Response> {
    let conn = TcpStream::connect(endpoint).await?;
    let mut req = Request::new(Method::Post, Url::parse(&format!("http://{}/", endpoint))?);
    req.set_body(body);
    async_h1::connect(conn, req).await
}