ark-invest-api-rust-data/tests/integration.rs

use ark_invest_api_rust_data::util::*;
use chrono::NaiveDate;
use polars::datatypes::DataType;
use serial_test::serial;
use std::error::Error;

#[test]
#[serial]
fn get_api_arkk() -> Result<(), Box<dyn Error>> {
    let df = Ark::new(
        Source::ApiIncremental,
        Ticker::ARKK,
        Some("data/test".to_owned()),
    )?
    .get_api(NaiveDate::from_ymd_opt(2023, 5, 18))?
    .collect()?;

    assert_eq!(
        df.get_column_names(),
        [
            "company",
            "cusip",
            "date",
            "market_value",
            "share_price",
            "shares",
            "ticker",
            "weight",
            "weight_rank"
        ]
    );
    Ok(())
}

#[test]
#[serial]
fn get_api_format_arkk() -> Result<(), Box<dyn Error>> {
    let dfl = Ark::new(
        Source::ApiIncremental,
        Ticker::ARKK,
        Some("data/test".to_owned()),
    )?
    .get_api(NaiveDate::from_ymd_opt(2023, 5, 18))?;
    let df = Ark::df_format(dfl.into())?.collect()?;

    assert_eq!(
        (df.get_column_names(), df.dtypes(), df.shape().1 > 1),
        (
            vec![
                "date",
                "ticker",
                "cusip",
                "company",
                "market_value",
                "shares",
                "share_price",
                "weight",
            ],
            vec![
                DataType::Date,
                DataType::Utf8,
                DataType::Utf8,
                DataType::Utf8,
                DataType::Int64,
                DataType::Int64,
                DataType::Float64,
                DataType::Float64,
            ],
            true
        )
    );
    Ok(())
}

#[test]
#[serial]
fn get_api_format_arkvc() -> Result<(), Box<dyn Error>> {
    let dfl = Ark::new(
        Source::ApiIncremental,
        Ticker::ARKVC,
        Some("data/test".to_owned()),
    )?
    .get_api(NaiveDate::from_ymd_opt(2023, 1, 1))?;
    let df = Ark::df_format(dfl.into())?.collect()?;

    assert_eq!(
        (df.get_column_names(), df.dtypes(), df.shape().1 > 1),
        (
            vec!["date", "ticker", "cusip", "company", "weight"],
            vec![
                DataType::Date,
                DataType::Utf8,
                DataType::Utf8,
                DataType::Utf8,
                DataType::Float64
            ],
            true
        )
    );
    Ok(())
}