kucoin_arbitrage 0.0.2

Kucoin Arbitrage Framework in Async Rust
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

use std::collections::HashMap;

pub type PVMap = HashMap<String, String>; //Prices to Volume
#[derive(Debug, Clone, Default)]
pub struct Orderbook {
    pub ask: PVMap,
    pub bid: PVMap,
    pub time: i64,
    pub sequence: u64,
}

pub type FullOrderbook = HashMap<String, Orderbook>; //Symbols to Orderbook

impl Orderbook {
    pub fn new() -> Orderbook {
        Orderbook {
            ask: PVMap::new(),
            bid: PVMap::new(),
            time: chrono::offset::Utc::now().timestamp(),
            sequence: 0,
        }
    }

    pub fn merge(&mut self, to_merge: Orderbook) -> Result<(), ()> {
        if self.sequence > to_merge.sequence || self.time > to_merge.time {
            return Err(());
        }
        // make sure that to_merge's PVMaps are already filtered such that
        // it is all behind the starting sequence
        self.sequence = to_merge.sequence;
        self.time = to_merge.time;
        for (price, volume) in to_merge.ask.into_iter() {
            self.ask.insert(price, volume);
        }
        for (price, volume) in to_merge.bid.into_iter() {
            self.bid.insert(price, volume);
        }
        Ok(())
    }
}