ig_client/model/

requests.rs

/******************************************************************************
   Author: Joaquín Béjar García
   Email: jb@taunais.com
   Date: 19/10/25
******************************************************************************/
use crate::constants::{DEFAULT_ORDER_BUY_LEVEL, DEFAULT_ORDER_SELL_LEVEL};
use crate::presentation::account::WorkingOrder;
use crate::presentation::order::{Direction, OrderType, TimeInForce};
use chrono::{Duration, Utc};
use pretty_simple_display::{DebugPretty, DisplaySimple};
use serde::{Deserialize, Serialize};
use std::fmt;
use std::fmt::{Debug, Display};

/// Parameters for getting recent prices (API v3)
#[derive(Clone, Default, Deserialize, Serialize)]
pub struct RecentPricesRequest<'a> {
    /// Instrument epic
    pub epic: &'a str,
    /// Optional price resolution (default: MINUTE)
    pub resolution: Option<&'a str>,
    /// Optional start date time (yyyy-MM-dd'T'HH:mm:ss)
    pub from: Option<&'a str>,
    /// Optional end date time (yyyy-MM-dd'T'HH:mm:ss)
    pub to: Option<&'a str>,
    /// Optional max number of price points (default: 10)
    #[serde(rename = "max")]
    pub max_points: Option<u32>,
    /// Optional page size (default: 20, disable paging = 0)
    #[serde(rename = "pageSize")]
    pub page_size: Option<u32>,
    /// Optional page number (default: 1)
    #[serde(rename = "pageNumber")]
    pub page_number: Option<u32>,
}

impl<'a> RecentPricesRequest<'a> {
    /// Create new parameters with just the epic (required field)
    #[must_use]
    pub fn new(epic: &'a str) -> Self {
        Self {
            epic,
            ..Default::default()
        }
    }

    /// Set the resolution
    #[must_use]
    pub fn with_resolution(mut self, resolution: &'a str) -> Self {
        self.resolution = Some(resolution);
        self
    }

    /// Set the from date
    #[must_use]
    pub fn with_from(mut self, from: &'a str) -> Self {
        self.from = Some(from);
        self
    }

    /// Set the to date
    #[must_use]
    pub fn with_to(mut self, to: &'a str) -> Self {
        self.to = Some(to);
        self
    }

    /// Set the max points
    #[must_use]
    pub fn with_max_points(mut self, max_points: u32) -> Self {
        self.max_points = Some(max_points);
        self
    }

    /// Set the page size
    #[must_use]
    pub fn with_page_size(mut self, page_size: u32) -> Self {
        self.page_size = Some(page_size);
        self
    }

    /// Set the page number
    #[must_use]
    pub fn with_page_number(mut self, page_number: u32) -> Self {
        self.page_number = Some(page_number);
        self
    }
}

impl Display for RecentPricesRequest<'_> {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        let json = serde_json::to_string(self).unwrap_or_else(|_| "Invalid JSON".to_string());
        write!(f, "{}", json)
    }
}

impl Debug for RecentPricesRequest<'_> {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        let json =
            serde_json::to_string_pretty(self).unwrap_or_else(|_| "Invalid JSON".to_string());
        write!(f, "{}", json)
    }
}

/// Model for creating a new order
#[derive(DebugPretty, DisplaySimple, Clone, Serialize, Deserialize)]
pub struct CreateOrderRequest {
    /// Instrument EPIC identifier
    pub epic: String,
    /// Order direction (buy or sell)
    pub direction: Direction,
    /// Order size/quantity
    pub size: f64,
    /// Type of order (market, limit, etc.)
    #[serde(rename = "orderType")]
    pub order_type: OrderType,
    /// Order duration (how long the order remains valid)
    #[serde(rename = "timeInForce")]
    pub time_in_force: TimeInForce,
    /// Price level for limit orders
    #[serde(skip_serializing_if = "Option::is_none")]
    pub level: Option<f64>,
    /// Whether to use a guaranteed stop
    #[serde(rename = "guaranteedStop")]
    pub guaranteed_stop: bool,
    /// Price level for stop loss
    #[serde(rename = "stopLevel", skip_serializing_if = "Option::is_none")]
    pub stop_level: Option<f64>,
    /// Stop loss distance
    #[serde(rename = "stopDistance", skip_serializing_if = "Option::is_none")]
    pub stop_distance: Option<f64>,
    /// Price level for take profit
    #[serde(rename = "limitLevel", skip_serializing_if = "Option::is_none")]
    pub limit_level: Option<f64>,
    /// Take profit distance
    #[serde(rename = "limitDistance", skip_serializing_if = "Option::is_none")]
    pub limit_distance: Option<f64>,
    /// Expiry date for the order
    #[serde(skip_serializing_if = "Option::is_none")]
    pub expiry: Option<String>,
    /// Client-generated reference for the deal
    #[serde(rename = "dealReference", skip_serializing_if = "Option::is_none")]
    pub deal_reference: Option<String>,
    /// Whether to force open a new position
    #[serde(rename = "forceOpen")]
    pub force_open: bool,
    /// Currency code for the order (e.g., "USD", "EUR")
    #[serde(rename = "currencyCode")]
    pub currency_code: String,
    /// Quote identifier for the order
    #[serde(rename = "quoteId", skip_serializing_if = "Option::is_none")]
    pub quote_id: Option<String>,
    /// Trailing stop enabled
    #[serde(rename = "trailingStop", skip_serializing_if = "Option::is_none")]
    pub trailing_stop: Option<bool>,
    /// Trailing stop increment (only if trailingStop is true)
    #[serde(
        rename = "trailingStopIncrement",
        skip_serializing_if = "Option::is_none"
    )]
    pub trailing_stop_increment: Option<f64>,
}

/// Rounds an order size to two decimal places (nearest, half away from zero).
///
/// IG accepts order sizes to two decimals. Rounding must go through the nearest
/// value, not `floor`: `0.29 * 100.0` is `28.999999999999996` in `f64`, so a
/// `floor`-based `(size * 100.0).floor() / 100.0` silently yields `0.28` and the
/// order is placed with a smaller size than the caller requested. `round` maps
/// it back to `0.29`. The rounding direction (nearest) is deliberate and applies
/// uniformly to every order constructor.
#[must_use]
#[inline]
fn round_order_size(size: f64) -> f64 {
    (size * 100.0).round() / 100.0
}

impl CreateOrderRequest {
    /// Creates a new market order, typically used for CFD (Contract for Difference) accounts
    #[must_use]
    pub fn market(
        epic: String,
        direction: Direction,
        size: f64,
        currency_code: Option<String>,
        deal_reference: Option<String>,
    ) -> Self {
        let rounded_size = round_order_size(size);

        let currency_code = currency_code.unwrap_or_else(|| "EUR".to_string());

        Self {
            epic,
            direction,
            size: rounded_size,
            order_type: OrderType::Market,
            time_in_force: TimeInForce::FillOrKill,
            level: None,
            guaranteed_stop: false,
            stop_level: None,
            stop_distance: None,
            limit_level: None,
            limit_distance: None,
            expiry: Some("-".to_string()),
            deal_reference,
            force_open: true,
            currency_code,
            quote_id: None,
            trailing_stop: Some(false),
            trailing_stop_increment: None,
        }
    }

    /// Creates a new limit order, typically used for CFD (Contract for Difference) accounts
    #[must_use]
    pub fn limit(
        epic: String,
        direction: Direction,
        size: f64,
        level: f64,
        currency_code: Option<String>,
        deal_reference: Option<String>,
    ) -> Self {
        let rounded_size = round_order_size(size);

        let currency_code = currency_code.unwrap_or_else(|| "EUR".to_string());

        Self {
            epic,
            direction,
            size: rounded_size,
            order_type: OrderType::Limit,
            time_in_force: TimeInForce::GoodTillCancelled,
            level: Some(level),
            guaranteed_stop: false,
            stop_level: None,
            stop_distance: None,
            limit_level: None,
            limit_distance: None,
            expiry: None,
            deal_reference,
            force_open: true,
            currency_code,
            quote_id: None,
            trailing_stop: Some(false),
            trailing_stop_increment: None,
        }
    }

    /// Creates a new instance of a market sell option with predefined parameters.
    ///
    /// This function sets up a sell option to the market for a given asset (`epic`)
    /// with the specified size. It configures the order with default values
    /// for attributes such as direction, order type, and time-in-force.
    ///
    /// # Parameters
    /// - `epic`: A `String` that represents the epic (unique identifier or code) of the instrument
    ///   being traded.
    /// - `size`: A `f64` value representing the size or quantity of the order.
    ///
    /// # Returns
    /// An instance of `Self` (the type implementing this function), containing the specified
    /// `epic` and `size`, along with default values for other parameters:
    ///
    /// - `direction`: Set to `Direction::Sell`.
    /// - `order_type`: Set to `OrderType::Limit`.
    /// - `time_in_force`: Set to `TimeInForce::FillOrKill`.
    /// - `level`: Set to `Some(DEFAULT_ORDER_SELL_SIZE)`.
    /// - `guaranteed_stop`: Set to `false`.
    /// - `stop_level`: Set to `None`.
    /// - `stop_distance`: Set to `None`.
    /// - `limit_level`: Set to `None`.
    /// - `limit_distance`: Set to `None`.
    /// - `expiry`: Set based on input or `None`.
    /// - `deal_reference`: Auto-generated if not provided.
    /// - `force_open`: Set to `true`.
    /// - `currency_code`: Defaults to `"EUR"` if not provided.
    ///
    /// Note that this function allows for minimal input (the instrument and size),
    /// while other fields are provided default values. If further customization is required,
    /// you can modify the returned instance as needed.
    #[must_use]
    pub fn sell_option_to_market(
        epic: String,
        size: f64,
        expiry: Option<String>,
        deal_reference: Option<String>,
        currency_code: Option<String>,
    ) -> Self {
        Self::option_to_market(
            Direction::Sell,
            true,
            epic,
            size,
            expiry,
            deal_reference,
            currency_code,
        )
    }

    /// Shared builder behind the four option-to-market limit-order constructors.
    ///
    /// The public `sell_option_to_market` / `buy_option_to_market` variants (with
    /// and without an explicit `force_open`) differ only by `direction` and
    /// `force_open`; every other field is identical, so the shared body lives
    /// here to keep the four wrappers in lock-step. The aggressive limit `level`
    /// is chosen from `direction` (`DEFAULT_ORDER_SELL_LEVEL` for a sell,
    /// `DEFAULT_ORDER_BUY_LEVEL` for a buy) so the order fills at market. `size`
    /// is rounded to two decimals via [`round_order_size`]; a missing
    /// `deal_reference` is auto-generated, and a missing `currency_code` defaults
    /// to `"EUR"`.
    #[must_use]
    fn option_to_market(
        direction: Direction,
        force_open: bool,
        epic: String,
        size: f64,
        expiry: Option<String>,
        deal_reference: Option<String>,
        currency_code: Option<String>,
    ) -> Self {
        let rounded_size = round_order_size(size);

        let currency_code = currency_code.unwrap_or_else(|| "EUR".to_string());

        let deal_reference = deal_reference.or_else(|| Some(crate::utils::id::get_id()));

        let level = match direction {
            Direction::Sell => DEFAULT_ORDER_SELL_LEVEL,
            Direction::Buy => DEFAULT_ORDER_BUY_LEVEL,
        };

        Self {
            epic,
            direction,
            size: rounded_size,
            order_type: OrderType::Limit,
            time_in_force: TimeInForce::FillOrKill,
            level: Some(level),
            guaranteed_stop: false,
            stop_level: None,
            stop_distance: None,
            limit_level: None,
            limit_distance: None,
            expiry,
            deal_reference,
            force_open,
            currency_code,
            quote_id: None,
            trailing_stop: Some(false),
            trailing_stop_increment: None,
        }
    }

    /// Constructs and returns a new instance of the `Self` struct representing a sell option
    /// to the market with specific parameters for execution.
    ///
    /// # Parameters
    /// - `epic`: A `String` that specifies the EPIC
    ///   (Exchanged Product Information Code) of the instrument for which the sell order is created.
    /// - `size`: A `f64` that represents the size of the sell
    ///   order. The size is rounded to the nearest two decimal places.
    /// - `expiry`: An optional `String` that indicates the expiry date or period for
    ///   the sell order. If `None`, no expiry date will be set for the order.
    /// - `deal_reference`: An optional `String` that contains a reference or identifier
    ///   for the deal. Can be used for tracking purposes.
    /// - `currency_code`: An optional `String` representing the currency code. Defaults
    ///   to `"EUR"` if not provided.
    /// - `force_open`: A `bool` that specifies whether to force open the
    ///   position. When `true`, a new position is opened even if an existing position for the
    ///   same instrument and direction is available.
    ///
    /// # Returns
    /// - `Self`: A new instance populated with the provided parameters, including the following default
    ///   properties:
    ///   - `direction`: Set to `Direction::Sell` to designate the sell operation.
    ///   - `order_type`: Set to `OrderType::Limit` to signify the type of the order.
    ///   - `time_in_force`: Set to `TimeInForce::FillOrKill` indicating the order should be fully
    ///     executed or canceled.
    ///   - `level`: Set to a constant value `DEFAULT_ORDER_SELL_SIZE`.
    ///   - `guaranteed_stop`: Set to `false`, indicating no guaranteed stop.
    ///   - Other optional levels/distance fields (`stop_level`, `stop_distance`, `limit_level`,
    ///     `limit_distance`): Set to `None` by default.
    ///
    /// # Notes
    /// - The input `size` is automatically rounded to the nearest two decimal places before being stored.
    #[must_use]
    pub fn sell_option_to_market_w_force(
        epic: String,
        size: f64,
        expiry: Option<String>,
        deal_reference: Option<String>,
        currency_code: Option<String>,
        force_open: bool, // Compensate position if it is already open
    ) -> Self {
        Self::option_to_market(
            Direction::Sell,
            force_open,
            epic,
            size,
            expiry,
            deal_reference,
            currency_code,
        )
    }

    /// Creates a new instance of an order to buy an option in the market with specified parameters.
    ///
    /// This method initializes an order with the following default values:
    /// - `direction` is set to `Buy`.
    /// - `order_type` is set to `Limit`.
    /// - `time_in_force` is set to `FillOrKill`.
    /// - `level` is set to `Some(DEFAULT_ORDER_BUY_SIZE)`.
    /// - `force_open` is set to `true`.
    ///   Other optional parameters, such as stop levels, distances, expiry, and currency code, are left as `None`.
    ///
    /// # Parameters
    /// - `epic` (`String`): The identifier for the market or instrument to trade.
    /// - `size` (`f64`): The size or quantity of the order to be executed.
    ///
    /// # Returns
    /// A new instance of `Self` that represents the configured buy option for the given market.
    ///
    /// # Note
    /// Ensure the `epic` and `size` values provided are valid and match required market conditions.
    #[must_use]
    pub fn buy_option_to_market(
        epic: String,
        size: f64,
        expiry: Option<String>,
        deal_reference: Option<String>,
        currency_code: Option<String>,
    ) -> Self {
        Self::option_to_market(
            Direction::Buy,
            true,
            epic,
            size,
            expiry,
            deal_reference,
            currency_code,
        )
    }

    /// Constructs a new instance of an order to buy an option in the market with optional force_open behavior.
    ///
    /// # Parameters
    ///
    /// * `epic` - A `String` representing the unique identifier of the instrument to be traded.
    /// * `size` - A `f64` value that represents the size of the order.
    /// * `expiry` - An optional `String` representing the expiry date of the option.
    /// * `deal_reference` - An optional `String` for the deal reference identifier.
    /// * `currency_code` - An optional `String` representing the currency in which the order is denominated.
    ///   Defaults to "EUR" if not provided.
    /// * `force_open` - A `bool` indicating whether to force open a new position regardless of existing positions.
    ///
    /// # Returns
    ///
    /// Returns a new instance of `Self`, representing the constructed order with the provided parameters.
    ///
    /// # Behavior
    ///
    /// * The size of the order will be rounded to the nearest two decimal places for precision.
    /// * If a `currency_code` is not provided, the default currency code "EUR" is used.
    /// * Other parameters are directly mapped into the returned instance.
    ///
    /// # Notes
    ///
    /// * This function assumes that other order-related fields such as `level`, `stop_level`, `stop_distance`,
    ///   etc., are set to their defaults or require specific business logic, such as
    ///   `DEFAULT_ORDER_BUY_SIZE` for the initial buy size.
    #[must_use]
    pub fn buy_option_to_market_w_force(
        epic: String,
        size: f64,
        expiry: Option<String>,
        deal_reference: Option<String>,
        currency_code: Option<String>,
        force_open: bool,
    ) -> Self {
        Self::option_to_market(
            Direction::Buy,
            force_open,
            epic,
            size,
            expiry,
            deal_reference,
            currency_code,
        )
    }

    /// Adds a stop loss to the order
    #[must_use]
    pub fn with_stop_loss(mut self, stop_level: f64) -> Self {
        self.stop_level = Some(stop_level);
        self
    }

    /// Adds a take profit to the order
    #[must_use]
    pub fn with_take_profit(mut self, limit_level: f64) -> Self {
        self.limit_level = Some(limit_level);
        self
    }

    /// Adds a trailing stop loss to the order
    #[must_use]
    pub fn with_trailing_stop_loss(mut self, trailing_stop_increment: f64) -> Self {
        self.trailing_stop = Some(true);
        self.trailing_stop_increment = Some(trailing_stop_increment);
        self
    }

    /// Adds a reference to the order
    #[must_use]
    pub fn with_reference(mut self, reference: String) -> Self {
        self.deal_reference = Some(reference);
        self
    }

    /// Adds a stop distance to the order
    #[must_use]
    pub fn with_stop_distance(mut self, stop_distance: f64) -> Self {
        self.stop_distance = Some(stop_distance);
        self
    }

    /// Adds a limit distance to the order
    #[must_use]
    pub fn with_limit_distance(mut self, limit_distance: f64) -> Self {
        self.limit_distance = Some(limit_distance);
        self
    }

    /// Adds a guaranteed stop to the order
    #[must_use]
    pub fn with_guaranteed_stop(mut self, guaranteed: bool) -> Self {
        self.guaranteed_stop = guaranteed;
        self
    }
}

/// Model for updating an existing position (PUT /positions/otc/{dealId})
///
/// # Constraints
/// - If `guaranteed_stop` is `true`, then `stop_level` must be set
/// - If `guaranteed_stop` is `true`, then `trailing_stop` must be `false`
/// - If `trailing_stop` is `false`, then DO NOT set `trailing_stop_distance` or `trailing_stop_increment`
/// - If `trailing_stop` is `true`, then `guaranteed_stop` must be `false`
/// - If `trailing_stop` is `true`, then `trailing_stop_distance`, `trailing_stop_increment`, and `stop_level` must be set
#[derive(DebugPretty, DisplaySimple, Clone, Serialize, Deserialize, Default)]
pub struct UpdatePositionRequest {
    /// True if a guaranteed stop is required
    #[serde(rename = "guaranteedStop", skip_serializing_if = "Option::is_none")]
    pub guaranteed_stop: Option<bool>,
    /// New price level for take profit
    #[serde(rename = "limitLevel", skip_serializing_if = "Option::is_none")]
    pub limit_level: Option<f64>,
    /// New price level for stop loss
    #[serde(rename = "stopLevel", skip_serializing_if = "Option::is_none")]
    pub stop_level: Option<f64>,
    /// True if trailing stop is required
    #[serde(rename = "trailingStop", skip_serializing_if = "Option::is_none")]
    pub trailing_stop: Option<bool>,
    /// Distance for trailing stop in points
    #[serde(
        rename = "trailingStopDistance",
        skip_serializing_if = "Option::is_none"
    )]
    pub trailing_stop_distance: Option<f64>,
    /// Trailing stop step increment in points
    #[serde(
        rename = "trailingStopIncrement",
        skip_serializing_if = "Option::is_none"
    )]
    pub trailing_stop_increment: Option<f64>,
}

/// Model for closing an existing position
#[derive(DebugPretty, DisplaySimple, Clone, Serialize, Deserialize)]
pub struct ClosePositionRequest {
    /// Unique identifier for the position to close
    #[serde(rename = "dealId", skip_serializing_if = "Option::is_none")]
    pub deal_id: Option<String>,
    /// Direction of the closing order (opposite to the position)
    pub direction: Direction,
    /// Instrument EPIC identifier
    #[serde(skip_serializing_if = "Option::is_none")]
    pub epic: Option<String>,
    /// Expiry date for the order
    #[serde(rename = "expiry", skip_serializing_if = "Option::is_none")]
    pub expiry: Option<String>,
    /// Price level for limit close orders
    #[serde(rename = "level", skip_serializing_if = "Option::is_none")]
    pub level: Option<f64>,
    /// Type of order to use for closing
    #[serde(rename = "orderType")]
    pub order_type: OrderType,
    /// Quote identifier for the order, used for certain order types that require a specific quote
    #[serde(rename = "quoteId", skip_serializing_if = "Option::is_none")]
    pub quote_id: Option<String>,
    /// Size/quantity to close
    pub size: f64,
    /// Order duration for the closing order
    #[serde(rename = "timeInForce")]
    pub time_in_force: TimeInForce,
}

impl ClosePositionRequest {
    /// Creates a request to close a position at market price
    #[must_use]
    pub fn market(deal_id: String, direction: Direction, size: f64) -> Self {
        Self {
            deal_id: Some(deal_id),
            direction,
            size,
            order_type: OrderType::Market,
            time_in_force: TimeInForce::FillOrKill,
            level: None,
            expiry: None,
            epic: None,
            quote_id: None,
        }
    }

    /// Creates a request to close a position at a specific price level
    ///
    /// This is useful for instruments that don't support market orders
    #[must_use]
    pub fn limit(deal_id: String, direction: Direction, size: f64, level: f64) -> Self {
        Self {
            deal_id: Some(deal_id),
            direction,
            size,
            order_type: OrderType::Limit,
            time_in_force: TimeInForce::FillOrKill,
            level: Some(level),
            expiry: None,
            epic: None,
            quote_id: None,
        }
    }

    /// Creates a request to close an option position by deal ID using a limit order with predefined price levels
    ///
    /// This is specifically designed for options trading where market orders are not supported
    /// and a limit order with a predefined price level is required based on the direction.
    ///
    /// # Arguments
    /// * `deal_id` - The ID of the deal to close
    /// * `direction` - The direction of the closing order (opposite of the position direction)
    /// * `size` - The size of the position to close
    #[must_use]
    pub fn close_option_to_market_by_id(deal_id: String, direction: Direction, size: f64) -> Self {
        // For options, we need to use limit orders with appropriate levels
        // Use reasonable levels based on direction to ensure fill while being accepted
        let level = match direction {
            Direction::Buy => Some(DEFAULT_ORDER_BUY_LEVEL),
            Direction::Sell => Some(DEFAULT_ORDER_SELL_LEVEL),
        };

        Self {
            deal_id: Some(deal_id),
            direction,
            size,
            order_type: OrderType::Limit,
            time_in_force: TimeInForce::FillOrKill,
            level,
            expiry: None,
            epic: None,
            quote_id: None,
        }
    }

    /// Creates a request to close an option position by epic identifier using a limit order with predefined price levels
    ///
    /// This is specifically designed for options trading where market orders are not supported
    /// and a limit order with a predefined price level is required based on the direction.
    /// This method is used when the deal ID is not available but the epic and expiry are known.
    ///
    /// # Arguments
    /// * `epic` - The epic identifier of the instrument
    /// * `expiry` - The expiry date of the option
    /// * `direction` - The direction of the closing order (opposite of the position direction)
    /// * `size` - The size of the position to close
    #[must_use]
    pub fn close_option_to_market_by_epic(
        epic: String,
        expiry: String,
        direction: Direction,
        size: f64,
    ) -> Self {
        // For options, we need to use limit orders with appropriate levels
        // Use reasonable levels based on direction to ensure fill while being accepted
        let level = match direction {
            Direction::Buy => Some(DEFAULT_ORDER_BUY_LEVEL),
            Direction::Sell => Some(DEFAULT_ORDER_SELL_LEVEL),
        };

        Self {
            deal_id: None,
            direction,
            size,
            order_type: OrderType::Limit,
            time_in_force: TimeInForce::FillOrKill,
            level,
            expiry: Some(expiry),
            epic: Some(epic),
            quote_id: None,
        }
    }
}

/// Model for creating a new working order
#[derive(DebugPretty, DisplaySimple, Clone, Deserialize, Serialize)]
pub struct CreateWorkingOrderRequest {
    /// Instrument EPIC identifier
    pub epic: String,
    /// Order direction (buy or sell)
    pub direction: Direction,
    /// Order size/quantity
    pub size: f64,
    /// Price level for the order
    pub level: f64,
    /// Type of working order (LIMIT or STOP)
    #[serde(rename = "type")]
    pub order_type: OrderType,
    /// Order duration (how long the order remains valid)
    #[serde(rename = "timeInForce")]
    pub time_in_force: TimeInForce,
    /// Whether to use a guaranteed stop
    #[serde(rename = "guaranteedStop", skip_serializing_if = "Option::is_none")]
    pub guaranteed_stop: Option<bool>,
    /// Price level for stop loss
    #[serde(rename = "stopLevel", skip_serializing_if = "Option::is_none")]
    pub stop_level: Option<f64>,
    /// Distance for stop loss
    #[serde(rename = "stopDistance", skip_serializing_if = "Option::is_none")]
    pub stop_distance: Option<f64>,
    /// Price level for take profit
    #[serde(rename = "limitLevel", skip_serializing_if = "Option::is_none")]
    pub limit_level: Option<f64>,
    /// Distance for take profit
    #[serde(rename = "limitDistance", skip_serializing_if = "Option::is_none")]
    pub limit_distance: Option<f64>,
    /// Expiry date for GTD orders
    #[serde(rename = "goodTillDate", skip_serializing_if = "Option::is_none")]
    pub good_till_date: Option<String>,
    /// Client-generated reference for the deal
    #[serde(rename = "dealReference", skip_serializing_if = "Option::is_none")]
    pub deal_reference: Option<String>,
    /// Currency code for the order (e.g., "USD", "EUR")
    #[serde(rename = "currencyCode")]
    pub currency_code: String,
    /// Expiry date for the order
    pub expiry: String,
}

impl From<WorkingOrder> for CreateWorkingOrderRequest {
    fn from(value: WorkingOrder) -> Self {
        let data = value.working_order_data;
        Self {
            epic: data.epic,
            direction: data.direction,
            size: data.order_size,
            level: data.order_level,
            order_type: data.order_type,
            time_in_force: data.time_in_force,
            guaranteed_stop: Some(data.guaranteed_stop),
            stop_level: data.stop_level,
            stop_distance: data.stop_distance,
            limit_level: data.limit_level,
            limit_distance: data.limit_distance,
            good_till_date: data.good_till_date,
            deal_reference: data.deal_reference,
            currency_code: data.currency_code,
            expiry: value.market_data.expiry,
        }
    }
}

impl CreateWorkingOrderRequest {
    /// Creates a new limit working order
    #[must_use]
    pub fn limit(
        epic: String,
        direction: Direction,
        size: f64,
        level: f64,
        currency_code: String,
        expiry: String,
    ) -> Self {
        Self {
            epic,
            direction,
            size,
            level,
            order_type: OrderType::Limit,
            time_in_force: TimeInForce::GoodTillCancelled,
            guaranteed_stop: Some(false),
            stop_level: None,
            stop_distance: None,
            limit_level: None,
            limit_distance: None,
            good_till_date: None,
            deal_reference: None,
            currency_code,
            expiry,
        }
    }

    /// Creates a new stop working order
    #[must_use]
    pub fn stop(
        epic: String,
        direction: Direction,
        size: f64,
        level: f64,
        currency_code: String,
        expiry: String,
    ) -> Self {
        Self {
            epic,
            direction,
            size,
            level,
            order_type: OrderType::Stop,
            time_in_force: TimeInForce::GoodTillCancelled,
            guaranteed_stop: Some(false),
            stop_level: None,
            stop_distance: None,
            limit_level: None,
            limit_distance: None,
            good_till_date: None,
            deal_reference: None,
            currency_code,
            expiry,
        }
    }

    /// Adds a stop loss to the working order
    #[must_use]
    pub fn with_stop_loss(mut self, stop_level: f64) -> Self {
        self.stop_level = Some(stop_level);
        self
    }

    /// Adds a take profit to the working order
    #[must_use]
    pub fn with_take_profit(mut self, limit_level: f64) -> Self {
        self.limit_level = Some(limit_level);
        self
    }

    /// Adds a reference to the working order
    #[must_use]
    pub fn with_reference(mut self, reference: String) -> Self {
        self.deal_reference = Some(reference);
        self
    }

    /// Sets the expiration date for an order and updates the time-in-force policy.
    ///
    /// This method updates the `time_in_force` property to `GoodTillDate` and assigns
    /// the provided expiration date to the `good_till_date` property. It allows chaining
    /// as it consumes the current instance and returns it after modification.
    ///
    /// # Arguments
    /// * `date` - A `String` representing the expiration date for the order.
    ///
    /// # Returns
    /// * `Self` - The updated instance of the type, allowing method chaining.
    ///
    /// In the example above, the expiration date for the order is set to
    /// "2023-12-31T23:59:59Z" and the `time_in_force` policy is set to `GoodTillDate`.
    #[must_use]
    pub fn expires_at(mut self, date: String) -> Self {
        self.time_in_force = TimeInForce::GoodTillDate;
        self.good_till_date = Some(date);
        self
    }

    ///
    /// Sets the order to expire by the end of the next day (tomorrow).
    ///
    /// This method modifies the `time_in_force` field to `GoodTillDate` and calculates
    /// the expiration date as tomorrow's date and time. The calculated date is then
    /// formatted as a string in the format `YYYY/MM/DD HH:MM:SS` and assigned to
    /// the `good_till_date` field.
    ///
    /// # Returns
    /// Returns the updated instance of the struct with the expiration date set to tomorrow.
    ///
    /// In this example, the `expires_tomorrow` method sets the order to expire at the
    /// same time on the next calendar day.
    ///
    /// Note: The function uses the UTC timezone for calculating the date and time.
    ///
    #[must_use]
    pub fn expires_tomorrow(mut self) -> Self {
        self.time_in_force = TimeInForce::GoodTillDate;
        let tomorrow = Utc::now() + Duration::days(1);
        self.good_till_date = Some(tomorrow.format("%Y/%m/%d %H:%M:%S").to_string());
        self
    }

    /// Sets the expiration time for an order and configures it to expire at a specific date and time.
    ///
    /// This method modifies the `time_in_force` for the order to `GoodTillDate`
    /// and calculates the expiration time by adding the provided `duration` to
    /// the current UTC time. The calculated expiration time is formatted as
    /// "YYYY/MM/DD HH:MM:SS" and stored in the `good_till_date` field.
    ///
    /// # Parameters
    /// - `duration`: A `Duration` instance that represents the amount of time
    ///   after the current UTC time when the order should expire.
    ///
    /// # Returns
    /// Returns `Self` with updated `time_in_force` and `good_till_date`.
    ///
    /// Note: This method assumes that the runtime uses the `chrono` crate for
    /// time handling and formatting.
    #[must_use]
    pub fn expires_in(mut self, duration: Duration) -> Self {
        self.time_in_force = TimeInForce::GoodTillDate;
        let tomorrow = Utc::now() + duration;
        self.good_till_date = Some(tomorrow.format("%Y/%m/%d %H:%M:%S").to_string());
        self
    }
}

// ============================================================================
// WATCHLIST REQUESTS
// ============================================================================

/// Request to create a new watchlist
#[derive(DebugPretty, DisplaySimple, Clone, Serialize, Deserialize, Default)]
pub struct CreateWatchlistRequest {
    /// Name for the new watchlist
    pub name: String,
    /// Optional list of EPICs to add to the watchlist
    #[serde(skip_serializing_if = "Option::is_none")]
    pub epics: Option<Vec<String>>,
}

impl CreateWatchlistRequest {
    /// Create a new watchlist request with just a name
    #[must_use]
    pub fn new(name: &str) -> Self {
        Self {
            name: name.to_string(),
            epics: None,
        }
    }

    /// Create a watchlist request with name and epics
    #[must_use]
    pub fn with_epics(name: &str, epics: Vec<String>) -> Self {
        Self {
            name: name.to_string(),
            epics: Some(epics),
        }
    }
}

/// Request to add an instrument to a watchlist
#[derive(DebugPretty, DisplaySimple, Clone, Serialize, Deserialize, Default)]
pub struct AddToWatchlistRequest {
    /// EPIC of the instrument to add
    pub epic: String,
}

// ============================================================================
// WORKING ORDER UPDATE REQUEST
// ============================================================================

/// Request to update an existing working order
#[derive(DebugPretty, DisplaySimple, Clone, Serialize, Deserialize)]
pub struct UpdateWorkingOrderRequest {
    /// Good till date for the order (format: yyyy/MM/dd HH:mm:ss)
    #[serde(rename = "goodTillDate", skip_serializing_if = "Option::is_none")]
    pub good_till_date: Option<String>,
    /// Order level
    pub level: f64,
    /// Distance from current price to limit level
    #[serde(rename = "limitDistance", skip_serializing_if = "Option::is_none")]
    pub limit_distance: Option<f64>,
    /// Limit level
    #[serde(rename = "limitLevel", skip_serializing_if = "Option::is_none")]
    pub limit_level: Option<f64>,
    /// Distance from current price to stop level
    #[serde(rename = "stopDistance", skip_serializing_if = "Option::is_none")]
    pub stop_distance: Option<f64>,
    /// Stop level
    #[serde(rename = "stopLevel", skip_serializing_if = "Option::is_none")]
    pub stop_level: Option<f64>,
    /// Whether the stop is guaranteed
    #[serde(rename = "guaranteedStop")]
    pub guaranteed_stop: bool,
    /// Time in force
    #[serde(rename = "timeInForce")]
    pub time_in_force: TimeInForce,
    /// Order type (LIMIT or STOP)
    #[serde(rename = "type")]
    pub order_type: OrderType,
}

impl UpdateWorkingOrderRequest {
    /// Create a new update working order request
    #[must_use]
    pub fn new(level: f64, order_type: OrderType, time_in_force: TimeInForce) -> Self {
        Self {
            level,
            order_type,
            time_in_force,
            guaranteed_stop: false,
            good_till_date: None,
            limit_distance: None,
            limit_level: None,
            stop_distance: None,
            stop_level: None,
        }
    }

    /// Set the stop level
    #[must_use]
    pub fn with_stop_level(mut self, stop_level: f64) -> Self {
        self.stop_level = Some(stop_level);
        self
    }

    /// Set the limit level
    #[must_use]
    pub fn with_limit_level(mut self, limit_level: f64) -> Self {
        self.limit_level = Some(limit_level);
        self
    }

    /// Set guaranteed stop
    #[must_use]
    pub fn with_guaranteed_stop(mut self, guaranteed: bool) -> Self {
        self.guaranteed_stop = guaranteed;
        self
    }
}

// ============================================================================
// INDICATIVE COSTS REQUESTS
// ============================================================================

/// Request for indicative costs when opening a position
#[derive(DebugPretty, DisplaySimple, Clone, Serialize, Deserialize)]
pub struct OpenCostsRequest {
    /// Instrument epic
    pub epic: String,
    /// Trade direction (BUY or SELL)
    pub direction: Direction,
    /// Trade size
    pub size: f64,
    /// Order type
    #[serde(rename = "orderType")]
    pub order_type: OrderType,
    /// Currency code
    #[serde(rename = "currencyCode")]
    pub currency_code: String,
    /// Whether the stop is guaranteed
    #[serde(rename = "guaranteedStop", skip_serializing_if = "Option::is_none")]
    pub guaranteed_stop: Option<bool>,
    /// Stop distance
    #[serde(rename = "stopDistance", skip_serializing_if = "Option::is_none")]
    pub stop_distance: Option<f64>,
    /// Limit distance
    #[serde(rename = "limitDistance", skip_serializing_if = "Option::is_none")]
    pub limit_distance: Option<f64>,
}

impl OpenCostsRequest {
    /// Create a new open costs request
    #[must_use]
    pub fn new(epic: &str, direction: Direction, size: f64, currency_code: &str) -> Self {
        Self {
            epic: epic.to_string(),
            direction,
            size,
            order_type: OrderType::Market,
            currency_code: currency_code.to_string(),
            guaranteed_stop: None,
            stop_distance: None,
            limit_distance: None,
        }
    }
}

/// Request for indicative costs when closing a position
#[derive(DebugPretty, DisplaySimple, Clone, Serialize, Deserialize)]
pub struct CloseCostsRequest {
    /// Deal ID of the position to close
    #[serde(rename = "dealId")]
    pub deal_id: String,
    /// Trade direction (opposite of the position direction)
    pub direction: Direction,
    /// Size to close
    pub size: f64,
    /// Order type
    #[serde(rename = "orderType")]
    pub order_type: OrderType,
}

impl CloseCostsRequest {
    /// Create a new close costs request
    #[must_use]
    pub fn new(deal_id: &str, direction: Direction, size: f64) -> Self {
        Self {
            deal_id: deal_id.to_string(),
            direction,
            size,
            order_type: OrderType::Market,
        }
    }
}

/// Request for indicative costs when editing a position
#[derive(DebugPretty, DisplaySimple, Clone, Serialize, Deserialize)]
pub struct EditCostsRequest {
    /// Deal ID of the position to edit
    #[serde(rename = "dealId")]
    pub deal_id: String,
    /// New stop level
    #[serde(rename = "stopLevel", skip_serializing_if = "Option::is_none")]
    pub stop_level: Option<f64>,
    /// New limit level
    #[serde(rename = "limitLevel", skip_serializing_if = "Option::is_none")]
    pub limit_level: Option<f64>,
    /// Whether the stop is guaranteed
    #[serde(rename = "guaranteedStop", skip_serializing_if = "Option::is_none")]
    pub guaranteed_stop: Option<bool>,
}

impl EditCostsRequest {
    /// Create a new edit costs request
    #[must_use]
    pub fn new(deal_id: &str) -> Self {
        Self {
            deal_id: deal_id.to_string(),
            stop_level: None,
            limit_level: None,
            guaranteed_stop: None,
        }
    }

    /// Set the new stop level
    #[must_use]
    pub fn with_stop_level(mut self, stop_level: f64) -> Self {
        self.stop_level = Some(stop_level);
        self
    }

    /// Set the new limit level
    #[must_use]
    pub fn with_limit_level(mut self, limit_level: f64) -> Self {
        self.limit_level = Some(limit_level);
        self
    }
}

// ============================================================================
// ACCOUNT PREFERENCES REQUEST
// ============================================================================

/// Request to update account preferences
#[derive(DebugPretty, DisplaySimple, Clone, Serialize, Deserialize, Default)]
pub struct UpdatePreferencesRequest {
    /// Whether trailing stops should be enabled
    #[serde(rename = "trailingStopsEnabled")]
    pub trailing_stops_enabled: bool,
}