mempoolspace 0.1.1

A Rust client library for interacting with the Mempool Space APIs.
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

//! Mempool client builder

#[cfg(feature = "socks")]
use std::net::SocketAddr;
use std::time::Duration;

#[cfg(feature = "socks")]
use reqwest::Proxy;
use reqwest::{Client, ClientBuilder};
use url::Url;

use crate::client::MempoolClient;
use crate::error::Error;

/// Mempool client builder
#[derive(Debug, Clone)]
pub struct MempoolClientBuilder {
    /// Endpoint URL
    pub url: Url,
    /// Timeout for requests
    pub timeout: Duration,
    /// Socks5 proxy
    #[cfg(feature = "socks")]
    pub proxy: Option<SocketAddr>,
}

impl MempoolClientBuilder {
    /// Construct a new builder
    pub fn new(url: Url) -> Self {
        Self {
            url,
            timeout: Duration::from_secs(60),
            #[cfg(feature = "socks")]
            proxy: None,
        }
    }

    /// Set a custom timeout
    #[inline]
    pub fn timeout(mut self, timeout: Duration) -> Self {
        self.timeout = timeout;
        self
    }

    /// Set proxy
    #[inline]
    #[cfg(feature = "socks")]
    pub fn proxy(mut self, proxy: SocketAddr) -> Self {
        self.proxy = Some(proxy);
        self
    }

    /// Build mempool client
    pub fn build(self) -> Result<MempoolClient, Error> {
        // Construct builder
        let mut builder: ClientBuilder = Client::builder();

        // Set proxy
        #[cfg(all(feature = "socks", not(target_arch = "wasm32")))]
        if let Some(proxy) = self.proxy {
            let proxy: String = format!("socks5h://{proxy}");
            builder = builder.proxy(Proxy::all(proxy)?);
        }

        // Set timeout
        builder = builder.timeout(self.timeout);

        // Build client
        let client: Client = builder.build()?;

        // Construct client
        Ok(MempoolClient::from_client(self.url, client))
    }
}