use clap::Args;
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::vpn::ipsecpolicy::list;
use openstack_sdk::api::{Pagination, paged};
use openstack_types::network::v2::vpn::ipsecpolicy::response;
#[derive(Args)]
#[command(about = "List IPsec policies")]
pub struct IpsecpoliciesCommand {
#[command(flatten)]
query: QueryParameters,
#[command(flatten)]
path: PathParameters,
#[arg(long, default_value_t = 10000)]
max_items: usize,
}
#[derive(Args)]
struct QueryParameters {
#[arg(help_heading = "Query parameters", long, value_parser = ["aes-cmac","aes-xcbc","sha1","sha256","sha384","sha512"])]
auth_algorithm: Option<String>,
#[arg(help_heading = "Query parameters", long)]
description: Option<String>,
#[arg(help_heading = "Query parameters", long, value_parser = ["transport","tunnel"])]
encapsulation_mode: Option<String>,
#[arg(help_heading = "Query parameters", long, value_parser = ["3des","aes-128","aes-128-ccm-12","aes-128-ccm-16","aes-128-ccm-8","aes-128-ctr","aes-128-gcm-12","aes-128-gcm-16","aes-128-gcm-8","aes-192","aes-192-ccm-12","aes-192-ccm-16","aes-192-ccm-8","aes-192-ctr","aes-192-gcm-12","aes-192-gcm-16","aes-192-gcm-8","aes-256","aes-256-ccm-12","aes-256-ccm-16","aes-256-ccm-8","aes-256-ctr","aes-256-gcm-12","aes-256-gcm-16","aes-256-gcm-8"])]
encryption_algorithm: Option<String>,
#[arg(help_heading = "Query parameters", long)]
id: Option<String>,
#[arg(
help_heading = "Query parameters",
long("page-size"),
visible_alias("limit")
)]
limit: Option<u32>,
#[arg(help_heading = "Query parameters", long)]
marker: Option<String>,
#[arg(help_heading = "Query parameters", long)]
name: Option<String>,
#[arg(action=clap::ArgAction::Set, help_heading = "Query parameters", long)]
page_reverse: Option<bool>,
#[arg(help_heading = "Query parameters", long, value_parser = ["group14","group15","group16","group17","group18","group19","group2","group20","group21","group22","group23","group24","group25","group26","group27","group28","group29","group30","group31","group5"])]
pfs: Option<String>,
#[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
sort_dir: Option<Vec<String>>,
#[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
sort_key: Option<Vec<String>>,
#[arg(help_heading = "Query parameters", long)]
tenant_id: Option<String>,
#[arg(help_heading = "Query parameters", long, value_parser = ["ah","ah-esp","esp"])]
transform_protocol: Option<String>,
}
#[derive(Args)]
struct PathParameters {}
impl IpsecpoliciesCommand {
pub async fn take_action<C: CliArgs>(
&self,
parsed_args: &C,
client: &mut AsyncOpenStack,
) -> Result<(), OpenStackCliError> {
info!("List Ipsecpolicies");
let op =
OutputProcessor::from_args(parsed_args, Some("network.vpn/ipsecpolicy"), Some("list"));
op.validate_args(parsed_args)?;
let mut ep_builder = list::Request::builder();
if let Some(val) = &self.query.auth_algorithm {
ep_builder.auth_algorithm(val);
}
if let Some(val) = &self.query.description {
ep_builder.description(val);
}
if let Some(val) = &self.query.encapsulation_mode {
ep_builder.encapsulation_mode(val);
}
if let Some(val) = &self.query.encryption_algorithm {
ep_builder.encryption_algorithm(val);
}
if let Some(val) = &self.query.id {
ep_builder.id(val);
}
if let Some(val) = &self.query.name {
ep_builder.name(val);
}
if let Some(val) = &self.query.pfs {
ep_builder.pfs(val);
}
if let Some(val) = &self.query.tenant_id {
ep_builder.tenant_id(val);
}
if let Some(val) = &self.query.transform_protocol {
ep_builder.transform_protocol(val);
}
if let Some(val) = &self.query.limit {
ep_builder.limit(*val);
}
if let Some(val) = &self.query.marker {
ep_builder.marker(val);
}
if let Some(val) = &self.query.page_reverse {
ep_builder.page_reverse(*val);
}
if let Some(val) = &self.query.sort_dir {
ep_builder.sort_dir(val.iter());
}
if let Some(val) = &self.query.sort_key {
ep_builder.sort_key(val.iter());
}
let ep = ep_builder
.build()
.map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
let data: Vec<serde_json::Value> = paged(ep, Pagination::Limit(self.max_items))
.query_async(client)
.await?;
op.output_list::<response::list::IpsecpolicyResponse>(data.clone())?;
op.show_command_hint()?;
Ok(())
}
}