gmsol-model 0.9.0

use num_traits::{CheckedAdd, CheckedDiv, CheckedSub, Zero};

use crate::{
    market::{PerpMarket, PerpMarketExt, SwapMarketMutExt},
    num::{MulDiv, Unsigned},
    params::fee::PositionFees,
    pool::delta::PriceImpact,
    position::{
        CollateralDelta, Position, PositionExt, PositionMut, PositionMutExt, PositionStateExt,
        WillCollateralBeSufficient,
    },
    price::{Price, Prices},
    BorrowingFeeMarketExt, PerpMarketMut, PoolExt,
};

use self::collateral_processor::{CollateralProcessor, ProcessResult};

mod claimable;
mod collateral_processor;
mod report;
mod utils;

pub use self::{
    claimable::ClaimableCollateral,
    report::{DecreasePositionReport, OutputAmounts, Pnl},
};

use super::{swap::SwapReport, MarketAction};

/// Decrease the position.
#[must_use = "actions do nothing unless you `execute` them"]
pub struct DecreasePosition<P: Position<DECIMALS>, const DECIMALS: u8> {
    position: P,
    params: DecreasePositionParams<P::Num>,
    withdrawable_collateral_amount: P::Num,
    size_delta_usd: P::Num,
}

/// Swap Type for the decrease position action.
#[derive(
    Debug,
    Clone,
    Copy,
    Default,
    num_enum::TryFromPrimitive,
    num_enum::IntoPrimitive,
    PartialEq,
    Eq,
    PartialOrd,
    Ord,
    Hash,
)]
#[cfg_attr(
    feature = "strum",
    derive(strum::EnumIter, strum::EnumString, strum::Display)
)]
#[cfg_attr(feature = "strum", strum(serialize_all = "snake_case"))]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
#[cfg_attr(feature = "serde", serde(rename_all = "snake_case"))]
#[cfg_attr(
    feature = "anchor-lang",
    derive(
        anchor_lang::AnchorSerialize,
        anchor_lang::AnchorDeserialize,
        anchor_lang::InitSpace
    )
)]
#[repr(u8)]
#[non_exhaustive]
pub enum DecreasePositionSwapType {
    /// No swap.
    #[default]
    NoSwap,
    /// Swap PnL token to collateral token.
    PnlTokenToCollateralToken,
    /// Swap collateral token to PnL token.
    CollateralToPnlToken,
}

/// Decrease Position Params.
#[derive(Debug, Clone, Copy)]
pub struct DecreasePositionParams<T> {
    prices: Prices<T>,
    initial_size_delta_usd: T,
    acceptable_price: Option<T>,
    initial_collateral_withdrawal_amount: T,
    flags: DecreasePositionFlags,
    swap: DecreasePositionSwapType,
}

impl<T> DecreasePositionParams<T> {
    /// Get prices.
    pub fn prices(&self) -> &Prices<T> {
        &self.prices
    }

    /// Get initial size delta usd.
    pub fn initial_size_delta_usd(&self) -> &T {
        &self.initial_size_delta_usd
    }

    /// Get acceptable price.
    pub fn acceptable_price(&self) -> Option<&T> {
        self.acceptable_price.as_ref()
    }

    /// Get initial collateral withdrawal amount.
    pub fn initial_collateral_withdrawal_amount(&self) -> &T {
        &self.initial_collateral_withdrawal_amount
    }

    /// Whether insolvent close is allowed.
    pub fn is_insolvent_close_allowed(&self) -> bool {
        self.flags.is_insolvent_close_allowed
    }

    /// Whether the order is a liquidation order.
    pub fn is_liquidation_order(&self) -> bool {
        self.flags.is_liquidation_order
    }

    /// Whether capping size_delta_usd is allowed.
    pub fn is_cap_size_delta_usd_allowed(&self) -> bool {
        self.flags.is_cap_size_delta_usd_allowed
    }

    /// Get the swap type.
    pub fn swap(&self) -> DecreasePositionSwapType {
        self.swap
    }
}

/// Decrease Position Flags.
#[derive(Debug, Clone, Copy, Default)]
pub struct DecreasePositionFlags {
    /// Whether insolvent close is allowed.
    pub is_insolvent_close_allowed: bool,
    /// Whether the order is a liquidation order.
    pub is_liquidation_order: bool,
    /// Whether capping size_delta_usd is allowed.
    pub is_cap_size_delta_usd_allowed: bool,
}

impl DecreasePositionFlags {
    fn init<T>(&mut self, size_in_usd: &T, size_delta_usd: &mut T) -> crate::Result<()>
    where
        T: Ord + Clone,
    {
        if *size_delta_usd > *size_in_usd {
            if self.is_cap_size_delta_usd_allowed {
                *size_delta_usd = size_in_usd.clone();
            } else {
                return Err(crate::Error::InvalidArgument("invalid decrease order size"));
            }
        }

        let is_full_close = *size_in_usd == *size_delta_usd;
        self.is_insolvent_close_allowed = is_full_close && self.is_insolvent_close_allowed;

        Ok(())
    }
}

struct ProcessCollateralResult<T: Unsigned> {
    price_impact_value: T::Signed,
    price_impact_diff: T,
    execution_price: T,
    size_delta_in_tokens: T,
    is_output_token_long: bool,
    is_secondary_output_token_long: bool,
    collateral: ProcessResult<T>,
    fees: PositionFees<T>,
    pnl: Pnl<T::Signed>,
}

impl<const DECIMALS: u8, P: PositionMut<DECIMALS>> DecreasePosition<P, DECIMALS>
where
    P::Market: PerpMarketMut<DECIMALS, Num = P::Num, Signed = P::Signed>,
{
    /// Create a new action to decrease the given position.
    pub fn try_new(
        position: P,
        prices: Prices<P::Num>,
        mut size_delta_usd: P::Num,
        acceptable_price: Option<P::Num>,
        collateral_withdrawal_amount: P::Num,
        mut flags: DecreasePositionFlags,
    ) -> crate::Result<Self> {
        if !prices.is_valid() {
            return Err(crate::Error::InvalidArgument("invalid prices"));
        }
        if position.is_empty() {
            return Err(crate::Error::InvalidPosition("empty position"));
        }

        let initial_size_delta_usd = size_delta_usd.clone();
        flags.init(position.size_in_usd(), &mut size_delta_usd)?;

        Ok(Self {
            params: DecreasePositionParams {
                prices,
                initial_size_delta_usd,
                acceptable_price,
                initial_collateral_withdrawal_amount: collateral_withdrawal_amount.clone(),
                flags,
                swap: DecreasePositionSwapType::NoSwap,
            },
            withdrawable_collateral_amount: collateral_withdrawal_amount
                .min(position.collateral_amount().clone()),
            size_delta_usd,
            position,
        })
    }

    /// Set the swap type.
    pub fn set_swap(mut self, kind: DecreasePositionSwapType) -> Self {
        self.params.swap = kind;
        self
    }

    /// Do a check when the position will be partially decreased.
    fn check_partial_close(&mut self) -> crate::Result<()> {
        use num_traits::CheckedMul;

        if self.will_size_remain() {
            let (estimated_pnl, _, _) = self
                .position
                .pnl_value(&self.params.prices, self.position.size_in_usd())?;
            let estimated_realized_pnl = self
                .size_delta_usd
                .checked_mul_div_with_signed_numerator(&estimated_pnl, self.position.size_in_usd())
                .ok_or(crate::Error::Computation("estimating realized pnl"))?;
            let estimated_remaining_pnl = estimated_pnl
                .checked_sub(&estimated_realized_pnl)
                .ok_or(crate::Error::Computation("estimating remaining pnl"))?;

            let delta = CollateralDelta::new(
                self.position
                    .size_in_usd()
                    .checked_sub(&self.size_delta_usd)
                    .expect("should have been capped"),
                self.position
                    .collateral_amount()
                    .checked_sub(&self.withdrawable_collateral_amount)
                    .expect("should have been capped"),
                estimated_realized_pnl,
                self.size_delta_usd.to_opposite_signed()?,
            );

            let mut will_be_sufficient = self
                .position
                .will_collateral_be_sufficient(&self.params.prices, &delta)?;

            if let WillCollateralBeSufficient::Insufficient(remaining_collateral_value) =
                &mut will_be_sufficient
            {
                if self.size_delta_usd.is_zero() {
                    return Err(crate::Error::InvalidArgument(
                        "unable to withdraw collateral: insufficient collateral",
                    ));
                }

                let collateral_token_price = if self.position.is_collateral_token_long() {
                    &self.params.prices.long_token_price
                } else {
                    &self.params.prices.short_token_price
                };
                // Add back to the estimated remaining collateral value && set withdrawable collateral amount to zero.
                let add_back = self
                    .withdrawable_collateral_amount
                    .checked_mul(collateral_token_price.pick_price(false))
                    .ok_or(crate::Error::Computation("overflow calculating add back"))?
                    .to_signed()?;
                *remaining_collateral_value = remaining_collateral_value
                    .checked_add(&add_back)
                    .ok_or(crate::Error::Computation("adding back"))?;
                self.withdrawable_collateral_amount = Zero::zero();
            }

            // Close all if collateral or position size too small.

            let params = self.position.market().position_params()?;

            let remaining_value = will_be_sufficient
                .checked_add(&estimated_remaining_pnl)
                .ok_or(crate::Error::Computation("calculating remaining value"))?;
            if remaining_value < params.min_collateral_value().to_signed()? {
                self.size_delta_usd = self.position.size_in_usd().clone();
            }

            if *self.position.size_in_usd() > self.size_delta_usd
                && self
                    .position
                    .size_in_usd()
                    .checked_sub(&self.size_delta_usd)
                    .expect("must success")
                    < *params.min_position_size_usd()
            {
                self.size_delta_usd = self.position.size_in_usd().clone();
            }
        }
        Ok(())
    }

    fn check_close(&mut self) -> crate::Result<()> {
        if self.size_delta_usd == *self.position.size_in_usd()
            && !self.withdrawable_collateral_amount.is_zero()
        {
            // Help ensure that the order can be executed.
            self.withdrawable_collateral_amount = Zero::zero();
        }
        Ok(())
    }

    fn check_liquidation(&self) -> crate::Result<()> {
        if self.params.is_liquidation_order() {
            let Some(_reason) =
                self.position
                    .check_liquidatable(&self.params.prices, true, true)?
            else {
                return Err(crate::Error::NotLiquidatable);
            };
            Ok(())
        } else {
            Ok(())
        }
    }

    fn will_size_remain(&self) -> bool {
        self.size_delta_usd < *self.position.size_in_usd()
    }

    /// Whether the action is a full close.
    pub fn is_full_close(&self) -> bool {
        self.size_delta_usd == *self.position.size_in_usd()
    }

    fn collateral_token_price(&self) -> &Price<P::Num> {
        self.position.collateral_price(self.params.prices())
    }

    #[allow(clippy::type_complexity)]
    fn process_collateral(&mut self) -> crate::Result<ProcessCollateralResult<P::Num>> {
        // is_insolvent_close_allowed => is_full_close
        debug_assert!(!self.params.is_insolvent_close_allowed() || self.is_full_close());

        let ExecutionParams {
            price_impact,
            price_impact_diff,
            execution_price,
        } = self.get_execution_params()?;

        // Calculate position pnl usd.
        let (base_pnl_usd, uncapped_base_pnl_usd, size_delta_in_tokens) = self
            .position
            .pnl_value(&self.params.prices, &self.size_delta_usd)?;

        let is_output_token_long = self.position.is_collateral_token_long();
        let is_pnl_token_long = self.position.is_long();
        let are_pnl_and_collateral_tokens_the_same =
            self.position.are_pnl_and_collateral_tokens_the_same();

        let mut fees = self.position.position_fees(
            self.params
                .prices
                .collateral_token_price(is_output_token_long),
            &self.size_delta_usd,
            price_impact.balance_change,
            self.params.is_liquidation_order(),
        )?;

        let remaining_collateral_amount = self.position.collateral_amount().clone();

        let processor = CollateralProcessor::new(
            self.position.market_mut(),
            is_output_token_long,
            is_pnl_token_long,
            are_pnl_and_collateral_tokens_the_same,
            &self.params.prices,
            remaining_collateral_amount,
            self.params.is_insolvent_close_allowed(),
        );

        let mut result = {
            let ty = self.params.swap;
            let mut swap_result = None;

            let price_impact_value = &price_impact.value;
            let result = processor.process(|mut ctx| {
                ctx.add_pnl_if_positive(&base_pnl_usd)?
                    .add_price_impact_if_positive(price_impact_value)?
                    .swap_profit_to_collateral_tokens(self.params.swap, |error| {
                        swap_result = Some(error);
                        Ok(())
                    })?
                    .pay_for_funding_fees(fees.funding_fees())?
                    .pay_for_pnl_if_negative(&base_pnl_usd)?
                    .pay_for_fees_excluding_funding(&mut fees)?
                    .pay_for_price_impact_if_negative(price_impact_value)?
                    .pay_for_price_impact_diff(&price_impact_diff)?;
                Ok(())
            })?;

            if let Some(result) = swap_result {
                match result {
                    Ok(report) => self.position.on_swapped(ty, &report)?,
                    Err(error) => self.position.on_swap_error(ty, error)?,
                }
            }

            result
        };

        // Handle initial collateral delta amount with price impact diff.
        // The price_impact_diff has been deducted from the output amount or the position's collateral
        // to reduce the chance that the position's collateral is reduced by an unexpected amount, adjust the
        // initial_collateral_delta_amount by the price_impact_diff_amount.
        // This would also help to prevent the position's leverage from being unexpectedly increased
        //
        // note that this calculation may not be entirely accurate since it is possible that the price_impact_diff
        // could have been paid with one of or a combination of collateral / output_amount / secondary_output_amount
        if !self.withdrawable_collateral_amount.is_zero() && !price_impact_diff.is_zero() {
            // The prices should have been validated to be non-zero.
            debug_assert!(!self.collateral_token_price().has_zero());
            let diff_amount = price_impact_diff
                .checked_div(self.collateral_token_price().pick_price(false))
                .ok_or(crate::Error::Computation("calculating diff amount"))?;
            if self.withdrawable_collateral_amount > diff_amount {
                self.withdrawable_collateral_amount = self
                    .withdrawable_collateral_amount
                    .checked_sub(&diff_amount)
                    .ok_or(crate::Error::Computation(
                        "calculating new withdrawable amount",
                    ))?;
            } else {
                self.withdrawable_collateral_amount = P::Num::zero();
            }
        }

        // Cap the withdrawal amount to the remaining collateral amount.
        if self.withdrawable_collateral_amount > result.remaining_collateral_amount {
            self.withdrawable_collateral_amount = result.remaining_collateral_amount.clone();
        }

        if !self.withdrawable_collateral_amount.is_zero() {
            result.remaining_collateral_amount = result
                .remaining_collateral_amount
                .checked_sub(&self.withdrawable_collateral_amount)
                .expect("must be success");
            result.output_amount = result
                .output_amount
                .checked_add(&self.withdrawable_collateral_amount)
                .ok_or(crate::Error::Computation(
                    "overflow occurred while adding withdrawable amount",
                ))?;
        }

        Ok(ProcessCollateralResult {
            price_impact_value: price_impact.value,
            price_impact_diff,
            execution_price,
            size_delta_in_tokens,
            is_output_token_long,
            is_secondary_output_token_long: is_pnl_token_long,
            collateral: result,
            fees,
            pnl: Pnl::new(base_pnl_usd, uncapped_base_pnl_usd),
        })
    }

    fn get_execution_params(&self) -> crate::Result<ExecutionParams<P::Num>> {
        let index_token_price = &self.params.prices.index_token_price;
        let size_delta_usd = &self.size_delta_usd;

        if size_delta_usd.is_zero() {
            return Ok(ExecutionParams {
                price_impact: Default::default(),
                price_impact_diff: Zero::zero(),
                execution_price: index_token_price
                    .pick_price(!self.position.is_long())
                    .clone(),
            });
        }

        let (price_impact, price_impact_diff_usd) = self.position.capped_position_price_impact(
            index_token_price,
            &self.size_delta_usd.to_opposite_signed()?,
            true,
        )?;

        let execution_price = utils::get_execution_price_for_decrease(
            index_token_price,
            self.position.size_in_usd(),
            self.position.size_in_tokens(),
            size_delta_usd,
            &price_impact.value,
            self.params.acceptable_price.as_ref(),
            self.position.is_long(),
        )?;

        Ok(ExecutionParams {
            price_impact,
            price_impact_diff: price_impact_diff_usd,
            execution_price,
        })
    }

    /// Swap the secondary output tokens to output tokens if needed.
    #[allow(clippy::type_complexity)]
    fn swap_collateral_token_to_pnl_token(
        market: &mut P::Market,
        report: &mut DecreasePositionReport<P::Num, P::Signed>,
        prices: &Prices<P::Num>,
        swap: DecreasePositionSwapType,
    ) -> crate::Result<Option<crate::Result<SwapReport<P::Num, <P::Num as Unsigned>::Signed>>>>
    {
        let is_token_in_long = report.is_output_token_long();
        let is_secondary_output_token_long = report.is_secondary_output_token_long();
        let (output_amount, secondary_output_amount) = report.output_amounts_mut();
        if !output_amount.is_zero()
            && matches!(swap, DecreasePositionSwapType::CollateralToPnlToken)
        {
            if is_token_in_long == is_secondary_output_token_long {
                return Err(crate::Error::InvalidArgument(
                    "swap collateral: swap is not required",
                ));
            }

            let token_in_amount = output_amount.clone();

            match market
                .swap(is_token_in_long, token_in_amount, prices.clone())
                .and_then(|a| a.execute())
            {
                Ok(swap_report) => {
                    *secondary_output_amount = secondary_output_amount
                        .checked_add(swap_report.token_out_amount())
                        .ok_or(crate::Error::Computation(
                            "swap collateral: overflow occurred while adding token_out_amount",
                        ))?;
                    *output_amount = Zero::zero();
                    Ok(Some(Ok(swap_report)))
                }
                Err(err) => Ok(Some(Err(err))),
            }
        } else {
            Ok(None)
        }
    }
}

impl<const DECIMALS: u8, P: PositionMut<DECIMALS>> MarketAction for DecreasePosition<P, DECIMALS>
where
    P::Market: PerpMarketMut<DECIMALS, Num = P::Num, Signed = P::Signed>,
{
    type Report = Box<DecreasePositionReport<P::Num, P::Signed>>;

    fn execute(mut self) -> crate::Result<Self::Report> {
        debug_assert!(
            self.size_delta_usd <= *self.position.size_in_usd_mut(),
            "must have been checked or capped by the position size"
        );
        debug_assert!(
            self.withdrawable_collateral_amount <= *self.position.collateral_amount_mut(),
            "must have been capped by the position collateral amount"
        );

        self.check_partial_close()?;
        self.check_close()?;

        if !matches!(self.params.swap, DecreasePositionSwapType::NoSwap)
            && self.position.are_pnl_and_collateral_tokens_the_same()
        {
            self.params.swap = DecreasePositionSwapType::NoSwap;
        }

        self.check_liquidation()?;

        let initial_collateral_amount = self.position.collateral_amount_mut().clone();

        let mut execution = self.process_collateral()?;

        let should_remove;
        {
            let is_long = self.position.is_long();
            let is_collateral_long = self.position.is_collateral_token_long();

            let next_position_size_in_usd = self
                .position
                .size_in_usd_mut()
                .checked_sub(&self.size_delta_usd)
                .ok_or(crate::Error::Computation(
                    "calculating next position size in usd",
                ))?;
            let next_position_borrowing_factor = self
                .position
                .market()
                .cumulative_borrowing_factor(is_long)?;

            // Update total borrowing before updating position size.
            self.position.update_total_borrowing(
                &next_position_size_in_usd,
                &next_position_borrowing_factor,
            )?;

            let next_position_size_in_tokens = self
                .position
                .size_in_tokens_mut()
                .checked_sub(&execution.size_delta_in_tokens)
                .ok_or(crate::Error::Computation("calculating next size in tokens"))?;
            let next_position_collateral_amount =
                execution.collateral.remaining_collateral_amount.clone();

            should_remove =
                next_position_size_in_usd.is_zero() || next_position_size_in_tokens.is_zero();

            if should_remove {
                *self.position.size_in_usd_mut() = Zero::zero();
                *self.position.size_in_tokens_mut() = Zero::zero();
                *self.position.collateral_amount_mut() = Zero::zero();
                execution.collateral.output_amount = execution
                    .collateral
                    .output_amount
                    .checked_add(&next_position_collateral_amount)
                    .ok_or(crate::Error::Computation("calculating output amount"))?;
            } else {
                *self.position.size_in_usd_mut() = next_position_size_in_usd;
                *self.position.size_in_tokens_mut() = next_position_size_in_tokens;
                *self.position.collateral_amount_mut() = next_position_collateral_amount;
            };

            // Update collateral sum.
            {
                let collateral_delta_amount = initial_collateral_amount
                    .checked_sub(self.position.collateral_amount_mut())
                    .ok_or(crate::Error::Computation("collateral amount increased"))?;

                self.position
                    .market_mut()
                    .collateral_sum_pool_mut(is_long)?
                    .apply_delta_amount(
                        is_collateral_long,
                        &collateral_delta_amount.to_opposite_signed()?,
                    )?;
            }

            // The state of the position must be up-to-date, even if it is going to be removed.
            *self.position.borrowing_factor_mut() = next_position_borrowing_factor;
            *self.position.funding_fee_amount_per_size_mut() = self
                .position
                .market()
                .funding_fee_amount_per_size(is_long, is_collateral_long)?;
            for is_long_collateral in [true, false] {
                *self
                    .position
                    .claimable_funding_fee_amount_per_size_mut(is_long_collateral) = self
                    .position
                    .market()
                    .claimable_funding_fee_amount_per_size(is_long, is_long_collateral)?;
            }
        }

        // Update open interest.
        self.position.update_open_interest(
            &self.size_delta_usd.to_opposite_signed()?,
            &execution.size_delta_in_tokens.to_opposite_signed()?,
        )?;

        if !should_remove {
            self.position.validate(&self.params.prices, false, false)?;
        }

        self.position.on_decreased()?;

        let mut report = Box::new(DecreasePositionReport::new(
            &self.params,
            execution,
            self.withdrawable_collateral_amount,
            self.size_delta_usd,
            should_remove,
        ));

        // Swap collateral tokens to pnl tokens.
        {
            let ty = self.params.swap;
            let swap_result = Self::swap_collateral_token_to_pnl_token(
                self.position.market_mut(),
                &mut report,
                self.params.prices(),
                ty,
            )?;

            if let Some(result) = swap_result {
                match result {
                    Ok(report) => {
                        self.position.on_swapped(ty, &report)?;
                    }
                    Err(err) => {
                        self.position.on_swap_error(ty, err)?;
                    }
                }
            }
        }

        // Merge amounts if needed.
        let (output_amount, secondary_output_amount) = report.output_amounts_mut();
        if self.position.are_pnl_and_collateral_tokens_the_same()
            && !secondary_output_amount.is_zero()
        {
            *output_amount = output_amount.checked_add(secondary_output_amount).ok_or(
                crate::Error::Computation(
                    "overflow occurred while merging the secondary output amount",
                ),
            )?;
            *secondary_output_amount = Zero::zero();
        }

        Ok(report)
    }
}

struct ExecutionParams<T: Unsigned> {
    price_impact: PriceImpact<T::Signed>,
    price_impact_diff: T,
    execution_price: T,
}

#[cfg(test)]
mod tests {
    use crate::{
        market::LiquidityMarketMutExt,
        test::{TestMarket, TestPosition},
        MarketAction,
    };

    use super::*;

    #[test]
    fn basic() -> crate::Result<()> {
        let mut market = TestMarket::<u64, 9>::default();
        let prices = Prices::new_for_test(120, 120, 1);
        market.deposit(1_000_000_000, 0, prices)?.execute()?;
        market.deposit(0, 1_000_000_000, prices)?.execute()?;
        println!("{market:#?}");
        let mut position = TestPosition::long(true);
        let report = position
            .ops(&mut market)
            .increase(
                Prices::new_for_test(123, 123, 1),
                100_000_000,
                80_000_000_000,
                None,
            )?
            .execute()?;
        println!("{report:#?}");
        println!("{position:#?}");

        let report = position
            .ops(&mut market)
            .decrease(
                Prices::new_for_test(125, 125, 1),
                40_000_000_000,
                None,
                100_000_000,
                Default::default(),
            )?
            .execute()?;
        println!("{report:#?}");
        println!("{position:#?}");
        println!("{market:#?}");

        let report = position
            .ops(&mut market)
            .decrease(
                Prices::new_for_test(118, 118, 1),
                40_000_000_000,
                None,
                0,
                Default::default(),
            )?
            .execute()?;
        println!("{report:#?}");
        println!("{position:#?}");
        println!("{market:#?}");
        Ok(())
    }
}