bpx_api_client/routes/
order.rs

1use bpx_api_types::order::{CancelOpenOrdersPayload, CancelOrderPayload, ExecuteOrderPayload, Order};
2
3use crate::error::{Error, Result};
4use crate::BpxClient;
5
6#[doc(hidden)]
7pub const API_ORDER: &str = "/api/v1/order";
8#[doc(hidden)]
9pub const API_ORDERS: &str = "/api/v1/orders";
10
11impl BpxClient {
12    /// Fetches a specific open order by symbol and either order ID or client ID.
13    pub async fn get_open_order(&self, symbol: &str, order_id: Option<&str>, client_id: Option<u32>) -> Result<Order> {
14        let mut url = format!("{}{}?symbol={}", self.base_url, API_ORDER, symbol);
15        if let Some(order_id) = order_id {
16            url.push_str(&format!("&orderId={}", order_id));
17        } else {
18            url.push_str(&format!(
19                "&clientId={}",
20                client_id
21                    .ok_or_else(|| Error::InvalidRequest("either order_id or client_id is required".to_string()))?
22            ));
23        }
24        let res = self.get(url).await?;
25        res.json().await.map_err(Into::into)
26    }
27
28    /// Executes a new order with the given payload.
29    pub async fn execute_order(&self, payload: ExecuteOrderPayload) -> Result<Order> {
30        let endpoint = format!("{}{}", self.base_url, API_ORDER);
31        let res = self.post(endpoint, payload).await?;
32        res.json().await.map_err(Into::into)
33    }
34
35    /// Cancels a specific order by symbol and either order ID or client ID.
36    pub async fn cancel_order(&self, symbol: &str, order_id: Option<&str>, client_id: Option<u32>) -> Result<Order> {
37        let url = format!("{}{}", self.base_url, API_ORDER);
38        let payload = CancelOrderPayload {
39            symbol: symbol.to_string(),
40            order_id: order_id.map(|s| s.to_string()),
41            client_id,
42        };
43
44        let res = self.delete(url, payload).await?;
45        res.json().await.map_err(Into::into)
46    }
47
48    /// Retrieves all open orders, optionally filtered by symbol.
49    pub async fn get_open_orders(&self, symbol: Option<&str>) -> Result<Vec<Order>> {
50        let mut url = format!("{}{}", self.base_url, API_ORDERS);
51        if let Some(s) = symbol {
52            url.push_str(&format!("?symbol={s}"));
53        }
54        let res = self.get(url).await?;
55        res.json().await.map_err(Into::into)
56    }
57
58    /// Cancels all open orders matching the specified payload.
59    pub async fn cancel_open_orders(&self, payload: CancelOpenOrdersPayload) -> Result<Vec<Order>> {
60        let url = format!("{}{}", self.base_url, API_ORDERS);
61        let res = self.delete(url, payload).await?;
62        res.json().await.map_err(Into::into)
63    }
64}
bpx_api_client/routes/order.rs

bpx_api_client/routes/
order.rs
