dinzai-datni 0.1.1

Cryptocurrency ticker library for Rust.
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

use rustc_serialize::json;
use rustc_serialize::Decodable;
use core;
use core::{Currency, Pair, TickerError};

#[derive(RustcEncodable, RustcDecodable, Debug)]
pub struct Ticker {
    last: f32,
    pub high: f32,
    pub low: f32,
    pub vwap: f32,
    pub volume: f32,
    bid: f32,
    ask: f32,
}

impl core::Ticker for Ticker {
    fn last(&self) -> f32 {
        self.last
    }
    fn bid(&self) -> f32 {
        self.bid
    }
    fn ask(&self) -> f32 {
        self.ask
    }
}

pub fn ticker(pair: Pair) -> Result<Ticker, TickerError> {
    let pair_str = match pair {
        (Currency::BTC, Currency::JPY) => "btc_jpy",
        (Currency::MONA, Currency::JPY) => "mona_jpy",
        (Currency::BTC, Currency::MONA) => "btc_mona",
        _ => return Err(TickerError::NotSupportPair),
    };
    let version = 1;
    let base_url = "https://api.zaif.jp/api";
    let url_string = format!("{}/{}/ticker/{}", base_url, version, pair_str);
    let json = core::get_json(&url_string);
    let mut decoder = json::Decoder::new(json);
    let result = Ticker::decode(&mut decoder);
    match  result {
        Ok(x) => Ok(x),
        Err(e) => Err(TickerError::DecoderError(e)),
    }
}

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

    #[test]
    fn test_ticker_okay() {
        let pair = (Currency::BTC, Currency::JPY);
        let ticker = ticker(pair);
        assert!(ticker.is_ok());
        println!("{:?}", ticker.ok().unwrap());
    }

    #[test]
    fn test_ticker_invalid_pair() {
        let pair = (Currency::BTC, Currency::USD);
        let ticker = ticker(pair);
        assert!(ticker.is_err());
    }
}