import { IOrder } from '@yuants/data-order';
import { decodePath, newError, roundToStep } from '@yuants/utils';
import { ICredential, submitOrder as submitOrderApi } from '../../api/private-api';

export const submitOrder = async (credential: ICredential, order: IOrder): Promise<{ order_id: string }> => {
  // Parse product_id to get pair_id
  const [, _SWAP, _NAME, pair_id] = decodePath(order.product_id);

  // Determine order_way based on order_direction
  // 1: 开多 (Open Long), 2: 平空 (Close Short), 3: 开空 (Open Short), 4: 平多 (Close Long)
  let order_way: 1 | 2 | 3 | 4;
  switch (order.order_direction) {
    case 'OPEN_LONG':
      order_way = 1;
      break;
    case 'CLOSE_SHORT':
      order_way = 2;
      break;
    case 'OPEN_SHORT':
      order_way = 3;
      break;
    case 'CLOSE_LONG':
      order_way = 4;
      break;
    default:
      throw new Error(`Unsupported order direction: ${order.order_direction}`);
  }

  // Determine order_type
  let order_type: 'limit' | 'market' | 'stop_limit' | 'stop_market';
  switch (order.order_type) {
    case 'LIMIT':
      order_type = 'limit';
      break;
    case 'MARKET':
      order_type = 'market';
      break;
    default:
      order_type = 'limit';
  }

  if (order.volume < 1) {
    throw newError('TURBOFLOW_MIN_ORDER_VOLUME', { volume: order.volume });
  }

  // Build the order request
  const leverage = order.volume > 100 ? 100 : Math.floor(order.volume);
  // 开仓时，保证金不得低于 1 USDC
  const vol = order.order_direction.includes('OPEN') ? order.volume / leverage : undefined; // usdc 保证金数量
  // 平仓时，剩余小于 1 USDC 时会自动平仓
  const size = order.order_direction.includes('CLOSE') ? Math.floor(order.volume).toString() : undefined; // 头寸名义价值

  const response = await submitOrderApi(credential, {
    request_id: Date.now(),
    pair_id,
    pool_id: 2, // usdc
    coin_code: '2', // usdc
    order_type,
    order_way,
    margin_type: 2, // Default to cross margin
    leverage,
    vol: vol, // usdc 保证金数量
    size: size, // 头寸名义价值
    position_mode: 1, // Default to one-way
    time_in_force: 'GTC' as const,
    fee_mode: 1,
    order_mode: 1 as const, // Normal order
    price: order.price?.toString(),
    position_id: order.position_id,
  });

  if (!response.data?.order) throw newError('TURBOFLOW_SUBMIT_ORDER_FAILED', { response });

  return { order_id: response.data.order.id };
};