crypto-crawler 4.7.4

use super::utils::fetch_symbols_retry;
use crate::{crawlers::utils::create_conversion_thread, msg::Message};
use crypto_market_type::MarketType;
use crypto_msg_type::MessageType;
use crypto_ws_client::*;
use std::sync::mpsc::Sender;

const EXCHANGE_NAME: &str = "okx";

#[allow(clippy::unnecessary_unwrap)]
pub(crate) async fn crawl_funding_rate(
    market_type: MarketType,
    symbols: Option<&[String]>,
    tx: Sender<Message>,
) {
    let tx = create_conversion_thread(
        EXCHANGE_NAME.to_string(),
        MessageType::FundingRate,
        market_type,
        tx,
    );

    let symbols: Vec<String> = if symbols.is_none() || symbols.unwrap().is_empty() {
        tokio::task::block_in_place(move || fetch_symbols_retry(EXCHANGE_NAME, market_type))
    } else {
        symbols.unwrap().to_vec()
    };
    let topics: Vec<(String, String)> =
        symbols.into_iter().map(|symbol| ("funding-rate".to_string(), symbol)).collect();

    match market_type {
        MarketType::InverseSwap | MarketType::LinearSwap => {
            let ws_client = OkxWSClient::new(tx, None).await;
            ws_client.subscribe(&topics).await;
            ws_client.run().await;
            ws_client.close().await;
        }
        _ => panic!("OKX {market_type} does NOT have funding rates"),
    }
}

#[deprecated(since = "4.1.2", note = "OKX open interest is fetched via HTTP for now")]
#[allow(dead_code)]
pub(crate) async fn crawl_open_interest(
    market_type: MarketType,
    symbols: Option<&[String]>,
    tx: Sender<Message>,
) {
    let tx = create_conversion_thread(
        EXCHANGE_NAME.to_string(),
        MessageType::OpenInterest,
        market_type,
        tx,
    );

    let symbols = if let Some(symbols) = symbols {
        if symbols.is_empty() {
            tokio::task::block_in_place(move || fetch_symbols_retry(EXCHANGE_NAME, market_type))
        } else {
            symbols.to_vec()
        }
    } else {
        tokio::task::block_in_place(move || fetch_symbols_retry(EXCHANGE_NAME, market_type))
    };
    let topics: Vec<(String, String)> =
        symbols.into_iter().map(|symbol| ("open-interest".to_string(), symbol)).collect();

    if market_type != MarketType::Spot {
        let ws_client = OkxWSClient::new(tx, None).await;
        ws_client.subscribe(&topics).await;
        ws_client.run().await;
        ws_client.close().await;
    } else {
        panic!("spot does NOT have open interest");
    }
}