toolproof 0.18.0

use super::{SegmentArgs, ToolproofInstruction};
use crate::civilization::Civilization;
use crate::errors::ToolproofStepError;

use async_trait::async_trait;

mod host_dir {
    use std::time::Duration;

    use actix_web::{App, HttpServer};
    use schematic::color::owo::OwoColorize;
    use tokio::time::sleep;

    use super::*;

    async fn host(dir: &String, civ: &mut Civilization<'_>) -> Result<(), ToolproofStepError> {
        civ.stop_servers().await;

        let mut attempts = 0;
        let mut running = false;
        while !running && attempts < 5 {
            let port = civ.ensure_port();
            let dir = civ.tmp_file_path(&dir);
            match HttpServer::new(move || {
                App::new().service(actix_files::Files::new("/", &dir).index_file("index.html"))
            })
            .bind(("127.0.0.1", port))
            {
                Ok(bound) => {
                    let server = bound.run();
                    let handle = server.handle();
                    civ.handles.push(handle);
                    civ.threads.push(tokio::task::spawn(async { server.await }));
                    running = true;
                }
                Err(_) => {
                    civ.purge_port();
                    attempts += 1;
                }
            }
        }

        assert!(running);
        // Wait a beat to make sure the server is ready to roll
        sleep(Duration::from_millis(100)).await;

        Ok(())
    }

    pub struct HostDir;

    inventory::submit! {
        &HostDir as &dyn ToolproofInstruction
    }

    #[async_trait]
    impl ToolproofInstruction for HostDir {
        fn segments(&self) -> &'static str {
            "I serve the directory {dir}"
        }

        async fn run(
            &self,
            args: &SegmentArgs<'_>,
            civ: &mut Civilization,
        ) -> Result<(), ToolproofStepError> {
            let dir = args.get_string("dir")?;

            host(&dir, civ).await
        }
    }

    pub struct DebugHostDir;

    inventory::submit! {
        &DebugHostDir as &dyn ToolproofInstruction
    }

    #[async_trait]
    impl ToolproofInstruction for DebugHostDir {
        fn segments(&self) -> &'static str {
            "I serve the directory {dir} and debug"
        }

        async fn run(
            &self,
            args: &SegmentArgs<'_>,
            civ: &mut Civilization,
        ) -> Result<(), ToolproofStepError> {
            let dir = args.get_string("dir")?;

            host(&dir, civ).await?;

            let url = format!("http://localhost:{}/", civ.ensure_port());
            println!(
                "{}",
                format!("----\nDirectory {dir} hosted at {url} for 60s\n----")
                    .yellow()
                    .bold()
            );
            sleep(Duration::from_secs(60)).await;

            Ok(())
        }
    }
}