digdigdig3 0.3.10

//! # Binance Response Parser
//!
//! Парсинг JSON ответов от Binance API.

use serde_json::Value;

use crate::core::types::{
    ExchangeError, ExchangeResult,
    Kline, OrderBook, OrderBookLevel, Ticker, Order, Balance, Position,
    OrderSide, OrderType, OrderStatus, PositionSide,
    FundingRate, SymbolInfo, FeeInfo,
    OcoResponse, CancelAllResponse, OrderResult,
    AlgoOrderResponse, BracketResponse,
    TransferResponse, DepositAddress, WithdrawResponse, FundsRecord,
    SubAccountResult, SubAccount,
    UserTrade,
    FundingPayment, LedgerEntry, LedgerEntryType,
    AccountType,
    LongShortRatio, OpenInterest,
    StreamEvent,
};
use crate::core::websocket::KlineInterval;

// ═══════════════════════════════════════════════════════════════════════════════
// PREMIUM INDEX DATA
// ═══════════════════════════════════════════════════════════════════════════════

/// Typed response from `GET /fapi/v1/premiumIndex`.
///
/// Contains mark price, index price, estimated settle price, and funding info.
#[derive(Debug, Clone)]
pub struct PremiumIndexData {
    /// Trading symbol.
    pub symbol: String,
    /// Current mark price.
    pub mark_price: f64,
    /// Current index price.
    pub index_price: f64,
    /// Estimated settle price (last hour average index).
    pub estimated_settle_price: Option<f64>,
    /// Last funding rate.
    pub last_funding_rate: f64,
    /// Next funding time (Unix ms).
    pub next_funding_time: i64,
    /// Interest rate.
    pub interest_rate: f64,
    /// Event timestamp (Unix ms).
    pub timestamp: i64,
}

/// Парсер ответов Binance API
pub struct BinanceParser;

impl BinanceParser {
    // ═══════════════════════════════════════════════════════════════════════════
    // HELPERS
    // ═══════════════════════════════════════════════════════════════════════════

    /// Парсить f64 из string или number
    fn parse_f64(value: &Value) -> Option<f64> {
        value.as_str()
            .and_then(|s| s.parse().ok())
            .or_else(|| value.as_f64())
    }

    /// Парсить f64 из поля
    fn get_f64(data: &Value, key: &str) -> Option<f64> {
        data.get(key).and_then(Self::parse_f64)
    }

    /// Парсить обязательный f64
    fn require_f64(data: &Value, key: &str) -> ExchangeResult<f64> {
        Self::get_f64(data, key)
            .ok_or_else(|| ExchangeError::Parse(format!("Missing or invalid '{}'", key)))
    }

    /// Парсить строку из поля
    fn get_str<'a>(data: &'a Value, key: &str) -> Option<&'a str> {
        data.get(key).and_then(|v| v.as_str())
    }

    /// Парсить обязательную строку
    fn _require_str<'a>(data: &'a Value, key: &str) -> ExchangeResult<&'a str> {
        Self::get_str(data, key)
            .ok_or_else(|| ExchangeError::Parse(format!("Missing '{}'", key)))
    }

    /// Проверить и обработать ошибки API
    pub fn check_error(response: &Value) -> ExchangeResult<()> {
        if let Some(code) = response.get("code").and_then(|c| c.as_i64()) {
            if code != 200 {
                let msg = response.get("msg")
                    .and_then(|m| m.as_str())
                    .unwrap_or("Unknown error");
                return Err(ExchangeError::Api {
                    code: code as i32,
                    message: msg.to_string(),
                });
            }
        }
        Ok(())
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // MARKET DATA
    // ═══════════════════════════════════════════════════════════════════════════

    /// Парсить price
    pub fn parse_price(response: &Value) -> ExchangeResult<f64> {
        Self::check_error(response)?;
        Self::require_f64(response, "price")
    }

    /// Парсить klines
    pub fn parse_klines(response: &Value) -> ExchangeResult<Vec<Kline>> {
        Self::check_error(response)?;

        let arr = response.as_array()
            .ok_or_else(|| ExchangeError::Parse("Response is not an array".to_string()))?;

        let mut klines = Vec::with_capacity(arr.len());

        for item in arr {
            let candle = item.as_array()
                .ok_or_else(|| ExchangeError::Parse("Kline is not an array".to_string()))?;

            if candle.len() < 12 {
                continue;
            }

            // Binance format: [time, open, high, low, close, volume, close_time, quote_volume, trades, ...]
            let open_time = candle[0].as_i64().unwrap_or(0);
            let close_time = candle[6].as_i64().unwrap_or(0);
            let trades = candle[8].as_i64().unwrap_or(0);

            klines.push(Kline {
                open_time,
                open: Self::parse_f64(&candle[1]).unwrap_or(0.0),
                high: Self::parse_f64(&candle[2]).unwrap_or(0.0),
                low: Self::parse_f64(&candle[3]).unwrap_or(0.0),
                close: Self::parse_f64(&candle[4]).unwrap_or(0.0),
                volume: Self::parse_f64(&candle[5]).unwrap_or(0.0),
                close_time: Some(close_time),
                quote_volume: Self::parse_f64(&candle[7]),
                trades: Some(trades as u64),
            });
        }

        Ok(klines)
    }

    /// Парсить orderbook
    pub fn parse_orderbook(response: &Value) -> ExchangeResult<OrderBook> {
        Self::check_error(response)?;

        let parse_levels = |key: &str| -> Vec<OrderBookLevel> {
            response.get(key)
                .and_then(|v| v.as_array())
                .map(|arr| {
                    arr.iter()
                        .filter_map(|level| {
                            let pair = level.as_array()?;
                            if pair.len() < 2 { return None; }
                            let price = Self::parse_f64(&pair[0])?;
                            let size = Self::parse_f64(&pair[1])?;
                            Some(OrderBookLevel::new(price, size))
                        })
                        .collect()
                })
                .unwrap_or_default()
        };

        let last_update_id = response.get("lastUpdateId")
            .and_then(|s| s.as_u64());

        Ok(OrderBook {
            timestamp: 0, // Binance doesn't provide timestamp in REST orderbook
            bids: parse_levels("bids"),
            asks: parse_levels("asks"),
            sequence: last_update_id.map(|n| n.to_string()),
            last_update_id,
            first_update_id: None,
            prev_update_id: None,
            event_time: None,
            transaction_time: None,
            checksum: None,
        })
    }

    /// Парсить ticker
    ///
    /// Supports both REST API format (long field names) and WebSocket format (short field names)
    pub fn parse_ticker(response: &Value) -> ExchangeResult<Ticker> {
        Self::check_error(response)?;

        // Detect format by checking for WebSocket-specific short field names
        let is_websocket = response.get("s").is_some() && response.get("c").is_some();

        if is_websocket {
            // WebSocket format: uses short field names
            // Reference: https://binance-docs.github.io/apidocs/spot/en/#individual-symbol-ticker-streams
            Ok(Ticker {
                last_price: Self::get_f64(response, "c").unwrap_or(0.0),
                bid_price: Self::get_f64(response, "b"),
                ask_price: Self::get_f64(response, "a"),
                high_24h: Self::get_f64(response, "h"),
                low_24h: Self::get_f64(response, "l"),
                volume_24h: Self::get_f64(response, "v"),
                quote_volume_24h: Self::get_f64(response, "q"),
                price_change_24h: Self::get_f64(response, "p"),
                price_change_percent_24h: Self::get_f64(response, "P"),
                timestamp: response.get("E").and_then(|t| t.as_i64()).unwrap_or(0),
            })
        } else {
            // REST API format: uses long field names
            // Reference: https://binance-docs.github.io/apidocs/spot/en/#24hr-ticker-price-change-statistics
            Ok(Ticker {
                last_price: Self::get_f64(response, "lastPrice").unwrap_or(0.0),
                bid_price: Self::get_f64(response, "bidPrice"),
                ask_price: Self::get_f64(response, "askPrice"),
                high_24h: Self::get_f64(response, "highPrice"),
                low_24h: Self::get_f64(response, "lowPrice"),
                volume_24h: Self::get_f64(response, "volume"),
                quote_volume_24h: Self::get_f64(response, "quoteVolume"),
                price_change_24h: Self::get_f64(response, "priceChange"),
                price_change_percent_24h: Self::get_f64(response, "priceChangePercent"),
                timestamp: response.get("closeTime").and_then(|t| t.as_i64()).unwrap_or(0),
            })
        }
    }

    /// Парсить funding rate
    pub fn parse_funding_rate(response: &Value) -> ExchangeResult<FundingRate> {
        Self::check_error(response)?;

        // Response is an array, take first element
        let data = if let Some(arr) = response.as_array() {
            arr.first().ok_or_else(|| ExchangeError::Parse("Empty funding rate array".to_string()))?
        } else {
            response
        };

        Ok(FundingRate {
            rate: Self::require_f64(data, "fundingRate")?,
            next_funding_time: data.get("fundingTime").and_then(|t| t.as_i64()),
            timestamp: data.get("fundingTime").and_then(|t| t.as_i64()).unwrap_or(0),
        })
    }

    /// Parse an array of funding rate records (CM `/dapi/v1/fundingRate` response).
    ///
    /// Each element: `{symbol, fundingTime, fundingRate, markPrice}`.
    pub fn parse_funding_rates(response: &Value) -> ExchangeResult<Vec<FundingRate>> {
        let arr = response.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected JSON array for funding rates".to_string()))?;
        let result = arr.iter().map(|item| FundingRate {
            rate: Self::get_f64(item, "fundingRate").unwrap_or(0.0),
            next_funding_time: item.get("fundingTime").and_then(|t| t.as_i64()),
            timestamp: item.get("fundingTime").and_then(|t| t.as_i64()).unwrap_or(0),
        }).collect();
        Ok(result)
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // TRADING
    // ═══════════════════════════════════════════════════════════════════════════

    /// Парсить order из response
    pub fn parse_order(response: &Value, _symbol: &str) -> ExchangeResult<Order> {
        Self::check_error(response)?;
        Self::parse_order_data(response)
    }

    /// Парсить order из data object
    pub fn parse_order_data(data: &Value) -> ExchangeResult<Order> {
        let side = match Self::get_str(data, "side").unwrap_or("BUY").to_uppercase().as_str() {
            "SELL" => OrderSide::Sell,
            _ => OrderSide::Buy,
        };

        let order_type = match Self::get_str(data, "type").unwrap_or("LIMIT").to_uppercase().as_str() {
            "MARKET" => OrderType::Market,
            _ => OrderType::Limit { price: 0.0 },
        };

        let status = Self::parse_order_status(data);

        Ok(Order {
            id: data.get("orderId")
                .and_then(|id| id.as_i64())
                .map(|id| id.to_string())
                .unwrap_or_default(),
            client_order_id: Self::get_str(data, "clientOrderId").map(String::from),
            symbol: Self::get_str(data, "symbol").map(String::from),
            side,
            order_type,
            status,
            price: Self::get_f64(data, "price"),
            stop_price: Self::get_f64(data, "stopPrice"),
            quantity: Self::get_f64(data, "origQty").unwrap_or(0.0),
            filled_quantity: Self::get_f64(data, "executedQty").unwrap_or(0.0),
            average_price: Self::get_f64(data, "avgPrice")
                .or_else(|| {
                    // Calculate from cummulativeQuoteQty / executedQty
                    let quote = Self::get_f64(data, "cummulativeQuoteQty")?;
                    let qty = Self::get_f64(data, "executedQty")?;
                    if qty > 0.0 {
                        Some(quote / qty)
                    } else {
                        None
                    }
                }),
            commission: None, // Not in standard order response
            commission_asset: None,
            created_at: data.get("time")
                .or_else(|| data.get("transactTime"))
                .and_then(|t| t.as_i64())
                .unwrap_or(0),
            updated_at: data.get("updateTime").and_then(|t| t.as_i64()),
            time_in_force: crate::core::TimeInForce::Gtc,
        })
    }

    /// Парсить статус ордера
    fn parse_order_status(data: &Value) -> OrderStatus {
        match Self::get_str(data, "status").unwrap_or("NEW").to_uppercase().as_str() {
            "NEW" => OrderStatus::New,
            "PARTIALLY_FILLED" => OrderStatus::PartiallyFilled,
            "FILLED" => OrderStatus::Filled,
            "CANCELED" => OrderStatus::Canceled,
            "PENDING_CANCEL" => OrderStatus::Canceled, // Treat as Canceled
            "REJECTED" => OrderStatus::Rejected,
            "EXPIRED" => OrderStatus::Expired,
            "EXPIRED_IN_MATCH" => OrderStatus::Expired,
            _ => OrderStatus::New,
        }
    }

    /// Парсить список ордеров
    pub fn parse_orders(response: &Value) -> ExchangeResult<Vec<Order>> {
        Self::check_error(response)?;

        let arr = response.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected array of orders".to_string()))?;

        arr.iter()
            .map(Self::parse_order_data)
            .collect()
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // FILLS / USER TRADES
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse a list of user trade fills from `/api/v3/myTrades` (spot) or
    /// `/fapi/v1/userTrades` (futures).
    ///
    /// Spot uses `isBuyer: bool` to determine side; futures uses `side: "BUY"/"SELL"`.
    /// Both are handled transparently — whichever field is present wins.
    pub fn parse_user_trades(response: &Value, is_futures: bool) -> ExchangeResult<Vec<UserTrade>> {
        Self::check_error(response)?;

        let arr = response.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected array of user trades".to_string()))?;

        arr.iter()
            .map(|item| {
                // Determine side.
                // Futures: "side" field ("BUY" / "SELL").
                // Spot:    "isBuyer" bool field (true = Buy, false = Sell).
                let side = if is_futures {
                    match Self::get_str(item, "side").unwrap_or("BUY").to_uppercase().as_str() {
                        "SELL" => OrderSide::Sell,
                        _ => OrderSide::Buy,
                    }
                } else {
                    let is_buyer = item.get("isBuyer")
                        .and_then(|v| v.as_bool())
                        .unwrap_or(true);
                    if is_buyer { OrderSide::Buy } else { OrderSide::Sell }
                };

                // Trade id — numeric on both endpoints.
                let id = item.get("id")
                    .and_then(|v| v.as_i64())
                    .map(|v| v.to_string())
                    .ok_or_else(|| ExchangeError::Parse("Missing 'id' in trade".to_string()))?;

                // Order id — numeric on both endpoints.
                let order_id = item.get("orderId")
                    .and_then(|v| v.as_i64())
                    .map(|v| v.to_string())
                    .ok_or_else(|| ExchangeError::Parse("Missing 'orderId' in trade".to_string()))?;

                let symbol = Self::get_str(item, "symbol")
                    .unwrap_or("")
                    .to_string();

                let price = Self::require_f64(item, "price")?;

                // Spot uses "qty", futures uses "qty" as well (both consistent).
                let quantity = Self::require_f64(item, "qty")?;

                let commission = Self::get_f64(item, "commission").unwrap_or(0.0);

                let commission_asset = Self::get_str(item, "commissionAsset")
                    .unwrap_or("")
                    .to_string();

                // is_maker: spot uses "isMaker", futures uses "maker".
                let is_maker = item.get("isMaker")
                    .or_else(|| item.get("maker"))
                    .and_then(|v| v.as_bool())
                    .unwrap_or(false);

                let timestamp = item.get("time")
                    .and_then(|v| v.as_i64())
                    .unwrap_or(0);

                Ok(UserTrade {
                    id,
                    order_id,
                    symbol,
                    side,
                    price,
                    quantity,
                    commission,
                    commission_asset,
                    is_maker,
                    timestamp,
                })
            })
            .collect()
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // ACCOUNT
    // ═══════════════════════════════════════════════════════════════════════════

    /// Парсить balances
    pub fn parse_balances(response: &Value) -> ExchangeResult<Vec<Balance>> {
        Self::check_error(response)?;

        let arr = response.get("balances")
            .and_then(|b| b.as_array())
            .ok_or_else(|| ExchangeError::Parse("Missing 'balances' array".to_string()))?;

        let mut balances = Vec::new();

        for item in arr {
            let asset = Self::get_str(item, "asset").unwrap_or("").to_string();
            if asset.is_empty() { continue; }

            let free = Self::get_f64(item, "free").unwrap_or(0.0);
            let locked = Self::get_f64(item, "locked").unwrap_or(0.0);

            // Skip zero balances
            if free == 0.0 && locked == 0.0 {
                continue;
            }

            balances.push(Balance {
                asset,
                free,
                locked,
                total: free + locked,
            });
        }

        Ok(balances)
    }

    /// Парсить futures account balances
    pub fn parse_futures_balances(response: &Value) -> ExchangeResult<Vec<Balance>> {
        Self::check_error(response)?;

        let arr = response.get("assets")
            .and_then(|a| a.as_array())
            .ok_or_else(|| ExchangeError::Parse("Missing 'assets' array".to_string()))?;

        let mut balances = Vec::new();

        for item in arr {
            let asset = Self::get_str(item, "asset").unwrap_or("").to_string();
            if asset.is_empty() { continue; }

            let free = Self::get_f64(item, "availableBalance").unwrap_or(0.0);
            let locked = Self::get_f64(item, "initialMargin")
                .unwrap_or(0.0);

            // Skip zero balances
            if free == 0.0 && locked == 0.0 {
                continue;
            }

            balances.push(Balance {
                asset,
                free,
                locked,
                total: free + locked,
            });
        }

        Ok(balances)
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // POSITIONS
    // ═══════════════════════════════════════════════════════════════════════════

    /// Парсить positions
    pub fn parse_positions(response: &Value) -> ExchangeResult<Vec<Position>> {
        Self::check_error(response)?;

        let arr = response.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected array of positions".to_string()))?;

        let mut positions = Vec::new();

        for item in arr {
            if let Some(pos) = Self::parse_position_data(item) {
                positions.push(pos);
            }
        }

        Ok(positions)
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // EXCHANGE INFO
    // ═══════════════════════════════════════════════════════════════════════════

    /// Парсить список торговых символов из exchangeInfo
    ///
    /// Возвращает только символы со статусом `TRADING`.
    pub fn parse_exchange_info(response: &serde_json::Value, account_type: AccountType) -> ExchangeResult<Vec<SymbolInfo>> {
        let symbols = response["symbols"].as_array()
            .ok_or_else(|| ExchangeError::Parse("missing symbols array".into()))?;

        let mut result = Vec::with_capacity(symbols.len());
        for s in symbols {
            let status = s["status"].as_str().unwrap_or("").to_string();
            if status != "TRADING" { continue; }

            let filters = s["filters"].as_array();

            let tick_size = filters.and_then(|f| {
                f.iter()
                    .find(|x| x["filterType"] == "PRICE_FILTER")
                    .and_then(|x| x["tickSize"].as_str())
                    .and_then(|s| s.parse::<f64>().ok())
            });

            let lot_size_filter = filters.and_then(|f| {
                f.iter().find(|x| x["filterType"] == "LOT_SIZE")
            });

            let step_size = lot_size_filter
                .and_then(|x| x["stepSize"].as_str())
                .and_then(|s| s.parse::<f64>().ok());

            let min_quantity = lot_size_filter
                .and_then(|x| x["minQty"].as_str())
                .and_then(|s| s.parse::<f64>().ok());

            let max_quantity = lot_size_filter
                .and_then(|x| x["maxQty"].as_str())
                .and_then(|s| s.parse::<f64>().ok());

            let min_notional = filters.and_then(|f| {
                f.iter()
                    .find(|x| x["filterType"] == "MIN_NOTIONAL" || x["filterType"] == "NOTIONAL")
                    .and_then(|x| x["minNotional"].as_str())
                    .and_then(|s| s.parse::<f64>().ok())
            });

            result.push(SymbolInfo {
                symbol: s["symbol"].as_str().unwrap_or("").to_string(),
                base_asset: s["baseAsset"].as_str().unwrap_or("").to_string(),
                quote_asset: s["quoteAsset"].as_str().unwrap_or("").to_string(),
                status,
                price_precision: s["pricePrecision"].as_u64().unwrap_or(8) as u8,
                quantity_precision: s["quantityPrecision"].as_u64().unwrap_or(8) as u8,
                min_quantity,
                max_quantity,
                tick_size,
                step_size,
                min_notional,
                account_type,
            });
        }
        Ok(result)
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // OCO / CANCEL ALL / BATCH
    // ═══════════════════════════════════════════════════════════════════════════

    /// Парсить ответ OCO ордера
    ///
    /// Binance returns `orderReports` array with 2 orders plus a `listOrderId`.
    pub fn parse_oco_response(response: &Value) -> ExchangeResult<OcoResponse> {
        Self::check_error(response)?;

        let reports = response.get("orderReports")
            .and_then(|r| r.as_array())
            .ok_or_else(|| ExchangeError::Parse("Missing 'orderReports' in OCO response".to_string()))?;

        if reports.len() < 2 {
            return Err(ExchangeError::Parse(format!(
                "Expected 2 orders in OCO response, got {}", reports.len()
            )));
        }

        let first_order = Self::parse_order_data(&reports[0])?;
        let second_order = Self::parse_order_data(&reports[1])?;

        let list_id = response.get("listClientOrderId")
            .or_else(|| response.get("orderListId"))
            .and_then(|v| {
                if let Some(s) = v.as_str() {
                    Some(s.to_string())
                } else {
                    v.as_i64().map(|n| n.to_string())
                }
            });

        Ok(OcoResponse {
            first_order,
            second_order,
            list_id,
        })
    }

    /// Парсить ответ OTOCO ордера (Bracket на Binance Spot)
    ///
    /// Binance OTOCO returns `orderReports` array with 3 orders:
    /// - [0] working order (entry)
    /// - [1] pending take-profit
    /// - [2] pending stop-loss
    pub fn parse_otoco_response(response: &Value) -> ExchangeResult<BracketResponse> {
        Self::check_error(response)?;

        let reports = response.get("orderReports")
            .and_then(|r| r.as_array())
            .ok_or_else(|| ExchangeError::Parse("Missing 'orderReports' in OTOCO response".to_string()))?;

        if reports.len() < 3 {
            return Err(ExchangeError::Parse(format!(
                "Expected 3 orders in OTOCO response, got {}", reports.len()
            )));
        }

        let entry_order = Self::parse_order_data(&reports[0])?;
        let tp_order = Self::parse_order_data(&reports[1])?;
        let sl_order = Self::parse_order_data(&reports[2])?;

        Ok(BracketResponse {
            entry_order,
            tp_order,
            sl_order,
        })
    }

    /// Парсить ответ Algo ордера (TWAP, VP и т.д.)
    ///
    /// Binance Algo API returns: `{"code": 0, "msg": "", "data": {"clientAlgoId": "...", "success": true}}`
    pub fn parse_algo_order_response(response: &Value) -> ExchangeResult<AlgoOrderResponse> {
        // Check top-level code (Algo API uses 0 for success, not 200)
        if let Some(code) = response.get("code").and_then(|c| c.as_i64()) {
            if code != 0 {
                let msg = response.get("msg")
                    .and_then(|m| m.as_str())
                    .unwrap_or("Algo order failed");
                return Err(ExchangeError::Api {
                    code: code as i32,
                    message: msg.to_string(),
                });
            }
        }

        // Extract from nested `data` object if present
        let data = response.get("data").unwrap_or(response);

        let algo_id = data.get("clientAlgoId")
            .or_else(|| data.get("algoId"))
            .and_then(|v| v.as_str())
            .map(String::from)
            .unwrap_or_default();

        let status = if data.get("success").and_then(|v| v.as_bool()).unwrap_or(true) {
            "Running".to_string()
        } else {
            "Failed".to_string()
        };

        Ok(AlgoOrderResponse {
            algo_id,
            status,
            executed_count: None,
            total_count: None,
        })
    }

    /// Парсить ответ cancel-all (массив отменённых ордеров или пустой объект)
    ///
    /// Binance Spot `DELETE /api/v3/openOrders` returns an array of cancelled orders.
    /// Binance Futures `DELETE /fapi/v1/allOpenOrders` returns `{"code": 200, "msg": "The operation of cancel all open order is done."}`.
    pub fn parse_cancel_all_response(response: &Value) -> ExchangeResult<CancelAllResponse> {
        Self::check_error(response)?;

        // Futures returns a success code object
        if response.is_object() && !response.as_object().map(|o| o.contains_key("code")).unwrap_or(false) {
            // Spot case: might be an array wrapped in object — shouldn't happen, but handle
            return Ok(CancelAllResponse {
                cancelled_count: 0,
                failed_count: 0,
                details: vec![],
            });
        }

        // Spot case: array of cancelled orders
        if let Some(arr) = response.as_array() {
            let details: Vec<OrderResult> = arr.iter().map(|item| {
                match Self::parse_order_data(item) {
                    Ok(order) => OrderResult {
                        order: Some(order),
                        client_order_id: None,
                        success: true,
                        error: None,
                        error_code: None,
                    },
                    Err(e) => OrderResult {
                        order: None,
                        client_order_id: None,
                        success: false,
                        error: Some(e.to_string()),
                        error_code: None,
                    },
                }
            }).collect();

            let cancelled_count = details.iter().filter(|d| d.success).count() as u32;
            let failed_count = details.iter().filter(|d| !d.success).count() as u32;

            return Ok(CancelAllResponse {
                cancelled_count,
                failed_count,
                details,
            });
        }

        // Futures success object: {"code": 200, "msg": "..."}
        Ok(CancelAllResponse {
            cancelled_count: 0, // Futures does not return individual cancelled orders
            failed_count: 0,
            details: vec![],
        })
    }

    /// Парсить ответ batch orders
    ///
    /// Binance Futures batch returns an array where each element is either
    /// an order object or an error object with `code`/`msg`.
    pub fn parse_batch_orders_response(response: &Value) -> ExchangeResult<Vec<OrderResult>> {
        Self::check_error(response)?;

        let arr = response.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected array in batch orders response".to_string()))?;

        Ok(arr.iter().map(|item| {
            // Check if this item is an error
            if let Some(code) = item.get("code").and_then(|c| c.as_i64()) {
                if code < 0 {
                    let msg = item.get("msg")
                        .and_then(|m| m.as_str())
                        .unwrap_or("Unknown batch error")
                        .to_string();
                    return OrderResult {
                        order: None,
                        client_order_id: item.get("clientOrderId")
                            .and_then(|v| v.as_str())
                            .map(String::from),
                        success: false,
                        error: Some(msg),
                        error_code: Some(code as i32),
                    };
                }
            }

            match Self::parse_order_data(item) {
                Ok(order) => OrderResult {
                    client_order_id: order.client_order_id.clone(),
                    order: Some(order),
                    success: true,
                    error: None,
                    error_code: None,
                },
                Err(e) => OrderResult {
                    order: None,
                    client_order_id: None,
                    success: false,
                    error: Some(e.to_string()),
                    error_code: None,
                },
            }
        }).collect())
    }

    /// Парсить fee info из:
    /// - `/sapi/v1/asset/tradeFee` — array of `{symbol, makerCommission, takerCommission}`
    /// - `/api/v3/account` — object with `commissionRates.{maker, taker}`
    /// - `/fapi/v1/commissionRate` — object with `{makerCommissionRate, takerCommissionRate}`
    pub fn parse_fee_info(response: &Value, symbol: Option<&str>) -> ExchangeResult<FeeInfo> {
        Self::check_error(response)?;

        // Spot trade fee endpoint: array of {symbol, makerCommission, takerCommission}
        if let Some(arr) = response.as_array() {
            if let Some(first) = arr.first() {
                let maker_rate = Self::get_f64(first, "makerCommission").unwrap_or(0.001);
                let taker_rate = Self::get_f64(first, "takerCommission").unwrap_or(0.001);
                return Ok(FeeInfo {
                    maker_rate,
                    taker_rate,
                    symbol: Self::get_str(first, "symbol").map(String::from),
                    tier: None,
                });
            }
            return Err(ExchangeError::Parse("Empty fee array".to_string()));
        }

        // Futures commissionRate endpoint: {symbol, makerCommissionRate, takerCommissionRate}
        if let (Some(maker_rate), Some(taker_rate)) = (
            Self::get_f64(response, "makerCommissionRate"),
            Self::get_f64(response, "takerCommissionRate"),
        ) {
            return Ok(FeeInfo {
                maker_rate,
                taker_rate,
                symbol: Self::get_str(response, "symbol")
                    .map(String::from)
                    .or_else(|| symbol.map(String::from)),
                tier: None,
            });
        }

        // Spot account endpoint: commissionRates object
        if let Some(rates) = response.get("commissionRates") {
            let maker_rate = rates.get("maker")
                .and_then(Self::parse_f64)
                .unwrap_or(0.001);
            let taker_rate = rates.get("taker")
                .and_then(Self::parse_f64)
                .unwrap_or(0.001);
            return Ok(FeeInfo {
                maker_rate,
                taker_rate,
                symbol: symbol.map(String::from),
                tier: None,
            });
        }

        // Futures account endpoint: feeTier (int) with no explicit rates in base response
        // feeTier 0 = Regular (0.02%/0.04%), each tier reduces rates by ~10%
        if let Some(fee_tier) = response.get("feeTier").and_then(|v| v.as_u64()) {
            // Standard Binance USDT-M fee schedule (VIP 0 baseline)
            let (maker_rate, taker_rate) = match fee_tier {
                0 => (0.0002, 0.0004),
                1 => (0.00016, 0.0004),
                2 => (0.00014, 0.00035),
                3 => (0.00012, 0.00032),
                4 => (0.0001, 0.0003),
                5 => (0.00008, 0.00027),
                6 => (0.00006, 0.00025),
                7 => (0.00005, 0.00022),
                8 => (0.00003, 0.0002),
                9 => (0.0, 0.00017),
                _ => (0.0002, 0.0004),
            };
            return Ok(FeeInfo {
                maker_rate,
                taker_rate,
                symbol: symbol.map(String::from),
                tier: Some(format!("VIP{}", fee_tier)),
            });
        }

        Err(ExchangeError::Parse("Cannot extract fee info from response".to_string()))
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // ACCOUNT TRANSFERS
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse transfer response from POST /sapi/v1/asset/transfer
    ///
    /// Binance returns: `{"tranId": 13526853623}`
    pub fn parse_transfer_response(response: &Value, asset: &str, amount: f64) -> ExchangeResult<TransferResponse> {
        Self::check_error(response)?;

        let transfer_id = response.get("tranId")
            .and_then(|v| {
                if let Some(n) = v.as_i64() {
                    Some(n.to_string())
                } else {
                    v.as_str().map(String::from)
                }
            })
            .ok_or_else(|| ExchangeError::Parse("Missing 'tranId' in transfer response".to_string()))?;

        Ok(TransferResponse {
            transfer_id,
            status: "Successful".to_string(),
            asset: asset.to_string(),
            amount,
            timestamp: None,
        })
    }

    /// Parse transfer history from GET /sapi/v1/asset/transfer
    ///
    /// Binance returns: `{"total": N, "rows": [{...}, ...]}`
    pub fn parse_transfer_history(response: &Value) -> ExchangeResult<Vec<TransferResponse>> {
        Self::check_error(response)?;

        let rows = response.get("rows")
            .and_then(|r| r.as_array())
            .ok_or_else(|| ExchangeError::Parse("Missing 'rows' in transfer history response".to_string()))?;

        let mut result = Vec::with_capacity(rows.len());
        for item in rows {
            let transfer_id = item.get("tranId")
                .and_then(|v| {
                    if let Some(n) = v.as_i64() {
                        Some(n.to_string())
                    } else {
                        v.as_str().map(String::from)
                    }
                })
                .unwrap_or_default();

            let asset = Self::get_str(item, "asset").unwrap_or("").to_string();
            let amount = Self::get_f64(item, "amount").unwrap_or(0.0);
            let status = Self::get_str(item, "status").unwrap_or("").to_string();
            let timestamp = item.get("timestamp").and_then(|t| t.as_i64());

            result.push(TransferResponse {
                transfer_id,
                status,
                asset,
                amount,
                timestamp,
            });
        }

        Ok(result)
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // CUSTODIAL FUNDS
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse deposit address from GET /sapi/v1/capital/deposit/address
    ///
    /// Binance returns: `{"address": "...", "coin": "BTC", "tag": "", "url": "..."}`
    pub fn parse_deposit_address(response: &Value) -> ExchangeResult<DepositAddress> {
        Self::check_error(response)?;

        let address = Self::get_str(response, "address")
            .ok_or_else(|| ExchangeError::Parse("Missing 'address' in deposit address response".to_string()))?
            .to_string();

        let asset = Self::get_str(response, "coin").unwrap_or("").to_string();
        let tag = Self::get_str(response, "tag")
            .filter(|s| !s.is_empty())
            .map(String::from);
        let network = Self::get_str(response, "network")
            .filter(|s| !s.is_empty())
            .map(String::from);

        Ok(DepositAddress {
            address,
            tag,
            network,
            asset,
            created_at: None,
        })
    }

    /// Parse withdraw response from POST /sapi/v1/capital/withdraw/apply
    ///
    /// Binance returns: `{"id": "7213fea8e94b4a5593d507237e5a555b"}`
    pub fn parse_withdraw_response(response: &Value) -> ExchangeResult<WithdrawResponse> {
        Self::check_error(response)?;

        let withdraw_id = Self::get_str(response, "id")
            .ok_or_else(|| ExchangeError::Parse("Missing 'id' in withdraw response".to_string()))?
            .to_string();

        Ok(WithdrawResponse {
            withdraw_id,
            status: "Pending".to_string(),
            tx_hash: None,
        })
    }

    /// Parse deposit history from GET /sapi/v1/capital/deposit/hisrec
    ///
    /// Binance returns an array of deposit records.
    pub fn parse_deposit_history(response: &Value) -> ExchangeResult<Vec<FundsRecord>> {
        Self::check_error(response)?;

        let arr = response.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected array in deposit history response".to_string()))?;

        let mut result = Vec::with_capacity(arr.len());
        for item in arr {
            let id = item.get("id")
                .and_then(|v| v.as_str())
                .unwrap_or("")
                .to_string();
            let asset = Self::get_str(item, "coin").unwrap_or("").to_string();
            let amount = Self::get_f64(item, "amount").unwrap_or(0.0);
            let tx_hash = Self::get_str(item, "txId")
                .filter(|s| !s.is_empty())
                .map(String::from);
            let network = Self::get_str(item, "network")
                .filter(|s| !s.is_empty())
                .map(String::from);
            // Binance deposit status: 0=pending, 1=credited, 6=wrong_deposit, 7=waiting_user_confirm
            let status_code = item.get("status").and_then(|s| s.as_i64()).unwrap_or(0);
            let status = match status_code {
                0 => "Pending",
                1 => "Credited",
                _ => "Unknown",
            }.to_string();
            let timestamp = item.get("insertTime").and_then(|t| t.as_i64()).unwrap_or(0);

            result.push(FundsRecord::Deposit {
                id,
                asset,
                amount,
                tx_hash,
                network,
                status,
                timestamp,
            });
        }

        Ok(result)
    }

    /// Parse withdrawal history from GET /sapi/v1/capital/withdraw/history
    ///
    /// Binance returns an array of withdrawal records.
    pub fn parse_withdrawal_history(response: &Value) -> ExchangeResult<Vec<FundsRecord>> {
        Self::check_error(response)?;

        let arr = response.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected array in withdrawal history response".to_string()))?;

        let mut result = Vec::with_capacity(arr.len());
        for item in arr {
            let id = Self::get_str(item, "id").unwrap_or("").to_string();
            let asset = Self::get_str(item, "coin").unwrap_or("").to_string();
            let amount = Self::get_f64(item, "amount").unwrap_or(0.0);
            let fee = Self::get_f64(item, "transactionFee");
            let address = Self::get_str(item, "address").unwrap_or("").to_string();
            let tag = Self::get_str(item, "addressTag")
                .filter(|s| !s.is_empty())
                .map(String::from);
            let tx_hash = Self::get_str(item, "txId")
                .filter(|s| !s.is_empty())
                .map(String::from);
            let network = Self::get_str(item, "network")
                .filter(|s| !s.is_empty())
                .map(String::from);
            // Binance withdrawal status: 0=email_sent, 1=cancelled, 2=awaiting_approval,
            //   3=rejected, 4=processing, 5=failure, 6=completed
            let status_code = item.get("status").and_then(|s| s.as_i64()).unwrap_or(0);
            let status = match status_code {
                0 => "EmailSent",
                1 => "Cancelled",
                2 => "AwaitingApproval",
                3 => "Rejected",
                4 => "Processing",
                5 => "Failed",
                6 => "Completed",
                _ => "Unknown",
            }.to_string();
            let timestamp = item.get("applyTime")
                .and_then(|t| t.as_str())
                .and_then(|s| s.parse::<i64>().ok())
                .or_else(|| item.get("applyTime").and_then(|t| t.as_i64()))
                .unwrap_or(0);

            result.push(FundsRecord::Withdrawal {
                id,
                asset,
                amount,
                fee,
                address,
                tag,
                tx_hash,
                network,
                status,
                timestamp,
            });
        }

        Ok(result)
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // SUB-ACCOUNTS
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse sub-account create response from POST /sapi/v1/sub-account/virtualSubAccount
    ///
    /// Binance returns: `{"email": "virtual_sub_email@binance.com"}`
    pub fn parse_sub_account_create(response: &Value) -> ExchangeResult<SubAccountResult> {
        Self::check_error(response)?;

        let email = Self::get_str(response, "email").unwrap_or("").to_string();

        Ok(SubAccountResult {
            id: Some(email.clone()),
            name: Some(email),
            accounts: Vec::new(),
            transaction_id: None,
        })
    }

    /// Parse sub-account list from GET /sapi/v1/sub-account/list
    ///
    /// Binance returns: `{"subAccounts": [{...}, ...]}`
    pub fn parse_sub_account_list(response: &Value) -> ExchangeResult<SubAccountResult> {
        Self::check_error(response)?;

        let arr = response.get("subAccounts")
            .and_then(|a| a.as_array())
            .ok_or_else(|| ExchangeError::Parse("Missing 'subAccounts' in list response".to_string()))?;

        let accounts: Vec<SubAccount> = arr.iter().map(|item| {
            SubAccount {
                id: Self::get_str(item, "email").unwrap_or("").to_string(),
                name: Self::get_str(item, "email").unwrap_or("").to_string(),
                status: if item.get("isFreeze").and_then(|v| v.as_bool()).unwrap_or(false) {
                    "Frozen".to_string()
                } else {
                    "Normal".to_string()
                },
            }
        }).collect();

        Ok(SubAccountResult {
            id: None,
            name: None,
            accounts,
            transaction_id: None,
        })
    }

    /// Parse sub-account universal transfer response from POST /sapi/v1/sub-account/universalTransfer
    ///
    /// Binance returns: `{"tranId": 12345, "clientTranId": "..."}`
    pub fn parse_sub_account_transfer(response: &Value) -> ExchangeResult<SubAccountResult> {
        Self::check_error(response)?;

        let tran_id = response.get("tranId")
            .and_then(|v| {
                if let Some(n) = v.as_i64() {
                    Some(n.to_string())
                } else {
                    v.as_str().map(String::from)
                }
            });

        Ok(SubAccountResult {
            id: None,
            name: None,
            accounts: Vec::new(),
            transaction_id: tran_id,
        })
    }

    /// Parse sub-account assets/balance from GET /sapi/v3/sub-account/assets
    ///
    /// Binance returns: `{"balances": [{...}, ...]}`
    pub fn parse_sub_account_assets(response: &Value) -> ExchangeResult<SubAccountResult> {
        Self::check_error(response)?;

        // The balance data is present but we store the transaction_id as a summary marker.
        // Callers who want detailed balance data should parse the raw response themselves.
        let balance_count = response.get("balances")
            .and_then(|b| b.as_array())
            .map(|arr| arr.len())
            .unwrap_or(0);

        Ok(SubAccountResult {
            id: None,
            name: None,
            accounts: Vec::new(),
            transaction_id: Some(format!("balance_assets_count={}", balance_count)),
        })
    }

    fn parse_position_data(data: &Value) -> Option<Position> {
        let symbol = Self::get_str(data, "symbol")?.to_string();
        let position_amt = Self::get_f64(data, "positionAmt").unwrap_or(0.0);

        // Skip empty positions
        if position_amt.abs() < f64::EPSILON {
            return None;
        }

        // Parse position side
        let side = match Self::get_str(data, "positionSide").unwrap_or("BOTH") {
            "LONG" => PositionSide::Long,
            "SHORT" => PositionSide::Short,
            _ => {
                // For BOTH mode, determine side from position amount
                if position_amt > 0.0 {
                    PositionSide::Long
                } else {
                    PositionSide::Short
                }
            }
        };

        let leverage = Self::get_f64(data, "leverage")
            .map(|l| l as u32)
            .unwrap_or(1);

        let margin_type = match Self::get_str(data, "marginType").unwrap_or("cross") {
            "isolated" => crate::core::MarginType::Isolated,
            _ => crate::core::MarginType::Cross,
        };

        Some(Position {
            symbol,
            side,
            quantity: position_amt.abs(),
            entry_price: Self::get_f64(data, "entryPrice").unwrap_or(0.0),
            mark_price: Self::get_f64(data, "markPrice"),
            unrealized_pnl: Self::get_f64(data, "unRealizedProfit").unwrap_or(0.0),
            realized_pnl: None, // Not in positionRisk response
            leverage,
            liquidation_price: Self::get_f64(data, "liquidationPrice"),
            margin: Self::get_f64(data, "isolatedMargin"),
            margin_type,
            take_profit: None,
            stop_loss: None,
        })
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // FUNDING HISTORY
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse funding payments from `GET /fapi/v1/income?incomeType=FUNDING_FEE`
    ///
    /// Response array item: `{"symbol":"BTCUSDT","incomeType":"FUNDING_FEE","income":"-0.01","asset":"USDT","time":1672531200000}`
    pub fn parse_funding_payments(response: &Value) -> ExchangeResult<Vec<FundingPayment>> {
        let arr = response.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected array for income history".to_string()))?;

        let mut payments = Vec::with_capacity(arr.len());
        for item in arr {
            let symbol = Self::get_str(item, "symbol")
                .ok_or_else(|| ExchangeError::Parse("Missing 'symbol' in income record".to_string()))?
                .to_string();
            let payment: f64 = item.get("income")
                .and_then(|v| v.as_str()).and_then(|s| s.parse().ok())
                .or_else(|| item.get("income").and_then(|v| v.as_f64()))
                .unwrap_or(0.0);
            let asset = Self::get_str(item, "asset").unwrap_or("USDT").to_string();
            let timestamp = item.get("time").and_then(|v| v.as_i64()).unwrap_or(0);
            payments.push(FundingPayment {
                symbol,
                funding_rate: 0.0,
                position_size: 0.0,
                payment,
                asset,
                timestamp,
            });
        }
        Ok(payments)
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // ACCOUNT LEDGER
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse ledger entries from `GET /fapi/v1/income` (all incomeTypes).
    ///
    /// Maps Binance `incomeType` to `LedgerEntryType`.
    pub fn parse_ledger(response: &Value) -> ExchangeResult<Vec<LedgerEntry>> {
        let arr = response.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected array for income history".to_string()))?;

        let mut entries = Vec::with_capacity(arr.len());
        for item in arr {
            let symbol = Self::get_str(item, "symbol").unwrap_or("").to_string();
            let income_type = Self::get_str(item, "incomeType").unwrap_or("OTHER");
            let amount: f64 = item.get("income")
                .and_then(|v| v.as_str()).and_then(|s| s.parse().ok())
                .or_else(|| item.get("income").and_then(|v| v.as_f64()))
                .unwrap_or(0.0);
            let asset = Self::get_str(item, "asset").unwrap_or("USDT").to_string();
            let timestamp = item.get("time").and_then(|v| v.as_i64()).unwrap_or(0);
            let entry_type = match income_type {
                "REALIZED_PNL" => LedgerEntryType::Trade,
                "FUNDING_FEE" => LedgerEntryType::Funding,
                "COMMISSION" => LedgerEntryType::Fee,
                "COMMISSION_REBATE" => LedgerEntryType::Rebate,
                "TRANSFER" => LedgerEntryType::Transfer,
                "LIQUIDATION_FEE" => LedgerEntryType::Liquidation,
                "DELIVERY_SETTLEMENT" => LedgerEntryType::Settlement,
                other => LedgerEntryType::Other(other.to_string()),
            };
            let id = format!("{}-{}-{}", timestamp, income_type, symbol);
            entries.push(LedgerEntry {
                id,
                asset,
                amount,
                balance: None,
                entry_type,
                description: format!("{} {}", income_type, symbol),
                ref_id: None,
                timestamp,
            });
        }
        Ok(entries)
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // LONG/SHORT RATIOS
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse long/short ratio array from any of the four Binance endpoints.
    ///
    /// `ratio_type` must be one of: `"top_account"`, `"top_position"`,
    /// `"global_account"`, `"taker"`.
    ///
    /// Per-endpoint field differences:
    /// - `top_account` / `global_account`: `longAccount`, `shortAccount`, `longShortRatio`
    /// - `top_position`: `longPosition`, `shortPosition`, `longShortRatio`
    /// - `taker`: `buySellRatio`, `buyVol`, `sellVol`
    pub fn parse_long_short_ratios(value: &Value, ratio_type: &str) -> ExchangeResult<Vec<LongShortRatio>> {
        let arr = value.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected JSON array for long/short ratios".to_string()))?;

        let mut result = Vec::with_capacity(arr.len());

        for item in arr {
            let symbol = Self::get_str(item, "symbol").unwrap_or("").to_string();
            let timestamp = item.get("timestamp").and_then(|t| t.as_i64()).unwrap_or(0);

            let (long_ratio, short_ratio, ratio) = if ratio_type == "taker" {
                // Taker endpoint: buyVol / sellVol for ratios, buySellRatio as raw ratio
                let buy_vol = Self::get_f64(item, "buyVol").unwrap_or(0.0);
                let sell_vol = Self::get_f64(item, "sellVol").unwrap_or(0.0);
                let total = buy_vol + sell_vol;
                let (lr, sr) = if total > 0.0 {
                    (buy_vol / total, sell_vol / total)
                } else {
                    (0.5, 0.5)
                };
                let ratio_val = Self::get_f64(item, "buySellRatio");
                (lr, sr, ratio_val)
            } else if ratio_type == "top_position" {
                let lr = Self::get_f64(item, "longPosition").unwrap_or(0.0);
                let sr = Self::get_f64(item, "shortPosition").unwrap_or(0.0);
                let ratio_val = Self::get_f64(item, "longShortRatio");
                (lr, sr, ratio_val)
            } else {
                // top_account, global_account
                let lr = Self::get_f64(item, "longAccount").unwrap_or(0.0);
                let sr = Self::get_f64(item, "shortAccount").unwrap_or(0.0);
                let ratio_val = Self::get_f64(item, "longShortRatio");
                (lr, sr, ratio_val)
            };

            result.push(LongShortRatio {
                symbol,
                ratio_type: ratio_type.to_string(),
                long_ratio,
                short_ratio,
                ratio,
                timestamp,
            });
        }

        Ok(result)
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // OPEN INTEREST HISTORY
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse open interest history array from `GET /futures/data/openInterestHist`.
    ///
    /// Binance returns: `[{"symbol":"BTCUSDT","sumOpenInterest":"12345.6",
    /// "sumOpenInterestValue":"987654321.0","timestamp":1583139600000}]`
    pub fn parse_open_interest_history(value: &Value) -> ExchangeResult<Vec<OpenInterest>> {
        let arr = value.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected JSON array for OI history".to_string()))?;

        let mut result = Vec::with_capacity(arr.len());

        for item in arr {
            let open_interest = Self::get_f64(item, "sumOpenInterest").unwrap_or(0.0);
            let open_interest_value = Self::get_f64(item, "sumOpenInterestValue");
            let timestamp = item.get("timestamp").and_then(|t| t.as_i64()).unwrap_or(0);

            result.push(OpenInterest {
                open_interest,
                open_interest_value,
                timestamp,
            });
        }

        Ok(result)
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // OPEN INTEREST (SINGULAR)
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse a single open interest record from `GET /fapi/v1/openInterest`.
    ///
    /// Binance returns: `{"openInterest":"12345.6","symbol":"BTCUSDT","time":1699999999000}`
    pub fn parse_open_interest(value: &Value) -> ExchangeResult<OpenInterest> {
        Self::check_error(value)?;

        let open_interest = Self::get_f64(value, "openInterest")
            .ok_or_else(|| ExchangeError::Parse("Missing 'openInterest' in response".to_string()))?;

        let timestamp = value.get("time")
            .and_then(|t| t.as_i64())
            .unwrap_or(0);

        Ok(OpenInterest {
            open_interest,
            open_interest_value: None,
            timestamp,
        })
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // PREMIUM INDEX
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse premium index data from `GET /fapi/v1/premiumIndex`.
    ///
    /// When `symbol` is specified Binance returns a single object; when omitted
    /// it returns an array — this parser handles a single object.
    pub fn parse_premium_index(value: &Value) -> ExchangeResult<PremiumIndexData> {
        Self::check_error(value)?;

        // If the response is an array, take the first element.
        let data = if let Some(arr) = value.as_array() {
            arr.first()
                .ok_or_else(|| ExchangeError::Parse("Empty premiumIndex array".to_string()))?
        } else {
            value
        };

        let symbol = Self::get_str(data, "symbol")
            .ok_or_else(|| ExchangeError::Parse("Missing 'symbol' in premiumIndex response".to_string()))?
            .to_string();

        let mark_price = Self::get_f64(data, "markPrice").unwrap_or(0.0);
        let index_price = Self::get_f64(data, "indexPrice").unwrap_or(0.0);
        let estimated_settle_price = Self::get_f64(data, "estimatedSettlePrice");
        let last_funding_rate = Self::get_f64(data, "lastFundingRate").unwrap_or(0.0);
        let next_funding_time = data.get("nextFundingTime").and_then(|t| t.as_i64()).unwrap_or(0);
        let interest_rate = Self::get_f64(data, "interestRate").unwrap_or(0.0);
        let timestamp = data.get("time").and_then(|t| t.as_i64()).unwrap_or(0);

        Ok(PremiumIndexData {
            symbol,
            mark_price,
            index_price,
            estimated_settle_price,
            last_funding_rate,
            next_funding_time,
            interest_rate,
            timestamp,
        })
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // LIQUIDATIONS
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse a liquidation orders array returned by `GET /fapi/v1/forceOrders`.
    ///
    /// Binance response is a JSON array of objects with fields:
    /// ```json
    /// [{"symbol":"BTCUSDT","side":"BUY","price":"28000","origQty":"0.01",
    ///   "executedQty":"0.01","time":1699999999000,"autoCloseType":"LIQUIDATION",...}]
    /// ```
    ///
    /// `side` semantics: `"BUY"` means the exchange bought (short was liquidated);
    /// `"SELL"` means the exchange sold (long was liquidated).
    pub fn parse_liquidations(response: &Value) -> ExchangeResult<Vec<crate::core::types::Liquidation>> {
        use crate::core::types::{Liquidation, TradeSide};

        let arr = response.as_array()
            .ok_or_else(|| ExchangeError::Parse("Expected JSON array for liquidations".to_string()))?;

        let mut result = Vec::with_capacity(arr.len());
        for item in arr {
            let symbol = Self::get_str(item, "symbol")
                .ok_or_else(|| ExchangeError::Parse("Missing 'symbol' in liquidation".to_string()))?
                .to_string();

            let side_str = Self::get_str(item, "side")
                .ok_or_else(|| ExchangeError::Parse("Missing 'side' in liquidation".to_string()))?;
            let side = match side_str {
                "BUY" => TradeSide::Buy,
                "SELL" => TradeSide::Sell,
                other => return Err(ExchangeError::Parse(
                    format!("Unknown liquidation side '{}'", other)
                )),
            };

            let price = Self::require_f64(item, "price")?;

            // Binance uses "origQty" for order quantity; fall back to "executedQty"
            let quantity = Self::get_f64(item, "origQty")
                .or_else(|| Self::get_f64(item, "executedQty"))
                .ok_or_else(|| ExchangeError::Parse("Missing quantity in liquidation".to_string()))?;

            let timestamp = item.get("time")
                .and_then(|v| v.as_i64())
                .ok_or_else(|| ExchangeError::Parse("Missing 'time' in liquidation".to_string()))?;

            result.push(Liquidation {
                symbol,
                side,
                price,
                quantity,
                timestamp,
                value: Some(price * quantity),
            });
        }
        Ok(result)
    }

    // ═══════════════════════════════════════════════════════════════════════════
    // WEBSOCKET PARSERS (called from BinanceProtocol)
    // ═══════════════════════════════════════════════════════════════════════════

    /// Parse WS trade event `{"e":"trade",...}`.
    pub fn parse_ws_trade(data: &Value) -> ExchangeResult<crate::core::PublicTrade> {
        use crate::core::PublicTrade;
        use crate::core::types::TradeSide;

        let parse_f64 = |key: &str| -> Option<f64> {
            data.get(key)
                .and_then(|v| v.as_str())
                .and_then(|s| s.parse().ok())
                .or_else(|| data.get(key).and_then(|v| v.as_f64()))
        };

        let is_buyer_maker = data.get("m").and_then(|m| m.as_bool()).unwrap_or(false);
        let side = if is_buyer_maker { TradeSide::Sell } else { TradeSide::Buy };

        Ok(PublicTrade {
            id: data.get("t").and_then(|t| t.as_i64()).map(|t| t.to_string()).unwrap_or_default(),
            price: parse_f64("p").unwrap_or(0.0),
            quantity: parse_f64("q").unwrap_or(0.0),
            side,
            timestamp: data.get("T").and_then(|t| t.as_i64()).unwrap_or(0),
        })
    }

    /// Parse WS kline event `{"e":"kline","k":{...}}`.
    pub fn parse_ws_kline(data: &Value) -> ExchangeResult<Kline> {
        let k = data
            .get("k")
            .ok_or_else(|| ExchangeError::Parse("Missing 'k' field in kline event".to_string()))?;

        let parse_f64 = |key: &str| -> Option<f64> {
            k.get(key)
                .and_then(|v| v.as_str())
                .and_then(|s| s.parse().ok())
                .or_else(|| k.get(key).and_then(|v| v.as_f64()))
        };

        Ok(Kline {
            open_time: k.get("t").and_then(|t| t.as_i64()).unwrap_or(0),
            open: parse_f64("o").unwrap_or(0.0),
            high: parse_f64("h").unwrap_or(0.0),
            low: parse_f64("l").unwrap_or(0.0),
            close: parse_f64("c").unwrap_or(0.0),
            volume: parse_f64("v").unwrap_or(0.0),
            close_time: k.get("T").and_then(|t| t.as_i64()),
            quote_volume: parse_f64("q"),
            trades: k.get("n").and_then(|n| n.as_i64()).map(|n| n as u64),
        })
    }

    /// Parse WS `markPriceKline` event.
    pub fn parse_ws_mark_price_kline(data: &Value) -> ExchangeResult<StreamEvent> {
        let k = data.get("k").ok_or_else(|| {
            ExchangeError::Parse("Missing 'k' in markPriceKline".to_string())
        })?;

        let parse_f64 = |key: &str| -> Option<f64> {
            k.get(key)
                .and_then(|v| v.as_str())
                .and_then(|s| s.parse().ok())
                .or_else(|| k.get(key).and_then(|v| v.as_f64()))
        };

        Ok(StreamEvent::MarkPriceKline {
            symbol: data.get("s").and_then(|s| s.as_str()).unwrap_or("").to_string(),
            interval: KlineInterval::new(k.get("i").and_then(|i| i.as_str()).unwrap_or("")),
            kline: Kline {
                open_time: k.get("t").and_then(|t| t.as_i64()).unwrap_or(0),
                open: parse_f64("o").unwrap_or(0.0),
                high: parse_f64("h").unwrap_or(0.0),
                low: parse_f64("l").unwrap_or(0.0),
                close: parse_f64("c").unwrap_or(0.0),
                volume: parse_f64("v").unwrap_or(0.0),
                close_time: k.get("T").and_then(|t| t.as_i64()),
                quote_volume: parse_f64("q"),
                trades: k.get("n").and_then(|n| n.as_i64()).map(|n| n as u64),
            },
        })
    }

    /// Parse WS `indexPriceKline` event.
    pub fn parse_ws_index_price_kline(data: &Value) -> ExchangeResult<StreamEvent> {
        let k = data.get("k").ok_or_else(|| {
            ExchangeError::Parse("Missing 'k' in indexPriceKline".to_string())
        })?;

        let parse_f64 = |key: &str| -> Option<f64> {
            k.get(key)
                .and_then(|v| v.as_str())
                .and_then(|s| s.parse().ok())
                .or_else(|| k.get(key).and_then(|v| v.as_f64()))
        };

        Ok(StreamEvent::IndexPriceKline {
            symbol: data.get("s").and_then(|s| s.as_str()).unwrap_or("").to_string(),
            interval: KlineInterval::new(k.get("i").and_then(|i| i.as_str()).unwrap_or("")),
            kline: Kline {
                open_time: k.get("t").and_then(|t| t.as_i64()).unwrap_or(0),
                open: parse_f64("o").unwrap_or(0.0),
                high: parse_f64("h").unwrap_or(0.0),
                low: parse_f64("l").unwrap_or(0.0),
                close: parse_f64("c").unwrap_or(0.0),
                volume: parse_f64("v").unwrap_or(0.0),
                close_time: k.get("T").and_then(|t| t.as_i64()),
                quote_volume: parse_f64("q"),
                trades: k.get("n").and_then(|n| n.as_i64()).map(|n| n as u64),
            },
        })
    }

    /// Parse WS `premiumIndexKline` event.
    pub fn parse_ws_premium_index_kline(data: &Value) -> ExchangeResult<StreamEvent> {
        let k = data.get("k").ok_or_else(|| {
            ExchangeError::Parse("Missing 'k' in premiumIndexKline".to_string())
        })?;

        let parse_f64 = |key: &str| -> Option<f64> {
            k.get(key)
                .and_then(|v| v.as_str())
                .and_then(|s| s.parse().ok())
                .or_else(|| k.get(key).and_then(|v| v.as_f64()))
        };

        Ok(StreamEvent::PremiumIndexKline {
            symbol: data.get("s").and_then(|s| s.as_str()).unwrap_or("").to_string(),
            interval: KlineInterval::new(k.get("i").and_then(|i| i.as_str()).unwrap_or("")),
            kline: Kline {
                open_time: k.get("t").and_then(|t| t.as_i64()).unwrap_or(0),
                open: parse_f64("o").unwrap_or(0.0),
                high: parse_f64("h").unwrap_or(0.0),
                low: parse_f64("l").unwrap_or(0.0),
                close: parse_f64("c").unwrap_or(0.0),
                volume: parse_f64("v").unwrap_or(0.0),
                close_time: k.get("T").and_then(|t| t.as_i64()),
                quote_volume: parse_f64("q"),
                trades: k.get("n").and_then(|n| n.as_i64()).map(|n| n as u64),
            },
        })
    }

    /// Parse WS `executionReport` (spot order update).
    pub fn parse_ws_execution_report(data: &Value) -> ExchangeResult<crate::core::OrderUpdateEvent> {
        use crate::core::{OrderUpdateEvent, OrderSide, OrderType, OrderStatus};

        let parse_f64 = |key: &str| -> Option<f64> {
            data.get(key)
                .and_then(|v| v.as_str())
                .and_then(|s| s.parse().ok())
                .or_else(|| data.get(key).and_then(|v| v.as_f64()))
        };

        let side = match data.get("S").and_then(|s| s.as_str()).unwrap_or("BUY") {
            "SELL" => OrderSide::Sell,
            _ => OrderSide::Buy,
        };

        let order_type = match data.get("o").and_then(|o| o.as_str()).unwrap_or("LIMIT") {
            "MARKET" => OrderType::Market,
            _ => OrderType::Limit { price: 0.0 },
        };

        let status = match data.get("X").and_then(|x| x.as_str()).unwrap_or("NEW") {
            "NEW" => OrderStatus::New,
            "PARTIALLY_FILLED" => OrderStatus::PartiallyFilled,
            "FILLED" => OrderStatus::Filled,
            "CANCELED" => OrderStatus::Canceled,
            "REJECTED" => OrderStatus::Rejected,
            "EXPIRED" => OrderStatus::Expired,
            _ => OrderStatus::New,
        };

        let filled_qty = parse_f64("z").unwrap_or(0.0);
        let avg_price = if filled_qty > 0.0 {
            parse_f64("Z").map(|q| q / filled_qty)
        } else {
            None
        };

        Ok(OrderUpdateEvent {
            order_id: data.get("i").and_then(|i| i.as_i64()).map(|i| i.to_string()).unwrap_or_default(),
            client_order_id: data.get("c").and_then(|c| c.as_str()).map(String::from),
            side,
            order_type,
            status,
            price: parse_f64("p"),
            quantity: parse_f64("q").unwrap_or(0.0),
            filled_quantity: filled_qty,
            average_price: avg_price,
            last_fill_price: parse_f64("L"),
            last_fill_quantity: parse_f64("l"),
            last_fill_commission: parse_f64("n"),
            commission_asset: data.get("N").and_then(|n| n.as_str()).map(String::from),
            trade_id: data.get("t").and_then(|t| t.as_i64()).map(|t| t.to_string()),
            timestamp: data.get("E").and_then(|e| e.as_i64()).unwrap_or(0),
        })
    }

    /// Parse WS `ORDER_TRADE_UPDATE` (futures order update).
    pub fn parse_ws_futures_order_update(data: &Value) -> ExchangeResult<crate::core::OrderUpdateEvent> {
        use crate::core::{OrderUpdateEvent, OrderSide, OrderType, OrderStatus};

        let order = data
            .get("o")
            .ok_or_else(|| ExchangeError::Parse("Missing 'o' in ORDER_TRADE_UPDATE".to_string()))?;

        let parse_f64 = |key: &str| -> Option<f64> {
            order.get(key)
                .and_then(|v| v.as_str())
                .and_then(|s| s.parse().ok())
                .or_else(|| order.get(key).and_then(|v| v.as_f64()))
        };

        let side = match order.get("S").and_then(|s| s.as_str()).unwrap_or("BUY") {
            "SELL" => OrderSide::Sell,
            _ => OrderSide::Buy,
        };

        let order_type = match order.get("o").and_then(|o| o.as_str()).unwrap_or("LIMIT") {
            "MARKET" => OrderType::Market,
            _ => OrderType::Limit { price: 0.0 },
        };

        let status = match order.get("X").and_then(|x| x.as_str()).unwrap_or("NEW") {
            "NEW" => OrderStatus::New,
            "PARTIALLY_FILLED" => OrderStatus::PartiallyFilled,
            "FILLED" => OrderStatus::Filled,
            "CANCELED" => OrderStatus::Canceled,
            "REJECTED" => OrderStatus::Rejected,
            "EXPIRED" => OrderStatus::Expired,
            _ => OrderStatus::New,
        };

        Ok(OrderUpdateEvent {
            order_id: order.get("i").and_then(|i| i.as_i64()).map(|i| i.to_string()).unwrap_or_default(),
            client_order_id: order.get("c").and_then(|c| c.as_str()).map(String::from),
            side,
            order_type,
            status,
            price: parse_f64("p"),
            quantity: parse_f64("q").unwrap_or(0.0),
            filled_quantity: parse_f64("z").unwrap_or(0.0),
            average_price: parse_f64("ap"),
            last_fill_price: parse_f64("L"),
            last_fill_quantity: parse_f64("l"),
            last_fill_commission: parse_f64("n"),
            commission_asset: order.get("N").and_then(|n| n.as_str()).map(String::from),
            trade_id: order.get("t").and_then(|t| t.as_i64()).map(|t| t.to_string()),
            timestamp: data.get("E").and_then(|e| e.as_i64()).unwrap_or(0),
        })
    }

    /// Parse WS `outboundAccountPosition` (spot balance).
    pub fn parse_ws_account_position(data: &Value) -> ExchangeResult<Option<crate::core::BalanceUpdateEvent>> {
        use crate::core::BalanceUpdateEvent;

        let balances = data
            .get("B")
            .and_then(|b| b.as_array())
            .ok_or_else(|| ExchangeError::Parse("Missing 'B' in outboundAccountPosition".to_string()))?;

        for balance in balances {
            let asset = balance.get("a").and_then(|a| a.as_str()).unwrap_or("");
            let free: f64 = balance.get("f").and_then(|f| f.as_str()).and_then(|s| s.parse().ok()).unwrap_or(0.0);
            let locked: f64 = balance.get("l").and_then(|l| l.as_str()).and_then(|s| s.parse().ok()).unwrap_or(0.0);

            if free > 0.0 || locked > 0.0 {
                return Ok(Some(BalanceUpdateEvent {
                    asset: asset.to_string(),
                    free,
                    locked,
                    total: free + locked,
                    delta: None,
                    reason: None,
                    timestamp: data.get("E").and_then(|e| e.as_i64()).unwrap_or(0),
                }));
            }
        }

        Ok(None)
    }

    /// Parse WS `balanceUpdate` event.
    pub fn parse_ws_balance_update(data: &Value) -> ExchangeResult<crate::core::BalanceUpdateEvent> {
        use crate::core::BalanceUpdateEvent;

        let parse_f64 = |key: &str| -> Option<f64> {
            data.get(key)
                .and_then(|v| v.as_str())
                .and_then(|s| s.parse().ok())
                .or_else(|| data.get(key).and_then(|v| v.as_f64()))
        };

        Ok(BalanceUpdateEvent {
            asset: data.get("a").and_then(|a| a.as_str()).unwrap_or("").to_string(),
            free: 0.0,
            locked: 0.0,
            total: 0.0,
            delta: parse_f64("d"),
            reason: None,
            timestamp: data.get("E").and_then(|e| e.as_i64()).unwrap_or(0),
        })
    }

    /// Parse WS `ACCOUNT_UPDATE` (futures balance + position).
    pub fn parse_ws_futures_account_update(data: &Value) -> ExchangeResult<Option<crate::core::BalanceUpdateEvent>> {
        use crate::core::{BalanceUpdateEvent, BalanceChangeReason};

        let account = match data.get("a") {
            Some(a) => a,
            None => return Ok(None),
        };

        let balances = match account.get("B").and_then(|b| b.as_array()) {
            Some(b) => b,
            None => return Ok(None),
        };

        let reason: Option<BalanceChangeReason> = account
            .get("m")
            .and_then(|m| m.as_str())
            .map(|m| match m {
                "DEPOSIT" => BalanceChangeReason::Deposit,
                "WITHDRAW" => BalanceChangeReason::Withdraw,
                "ORDER" | "TRADE" => BalanceChangeReason::Trade,
                "FUNDING_FEE" => BalanceChangeReason::Funding,
                "REALIZED_PNL" => BalanceChangeReason::RealizedPnl,
                "TRANSFER" => BalanceChangeReason::Transfer,
                "COMMISSION" => BalanceChangeReason::Commission,
                _ => BalanceChangeReason::Other,
            });

        let timestamp = data.get("T").and_then(|t| t.as_i64()).unwrap_or(0);

        for balance in balances {
            let asset = balance.get("a").and_then(|a| a.as_str()).unwrap_or("");
            if asset.is_empty() {
                continue;
            }

            let parse_f64 = |key: &str| -> f64 {
                balance
                    .get(key)
                    .and_then(|v| v.as_str())
                    .and_then(|s| s.parse().ok())
                    .or_else(|| balance.get(key).and_then(|v| v.as_f64()))
                    .unwrap_or(0.0)
            };

            let total = parse_f64("wb");
            let cross_wallet = parse_f64("cw");

            return Ok(Some(BalanceUpdateEvent {
                asset: asset.to_string(),
                free: cross_wallet,
                locked: (total - cross_wallet).max(0.0),
                total,
                delta: None,
                reason,
                timestamp,
            }));
        }

        Ok(None)
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use serde_json::json;

    #[test]
    fn test_parse_price() {
        let response = json!({
            "symbol": "BTCUSDT",
            "price": "42000.50"
        });

        let price = BinanceParser::parse_price(&response).unwrap();
        assert!((price - 42000.50).abs() < f64::EPSILON);
    }

    #[test]
    fn test_parse_orderbook() {
        let response = json!({
            "lastUpdateId": 1027024,
            "bids": [["42000", "1.5"], ["41999", "2.0"]],
            "asks": [["42001", "1.0"], ["42002", "0.5"]]
        });

        let orderbook = BinanceParser::parse_orderbook(&response).unwrap();
        assert_eq!(orderbook.bids.len(), 2);
        assert_eq!(orderbook.asks.len(), 2);
        assert!((orderbook.bids[0].price - 42000.0).abs() < f64::EPSILON);
    }

    #[test]
    fn test_parse_funding_rates() {
        let response = json!([
            {"symbol":"BTCUSDT","fundingRate":"0.00010000","fundingTime":1601365200000i64,"markPrice":"42000.5"},
            {"symbol":"BTCUSDT","fundingRate":"-0.00005000","fundingTime":1601394000000i64,"markPrice":"42100.0"}
        ]);

        let rates = BinanceParser::parse_funding_rates(&response).unwrap();
        assert_eq!(rates.len(), 2);
        assert!((rates[0].rate - 0.0001).abs() < 1e-9);
        assert_eq!(rates[0].timestamp, 1601365200000);
        assert_eq!(rates[0].next_funding_time, Some(1601365200000));
        assert!((rates[1].rate - (-0.00005)).abs() < 1e-9);
        assert_eq!(rates[1].timestamp, 1601394000000);
    }

    #[test]
    fn test_parse_ticker() {
        let response = json!({
            "symbol": "BTCUSDT",
            "lastPrice": "42000.50",
            "bidPrice": "42000.00",
            "askPrice": "42001.00",
            "highPrice": "43000.00",
            "lowPrice": "41000.00",
            "volume": "1000.0",
            "quoteVolume": "42000000.0",
            "priceChange": "100.5",
            "priceChangePercent": "0.24",
            "closeTime": 1499869899040i64
        });

        let ticker = BinanceParser::parse_ticker(&response).unwrap();
        assert!((ticker.last_price - 42000.50).abs() < f64::EPSILON);
        assert!((ticker.bid_price.unwrap() - 42000.0).abs() < f64::EPSILON);
        assert!((ticker.ask_price.unwrap() - 42001.0).abs() < f64::EPSILON);
    }
}