use clap::Args;
use eyre::WrapErr;
use tracing::info;
use openstack_cli_core::cli::CliArgs;
use openstack_cli_core::error::OpenStackCliError;
use openstack_cli_core::output::OutputProcessor;
use openstack_sdk::AsyncOpenStack;
use openstack_sdk::api::QueryAsync;
use openstack_sdk::api::network::v2::network::create;
use openstack_types::network::v2::network::response;
use serde_json::Value;
#[derive(Args)]
#[command(about = "Create network")]
pub struct NetworkCommand {
#[command(flatten)]
query: QueryParameters,
#[command(flatten)]
path: PathParameters,
#[command(flatten)]
network: Network,
}
#[derive(Args)]
struct QueryParameters {}
#[derive(Args)]
struct PathParameters {}
#[derive(Args, Clone)]
struct Network {
#[arg(action=clap::ArgAction::Set, help_heading = "Body parameters", long)]
admin_state_up: Option<bool>,
#[arg(action=clap::ArgAction::Append, help_heading = "Body parameters", long)]
availability_zone_hints: Option<Vec<String>>,
#[arg(help_heading = "Body parameters", long)]
description: Option<String>,
#[arg(help_heading = "Body parameters", long)]
dns_domain: Option<String>,
#[arg(action=clap::ArgAction::Set, help_heading = "Body parameters", long)]
ha: Option<bool>,
#[arg(action=clap::ArgAction::Set, help_heading = "Body parameters", long)]
is_default: Option<bool>,
#[arg(help_heading = "Body parameters", long)]
mtu: Option<u32>,
#[arg(help_heading = "Body parameters", long)]
name: Option<String>,
#[arg(action=clap::ArgAction::Set, help_heading = "Body parameters", long)]
port_security_enabled: Option<bool>,
#[arg(help_heading = "Body parameters", long)]
provider_network_type: Option<String>,
#[arg(help_heading = "Body parameters", long)]
provider_physical_network: Option<String>,
#[arg(help_heading = "Body parameters", long)]
provider_segmentation_id: Option<String>,
#[arg(action=clap::ArgAction::Set, help_heading = "Body parameters", long)]
qinq: Option<bool>,
#[arg(help_heading = "Body parameters", long)]
qos_policy_id: Option<String>,
#[arg(help_heading = "Body parameters", long, action = clap::ArgAction::SetTrue, conflicts_with = "qos_policy_id")]
no_qos_policy_id: bool,
#[arg(action=clap::ArgAction::Set, help_heading = "Body parameters", long)]
router_external: Option<bool>,
#[arg(action=clap::ArgAction::Append, help_heading = "Body parameters", long, value_name="JSON", value_parser=openstack_cli_core::common::parse_json)]
segments: Option<Vec<Value>>,
#[arg(action=clap::ArgAction::Set, help_heading = "Body parameters", long)]
shared: Option<bool>,
#[arg(help_heading = "Body parameters", long)]
tenant_id: Option<String>,
#[arg(action=clap::ArgAction::Set, help_heading = "Body parameters", long)]
vlan_transparent: Option<bool>,
}
impl NetworkCommand {
pub async fn take_action<C: CliArgs>(
&self,
parsed_args: &C,
client: &mut AsyncOpenStack,
) -> Result<(), OpenStackCliError> {
info!("Create Network");
let op = OutputProcessor::from_args(parsed_args, Some("network.network"), Some("create"));
op.validate_args(parsed_args)?;
let mut ep_builder = create::Request::builder();
let args = &self.network;
let mut network_builder = create::NetworkBuilder::default();
if let Some(val) = &args.admin_state_up {
network_builder.admin_state_up(*val);
}
if let Some(val) = &args.availability_zone_hints {
network_builder.availability_zone_hints(val.iter().map(Into::into).collect::<Vec<_>>());
}
if let Some(val) = &args.description {
network_builder.description(val);
}
if let Some(val) = &args.dns_domain {
network_builder.dns_domain(val);
}
if let Some(val) = &args.ha {
network_builder.ha(*val);
}
if let Some(val) = &args.is_default {
network_builder.is_default(*val);
}
if let Some(val) = &args.mtu {
network_builder.mtu(*val);
}
if let Some(val) = &args.name {
network_builder.name(val);
}
if let Some(val) = &args.port_security_enabled {
network_builder.port_security_enabled(*val);
}
if let Some(val) = &args.provider_network_type {
network_builder.provider_network_type(val);
}
if let Some(val) = &args.provider_physical_network {
network_builder.provider_physical_network(val);
}
if let Some(val) = &args.provider_segmentation_id {
network_builder.provider_segmentation_id(val);
}
if let Some(val) = &args.qinq {
network_builder.qinq(*val);
}
if let Some(val) = &args.qos_policy_id {
network_builder.qos_policy_id(Some(val.into()));
} else if args.no_qos_policy_id {
network_builder.qos_policy_id(None);
}
if let Some(val) = &args.router_external {
network_builder.router_external(*val);
}
if let Some(val) = &args.segments {
let segments_builder: Vec<create::Segments> = val
.iter()
.flat_map(|v| serde_json::from_value::<create::Segments>(v.to_owned()))
.collect::<Vec<create::Segments>>();
network_builder.segments(segments_builder);
}
if let Some(val) = &args.shared {
network_builder.shared(*val);
}
if let Some(val) = &args.tenant_id {
network_builder.tenant_id(val);
}
if let Some(val) = &args.vlan_transparent {
network_builder.vlan_transparent(*val);
}
ep_builder.network(
network_builder
.build()
.wrap_err("error preparing the request data")?,
);
let ep = ep_builder
.build()
.map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
let data: serde_json::Value = ep.query_async(client).await?;
op.output_single::<response::create::NetworkResponse>(data.clone())?;
op.show_command_hint()?;
Ok(())
}
}