bullet_ws_interface/
client.rs

1use serde::{Deserialize, Serialize};
2
3use crate::RequestId;
4
5/// Parameters for order operations
6#[derive(Serialize, Deserialize, Clone, Debug)]
7pub struct OrderParams {
8    /// Base64-encoded raw transaction bytes
9    pub tx: String,
10}
11
12/// Messages sent from client to server (Binance-style)
13#[derive(Serialize, Deserialize, Clone, Debug)]
14#[serde(tag = "method", rename_all = "SCREAMING_SNAKE_CASE")]
15pub enum ClientMessage {
16    #[serde(alias = "subscribe")]
17    Subscribe {
18        id: Option<RequestId>,
19        #[serde(default)]
20        params: Vec<String>,
21    },
22
23    #[serde(alias = "unsubscribe")]
24    Unsubscribe {
25        id: Option<RequestId>,
26        #[serde(default)]
27        params: Vec<String>,
28    },
29
30    #[serde(alias = "list_subscriptions")]
31    ListSubscriptions { id: Option<RequestId> },
32
33    #[serde(alias = "ping")]
34    Ping { id: Option<RequestId> },
35
36    /// Place an order via the rollup WebSocket
37    #[serde(alias = "order.place", rename = "ORDER.PLACE")]
38    OrderPlace { id: Option<RequestId>, params: OrderParams },
39
40    /// Cancel an order via the rollup WebSocket
41    #[serde(alias = "order.cancel", rename = "ORDER.CANCEL")]
42    OrderCancel { id: Option<RequestId>, params: OrderParams },
43
44    /// Amend an order via the rollup WebSocket
45    #[serde(alias = "order.amend", alias = "order.modify", rename = "ORDER.AMEND")]
46    OrderAmend { id: Option<RequestId>, params: OrderParams },
47
48    /// Cancel all open orders via the rollup WebSocket
49    #[serde(alias = "order.cancelAll", rename = "ORDER.CANCEL_ALL")]
50    OrderCancelAll { id: Option<RequestId>, params: OrderParams },
51}
bullet_ws_interface/client.rs

bullet_ws_interface/
client.rs
