use chipp_http::{HttpClient, Interceptor, Request};
use curl::easy::Auth;
use futures_executor::block_on;
use serde::Deserialize;

#[test]
fn test_get() {
    #[derive(Deserialize)]
    struct Response {
        url: String,
    }

    let url = url::Url::parse("https://httpbin.org/").unwrap();
    let http_client = HttpClient::new(url.as_ref()).unwrap();

    assert_eq!(
        block_on(http_client.get::<Response, _>(vec!["get"]))
            .unwrap()
            .url,
        "https://httpbin.org/get"
    );
}

#[test]
fn test_get_with_params() {
    use std::collections::HashMap;

    #[derive(Deserialize)]
    struct Response {
        url: String,
        args: HashMap<String, String>,
    }

    let http_client = HttpClient::new("https://httpbin.org/").unwrap();

    let params = vec![("key1", "value1"), ("key2", "value2")];
    let response =
        block_on(http_client.get_with_params::<Response, _, _, _, _>(vec!["get"], params)).unwrap();

    assert_eq!(
        response.url,
        "https://httpbin.org/get?key1=value1&key2=value2"
    );
    assert_eq!(
        response.args,
        [
            ("key1".to_owned(), "value1".to_owned()),
            ("key2".to_owned(), "value2".to_owned())
        ]
        .iter()
        .cloned()
        .collect()
    )
}

#[test]
fn test_interceptor() {
    #[derive(Deserialize)]
    struct Response {
        authenticated: bool,
        user: String,
    }

    let http_client = HttpClient::new("https://httpbin.org/")
        .unwrap()
        .with_interceptor(|easy: &mut curl::easy::Easy, _: &Request| {
            let mut auth = Auth::new();
            auth.basic(true);
            easy.http_auth(&auth).unwrap();

            easy.username("me").unwrap();
            easy.password("secure").unwrap();
        });

    let response =
        block_on(http_client.get::<Response, _>(vec!["basic-auth", "me", "secure"])).unwrap();

    assert_eq!(response.user, "me");
    assert!(response.authenticated);
}

#[test]
fn test_default_headers() {
    #[derive(Deserialize)]
    struct Response {
        headers: std::collections::HashMap<String, String>,
    }

    let mut http_client = HttpClient::new("https://httpbin.org/").unwrap();
    http_client.set_default_headers(&[("Authorization", "Bearer kek")]);

    let response = block_on(http_client.get::<Response, _>(vec!["get"])).unwrap();

    assert_eq!(
        response.headers.get("Authorization"),
        Some(&"Bearer kek".to_owned())
    );
}

#[test]
fn test_request_headers() {
    #[derive(Deserialize)]
    struct Response {
        headers: std::collections::HashMap<String, String>,
    }

    let mut http_client = HttpClient::new("https://httpbin.org/").unwrap();
    http_client.set_default_headers(&[("Authorization", "Bearer default")]);

    let mut request = http_client.new_request(["get"]);
    request.headers = Some(vec![("X-Kek-Id".to_string(), "123".to_string())]);

    let response =
        block_on(http_client.perform_request::<Response, _>(request, chipp_http::json::parse_json))
            .unwrap();

    assert_eq!(
        response.headers.get("Authorization"),
        Some(&"Bearer default".to_owned())
    );

    assert_eq!(response.headers.get("X-Kek-Id"), Some(&"123".to_owned()));
}

#[test]
fn test_interceptor_headers() {
    struct Authenticator;

    impl Interceptor for Authenticator {
        fn modify(&self, _: &mut curl::easy::Easy, _: &Request) {}

        fn add_headers(&self, headers: &mut curl::easy::List, _: &Request) {
            headers
                .append(&format!("X-Interceptor: intercepted"))
                .unwrap();
        }
    }

    #[derive(Deserialize)]
    struct Response {
        headers: std::collections::HashMap<String, String>,
    }

    let mut http_client = HttpClient::new("https://httpbin.org/")
        .unwrap()
        .with_interceptor(Authenticator);
    http_client.set_default_headers(&[("Authorization", "Bearer default")]);

    let request = http_client.new_request(["get"]);
    let response =
        block_on(http_client.perform_request::<Response, _>(request, chipp_http::json::parse_json))
            .unwrap();

    assert_eq!(
        response.headers.get("Authorization"),
        Some(&"Bearer default".to_owned())
    );

    assert_eq!(
        response.headers.get("X-Interceptor"),
        Some(&"intercepted".to_owned())
    );
}