binance-rs

Rust Library for the Binance API

Usage

Add this to your Cargo.toml

toml [dependencies] binance = { git = "https://github.com/wisespace-io/binance-rs.git" }

MARKET DATA

``` extern crate binance;

use binance::api::; use binance::market::;

fn main() { let market: Market = Binance::new(None, None);

// Order book
match market.get_depth("BNBETH".into()) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
}         

// Latest price for ALL symbols
match market.get_all_prices() {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
} 

// Latest price for ONE symbol
match market.get_price("KNCETH".into()) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
} 

// Best price/qty on the order book for ALL symbols
match market.get_all_book_tickers("BNBETH".into()) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
}

// Best price/qty on the order book for ONE symbol
match market.get_book_ticker("BNBETH".into()) {
    Ok(answer) => println!("Bid Price: {}, Ask Price: {}", answer.bid_price, answer.ask_price),
    Err(e) => println!("Error: {}", e),
}     

// 24hr ticker price change statistics
match market.get_24h_price_stats("BNBETH".into()) {
    Ok(answer) => println!("Open Price: {}, Higher Price: {}, Lower Price: {:?}",
                            answer.open_price, answer.high_price, answer.low_price),
    Err(e) => println!("Error: {}", e),
}

} ```

ACCOUNT DATA

``` extern crate binance;

use binance::api::; use binance::account::;

fn main() { let apikey = Some("YOURAPIKEY".into()); let secretkey = Some("YOURSECRETKEY".into());

let account: Account = Binance::new(api_key, secret_key);

match account.get_account() {
    Ok(answer) => println!("{:?}", answer.balances),
    Err(e) => println!("Error: {}", e),
}

match account.get_open_orders("WTCETH".into()) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
} 

match account.limit_buy("WTCETH".into(), 10, 0.014000) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
}

match account.market_buy("WTCETH".into(), 5) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
}

match account.limit_sell("WTCETH".into(), 10, 0.035000) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
}

match account.market_sell("WTCETH".into(), 5) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
}

let order_id = 1957528;
match account.order_status("WTCETH".into(), order_id) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
}

match account.cancel_order("WTCETH".into(), order_id) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
}   

match account.get_balance("KNC".into()) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
}

match account.trade_history("WTCETH".into()) {
    Ok(answer) => println!("{:?}", answer),
    Err(e) => println!("Error: {}", e),
}

} ```

USER STREAM

``` extern crate binance;

use binance::api::; use binance::userstream::;

fn main() { let apikeyuser = Some("YOURAPIKEY".into()); let userstream: UserStream = Binance::new(apikey_user.clone(), None);

if let Ok(answer) = user_stream.start() {
    println!("Data Stream Started ...");
    let listen_key = answer.listen_key;

    match user_stream.keep_alive(listen_key.clone()) {
        Ok(msg) => println!("Keepalive user data stream: {:?}", msg),
        Err(e) => println!("Error: {}", e),
    }

    match user_stream.close(listen_key.clone()) {
        Ok(msg) => println!("Close user data stream: {:?}", msg),
        Err(e) => println!("Error: {}", e),
    }       
} else {
    println!("Not able to start an User Stream (Check your API_KEY)");
};

} ```

WEBSOCKETS - USER STREAM

``` extern crate binance;

use binance::api::; use binance::userstream::; use binance::websockets::*; use binance::model::{AccountUpdateEvent, OrderTradeEvent};

struct WebSocketHandler;

impl UserStreamEventHandler for WebSocketHandler { fn accountupdatehandler(&self, event: &AccountUpdateEvent) { for balance in &event.balance { println!("Asset: {}, free: {}, locked: {}", balance.asset, balance.free, balance.locked); } }

fn order_trade_handler(&self, event: &OrderTradeEvent) {
    println!("Symbol: {}, Side: {}, Price: {}, Execution Type: {}", 
             event.symbol, event.side, event.price, event.execution_type);
}

}

fn main() { let apikeyuser = Some("YOURKEY".into()); let userstream: UserStream = Binance::new(apikeyuser, None);

if let Ok(answer) = user_stream.start() {
    let listen_key = answer.listen_key;

    let mut web_socket: WebSockets = WebSockets::new();
    web_socket.add_user_stream_handler(WebSocketHandler);
    web_socket.connect(listen_key).unwrap(); // check error
    web_socket.event_loop();

} else {
    println!("Not able to start an User Stream (Check your API_KEY)");
};

} ```

WEBSOCKETS - TRADES

``` extern crate binance;

use binance::api::; use binance::userstream::; use binance::websockets::*; use binance::model::{TradesEvent};

struct WebSocketHandler;

impl MarketEventHandler for WebSocketHandler {
    fn aggregated_trades_handler(&self, event: &TradesEvent) {
        println!("Symbol: {}, price: {}, qty: {}", event.symbol, event.price, event.qty);
    }     
}

fn main() { let aggtrade: String = format!("{}@aggTrade", "ethbtc"); let mut websocket: WebSockets = WebSockets::new();

web_socket.add_market_handler(WebSocketHandler);
web_socket.connect(agg_trade).unwrap(); // check error  
web_socket.event_loop();

} ```