use kanidm_lib_crypto::mtls::build_self_signed_server_and_client_identity;

use kanidmd_testkit::{is_free_port, PORT_ALLOC};
use std::sync::atomic::Ordering;

use std::net::{IpAddr, Ipv6Addr, SocketAddr};
use std::pin::Pin;
use std::time::Duration;
use tokio::net::{TcpListener, TcpStream};
use tokio::sync::oneshot;
use tokio::time;
use tracing::{error, trace};

use openssl::ssl::{Ssl, SslAcceptor, SslMethod, SslRef};
use openssl::ssl::{SslConnector, SslVerifyMode};
use openssl::x509::X509;
use tokio_openssl::SslStream;

use uuid::Uuid;

fn keylog_cb(_ssl_ref: &SslRef, key: &str) {
    trace!(?key);
}

async fn setup_mtls_test(
    testcase: TestCase,
) -> (
    SslStream<TcpStream>,
    tokio::task::JoinHandle<Result<(), u64>>,
    oneshot::Sender<()>,
) {
    sketching::test_init();

    let mut counter = 0;
    let port = loop {
        let possible_port = PORT_ALLOC.fetch_add(1, Ordering::SeqCst);
        if is_free_port(possible_port) {
            break possible_port;
        }
        counter += 1;
        #[allow(clippy::panic)]
        if counter >= 5 {
            error!("Unable to allocate port!");
            panic!();
        }
    };

    trace!("{:?}", port);

    // First we need the two certificates.
    let client_uuid = Uuid::new_v4();
    let (client_key, client_cert) =
        build_self_signed_server_and_client_identity(client_uuid, "localhost", 1).unwrap();

    let server_san = if testcase == TestCase::ServerCertSanInvalid {
        "evilcorp.com"
    } else {
        "localhost"
    };
    let server_uuid = Uuid::new_v4();
    let (server_key, server_cert): (_, X509) =
        build_self_signed_server_and_client_identity(server_uuid, server_san, 1).unwrap();
    let server_addr = SocketAddr::new(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 0, 0, 0, 1)), port);

    let listener = TcpListener::bind(&server_addr)
        .await
        .expect("Failed to bind");

    // Setup the TLS parameters.
    let (tx, mut rx) = oneshot::channel();

    let mut ssl_builder = SslAcceptor::mozilla_modern_v5(SslMethod::tls()).unwrap();
    ssl_builder.set_keylog_callback(keylog_cb);

    ssl_builder.set_certificate(&server_cert).unwrap();
    ssl_builder.set_private_key(&server_key).unwrap();
    ssl_builder.check_private_key().unwrap();

    if testcase != TestCase::ServerWithoutClientCa {
        let cert_store = ssl_builder.cert_store_mut();
        cert_store.add_cert(client_cert.clone()).unwrap();
    }
    // Request a client cert.
    let mut verify = SslVerifyMode::PEER;
    verify.insert(SslVerifyMode::FAIL_IF_NO_PEER_CERT);
    ssl_builder.set_verify(verify);
    // Setup the client cert store.

    let tls_parms = ssl_builder.build();

    // Start the server in a task.
    // The server is designed to stop/die as soon as a single connection has been made.
    let handle = tokio::spawn(async move {
        // This is our safety net.
        let sleep = time::sleep(Duration::from_secs(15));
        tokio::pin!(sleep);

        trace!("Started listener");
        tokio::select! {
            Ok((tcpstream, client_socket_addr)) = listener.accept() => {
                let mut tlsstream = match Ssl::new(tls_parms.context())
                    .and_then(|tls_obj| SslStream::new(tls_obj, tcpstream))
                {
                    Ok(ta) => ta,
                    Err(err) => {
                        error!("LDAP TLS setup error, continuing -> {:?}", err);
                        let ossl_err = err.errors().last().unwrap();

                    return Err(
                        ossl_err.code()
                    );
                    }
                };

                if let Err(err) = SslStream::accept(Pin::new(&mut tlsstream)).await {
                    error!("LDAP TLS accept error, continuing -> {:?}", err);

                    let ossl_err = err.ssl_error().and_then(|e| e.errors().last()).unwrap();

                    return Err(
                        ossl_err.code()
                    );
                };

                trace!("Got connection. {:?}", client_socket_addr);

                let tlsstream_ref = tlsstream.ssl();

                match tlsstream_ref.peer_certificate() {
                    Some(peer_cert) => {
                        trace!("{:?}", peer_cert.subject_name());
                    }
                    None => {
                        return Err(2);
                    }
                }

                Ok(())
            }
            Ok(()) = &mut rx => {
                trace!("stopping listener");
                Err(1)
            }
            _ = &mut sleep => {
                error!("timeout");
                Err(1)
            }
            else => {
                trace!("error condition in accept");
                Err(1)
            }
        }
    });

    // Create the client and connect. We do this inline to be sensitive to errors.
    let tcpclient = TcpStream::connect(server_addr).await.unwrap();
    trace!("connection established");

    let mut ssl_builder = SslConnector::builder(SslMethod::tls_client()).unwrap();
    if testcase != TestCase::ClientWithoutClientCert {
        ssl_builder.set_certificate(&client_cert).unwrap();
        ssl_builder.set_private_key(&client_key).unwrap();
        ssl_builder.check_private_key().unwrap();
    }
    // Add the server cert
    if testcase != TestCase::ClientWithoutServerCa {
        let cert_store = ssl_builder.cert_store_mut();
        cert_store.add_cert(server_cert).unwrap();
    }

    let verify_param = ssl_builder.verify_param_mut();
    verify_param.set_host("localhost").unwrap();

    ssl_builder.set_verify(SslVerifyMode::PEER);
    let tls_parms = ssl_builder.build();
    let tlsstream = Ssl::new(tls_parms.context())
        .and_then(|tls_obj| SslStream::new(tls_obj, tcpclient))
        .unwrap();

    (tlsstream, handle, tx)
}

#[derive(PartialEq, Eq, Debug)]
enum TestCase {
    Valid,
    ServerCertSanInvalid,
    ServerWithoutClientCa,
    ClientWithoutClientCert,
    ClientWithoutServerCa,
}

#[tokio::test]
async fn test_mtls_basic_auth() {
    let (mut tlsstream, handle, _tx) = setup_mtls_test(TestCase::Valid).await;

    SslStream::connect(Pin::new(&mut tlsstream)).await.unwrap();

    trace!("Waiting on listener ...");
    let result = handle.await.expect("Failed to stop task.");

    // If this isn't true, it means something failed in the server accept process.
    assert!(result.is_ok());
}

#[tokio::test]
async fn test_mtls_server_san_invalid() {
    let (mut tlsstream, handle, _tx) = setup_mtls_test(TestCase::ServerCertSanInvalid).await;

    let err: openssl::ssl::Error = SslStream::connect(Pin::new(&mut tlsstream))
        .await
        .unwrap_err();
    trace!(?err);
    // Certification Verification Failure
    let ossl_err = err.ssl_error().and_then(|e| e.errors().last()).unwrap();
    assert_eq!(ossl_err.code(), 167772294);

    trace!("Waiting on listener ...");
    let result = handle.await.expect("Failed to stop task.");

    // Must be FALSE server should not have accepted the connection.
    trace!(?result);
    // SSL Read bytes (client disconnected)
    assert_eq!(result, Err(167773202));
}

#[tokio::test]
async fn test_mtls_server_without_client_ca() {
    let (mut tlsstream, handle, _tx) = setup_mtls_test(TestCase::ServerWithoutClientCa).await;

    // The client isn't the one that errors, the server does.
    SslStream::connect(Pin::new(&mut tlsstream)).await.unwrap();

    trace!("Waiting on listener ...");
    let result = handle.await.expect("Failed to stop task.");

    // Must be FALSE server should not have accepted the connection.
    trace!(?result);
    // Certification Verification Failure
    assert_eq!(result, Err(167772294));
}

#[tokio::test]
async fn test_mtls_client_without_client_cert() {
    let (mut tlsstream, handle, _tx) = setup_mtls_test(TestCase::ClientWithoutClientCert).await;

    // The client isn't the one that errors, the server does.
    SslStream::connect(Pin::new(&mut tlsstream)).await.unwrap();

    trace!("Waiting on listener ...");
    let result = handle.await.expect("Failed to stop task.");

    // Must be FALSE server should not have accepted the connection.
    trace!(?result);
    // Peer Did Not Provide Certificate
    assert_eq!(result, Err(167772359));
}

#[tokio::test]
async fn test_mtls_client_without_server_ca() {
    let (mut tlsstream, handle, _tx) = setup_mtls_test(TestCase::ClientWithoutServerCa).await;

    let err: openssl::ssl::Error = SslStream::connect(Pin::new(&mut tlsstream))
        .await
        .unwrap_err();
    trace!(?err);
    // Tls Post Process Certificate (Certificate Verify Failed)
    let ossl_err = err.ssl_error().and_then(|e| e.errors().last()).unwrap();
    assert_eq!(ossl_err.code(), 167772294);

    trace!("Waiting on listener ...");
    let result = handle.await.expect("Failed to stop task.");

    // Must be FALSE server should not have accepted the connection.
    trace!(?result);
    // SSL Read bytes (client disconnected)
    assert_eq!(result, Err(167773208));
}