exc 0.7.3

The abstraction layer of exchanges.
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
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::ops::{Bound, RangeBounds};

use crate::core::types::Period;
use futures::{future::BoxFuture, FutureExt};
use time::OffsetDateTime;
use tower::ServiceExt;

use crate::core::types::candle::{CandleStream, QueryCandles};

use crate::ExcService;

/// Fetch candles service.
pub trait FetchCandlesService {
    /// Query candles
    fn fetch_candles(
        &mut self,
        inst: &str,
        period: Period,
        start: Bound<OffsetDateTime>,
        end: Bound<OffsetDateTime>,
    ) -> BoxFuture<'_, crate::Result<CandleStream>>;
}

impl<S> FetchCandlesService for S
where
    S: ExcService<QueryCandles> + Send,
    S::Future: Send,
{
    fn fetch_candles(
        &mut self,
        inst: &str,
        period: Period,
        start: Bound<OffsetDateTime>,
        end: Bound<OffsetDateTime>,
    ) -> BoxFuture<'_, crate::Result<CandleStream>> {
        ServiceExt::<QueryCandles>::oneshot(
            self.as_service(),
            QueryCandles::new(inst, period, (start, end)),
        )
        .boxed()
    }
}

/// Helper methods for fetch candle services.
pub trait FetchCandlesServiceExt: FetchCandlesService {
    /// Fetch candles in range.
    fn fetch_candles_range(
        &mut self,
        inst: impl AsRef<str>,
        period: Period,
        range: impl RangeBounds<OffsetDateTime>,
    ) -> BoxFuture<'_, crate::Result<CandleStream>> {
        self.fetch_candles(
            inst.as_ref(),
            period,
            range.start_bound().cloned(),
            range.end_bound().cloned(),
        )
    }
}

impl<S: FetchCandlesService> FetchCandlesServiceExt for S {}

impl<'a> FetchCandlesService for Box<dyn FetchCandlesService + 'a> {
    fn fetch_candles(
        &mut self,
        inst: &str,
        period: Period,
        start: Bound<OffsetDateTime>,
        end: Bound<OffsetDateTime>,
    ) -> BoxFuture<'_, crate::Result<CandleStream>> {
        self.as_mut().fetch_candles(inst, period, start, end)
    }
}

#[cfg(feature = "fetch-candles")]
pub use crate::core::util::fetch_candles::*;