//!
//! Please ensure that any tests added to this file use the tokio multi-threaded test executor.
//!

use apollo_compiler::ast::Document;
use uhg_custom_appollo_roouter::graphql::Request;
use uhg_custom_appollo_roouter::graphql::Response;
use uhg_custom_appollo_roouter::plugin::test::MockSubgraph;
use uhg_custom_appollo_roouter::services::supergraph;
use uhg_custom_appollo_roouter::MockedSubgraphs;
use uhg_custom_appollo_roouter::TestHarness;
use serde::Deserialize;
use serde_json::json;
use serde_json_bytes::ByteString;
use serde_json_bytes::Value;
use tower::ServiceExt;

type JsonMap = serde_json_bytes::Map<ByteString, Value>;

#[derive(Deserialize)]
struct SubgraphMock {
    mocks: Vec<RequestAndResponse>,
}

#[derive(Deserialize)]
struct RequestAndResponse {
    request: Request,
    response: Response,
}

#[tokio::test(flavor = "multi_thread")]
async fn test_type_conditions_enabled() {
    _test_type_conditions_enabled("legacy").await;
    _test_type_conditions_enabled("new").await;
}

#[tokio::test(flavor = "multi_thread")]
async fn test_type_conditions_enabled_generate_query_fragments() {
    _test_type_conditions_enabled_generate_query_fragments("legacy").await;
    _test_type_conditions_enabled_generate_query_fragments("new").await;
}

#[tokio::test(flavor = "multi_thread")]
async fn test_type_conditions_enabled_list_of_list() {
    _test_type_conditions_enabled_list_of_list("legacy").await;
    _test_type_conditions_enabled_list_of_list("new").await;
}

#[tokio::test(flavor = "multi_thread")]
async fn test_type_conditions_enabled_list_of_list_of_list() {
    _test_type_conditions_enabled_list_of_list_of_list("legacy").await;
    _test_type_conditions_enabled_list_of_list_of_list("new").await;
}

#[tokio::test(flavor = "multi_thread")]
async fn test_type_conditions_disabled() {
    _test_type_conditions_disabled("legacy").await;
    _test_type_conditions_disabled("new").await;
}

#[tokio::test(flavor = "multi_thread")]
async fn test_type_conditions_enabled_shouldnt_make_article_fetch() {
    _test_type_conditions_enabled_shouldnt_make_article_fetch("legacy").await;
    _test_type_conditions_enabled_shouldnt_make_article_fetch("new").await;
}

async fn _test_type_conditions_enabled(planner_mode: &str) -> Response {
    let harness = setup_from_mocks(
        json! {{
            "experimental_type_conditioned_fetching": true,
            "experimental_query_planner_mode": planner_mode,
            // will make debugging easier
            "plugins": {
                "experimental.expose_query_plan": true
            },
            "include_subgraph_errors": {
                "all": true
            }
        }},
        &[
            (
                "searchSubgraph",
                include_str!("fixtures/type_conditions/search.json"),
            ),
            (
                "artworkSubgraph",
                include_str!("fixtures/type_conditions/artwork.json"),
            ),
        ],
    );
    let supergraph_service = harness.build_supergraph().await.unwrap();
    let mut variables = JsonMap::new();
    variables.insert("movieResultParam", "movieResultEnabled".into());
    variables.insert("articleResultParam", "articleResultEnabled".into());
    let request = supergraph::Request::fake_builder()
        .query(QUERY.to_string())
        .header("Apollo-Expose-Query-Plan", "true")
        .variables(variables)
        .build()
        .expect("expecting valid request");

    let response = supergraph_service
        .oneshot(request)
        .await
        .unwrap()
        .next_response()
        .await
        .unwrap();

    let response = normalize_response_extensions(response);

    insta::assert_json_snapshot!(response);
    response
}

async fn _test_type_conditions_enabled_generate_query_fragments(planner_mode: &str) -> Response {
    let harness = setup_from_mocks(
        json! {{
            "experimental_type_conditioned_fetching": true,
            "experimental_query_planner_mode": planner_mode,
            // will make debugging easier
            "plugins": {
                "experimental.expose_query_plan": true
            },
            "include_subgraph_errors": {
                "all": true
            }
        }},
        &[
            (
                "searchSubgraph",
                include_str!("fixtures/type_conditions/search_query_fragments_enabled.json"),
            ),
            (
                "artworkSubgraph",
                include_str!("fixtures/type_conditions/artwork_query_fragments_enabled.json"),
            ),
        ],
    );
    let supergraph_service = harness.build_supergraph().await.unwrap();
    let mut variables = JsonMap::new();
    variables.insert("movieResultParam", "movieResultEnabled".into());
    variables.insert("articleResultParam", "articleResultEnabled".into());
    let request = supergraph::Request::fake_builder()
        .query(QUERY.to_string())
        .header("Apollo-Expose-Query-Plan", "true")
        .variables(variables)
        .build()
        .expect("expecting valid request");

    let response = supergraph_service
        .oneshot(request)
        .await
        .unwrap()
        .next_response()
        .await
        .unwrap();

    let response = normalize_response_extensions(response);

    insta::assert_json_snapshot!(response);
    response
}

async fn _test_type_conditions_enabled_list_of_list(planner_mode: &str) -> Response {
    let harness = setup_from_mocks(
        json! {{
            "experimental_type_conditioned_fetching": true,
            "experimental_query_planner_mode": planner_mode,
            // will make debugging easier
            "plugins": {
                "experimental.expose_query_plan": true
            },
            "include_subgraph_errors": {
                "all": true
            }
        }},
        &[
            (
                "searchSubgraph",
                include_str!("fixtures/type_conditions/search_list_of_list.json"),
            ),
            (
                "artworkSubgraph",
                include_str!("fixtures/type_conditions/artwork.json"),
            ),
        ],
    );
    let supergraph_service = harness.build_supergraph().await.unwrap();
    let mut variables = JsonMap::new();
    variables.insert("movieResultParam", "movieResultEnabled".into());
    variables.insert("articleResultParam", "articleResultEnabled".into());
    let request = supergraph::Request::fake_builder()
        .query(QUERY_LIST_OF_LIST.to_string())
        .header("Apollo-Expose-Query-Plan", "true")
        .variables(variables)
        .build()
        .expect("expecting valid request");

    let response = supergraph_service
        .oneshot(request)
        .await
        .unwrap()
        .next_response()
        .await
        .unwrap();

    let response = normalize_response_extensions(response);

    insta::assert_json_snapshot!(response);
    response
}

// one last to make sure unnesting is correct
async fn _test_type_conditions_enabled_list_of_list_of_list(planner_mode: &str) -> Response {
    let harness = setup_from_mocks(
        json! {{
            "experimental_type_conditioned_fetching": true,
            "experimental_query_planner_mode": planner_mode,
            // will make debugging easier
            "plugins": {
                "experimental.expose_query_plan": true
            },
            "include_subgraph_errors": {
                "all": true
            }
        }},
        &[
            (
                "searchSubgraph",
                include_str!("fixtures/type_conditions/search_list_of_list_of_list.json"),
            ),
            (
                "artworkSubgraph",
                include_str!("fixtures/type_conditions/artwork.json"),
            ),
        ],
    );
    let supergraph_service = harness.build_supergraph().await.unwrap();
    let mut variables = JsonMap::new();
    variables.insert("movieResultParam", "movieResultEnabled".into());
    variables.insert("articleResultParam", "articleResultEnabled".into());
    let request = supergraph::Request::fake_builder()
        .query(QUERY_LIST_OF_LIST_OF_LIST.to_string())
        .header("Apollo-Expose-Query-Plan", "true")
        .variables(variables)
        .build()
        .expect("expecting valid request");

    let response = supergraph_service
        .oneshot(request)
        .await
        .unwrap()
        .next_response()
        .await
        .unwrap();

    let response = normalize_response_extensions(response);

    insta::assert_json_snapshot!(response);
    response
}

async fn _test_type_conditions_disabled(planner_mode: &str) -> Response {
    let harness = setup_from_mocks(
        json! {{
            "experimental_type_conditioned_fetching": false,
            "experimental_query_planner_mode": planner_mode,
            // will make debugging easier
            "plugins": {
                "experimental.expose_query_plan": true
            },
            "include_subgraph_errors": {
                "all": true
            }
        }},
        &[
            (
                "searchSubgraph",
                include_str!("fixtures/type_conditions/search.json"),
            ),
            (
                "artworkSubgraph",
                include_str!("fixtures/type_conditions/artwork_disabled.json"),
            ),
        ],
    );
    let supergraph_service = harness.build_supergraph().await.unwrap();
    let mut variables = JsonMap::new();
    variables.insert("movieResultParam", "movieResultDisabled".into());
    variables.insert("articleResultParam", "articleResultDisabled".into());
    let request = supergraph::Request::fake_builder()
        .query(QUERY.to_string())
        .header("Apollo-Expose-Query-Plan", "true")
        .build()
        .expect("expecting valid request");

    let response = supergraph_service
        .oneshot(request)
        .await
        .unwrap()
        .next_response()
        .await
        .unwrap();

    let response = normalize_response_extensions(response);

    insta::assert_json_snapshot!(response);
    response
}

async fn _test_type_conditions_enabled_shouldnt_make_article_fetch(planner_mode: &str) -> Response {
    let harness = setup_from_mocks(
        json! {{
            "experimental_type_conditioned_fetching": true,
            "experimental_query_planner_mode": planner_mode,
            // will make debugging easier
            "plugins": {
                "experimental.expose_query_plan": true
            },
            // TODO(@goto-bus-stop): need to update the mocks and remove this, #6013
            "supergraph": {
                "generate_query_fragments": false,
            },
            "include_subgraph_errors": {
                "all": true
            }
        }},
        &[
            (
                "searchSubgraph",
                include_str!("fixtures/type_conditions/search_no_articles.json"),
            ),
            (
                "artworkSubgraph",
                include_str!("fixtures/type_conditions/artwork_no_articles.json"),
            ),
        ],
    );
    let supergraph_service = harness.build_supergraph().await.unwrap();
    let mut variables = JsonMap::new();
    variables.insert("movieResultParam", "movieResultEnabled".into());
    variables.insert("articleResultParam", "articleResultEnabled".into());
    let request = supergraph::Request::fake_builder()
        .query(QUERY.to_string())
        .header("Apollo-Expose-Query-Plan", "true")
        .variables(variables)
        .build()
        .expect("expecting valid request");

    let response = supergraph_service
        .oneshot(request)
        .await
        .unwrap()
        .next_response()
        .await
        .unwrap();

    let response = normalize_response_extensions(response);

    insta::assert_json_snapshot!(response);
    response
}

fn setup_from_mocks(
    configuration: serde_json::Value,
    mocks: &[(&'static str, &'static str)],
) -> TestHarness<'static> {
    let mut mocked_subgraphs = MockedSubgraphs::default();

    for (name, m) in mocks {
        let subgraph_mock: SubgraphMock = serde_json::from_str(m).unwrap();

        let mut builder = MockSubgraph::builder();

        for mock in subgraph_mock.mocks {
            builder = builder.with_json(
                serde_json::to_value(mock.request).unwrap(),
                serde_json::to_value(mock.response).unwrap(),
            );
        }

        mocked_subgraphs.insert(name, builder.build());
    }

    let schema = include_str!("fixtures/type_conditions/type_conditions.graphql");
    TestHarness::builder()
        .try_log_level("info")
        .configuration_json(configuration)
        .unwrap()
        .schema(schema)
        .extra_plugin(mocked_subgraphs)
}

static QUERY: &str = r#"
query Search($movieResultParam: String, $articleResultParam: String) {
    search {
      ... on MovieResult {
        sections {
          ... on EntityCollectionSection {
            id
            title
            artwork(params: $movieResultParam)
          }
          ... on GallerySection {
            artwork(params: $movieResultParam)
            id
          }
        }
        id
      }
      ... on ArticleResult {
        id
        sections {
          ... on GallerySection {
            artwork(params: $articleResultParam)
          }
          ... on EntityCollectionSection {
            artwork(params: $articleResultParam)
            title
          }
        }
      }
    }
}"#;

static QUERY_LIST_OF_LIST: &str = r#"
query Search($movieResultParam: String, $articleResultParam: String) {
    searchListOfList {
      ... on MovieResult {
        sections {
          ... on EntityCollectionSection {
            id
            title
            artwork(params: $movieResultParam)
          }
          ... on GallerySection {
            artwork(params: $movieResultParam)
            id
          }
        }
        id
      }
      ... on ArticleResult {
        id
        sections {
          ... on GallerySection {
            artwork(params: $articleResultParam)
          }
          ... on EntityCollectionSection {
            artwork(params: $articleResultParam)
            title
          }
        }
      }
    }
}"#;

static QUERY_LIST_OF_LIST_OF_LIST: &str = r#"
query Search($movieResultParam: String, $articleResultParam: String) {
    searchListOfListOfList {
      ... on MovieResult {
        sections {
          ... on EntityCollectionSection {
            id
            title
            artwork(params: $movieResultParam)
          }
          ... on GallerySection {
            artwork(params: $movieResultParam)
            id
          }
        }
        id
      }
      ... on ArticleResult {
        id
        sections {
          ... on GallerySection {
            artwork(params: $articleResultParam)
          }
          ... on EntityCollectionSection {
            artwork(params: $articleResultParam)
            title
          }
        }
      }
    }
}"#;

fn normalize_response_extensions(mut response: Response) -> Response {
    let extensions = &mut response.extensions;

    for (key, value) in extensions.iter_mut() {
        visit_object(key, value, &mut |key, value| {
            if key.as_str() == "operation" {
                if let Value::String(s) = value {
                    let new_value = Document::parse(s.as_str(), key.as_str())
                        .unwrap()
                        .serialize()
                        .no_indent()
                        .to_string();
                    *value = Value::String(new_value.into());
                }
            }
        });
    }
    response
}

fn visit_object(key: &ByteString, value: &mut Value, cb: &mut impl FnMut(&ByteString, &mut Value)) {
    cb(key, value);

    match value {
        Value::Object(o) => {
            for (key, value) in o.iter_mut() {
                visit_object(key, value, cb);
            }
        }
        Value::Array(a) => {
            for v in a.iter_mut() {
                if let Some(m) = v.as_object_mut() {
                    for (k, v) in m.iter_mut() {
                        visit_object(k, v, cb);
                    }
                }
            }
        }
        _ => {}
    }
}