#![recursion_limit = "512"]
// Replacing .map(|arch| arch.to_string())
//      with .map(systems::System::to_string)
//
// seems much less clear and I just don't like it :)
#![allow(clippy::redundant_closure)]

use std::env;

use tracing_subscriber::EnvFilter;
use tracing_subscriber::prelude::*;

pub mod acl;
pub mod asynccmd;
pub mod buildtool;
pub mod checkout;
pub mod clone;
pub mod commentparser;
pub mod commitstatus;
pub mod config;
pub mod easyamqp;
pub mod easylapin;
pub mod evalchecker;
pub mod files;
pub mod ghevent;
pub mod locks;
pub mod message;
pub mod notifyworker;
pub mod stats;
pub mod systems;
pub mod tagger;
pub mod tasks;
pub mod test_scratch;
pub mod worker;
pub mod writetoline;

pub mod tickborg {
    pub use crate::acl;
    pub use crate::asynccmd;
    pub use crate::buildtool;
    pub use crate::checkout;
    pub use crate::clone;
    pub use crate::commentparser;
    pub use crate::commitstatus;
    pub use crate::config;
    pub use crate::easyamqp;
    pub use crate::evalchecker;
    pub use crate::files;
    pub use crate::ghevent;
    pub use crate::locks;
    pub use crate::message;
    pub use crate::notifyworker;
    pub use crate::stats;
    pub use crate::systems;
    pub use crate::tagger;
    pub use crate::tasks;
    pub use crate::test_scratch;
    pub use crate::worker;
    pub use crate::writetoline;

    pub const VERSION: &str = env!("CARGO_PKG_VERSION");

    pub fn partition_result<A, B>(results: Vec<Result<A, B>>) -> (Vec<A>, Vec<B>) {
        let mut ok = Vec::new();
        let mut err = Vec::new();
        for result in results.into_iter() {
            match result {
                Ok(x) => {
                    ok.push(x);
                }
                Err(x) => {
                    err.push(x);
                }
            }
        }

        (ok, err)
    }
}

pub fn setup_log() {
    let filter_layer = EnvFilter::try_from_default_env()
        .or_else(|_| EnvFilter::try_new("info"))
        .unwrap();

    let log_json = env::var("RUST_LOG_JSON").is_ok_and(|s| s == "1");

    if log_json {
        let fmt_layer = tracing_subscriber::fmt::layer().json();
        tracing_subscriber::registry()
            .with(filter_layer)
            .with(fmt_layer)
            .init();
    } else {
        let fmt_layer = tracing_subscriber::fmt::layer();
        tracing_subscriber::registry()
            .with(filter_layer)
            .with(fmt_layer)
            .init();
    }

    tracing::info!("Logging configured");
}