use momento::cache::{
    CollectionTtl, ListConcatenateBackRequest, ListConcatenateBackResponse,
    ListConcatenateFrontRequest, ListConcatenateFrontResponse, ListFetchResponse,
    ListLengthResponse, ListPopBackResponse, ListPopFrontResponse, ListPushBackRequest,
    ListPushBackResponse, ListPushFrontRequest, ListPushFrontResponse, ListRemoveValueResponse,
};
use momento::{MomentoErrorCode, MomentoResult};

use momento_test_util::{unique_cache_name, TestList, CACHE_TEST_STATE};

use std::convert::TryInto;
use std::time::Duration;

fn assert_list_eq(
    list_fetch_result: ListFetchResponse,
    expected: Vec<String>,
) -> MomentoResult<()> {
    let expected: ListFetchResponse = expected.into();
    assert_eq!(
        list_fetch_result, expected,
        "Expected ListFetchResponse::Hit to be equal to {:?}, but got {:?}",
        expected, list_fetch_result
    );
    Ok(())
}

mod list_concatenate_back {
    use super::*;

    #[tokio::test]
    async fn nonexistent_cache() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = unique_cache_name();

        let result = client
            .list_concatenate_back(cache_name, "list", vec!["value1", "value2"])
            .await
            .unwrap_err();

        assert_eq!(result.error_code, MomentoErrorCode::CacheNotFoundError);

        Ok(())
    }

    #[tokio::test]
    async fn happy_path() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        let result = client
            .list_concatenate_back(cache_name, test_list.name(), test_list.values().to_vec())
            .await?;
        assert_eq!(result, ListConcatenateBackResponse {});
        assert_list_eq(
            client.list_fetch(cache_name, test_list.name()).await?,
            test_list.values().to_vec(),
        )?;

        Ok(())
    }

    #[tokio::test]
    async fn happy_path_with_optional_arguments() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        // Concatenates with truncation and collection ttl
        let request = ListConcatenateBackRequest::new(
            cache_name.to_string(),
            test_list.name(),
            [test_list.values().to_vec(), test_list.values().to_vec()].concat(),
        )
        .truncate_front_to_size(2)
        .ttl(CollectionTtl::new(Some(Duration::from_secs(3)), false));
        let result = client.send_request(request).await?;
        assert_eq!(result, ListConcatenateBackResponse {});

        // Should have truncated to only 2 elements
        assert_list_eq(
            client.list_fetch(cache_name, test_list.name()).await?,
            test_list.values().to_vec(),
        )?;

        tokio::time::sleep(Duration::from_secs(3)).await;

        // Expect a miss after collection ttl expires
        let result = client.list_fetch(cache_name, test_list.name()).await?;
        assert_eq!(result, ListFetchResponse::Miss);

        Ok(())
    }
}

mod list_concatenate_front {
    use super::*;

    #[tokio::test]
    async fn nonexistent_cache() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = unique_cache_name();

        let result = client
            .list_concatenate_front(cache_name, "list", vec!["value1", "value2"])
            .await
            .unwrap_err();

        assert_eq!(result.error_code, MomentoErrorCode::CacheNotFoundError);

        Ok(())
    }

    #[tokio::test]
    async fn happy_path() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        // Concatenates string values
        let result = client
            .list_concatenate_front(cache_name, test_list.name(), test_list.values().to_vec())
            .await?;
        assert_eq!(result, ListConcatenateFrontResponse {});
        assert_list_eq(
            client.list_fetch(cache_name, test_list.name()).await?,
            test_list.values().to_vec(),
        )?;

        Ok(())
    }

    #[tokio::test]
    async fn happy_path_with_optional_arguments() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        // Concatenates with truncation and collection ttl
        let request = ListConcatenateFrontRequest::new(
            cache_name.to_string(),
            test_list.name(),
            [test_list.values().to_vec(), test_list.values().to_vec()].concat(),
        )
        .truncate_back_to_size(2)
        .ttl(CollectionTtl::new(Some(Duration::from_secs(3)), false));
        let result = client.send_request(request).await?;
        assert_eq!(result, ListConcatenateFrontResponse {});

        // Should have truncated to only 2 elements
        assert_list_eq(
            client.list_fetch(cache_name, test_list.name()).await?,
            test_list.values().to_vec(),
        )?;

        tokio::time::sleep(Duration::from_secs(3)).await;

        // Expect a miss after collection ttl expires
        let result = client.list_fetch(cache_name, test_list.name()).await?;
        assert_eq!(result, ListFetchResponse::Miss);

        Ok(())
    }
}

mod list_length {
    use super::*;

    #[tokio::test]
    async fn nonexistent_cache() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = unique_cache_name();

        let result = client.list_length(cache_name, "list").await.unwrap_err();

        assert_eq!(result.error_code, MomentoErrorCode::CacheNotFoundError);

        Ok(())
    }

    #[tokio::test]
    async fn nonexistent_list() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let list_name = unique_cache_name();

        let result = client.list_length(cache_name, list_name).await?;

        assert_eq!(result, ListLengthResponse::Miss {});

        Ok(())
    }

    #[tokio::test]
    async fn happy_path() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        // Concatenates some values first
        let result = client
            .list_concatenate_back(cache_name, test_list.name(), test_list.values().to_vec())
            .await?;
        assert_eq!(result, ListConcatenateBackResponse {});

        // Fetch list length
        let result = client.list_length(cache_name, test_list.name()).await?;
        assert_eq!(result, ListLengthResponse::Hit { length: 2 });

        Ok(())
    }
}

mod list_fetch {
    use momento::cache::ListFetchRequest;

    use super::*;

    #[tokio::test]
    async fn nonexistent_cache() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = unique_cache_name();

        let result = client.list_fetch(cache_name, "list").await.unwrap_err();

        assert_eq!(result.error_code, MomentoErrorCode::CacheNotFoundError);

        Ok(())
    }

    #[tokio::test]
    async fn nonexistent_list() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let list_name = unique_cache_name();

        let result = client.list_fetch(cache_name, list_name).await?;

        assert_eq!(result, ListFetchResponse::Miss {});

        Ok(())
    }

    #[tokio::test]
    async fn happy_path() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let list1 = TestList::default();
        let list2 = TestList::default();

        // Concatenates some values first
        let result = client
            .list_concatenate_back(
                cache_name,
                list1.name(),
                [list1.values().to_vec(), list2.values().to_vec()].concat(),
            )
            .await?;
        assert_eq!(result, ListConcatenateBackResponse {});

        // Fetch entire list
        let fetch_full_list = client.list_fetch(cache_name, list1.name()).await?;
        assert_list_eq(
            fetch_full_list,
            [list1.values().to_vec(), list2.values().to_vec()].concat(),
        )?;

        // Fetch a list slice
        let request = ListFetchRequest::new(cache_name, list1.name())
            .start_index(2)
            .end_index(4);
        let fetch_slice = client.send_request(request).await?;
        assert_list_eq(fetch_slice, list2.values().to_vec())?;

        Ok(())
    }
}

mod list_pop_back {
    use std::convert::TryInto;

    use super::*;

    #[tokio::test]
    async fn nonexistent_cache() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = unique_cache_name();

        let result = client.list_pop_back(cache_name, "list").await.unwrap_err();

        assert_eq!(result.error_code, MomentoErrorCode::CacheNotFoundError);

        Ok(())
    }

    #[tokio::test]
    async fn nonexistent_list() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let list_name = unique_cache_name();

        let result = client.list_pop_back(cache_name, list_name).await?;

        assert_eq!(result, ListPopBackResponse::Miss {});

        Ok(())
    }

    #[tokio::test]
    async fn happy_path() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        // Concatenates some values first
        let result = client
            .list_concatenate_back(cache_name, test_list.name(), test_list.values().to_vec())
            .await?;
        assert_eq!(result, ListConcatenateBackResponse {});

        // Pop first value from the back
        let popped_first: String = client
            .list_pop_back(cache_name, test_list.name())
            .await?
            .try_into()
            .expect("Expected a popped list value!");
        assert_eq!(popped_first, test_list.values().last().unwrap().to_string());

        // Pop second value from the back
        let popped_second: String = client
            .list_pop_back(cache_name, test_list.name())
            .await?
            .try_into()
            .expect("Expected a popped list value!");
        assert_eq!(
            popped_second,
            test_list.values().first().unwrap().to_string()
        );

        Ok(())
    }
}

mod list_pop_front {
    use super::*;

    #[tokio::test]
    async fn nonexistent_cache() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = unique_cache_name();

        let result = client.list_pop_front(cache_name, "list").await.unwrap_err();

        assert_eq!(result.error_code, MomentoErrorCode::CacheNotFoundError);

        Ok(())
    }

    #[tokio::test]
    async fn nonexistent_list() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let list_name = unique_cache_name();

        let result = client.list_pop_front(cache_name, list_name).await?;

        assert_eq!(result, ListPopFrontResponse::Miss {});

        Ok(())
    }

    #[tokio::test]
    async fn happy_path() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        // Concatenates some values first
        let result = client
            .list_concatenate_back(cache_name, test_list.name(), test_list.values().to_vec())
            .await?;
        assert_eq!(result, ListConcatenateBackResponse {});

        // Pop first value from the front
        let popped_first: String = client
            .list_pop_front(cache_name, test_list.name())
            .await?
            .try_into()
            .expect("Expected a popped list value!");
        assert_eq!(
            popped_first,
            test_list.values().first().unwrap().to_string()
        );

        // Pop second value from the front
        let popped_second: String = client
            .list_pop_front(cache_name, test_list.name())
            .await?
            .try_into()
            .expect("Expected a popped list value!");
        assert_eq!(
            popped_second,
            test_list.values().last().unwrap().to_string()
        );

        Ok(())
    }
}

mod list_push_back {
    use super::*;

    #[tokio::test]
    async fn nonexistent_cache() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = unique_cache_name();

        let result = client
            .list_push_back(cache_name, "list", "value")
            .await
            .unwrap_err();

        assert_eq!(result.error_code, MomentoErrorCode::CacheNotFoundError);

        Ok(())
    }

    #[tokio::test]
    async fn happy_path() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        let one_value = test_list.values()[0].to_string();
        let result = client
            .list_push_back(cache_name, test_list.name(), one_value.clone())
            .await?;
        assert_eq!(result, ListPushBackResponse {});
        assert_list_eq(
            client.list_fetch(cache_name, test_list.name()).await?,
            vec![one_value],
        )?;

        Ok(())
    }

    #[tokio::test]
    async fn happy_path_with_optional_arguments() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        // Add more values first
        let result = client
            .list_concatenate_back(cache_name, test_list.name(), test_list.values().to_vec())
            .await?;
        assert_eq!(result, ListConcatenateBackResponse {});

        // Push back with truncation and collection ttl
        let request = ListPushBackRequest::new(
            cache_name.to_string(),
            test_list.name(),
            test_list.values()[0].to_string(),
        )
        .truncate_front_to_size(2)
        .ttl(CollectionTtl::new(Some(Duration::from_secs(3)), true));
        let result = client.send_request(request).await?;
        assert_eq!(result, ListPushBackResponse {});

        // Should have truncated to only 2 elements
        assert_list_eq(
            client.list_fetch(cache_name, test_list.name()).await?,
            vec![
                test_list.values()[1].to_string(),
                test_list.values()[0].to_string(),
            ],
        )?;

        tokio::time::sleep(Duration::from_secs(3)).await;

        // Expect a miss after collection ttl expires
        let result = client.list_fetch(cache_name, test_list.name()).await?;
        assert_eq!(result, ListFetchResponse::Miss);

        Ok(())
    }
}

mod list_push_front {
    use super::*;

    #[tokio::test]
    async fn nonexistent_cache() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = unique_cache_name();

        let result = client
            .list_push_front(cache_name, "list", "value")
            .await
            .unwrap_err();

        assert_eq!(result.error_code, MomentoErrorCode::CacheNotFoundError);

        Ok(())
    }

    #[tokio::test]
    async fn happy_path() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        let one_value = test_list.values()[0].to_string();
        let result = client
            .list_push_front(cache_name, test_list.name(), one_value.clone())
            .await?;
        assert_eq!(result, ListPushFrontResponse {});
        assert_list_eq(
            client.list_fetch(cache_name, test_list.name()).await?,
            vec![one_value],
        )?;

        Ok(())
    }

    #[tokio::test]
    async fn happy_path_with_optional_arguments() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        // Add more values first
        let result = client
            .list_concatenate_back(cache_name, test_list.name(), test_list.values().to_vec())
            .await?;
        assert_eq!(result, ListConcatenateBackResponse {});

        // Push back with truncation and collection ttl
        let request = ListPushFrontRequest::new(
            cache_name.to_string(),
            test_list.name(),
            test_list.values()[0].to_string(),
        )
        .truncate_back_to_size(2)
        .ttl(CollectionTtl::new(Some(Duration::from_secs(3)), true));
        let result = client.send_request(request).await?;
        assert_eq!(result, ListPushFrontResponse {});

        // Should have truncated to only 2 elements
        assert_list_eq(
            client.list_fetch(cache_name, test_list.name()).await?,
            vec![
                test_list.values()[0].to_string(),
                test_list.values()[0].to_string(),
            ],
        )?;

        tokio::time::sleep(Duration::from_secs(3)).await;

        // Expect a miss after collection ttl expires
        let result = client.list_fetch(cache_name, test_list.name()).await?;
        assert_eq!(result, ListFetchResponse::Miss);

        Ok(())
    }
}

mod list_remove {
    use super::*;

    #[tokio::test]
    async fn nonexistent_cache() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = unique_cache_name();

        let result = client
            .list_remove_value(cache_name, "list", "value")
            .await
            .unwrap_err();

        assert_eq!(result.error_code, MomentoErrorCode::CacheNotFoundError);

        Ok(())
    }

    #[tokio::test]
    async fn nonexistent_list() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let list_name = unique_cache_name();

        let result = client
            .list_remove_value(cache_name, list_name, "value")
            .await?;

        assert_eq!(result, ListRemoveValueResponse {});

        Ok(())
    }

    #[tokio::test]
    async fn happy_path() -> MomentoResult<()> {
        let client = &CACHE_TEST_STATE.client;
        let cache_name = &CACHE_TEST_STATE.cache_name;
        let test_list = TestList::default();

        // Concatenates some values first
        let result = client
            .list_concatenate_back(cache_name, test_list.name(), test_list.values().to_vec())
            .await?;
        assert_eq!(result, ListConcatenateBackResponse {});

        let first_value = test_list
            .values()
            .first()
            .expect("Expected first value from TestList")
            .to_string();
        let second_value = test_list
            .values()
            .last()
            .expect("Expected last value from TestList")
            .to_string();

        // Remove one of the values and only the other should remain
        let result = client
            .list_remove_value(cache_name, test_list.name(), first_value)
            .await?;
        assert_eq!(result, ListRemoveValueResponse {});
        assert_list_eq(
            client.list_fetch(cache_name, test_list.name()).await?,
            vec![second_value],
        )?;

        Ok(())
    }
}