risq 0.4.1

Re-implementation of Bisq (https://github.com/bisq-network/bisq) in 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

use crate::domain::amount::*;
use std::time::SystemTime;

pub struct Volume {
    pub period_start: SystemTime,
    pub volume: NumberWithPrecision,
    pub num_trades: u32,
}

#[cfg(feature = "statistics")]
pub use inner::*;
#[cfg(feature = "statistics")]
mod inner {
    use super::*;
    use crate::domain::{
        market::*,
        statistics::{interval::*, trade::*},
    };
    use std::time::SystemTime;

    impl Volume {
        pub fn from_trades(
            history: &TradeHistory,
            market: Option<&'static Market>,
            interval: Option<Interval>,
        ) -> Vec<Volume> {
            let interval = interval.unwrap_or(Interval::Year);
            let from = match history.first_trade_time() {
                None => return Vec::new(),
                Some(time) => time,
            };

            let mut ret = Vec::new();
            let mut trades = history
                .iter()
                .filter(|t| market.map(|m| t.market.pair == m.pair).unwrap_or(true));
            let mut trade = match trades.next() {
                None => return ret,
                Some(next) => next,
            };
            for (period_start, end) in interval.intervals(from, SystemTime::now()) {
                while trade.timestamp < period_start {
                    trade = match trades.next() {
                        None => return ret,
                        Some(next) => next,
                    };
                }
                if trade.timestamp >= end {
                    continue;
                }
                let mut current = Volume {
                    period_start,
                    volume: ZERO,
                    num_trades: 0,
                };
                while trade.timestamp < end {
                    current.volume += if trade.market.non_btc_side().is_crypto() {
                        trade.volume
                    } else {
                        trade.amount
                    };
                    current.num_trades += 1;
                    trade = match trades.next() {
                        None => {
                            ret.push(current);
                            return ret;
                        }
                        Some(next) => next,
                    };
                }
                ret.push(current);
            }
            ret
        }
    }
}