use cucumber::World;
use data::PeersWorld;
use report::Markdown;
use rudp2plib::configuration::Configuration;
use std::fs;
use tracing_subscriber::{
    filter::LevelFilter,
    fmt::format::{DefaultFields, Format},
    layer::SubscriberExt as _,
    Layer as _,
};

pub(crate) mod dao;
pub(crate) mod data;
pub(crate) mod mysql;
pub(crate) mod report;
pub(crate) mod steps;
pub(crate) mod sqlite;
pub(crate) mod utils;

#[cfg(not(feature = "ssl"))]
fn configure(port: u16) -> Configuration {
    Configuration::builder()
        .port(port)
        .share_connections(true)
        .build()
}

#[cfg(feature = "ssl")]
fn configure(port: u16) -> Configuration {
    use rudp2plib::configuration::SSL;

    Configuration::builder(SSL::default())
        .port(port)
        .share_connections(true)
        .build()
}

fn main() {
    let report = if cfg!(feature = "ssl") {
        "../reports/ssl.md"
    } else {
        "../reports/default.md"
    };
    let output = fs::File::create(report).unwrap();
    let writer = Markdown::new(output);
    let res = futures::executor::block_on(
        PeersWorld::cucumber()
            .fail_fast()
            .max_concurrent_scenarios(5)
            .after(|_feature, _rule, _scenario, _ev, world| world.unwrap().close())
            .with_writer(writer)
            .with_default_cli()
            .configure_and_init_tracing(
                DefaultFields::new(),
                Format::default().pretty().with_ansi(false),
                |layer| tracing_subscriber::registry().with(LevelFilter::INFO.and_then(layer)),
            )
            .run("features"),
    );
    assert!(!res.is_failed(), "Features failed");
}