sandbox-quant 1.0.7

Exchange-truth trading core for Binance Spot and Futures
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

use crate::error::exchange_error::ExchangeError;
use crate::exchange::facade::ExchangeFacade;
use crate::exchange::types::AuthoritativeSnapshot;
use crate::portfolio::reconcile::apply_authoritative_snapshot;
use crate::portfolio::snapshot::PortfolioStateSnapshot;
use crate::portfolio::staleness::StalenessState;

#[derive(Debug, Clone, PartialEq)]
pub struct PortfolioStateStore {
    pub snapshot: PortfolioStateSnapshot,
    pub staleness: StalenessState,
}

impl Default for PortfolioStateStore {
    fn default() -> Self {
        Self {
            snapshot: PortfolioStateSnapshot::default(),
            staleness: StalenessState::Fresh,
        }
    }
}

impl PortfolioStateStore {
    pub fn apply_snapshot(&mut self, snapshot: AuthoritativeSnapshot) {
        self.snapshot = apply_authoritative_snapshot(snapshot);
        self.staleness = StalenessState::Fresh;
    }

    pub fn mark_market_data_stale(&mut self) {
        self.staleness = StalenessState::MarketDataStale;
    }

    pub fn mark_account_state_stale(&mut self) {
        self.staleness = StalenessState::AccountStateStale;
    }

    pub fn mark_reconciliation_stale(&mut self) {
        self.staleness = StalenessState::ReconciliationStale;
    }

    /// Exchange snapshots always win here.
    /// Local runtime cache is authoritative only until a fresher exchange snapshot arrives.
    pub fn refresh_from_exchange<E: ExchangeFacade<Error = ExchangeError>>(
        &mut self,
        exchange: &E,
    ) -> Result<(), ExchangeError> {
        let snapshot = exchange.load_authoritative_snapshot()?;
        self.apply_snapshot(snapshot);
        Ok(())
    }
}