openlimits_exchange/model/
websocket.rs

1use super::{OrderBookResponse, Trade};
2use crate::model::{OrderStatus, OrderType, Side};
3use serde::{Deserialize, Serialize};
4use std::ops::Range;
5use crate::model::market_pair::MarketPair;
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(OpenLimitsWebSocketMessage),
32    Raw(T),
33}
34
35/// This enum represents a websocket message type
36#[derive(Debug, Clone, Serialize)]
37pub enum OpenLimitsWebSocketMessage {
38    Ping,
39    OrderBook(OrderBookResponse),
40    // OrderBookDiff(OrderBookResponse),
41    Trades(Vec<Trade>),
42}