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

use crate::error::DataError;
use barter_integration::model::{Exchange, Instrument};
use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};

/// Convenient new type containing a collection of [`Market<Event>`](Market)s.
#[derive(Debug)]
pub struct MarketIter<Event>(pub Vec<Result<Market<Event>, DataError>>);

impl<Event> FromIterator<Result<Market<Event>, DataError>> for MarketIter<Event> {
    fn from_iter<T>(iter: T) -> Self
    where
        T: IntoIterator<Item = Result<Market<Event>, DataError>>,
    {
        Self(iter.into_iter().collect())
    }
}

/// Normalised Barter [`Market<Event>`](Self) wrapping the `Event` variant in metadata.
///
/// Note: `Event` can be an enum if required.
///
/// See [`crate::subscription`] for all existing Barter Market event variants
/// (eg/ [`Market<PublicTrade>`](crate::subscription::trade::PublicTrade)).
#[derive(Clone, PartialEq, Eq, PartialOrd, Ord, Debug, Deserialize, Serialize)]
pub struct Market<Event> {
    pub exchange_time: DateTime<Utc>,
    pub received_time: DateTime<Utc>,
    pub exchange: Exchange,
    pub instrument: Instrument,
    pub event: Event,
}