use anyhow::{Context, Result};
use clap::Parser;
use futures::TryStreamExt;
use testsys_model::test_manager::{DeleteEvent, TestManager};

/// Delete all objects from a testsys cluster.
#[derive(Debug, Parser)]
pub(crate) struct Delete {}

impl Delete {
    pub(crate) async fn run(self, client: TestManager) -> Result<()> {
        let mut stream = client.delete_all().await.context("Unable to delete all")?;

        while let Some(delete) = stream
            .try_next()
            .await
            .context("A deletion error occurred")?
        {
            match delete {
                DeleteEvent::Starting(crd) => println!("Starting delete for {}", crd.name()),
                DeleteEvent::Deleted(crd) => println!("Delete finished for {}", crd.name()),
                DeleteEvent::Failed(crd) => println!("Delete failed for {}", crd.name()),
            }
        }
        Ok(())
    }
}