use std::{error::Error, sync::Arc, time::Instant};

use alhc::prelude::*;
use alhc::*;

use futures::future::join_all;
use pollster::FutureExt;

fn main() {
    // tracing_subscriber::fmt()
    //     .with_max_level(Level::DEBUG)
    //     .init();
    async {
        let client = Arc::new(get_client_builder().build().unwrap());

        let mut success = 0;
        let mut failed = 0;

        println!("Sending httpbin");

        for (i, r) in join_all((0..10).map(|i| {
            let client = client.clone();
            async move {
                let instant = Instant::now();
                let r = client
                    .post("http://httpbin.org/anything")?
                    .body_string(format!("Requesting {}", i).repeat(4));
                println!("Requesting {}", i);
                let r = r.await?.recv_string().await;
                if let Err(err) = &r {
                    println!("Request {} Error: {}", i, err);
                } else {
                    let e = instant.elapsed().as_millis();
                    println!("Request {} ok in {}ms", i, e);
                }
                Ok::<String, Box<dyn Error>>(r?)
            }
        }))
        .await
        .into_iter()
        .enumerate()
        {
            match r {
                Ok(_) => {
                    success += 1;
                    // println!("Request {} ok", i);
                }
                Err(err) => {
                    failed += 1;
                    println!("Request {} Error: {}", i, err);
                }
            }
        }

        println!(
            "Sent {} requests, {} succeed, {} failed",
            success + failed,
            success,
            failed
        );

        DynResult::Ok(())
    }
    .block_on()
    .unwrap();
}