data-center/standard/src/phemex_swap_handle.rs

use std::str::FromStr;
use rust_decimal::Decimal;
use rust_decimal::prelude::FromPrimitive;
use serde_json::Value;
use exchanges::response_base::ResponseData;
use crate::{OrderBook, Trade, Record};

pub fn handle_records(value: &Value) -> Vec<Record> {
    let mut records = vec![];
    let symbol = value["symbol"].as_str().unwrap().replace("USDT", "_USDT").replace("u1000", "1000");

    for record_value in value["kline_p"].as_array().unwrap() {
        records.push(Record {
            time: Decimal::from_i64(record_value[0].as_i64().unwrap() * 1000).unwrap(),
            open: Decimal::from_str(record_value[3].as_str().unwrap()).unwrap(),
            high: Decimal::from_str(record_value[4].as_str().unwrap()).unwrap(),
            low: Decimal::from_str(record_value[5].as_str().unwrap()).unwrap(),
            close: Decimal::from_str(record_value[6].as_str().unwrap()).unwrap(),
            volume: Decimal::from_str(record_value[7].as_str().unwrap()).unwrap(),
            symbol: symbol.clone(),
        });
    }

    return records;
}

pub fn format_depth_items(value: &Value) -> Vec<OrderBook> {
    let mut depth_items: Vec<OrderBook> = vec![];
    for value in value.as_array().unwrap() {
        depth_items.push(OrderBook {
            price: Decimal::from_str(value[0].as_str().unwrap()).unwrap(),
            amount: Decimal::from_str(value[1].as_str().unwrap()).unwrap(),
        })
    }
    return depth_items;
}

pub fn format_trade_items(res_data: &ResponseData) -> Vec<Trade> {
    let result = res_data.data["trades_p"].as_array().unwrap();
    let mut trades = vec![];

    for item in result {
        let side = item[1] == "Buy";
        let size = Decimal::from_str(item[3].as_str().unwrap()).unwrap();
        trades.push(Trade {
            id: item[0].to_string(),
            time: Decimal::from_i64(item[0].as_i64().unwrap() / 1000 / 1000).unwrap(),
            size: if side { size } else { -size },
            price: Decimal::from_str(item[2].as_str().unwrap().to_string().as_str()).unwrap(),
            symbol: res_data.data["symbol"].as_str().unwrap().replace("USDT", "_USDT").replace("u1000", "1000"),
        })
    }

    return trades;
}