use laboratory::{describe, Suite};

use crate::{clear_state, new_state, TestState, STATE};

mod connection;
mod queue;

pub fn suite() -> Suite<TestState> {
    describe("mqtt", |context| {
        context.describe("MqttConnection", |context| {
            context.it("new() with default", connection::new_default);
            context.it("new() with zero", connection::new_zero);
            context.it("new() with wrong opts", connection::new_wrong_opts);

            context.it("status()", connection::properties);

            context.it("connect() without handler", connection::connect_no_handler);
            context.it("connect() with handler", connection::connect_with_handler);
            context.it(
                "connect() after connect()",
                connection::connect_after_connect,
            );

            context.it("remove_handler()", connection::remove_handler);

            context.it("close()", connection::close);
            context.it("close() after close()", connection::close_after_close);

            context.after_each(clear_state);
        });

        context.describe("MqttQueue", |context| {
            context.it("new() with default", queue::new_default);
            context.it("new() with wrong opts", queue::new_wrong_opts);

            context.it("name(), is_recv(), status()", queue::properties);

            context.it("connect() without handler", queue::connect_no_handler);
            context.it("connect() with handler", queue::connect_with_handler);
            context.it("connect() after connect()", queue::connect_after_connect);

            context.it("clear_handler()", queue::clear_handler);

            context.it("close()", queue::close);
            context.it("close() after close()", queue::close_after_close);

            context.it("send_msg() with error conditions", queue::send_error);

            context.after_each(clear_state);
        });

        context.describe("General Queue", |context| {
            context.it("new() with default", queue::mq_new_default);
            context.it("new() with wrong opts", queue::mq_new_wrong_opts);

            context.it("name(), is_recv(), status()", queue::mq_properties);

            context.it("connect() without handler", queue::mq_connect_no_handler);
            context.it("connect() with handler", queue::mq_connect_with_handler);
            context.it("connect() after connect()", queue::mq_connect_after_connect);

            context.it("clear_handler()", queue::mq_clear_handler);

            context.it("close()", queue::mq_close);
            context.it("close() after close()", queue::mq_close_after_close);

            context.it("send_msg() with error conditions", queue::mq_send_error);

            context.after_each(clear_state);
        });

        context.describe("Scenarios", |context| {
            context.it("reconnect", queue::reconnect);

            context.it("unicast 1 to 1", queue::data_unicast_1to1);
            context.it("unicast 1 to 3", queue::data_unicast_1to3);

            context.it("broadcast 1 to 1", queue::data_broadcast_1to1);
            context.it("broadcast 1 to 3", queue::data_broadcast_1to3);

            context.it_skip("reliable", queue::data_reliable);
            context.it("best effort", queue::data_best_effort);

            context.after_each(clear_state);
        });

        context.before_all(|state| {
            state.insert(STATE, new_state());
        });
    })
}