finance-query 3.3.0

use crate::adapters::fmp::blank_as_none;
use crate::adapters::fmp::client::ResponseLimits;
use crate::{CompanyProfile, FinanceError, Provider, Result};
use serde::Deserialize;
use std::time::Duration;

const PROFILE_LIMITS: ResponseLimits = ResponseLimits::bytes(1024 * 1024);
/// A bulk part is about 30 MB, uncompressed, streamed at roughly 80 KB/s.
const BULK_PART_LIMITS: ResponseLimits =
    ResponseLimits::slow(128 * 1024 * 1024, Duration::from_secs(600));

#[derive(Deserialize)]
#[serde(rename_all = "camelCase")]
struct Profile {
    symbol: String,
    #[serde(default, deserialize_with = "blank_as_none")]
    isin: Option<String>,
    #[serde(default, deserialize_with = "blank_as_none")]
    cusip: Option<String>,
    is_actively_trading: Option<bool>,
    is_etf: Option<bool>,
    is_adr: Option<bool>,
    is_fund: Option<bool>,
    #[serde(default, deserialize_with = "blank_as_none")]
    cik: Option<String>,
    #[serde(default, deserialize_with = "blank_as_none")]
    ipo_date: Option<String>,
    #[serde(default, deserialize_with = "blank_as_none")]
    company_name: Option<String>,
    #[serde(default, deserialize_with = "blank_as_none")]
    description: Option<String>,
    #[serde(default, deserialize_with = "blank_as_none")]
    exchange: Option<String>,
    #[serde(default, deserialize_with = "blank_as_none")]
    currency: Option<String>,
    #[serde(default, deserialize_with = "blank_as_none")]
    country: Option<String>,
    #[serde(default, deserialize_with = "blank_as_none")]
    sector: Option<String>,
    #[serde(default, deserialize_with = "blank_as_none")]
    industry: Option<String>,
    market_cap: Option<f64>,
}

pub(crate) async fn fetch_company_profile(symbol: &str) -> Result<CompanyProfile> {
    let client = crate::adapters::fmp::build_client()?;
    let rows: Vec<Profile> = client
        .get_limited(
            "/stable/profile",
            &[("symbol", symbol)],
            Some(PROFILE_LIMITS),
        )
        .await?;
    let row = match <[Profile; 1]>::try_from(rows) {
        Ok([row]) if row.symbol.eq_ignore_ascii_case(symbol) => row,
        Err(rows) if rows.is_empty() => {
            return Err(FinanceError::SymbolNotFound {
                symbol: Some(symbol.into()),
                context: "FMP profile is empty".into(),
            });
        }
        _ => {
            return Err(FinanceError::ResponseStructureError {
                field: "symbol".into(),
                context: "FMP profile is ambiguous or mismatched".into(),
            });
        }
    };
    into_profile(row)
}

pub(crate) async fn fetch_company_profiles_bulk(part: u32) -> Result<Vec<CompanyProfile>> {
    let client = crate::adapters::fmp::build_client()?;
    let bytes = client
        .get_bytes(
            "/stable/profile-bulk",
            &[("part", &part.to_string())],
            Some(BULK_PART_LIMITS),
        )
        .await?;
    tokio::task::spawn_blocking(move || parse_bulk(&bytes))
        .await
        .map_err(|_| FinanceError::ResponseStructureError {
            field: "profile_bulk".into(),
            context: "FMP bulk-profile parser did not finish".into(),
        })?
}

fn parse_bulk(bytes: &[u8]) -> Result<Vec<CompanyProfile>> {
    let bytes = bytes.strip_prefix(&[0xef, 0xbb, 0xbf]).unwrap_or(bytes);
    let first = bytes
        .iter()
        .copied()
        .find(|byte| !byte.is_ascii_whitespace());
    if first.is_none() {
        return Err(FinanceError::ResponseStructureError {
            field: "profile_bulk".into(),
            context: "empty FMP bulk-profile response".into(),
        });
    }
    if first == Some(b'[') {
        let rows: Vec<Profile> =
            serde_json::from_slice(bytes).map_err(|_| FinanceError::ResponseStructureError {
                field: "profile_bulk".into(),
                context: "invalid FMP bulk-profile JSON".into(),
            })?;
        return rows.into_iter().map(into_profile).collect();
    }
    let mut reader = csv::ReaderBuilder::new().from_reader(bytes);
    let header = reader
        .headers()
        .map_err(|_| FinanceError::ResponseStructureError {
            field: "profile_bulk".into(),
            context: "invalid FMP bulk-profile CSV header".into(),
        })?;
    if !header.iter().any(|name| name == "symbol") {
        return Err(FinanceError::ResponseStructureError {
            field: "symbol".into(),
            context: "FMP bulk-profile CSV has no symbol column".into(),
        });
    }
    reader
        .deserialize::<Profile>()
        .enumerate()
        .map(|(index, row)| {
            let row = row.map_err(|_| FinanceError::ResponseStructureError {
                field: "profile_bulk".into(),
                context: format!("invalid FMP bulk-profile CSV record {}", index + 1),
            })?;
            into_profile(row)
        })
        .collect()
}

fn into_profile(row: Profile) -> Result<CompanyProfile> {
    if row.symbol.trim().is_empty() {
        return Err(FinanceError::ResponseStructureError {
            field: "symbol".into(),
            context: "FMP profile has a blank symbol".into(),
        });
    }
    let ipo_date = row
        .ipo_date
        .filter(|date| crate::models::discovery::listings::date(date).is_ok());
    Ok(CompanyProfile {
        symbol: Some(row.symbol),
        name: row.company_name,
        description: row.description,
        exchange: row.exchange,
        currency: row.currency,
        country: row.country,
        sector: row.sector,
        industry: row.industry,
        market_capitalization: row.market_cap,
        asset_type: None,
        isin: row.isin,
        cusip: row.cusip,
        active: row.is_actively_trading,
        is_etf: row.is_etf,
        is_adr: row.is_adr,
        is_fund: row.is_fund,
        cik: row.cik,
        ipo_date,
        provider_id: Some(Provider::Fmp),
    })
}