alchemy-api 0.1.0

A high-level binding for Alchemy Enhanced APIs, written in Rust.
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

use crate::cores;
use async_trait::async_trait;
use reqwest::{Client, Request};
use url::Url;

/// A representation of the Alchemy API.
#[derive(Clone, Debug)]
pub struct Alchemy {
    /// The client to use for API calls.
    client: Client,
    /// The base URL to use for API calls.
    base_url: Url,
    /// The authentication information to use when communicating with [Alchemy API].
    ///
    /// Will be added as `X-Alchemy-Token` header in every requests.
    auth: String,
}

impl Alchemy {
    /// Create a new Alchemy instance, with X-Alchemy-Token.
    pub fn new(auth: &str) -> Self {
        Self {
            client: Client::new(),
            base_url: Url::parse("https://dashboard.alchemy.com").unwrap(),
            auth: auth.to_string(),
        }
    }
}

#[async_trait]
impl cores::client::Client for Alchemy {
    fn endpoint(&self, endpoint: &str) -> anyhow::Result<Url> {
        self.base_url.join(endpoint).map_err(anyhow::Error::from)
    }

    async fn send(
        &self,
        req: http::request::Builder,
        body: Vec<u8>,
    ) -> anyhow::Result<http::Response<bytes::Bytes>> {
        let http_req = req.body(body)?;
        let mut request: Request = http_req.try_into()?;
        request
            .headers_mut()
            .insert("X-Alchemy-Token", self.auth.parse().unwrap());

        let resp = self.client.execute(request).await?;
        let mut http_resp = http::Response::builder()
            .status(resp.status())
            .version(resp.version());
        let headers = http_resp.headers_mut().unwrap();
        for (key, value) in resp.headers() {
            headers.insert(key, value.clone());
        }

        Ok(http_resp.body(resp.bytes().await?)?)
    }
}