use bytes::Bytes;
use clap::Args;
use eyre::eyre;
use http::Response;
use serde::{Deserialize, Serialize};
use tracing::info;
use crate::Cli;
use crate::OpenStackCliError;
use crate::output::OutputProcessor;
use structable::{StructTable, StructTableOptions};
use openstack_sdk::{
AsyncOpenStack,
api::RestClient,
types::{ApiVersion, ServiceType},
};
use openstack_sdk::api::RawQueryAsync;
use openstack_sdk::api::object_store::v1::container::delete::Request;
#[derive(Args, Clone, Debug)]
pub struct ContainerCommand {
#[arg()]
container: String,
}
#[derive(Deserialize, Debug, Clone, Serialize, StructTable)]
pub struct Container {}
impl ContainerCommand {
pub async fn take_action(
&self,
parsed_args: &Cli,
client: &mut AsyncOpenStack,
) -> Result<(), OpenStackCliError> {
info!("Delete Container with {:?}", self);
let op =
OutputProcessor::from_args(parsed_args, Some("object-store.container"), Some("delete"));
op.validate_args(parsed_args)?;
let mut ep_builder = Request::builder();
let ep = client.get_service_endpoint(
&ServiceType::ObjectStore,
Some(ApiVersion::new(1, 0)).as_ref(),
)?;
let account = ep
.url()
.path_segments()
.ok_or_else(|| eyre!("Object Store endpoint must not point to a bare domain"))?
.rfind(|x| !x.is_empty());
if let Some(account) = account {
ep_builder.account(account);
}
ep_builder.container(&self.container);
let ep = ep_builder
.build()
.map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
let _rsp: Response<Bytes> = ep.raw_query_async(client).await?;
op.show_command_hint()?;
Ok(())
}
}