use self::spot::SideEffect;
use super::{MarginOp, Rest, RestEndpoint, RestError};
use serde::Serialize;
pub mod usd_margin_futures;
pub mod spot;
#[derive(Debug, Clone)]
pub struct PlaceOrder {
pub(crate) inner: exc_core::types::PlaceOrder,
}
impl PlaceOrder {
fn dispatch(&self, endpoint: &RestEndpoint) -> Result<PlaceOrderKind, RestError> {
match endpoint {
RestEndpoint::UsdMarginFutures => Ok(PlaceOrderKind::UsdMarginFutures(
usd_margin_futures::PlaceOrder::try_from(&self.inner)?,
)),
RestEndpoint::Spot(options) => {
let mut req = spot::PlaceOrder::try_from(&self.inner)?;
if let Some(margin) = options.margin.as_ref() {
let margin = if self.inner.place.size.is_sign_positive() {
margin.buy.as_ref()
} else {
margin.sell.as_ref()
};
match margin {
Some(MarginOp::Loan) => {
req.side_effect_type = Some(SideEffect::MarginBuy);
}
Some(MarginOp::Repay) => {
req.side_effect_type = Some(SideEffect::AutoRepay);
}
None => {
req.side_effect_type = None;
}
}
}
Ok(PlaceOrderKind::Spot(req))
}
}
}
}
#[derive(Debug, Clone, Serialize)]
#[serde(untagged)]
pub enum PlaceOrderKind {
UsdMarginFutures(usd_margin_futures::PlaceOrder),
Spot(spot::PlaceOrder),
}
impl Rest for PlaceOrder {
fn method(&self, _endpoint: &RestEndpoint) -> Result<http::Method, RestError> {
Ok(http::Method::POST)
}
fn to_path(&self, endpoint: &RestEndpoint) -> Result<String, RestError> {
match endpoint {
RestEndpoint::UsdMarginFutures => Ok("/fapi/v1/order".to_string()),
RestEndpoint::Spot(options) => {
if options.margin.is_some() {
Ok("/sapi/v1/margin/order".to_string())
} else {
Ok("/api/v3/order".to_string())
}
}
}
}
fn need_apikey(&self) -> bool {
true
}
fn need_sign(&self) -> bool {
true
}
fn serialize(&self, endpoint: &RestEndpoint) -> Result<serde_json::Value, RestError> {
Ok(serde_json::to_value(self.dispatch(endpoint)?)?)
}
fn to_payload(&self) -> super::Payload {
super::Payload::new(self.clone())
}
}
#[derive(Debug, Clone, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct GetOrderInner {
pub symbol: String,
#[serde(skip_serializing_if = "Option::is_none")]
pub order_id: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub orig_client_order_id: Option<String>,
}
#[derive(Debug, Clone, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct CancelOrder {
#[serde(flatten)]
pub inner: GetOrderInner,
}
impl Rest for CancelOrder {
fn method(&self, _endpoint: &RestEndpoint) -> Result<http::Method, RestError> {
Ok(http::Method::DELETE)
}
fn to_path(&self, endpoint: &RestEndpoint) -> Result<String, RestError> {
match endpoint {
RestEndpoint::UsdMarginFutures => Ok("/fapi/v1/order".to_string()),
RestEndpoint::Spot(options) => {
if options.margin.is_some() {
Ok("/sapi/v1/margin/order".to_string())
} else {
Ok("/api/v3/order".to_string())
}
}
}
}
fn need_apikey(&self) -> bool {
true
}
fn need_sign(&self) -> bool {
true
}
fn serialize(&self, _endpoint: &RestEndpoint) -> Result<serde_json::Value, RestError> {
Ok(serde_json::to_value(self)?)
}
fn to_payload(&self) -> super::Payload {
super::Payload::new(self.clone())
}
}
#[derive(Debug, Clone, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct GetOrder {
#[serde(flatten)]
pub inner: GetOrderInner,
}
impl Rest for GetOrder {
fn method(&self, _endpoint: &RestEndpoint) -> Result<http::Method, RestError> {
Ok(http::Method::GET)
}
fn to_path(&self, endpoint: &RestEndpoint) -> Result<String, RestError> {
match endpoint {
RestEndpoint::UsdMarginFutures => Ok("/fapi/v1/order".to_string()),
RestEndpoint::Spot(options) => {
if options.margin.is_some() {
Ok("/sapi/v1/margin/order".to_string())
} else {
Ok("/api/v3/order".to_string())
}
}
}
}
fn need_apikey(&self) -> bool {
true
}
fn need_sign(&self) -> bool {
true
}
fn serialize(&self, _endpoint: &RestEndpoint) -> Result<serde_json::Value, RestError> {
Ok(serde_json::to_value(self)?)
}
fn to_payload(&self) -> super::Payload {
super::Payload::new(self.clone())
}
}