use clap::Args;
use eyre::WrapErr;
use tracing::info;
use openstack_sdk::AsyncOpenStack;
use crate::Cli;
use crate::OpenStackCliError;
use crate::output::OutputProcessor;
use clap::ValueEnum;
use openstack_sdk::api::QueryAsync;
use openstack_sdk::api::compute::v2::server_group::create_215;
use openstack_types::compute::v2::server_group::response::create::ServerGroupResponse;
#[derive(Args)]
#[command(about = "Create Server Group (microversion = 2.15)")]
pub struct ServerGroupCommand {
#[command(flatten)]
query: QueryParameters,
#[command(flatten)]
path: PathParameters,
#[command(flatten)]
server_group: ServerGroup,
}
#[derive(Args)]
struct QueryParameters {}
#[derive(Args)]
struct PathParameters {}
#[derive(Clone, Eq, Ord, PartialEq, PartialOrd, ValueEnum)]
enum Policies {
Affinity,
AntiAffinity,
SoftAffinity,
SoftAntiAffinity,
}
#[derive(Args, Clone)]
struct ServerGroup {
#[arg(help_heading = "Body parameters", long)]
name: String,
#[arg(action=clap::ArgAction::Append, help_heading = "Body parameters", long)]
policies: Vec<Policies>,
}
impl ServerGroupCommand {
pub async fn take_action(
&self,
parsed_args: &Cli,
client: &mut AsyncOpenStack,
) -> Result<(), OpenStackCliError> {
info!("Create ServerGroup");
let op =
OutputProcessor::from_args(parsed_args, Some("compute.server_group"), Some("create"));
op.validate_args(parsed_args)?;
let mut ep_builder = create_215::Request::builder();
ep_builder.header(
http::header::HeaderName::from_static("openstack-api-version"),
http::header::HeaderValue::from_static("compute 2.15"),
);
let args = &self.server_group;
let mut server_group_builder = create_215::ServerGroupBuilder::default();
server_group_builder.name(&args.name);
server_group_builder.policies(
args.policies
.iter()
.map(|x| match x {
Policies::Affinity => create_215::Policies::Affinity,
Policies::AntiAffinity => create_215::Policies::AntiAffinity,
Policies::SoftAffinity => create_215::Policies::SoftAffinity,
Policies::SoftAntiAffinity => create_215::Policies::SoftAntiAffinity,
})
.collect::<Vec<_>>(),
);
ep_builder.server_group(
server_group_builder
.build()
.wrap_err("error preparing the request data")?,
);
let ep = ep_builder
.build()
.map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
let data = ep.query_async(client).await?;
op.output_single::<ServerGroupResponse>(data)?;
op.show_command_hint()?;
Ok(())
}
}