use log::trace;

use rotonda_store::prelude::*;
use rotonda_store::prelude::multi::*;
use rotonda_store::meta_examples::PrefixAs;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    #[cfg(feature = "cli")]
    env_logger::init();

    trace!("Starting multi-threaded yolo testing....");
    let tree_bitmap = MultiThreadedStore::<PrefixAs>::new()?;
    // let f = Arc::new(std::sync::atomic::AtomicBool::new(false));

    let pfx = Prefix::new_relaxed(
        0b1111_1111_1111_1111_1111_1111_1111_1111_u32.into_ipaddr(),
        32,
    );

    print!("\nstart {} ---", 1);
    let mut x = 0;
    loop {
        x += 1;
        // print!("{}-", i);
        match tree_bitmap.insert(&pfx.unwrap(), Record::new(0, 0, RouteStatus::Active, PrefixAs(x % 1000)), None) {
            Ok(_) => {}
            Err(e) => {
                println!("{}", e);
            }
        };
        if (x % 1_000_000) == 0 { println!("inserts: {}", x); }
        if x == 100_000_000 { break; }
    }
    println!("--thread {} done.", 1);

    println!("------ end of inserts\n");

    let guard = unsafe { epoch::unprotected() };

    let s_spfx = tree_bitmap.match_prefix(
        &pfx.unwrap(),
        &MatchOptions {
            match_type: rotonda_store::MatchType::ExactMatch,
            include_withdrawn: true,
            include_less_specifics: true,
            include_more_specifics: true,
            mui: None
        },
        guard,
    );
    println!("query result");
    println!("{}", s_spfx);
    println!("{}", s_spfx.more_specifics.unwrap());

    println!("-----------");

    Ok(())
}