ecbt_exchange/model/
websocket.rs

1use super::{OrderBookResponse, Trade};
2use crate::model::market_pair::MarketPair;
3use crate::model::{OrderStatus, OrderType, Side};
4use serde::{Deserialize, Serialize};
5use std::ops::Range;
6
7/// This struct represents the account order
8#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, Hash)]
9pub struct AccountOrders {
10    pub market: Option<MarketPair>,
11    pub order_type: Option<Vec<OrderType>>,
12    pub buy_or_sell: Option<Side>,
13    pub range: Option<Range<u64>>,
14    pub status: Option<Vec<OrderStatus>>,
15}
16
17/// This enum represents a subscription
18#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, Hash)]
19pub enum Subscription {
20    // Ticker(MarketPair),           // symbol
21    OrderBookUpdates(MarketPair), // symbol
22    Trades(MarketPair),           // symbol
23                                  // AccountTrades(MarketPair),    // symbol
24                                  // AccountBalance(MarketPair),   // symbol
25                                  // AccountOrders(AccountOrders),
26}
27
28/// This enum represents a websocket response
29#[derive(Debug, Clone)]
30pub enum WebSocketResponse<T> {
31    Generic(EcbtWebSocketMessage),
32    Raw(T),
33}
34
35/// This enum represents a websocket message type
36#[derive(Debug, Clone, Serialize)]
37pub enum EcbtWebSocketMessage {
38    Ping,
39    OrderBook(OrderBookResponse),
40    // OrderBookDiff(OrderBookResponse),
41    Trades(Vec<Trade>),
42}