sfox 0.1.6

Unofficial HTTP and Websocket Client for the SFox API
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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103

use std::collections::HashMap;

use futures_util::Future;
use serde::Deserialize;

use super::super::{Client, HttpError, HttpVerb};

#[derive(Clone, Debug, Deserialize)]
pub struct CryptoDepositAddress {
    pub address: String,
    pub currency: String,
}

static CRYPTO_DEPOSIT_ADDRESS_RESOURCE: &str = "user/deposit/address";

impl Client {
    pub fn crypto_deposit_address(
        self,
        currency: &str,
    ) -> impl Future<Output = Result<Vec<CryptoDepositAddress>, HttpError>> {
        let url = self.url_for_v1_resource(&currency_path(currency));
        self.request::<Vec<CryptoDepositAddress>>(HttpVerb::Get, &url, None)
    }

    pub fn new_crypto_deposit_address(
        self,
        currency: &str,
    ) -> impl Future<Output = Result<CryptoDepositAddress, HttpError>> {
        let url = self.url_for_v1_resource(&currency_path(currency));
        self.request(HttpVerb::Post, &url, Some(&HashMap::new()))
    }
}

fn currency_path(currency: &str) -> String {
    format!("{}/{}", CRYPTO_DEPOSIT_ADDRESS_RESOURCE, currency)
}

#[cfg(test)]
mod tests {
    use super::*;

    use crate::util::server::{new_test_server_and_client, ApiMock};

    const GET_RESPONSE_BODY: &str = r#"
        [
            {
                "address": "0x123456789",
                "currency": "eth"
            },
            {
                "address": "0x987654321",
                "currency": "btc"
            }
        ]
    "#;

    const POST_RESPONSE_BODY: &str = r#"
        {
            "address": "0x123456789",
            "currency": "eth"
        }
    "#;

    #[tokio::test]
    async fn test_crypto_deposit_address() {
        let mock = ApiMock {
            action: HttpVerb::Get,
            body: GET_RESPONSE_BODY.into(),
            path: format!("/v1/{}/btc", CRYPTO_DEPOSIT_ADDRESS_RESOURCE),
            response_code: 200,
        };

        let (client, _server, mock_results) = new_test_server_and_client(vec![mock]).await;

        let result = client.crypto_deposit_address("btc").await;

        assert!(result.is_ok());

        for mock in mock_results {
            mock.assert_async().await;
        }
    }

    #[tokio::test]
    async fn test_new_crypto_deposit_address() {
        let mock = ApiMock {
            action: HttpVerb::Post,
            body: POST_RESPONSE_BODY.into(),
            path: format!("/v1/{}/btc", CRYPTO_DEPOSIT_ADDRESS_RESOURCE),
            response_code: 200,
        };

        let (client, _server, mock_results) = new_test_server_and_client(vec![mock]).await;

        let result = client.new_crypto_deposit_address("btc").await;

        assert!(result.is_ok());

        for mock in mock_results {
            mock.assert_async().await;
        }
    }
}