blockfrost 1.2.3

A Rust SDK for Blockfrost.io 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
104
105
106

use crate::*;
use blockfrost_openapi::models::{
    nutlink_address::NutlinkAddress, nutlink_address_ticker_inner::NutlinkAddressTickerInner,
    nutlink_address_tickers_inner::NutlinkAddressTickersInner,
    nutlink_tickers_ticker_inner::NutlinkTickersTickerInner,
};

impl BlockfrostAPI {
    /// Return the metadata for a Nut.link oracle address.
    pub async fn nutlink_address(&self, address: &str) -> BlockfrostResult<NutlinkAddress> {
        self.call_endpoint(format!("/nutlink/{address}").as_str())
            .await
    }

    /// Return the list of tickers for a Nut.link oracle address.
    pub async fn nutlink_address_tickers(
        &self, address: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<NutlinkAddressTickersInner>> {
        self.call_paged_endpoint(format!("/nutlink/{address}/tickers").as_str(), pagination)
            .await
    }

    /// Return the records for a specific ticker from a Nut.link oracle address.
    pub async fn nutlink_address_ticker_by_id(
        &self, address: &str, ticker: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<NutlinkAddressTickerInner>> {
        self.call_paged_endpoint(
            format!("/nutlink/{address}/tickers/{ticker}").as_str(),
            pagination,
        )
        .await
    }

    /// Return the records for a specific ticker from all Nut.link oracle addresses.
    pub async fn nutlink_ticker_by_id(
        &self, ticker: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<NutlinkTickersTickerInner>> {
        self.call_paged_endpoint(format!("/nutlink/tickers/{ticker}").as_str(), pagination)
            .await
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use blockfrost_openapi::models::nutlink_address_tickers_inner::NutlinkAddressTickersInner;
    use serde_json::json;

    #[tokio::test]
    async fn test_nutlink_address() {
        let json_value = json!({
            "address": "addr1qxqs59lphg8g6qndelq8xwqn60ag3aeyfcp33c2kdp46a09re5df3pzwwmyq946axfcejy5n4x0y99wqpgtp2gd0k09qsgy6pz",
            "metadata_url": "https://nut.link/metadata.json",
            "metadata_hash": "6bf124f217d0e5a0a8adb1dbd8540e1334280d49ab861127868339f43b3948af",
            "metadata": {}
        });

        serde_json::from_value::<NutlinkAddress>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_nutlink_address_tickers() {
        let json_value = json!([
            {
                "name": "ADAUSD",
                "count": 1980038,
                "latest_block": 2657092
            },
            {
                "name": "ADAEUR",
                "count": 1980038,
                "latest_block": 2657092
            },
            {
                "name": "ADABTC",
                "count": 1980038,
                "latest_block": 2657092
            }
        ]);

        serde_json::from_value::<Vec<NutlinkAddressTickersInner>>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_nutlink_address_ticker_detailed() {
        let json_value = json!([
            {
                "tx_hash": "e8073fd5318ff43eca18a852527166aa8008bee9ee9e891f585612b7e4ba700b",
                "block_height": 2657092,
                "tx_index": 8,
                "payload": [
                    {
                        "source": "coinGecko",
                        "value": "1.29"
                    },
                    {
                        "source": "cryptoCompare",
                        "value": "1.283"
                    }
                ]
            }
        ]);

        serde_json::from_value::<Vec<NutlinkAddressTickerInner>>(json_value).unwrap();
    }
}