use crate::e2e_tests::{FIRST_ENTITY_DB, FIRST_ENTITY_DB_CASED};
use crate::utils::ayb::{create_database, query, query_no_api_token, set_default_url};
use ayb::client::config::ClientConfig;
use std::collections::HashMap;
use std::fs;

pub fn test_create_and_query_db(
    config_path: &str,
    api_keys: &HashMap<String, Vec<String>>,
    server_url: &str,
    expected_config: &mut ClientConfig,
) -> Result<(), Box<dyn std::error::Error>> {
    // Can't create database on e2e-first with e2e-second's token.
    create_database(
        &config_path,
        &api_keys.get("second").unwrap()[0],
        "Error: Authenticated entity e2e-second can not create a database for entity e2e-first",
    )?;

    // Can't create database on e2e-first with invalid token.
    create_database(
        &config_path,
        &format!("{}bad", api_keys.get("first").unwrap()[0]),
        "Error: Invalid API token",
    )?;

    // Create a database with the appropriate user/key pair.
    create_database(
        &config_path,
        &api_keys.get("first").unwrap()[0],
        "Successfully created e2e-first/test.sqlite",
    )?;

    // Can't create a database twice.
    create_database(
        &config_path,
        &api_keys.get("first").unwrap()[0],
        "Error: Database already exists",
    )?;

    // Can't query database with second account's API key
    query(
        &config_path,
        &api_keys.get("second").unwrap()[0],
        "CREATE TABLE test_table(fname varchar, lname varchar);",
        FIRST_ENTITY_DB,
        "table",
        "Error: Authenticated entity e2e-second can not query database e2e-first/test.sqlite",
    )?;

    // Can't query database with bad API key.
    query(
        &config_path,
        &format!("{}bad", api_keys.get("first").unwrap()[0]),
        "CREATE TABLE test_table(fname varchar, lname varchar);",
        FIRST_ENTITY_DB,
        "table",
        "Error: Invalid API token",
    )?;

    // Populate and query database. Alternate through the three API
    // keys for the first account to ensure they all work.
    query(
        &config_path,
        &api_keys.get("first").unwrap()[0],
        "CREATE TABLE test_table(fname varchar, lname varchar);",
        FIRST_ENTITY_DB,
        "table",
        "\nRows: 0",
    )?;
    query(
        &config_path,
        &api_keys.get("first").unwrap()[1],
        "INSERT INTO test_table (fname, lname) VALUES (\"the first\", \"the last\");",
        FIRST_ENTITY_DB,
        "table",
        "\nRows: 0",
    )?;
    query(
        &config_path,
        &api_keys.get("first").unwrap()[2],
        "INSERT INTO test_table (fname, lname) VALUES (\"the first2\", \"the last2\");",
        FIRST_ENTITY_DB,
        "table",
        "\nRows: 0",
    )?;
    query(
        &config_path,
        &api_keys.get("first").unwrap()[0],
        "SELECT * FROM test_table;",
        FIRST_ENTITY_DB,
        "table",                 
        " fname      | lname \n------------+-----------\n the first  | the last \n the first2 | the last2 \n\nRows: 2")?;
    query(
        &config_path,
        &api_keys.get("first").unwrap()[0],
        "SELECT * FROM test_table;",
        FIRST_ENTITY_DB,
        "csv",
        "fname,lname\nthe first,the last\nthe first2,the last2\n\nRows: 2",
    )?;

    // Querying with no API token also works, because the first
    // account token is saved in the configuration file.
    query_no_api_token(
        &config_path,
        "SELECT * FROM test_table;",
        FIRST_ENTITY_DB,
        "csv",
        "fname,lname\nthe first,the last\nthe first2,the last2\n\nRows: 2",
    )?;

    // We now test setting the default server URL: we set it to
    // something nonsensical and it breaks connections, and when we
    // reset it, the connections work again.
    set_default_url(
        &config_path,
        &format!("{}badport", server_url),
        &format!("Saved {}badport as new default_url", server_url),
    )?;
    expected_config.default_url = Some(format!("{}badport", server_url));
    assert_eq!(
        fs::read_to_string(&config_path).unwrap(),
        serde_json::to_string(&expected_config)?
    );
    query(
        &config_path,
        &api_keys.get("first").unwrap()[0],
        "SELECT * FROM test_table;",
        FIRST_ENTITY_DB,
        "csv",
        "Error: reqwest::Error { kind: Builder, source: InvalidPort }",
    )?;
    set_default_url(
        &config_path,
        server_url,
        &format!("Saved {} as new default_url", server_url),
    )?;
    expected_config.default_url = Some(server_url.to_string());
    assert_eq!(
        fs::read_to_string(&config_path).unwrap(),
        serde_json::to_string(&expected_config)?
    );
    query(
        &config_path,
        &api_keys.get("first").unwrap()[0],
        "SELECT * FROM test_table;",
        FIRST_ENTITY_DB_CASED, // Entity slugs should be case-insensitive
        "csv",
        "fname,lname\nthe first,the last\nthe first2,the last2\n\nRows: 2",
    )?;

    Ok(())
}