use condow_fs::{Condow, FsClient};

fn create_condow_condow() -> Condow<FsClient> {
    FsClient::condow(Default::default()).unwrap()
}

fn get_test_file_path() -> String {
    format!(
        "{}/tests/test_data",
        std::env::current_dir().unwrap().display()
    )
}

#[tokio::test]
async fn download_full() {
    let condow = create_condow_condow();

    let f = async {
        let data = condow
            .blob()
            .at(get_test_file_path())
            .range(..)
            .download_chunks_ordered()
            .await?
            .into_vec()
            .await?;

        Ok::<_, anyhow::Error>(data)
    };

    match f.await {
        Ok(data) => assert_eq!(&data[..], b"abcdefghijklmnopqrstuvwxyz"),
        Err(err) => {
            dbg!(err);
            panic!("failed. see debug output")
        }
    }
}

#[tokio::test]
async fn download_to() {
    let condow = create_condow_condow();

    let data = condow
        .blob()
        .at(get_test_file_path())
        .range(..5)
        .download_chunks_ordered()
        .await
        .unwrap()
        .into_vec()
        .await
        .unwrap();

    assert_eq!(&data[..], b"abcde");
}

#[tokio::test]
async fn download_to_end() {
    let condow = create_condow_condow();

    let data = condow
        .blob()
        .at(get_test_file_path())
        .range(..=25)
        .download_chunks_ordered()
        .await
        .unwrap()
        .into_vec()
        .await
        .unwrap();

    assert_eq!(&data[..], b"abcdefghijklmnopqrstuvwxyz");
}

#[tokio::test]
async fn download_from() {
    let condow = create_condow_condow();

    let data = condow
        .blob()
        .at(get_test_file_path())
        .range(10..)
        .download_chunks_ordered()
        .await
        .unwrap()
        .into_vec()
        .await
        .unwrap();

    assert_eq!(&data[..], b"klmnopqrstuvwxyz");
}

#[tokio::test]
async fn download_from_to() {
    let condow = create_condow_condow();

    let data = condow
        .blob()
        .at(get_test_file_path())
        .range(1..11)
        .download_chunks_ordered()
        .await
        .unwrap()
        .into_vec()
        .await
        .unwrap();

    assert_eq!(&data[..], b"bcdefghijk");
}