rustlink 0.0.4

A lightweight and easy-to-use library for periodically retrieving data from the Chainlink decentralized data feed.
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

/// # Rustlink
/// This library provides a simple interface to fetch price data from the Chainlink decentralized data feed.
/// Core is the main module that contains the main struct `Rustlink` that you will need to interact with.
pub mod core;
mod error;
mod fetcher;
mod interface;
#[cfg(test)]
mod tests {

    use async_std::channel::unbounded;

    use crate::core::{Reflector, Rustlink};

    #[tokio::test]
    async fn ensure_price_is_received() {
        let mut contracts: Vec<(String, String)> = Vec::new();
        contracts.push((
            "ETH".to_string(),
            "0x9ef1B8c0E4F7dc8bF5719Ea496883DC6401d5b2e".to_string(),
        ));

        let (sender, receiver) = unbounded();

        let rustlink = Rustlink::try_new(
            "https://bsc-dataseed1.binance.org/",
            1,
            Reflector::Sender(sender),
            contracts,
            std::time::Duration::from_secs(3),
        )
        .unwrap();

        rustlink.start();
        let round_data = receiver.recv().await.unwrap();
        println!("Received data: {:#?}", round_data);
        assert!(round_data.answer.ge(&0f64));
    }
}