use jiff::Timestamp;
use reqwest::Method;
use serde::{Deserialize, Serialize};
use crate::{enums::SecurityType, rest_api::endpoint, web_socket_api::web_socket};
endpoint!(
"/api/v3/myAllocations",
Method::GET,
SecurityType::UserData,
QueryAllocationsEndpoint,
QueryAllocationsParams,
QueryAllocationsResponse
);
pub struct QueryAllocationsEndpoint<'r> {
client: &'r crate::rest_api::RestApiClient,
}
impl<'r> QueryAllocationsEndpoint<'r> {
pub fn new(client: &'r crate::rest_api::RestApiClient) -> Self {
Self { client }
}
}
#[derive(Debug, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct QueryAllocationsParams {
symbol: String,
#[serde(skip_serializing_if = "Option::is_none")]
start_time: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
end_time: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
from_allocation_id: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
limit: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
order_id: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
recv_window: Option<i64>,
timestamp: i64,
}
impl QueryAllocationsParams {
pub fn new(symbol: &str) -> Self {
Self {
symbol: symbol.to_owned(),
start_time: None,
end_time: None,
from_allocation_id: None,
limit: None,
order_id: None,
recv_window: None,
timestamp: Timestamp::now().as_millisecond(),
}
}
pub fn start_time(mut self, start_time: i64) -> Self {
self.start_time = Some(start_time);
self
}
pub fn end_time(mut self, end_time: i64) -> Self {
self.end_time = Some(end_time);
self
}
pub fn from_allocation_id(mut self, from_allocation_id: i64) -> Self {
self.from_allocation_id = Some(from_allocation_id);
self
}
pub fn limit(mut self, limit: i64) -> Self {
self.limit = Some(limit);
self
}
pub fn order_id(mut self, order_id: i64) -> Self {
self.order_id = Some(order_id);
self
}
pub fn recv_window(mut self, recv_window: i64) -> Self {
self.recv_window = Some(recv_window);
self
}
}
pub type QueryAllocationsResponse = Vec<Allocation>;
#[derive(Debug, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct Allocation {
pub symbol: String,
pub allocation_id: i64,
pub allocation_type: String,
pub order_id: i64,
pub order_list_id: i64,
pub price: String,
pub qty: String,
pub quote_qty: String,
pub commission: String,
pub commission_asset: String,
pub time: i64,
pub is_buyer: bool,
pub is_maker: bool,
pub is_allocator: bool,
}
web_socket!(
"myAllocations",
QueryAllocationsWebSocket,
QueryAllocationsParams,
QueryAllocationsResponse
);
pub struct QueryAllocationsWebSocket<'w> {
client: &'w crate::web_socket_api::WebSocketApiClient,
}
impl<'w> QueryAllocationsWebSocket<'w> {
pub fn new(client: &'w crate::web_socket_api::WebSocketApiClient) -> Self {
Self { client }
}
}