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
68
69
70
71
72
73
74
75
76
77

use std::io::Read;
use std::io;
use rustc_serialize::json::DecoderError;
use rustc_serialize::json::Json;
use hyper::Url;
use hyper::Client;
use hyper::header::{Connection, ConnectionOption};

pub enum ServerList {
    Zaif,
    Coincheck,
    BitBankTrade,
    BitFlyer,
    BtcE,
}

pub enum Currency {
    FXBTC,
    BTC,
    LTC,
    MONA,
    PPC,
    NMC,
    NVC,

    JPY,
    USD,
    RUR,
    EUR,
}

pub type Pair = (Currency, Currency);

pub enum TickerError {
    NotSupportPair,
    DecoderError(DecoderError),
    Other,
}

pub trait Ticker {
    fn last(&self) -> f32;
    fn bid(&self) -> f32;
    fn ask(&self) -> f32;
}

pub trait HasHighLow : Ticker {
    fn high(&self) -> f32;
    fn low(&self) -> f32;
}

pub trait HasVolume : Ticker {
    fn volume(&self) -> f32;
}

pub trait HasVwap : Ticker {
    fn vwap(&self) -> f32;
}

/// Get request
fn get(url: Url) -> Result<String, io::Error> {
    let client = Client::new();
    let mut res = client.get(url)
        .header(Connection(vec![ConnectionOption::Close]))
        .send().unwrap();
    // Read the Response.
    let mut body = String::new();
    match res.read_to_string(&mut body) {
        Ok(_) => { Ok(body) },
        Err(e) => { Err(e) },
    }
}

pub fn get_json(url_string: &str) -> Json {
    let url = Url::parse(&url_string).unwrap();
    let result = get(url).unwrap();
    Json::from_str(&result).ok().expect("Can not decode a json value from the string")
}