openstack_cli_network/v2/vpn/endpoint_group/
set.rs1use clap::Args;
23use eyre::WrapErr;
24use tracing::info;
25
26use openstack_cli_core::cli::CliArgs;
27use openstack_cli_core::error::OpenStackCliError;
28use openstack_cli_core::output::OutputProcessor;
29use openstack_sdk::AsyncOpenStack;
30
31use openstack_sdk::api::QueryAsync;
32use openstack_sdk::api::find;
33use openstack_sdk::api::network::v2::vpn::endpoint_group::find;
34use openstack_sdk::api::network::v2::vpn::endpoint_group::set;
35use openstack_types::network::v2::vpn::endpoint_group::response;
36
37#[derive(Args)]
43#[command(about = "Update VPN endpoint group")]
44pub struct EndpointGroupCommand {
45 #[command(flatten)]
47 query: QueryParameters,
48
49 #[command(flatten)]
51 path: PathParameters,
52
53 #[command(flatten)]
54 endpoint_group: EndpointGroup,
55}
56
57#[derive(Args)]
59struct QueryParameters {}
60
61#[derive(Args)]
63struct PathParameters {
64 #[arg(
66 help_heading = "Path parameters",
67 id = "path_param_id",
68 value_name = "ID"
69 )]
70 id: String,
71}
72#[derive(Args, Clone)]
74struct EndpointGroup {
75 #[arg(help_heading = "Body parameters", long)]
78 description: Option<String>,
79
80 #[arg(help_heading = "Body parameters", long)]
82 name: Option<String>,
83}
84
85impl EndpointGroupCommand {
86 pub async fn take_action<C: CliArgs>(
88 &self,
89 parsed_args: &C,
90 client: &mut AsyncOpenStack,
91 ) -> Result<(), OpenStackCliError> {
92 info!("Set EndpointGroup");
93
94 let op = OutputProcessor::from_args(
95 parsed_args,
96 Some("network.vpn/endpoint_group"),
97 Some("set"),
98 );
99 op.validate_args(parsed_args)?;
100
101 let mut find_builder = find::Request::builder();
102
103 find_builder.id(&self.path.id);
104
105 let find_ep = find_builder
106 .build()
107 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
108 let find_data: serde_json::Value = find(find_ep).query_async(client).await?;
109
110 let mut ep_builder = set::Request::builder();
111
112 let resource_id = find_data["id"]
113 .as_str()
114 .ok_or_else(|| eyre::eyre!("resource ID must be a string"))?
115 .to_string();
116 ep_builder.id(resource_id.clone());
117
118 let args = &self.endpoint_group;
121 let mut endpoint_group_builder = set::EndpointGroupBuilder::default();
122 if let Some(val) = &args.description {
123 endpoint_group_builder.description(val);
124 }
125
126 if let Some(val) = &args.name {
127 endpoint_group_builder.name(val);
128 }
129
130 ep_builder.endpoint_group(
131 endpoint_group_builder
132 .build()
133 .wrap_err("error preparing the request data")?,
134 );
135
136 let ep = ep_builder
137 .build()
138 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
139
140 let data: serde_json::Value = ep.query_async(client).await?;
141
142 op.output_single::<response::set::EndpointGroupResponse>(data.clone())?;
143 op.show_command_hint()?;
145 Ok(())
146 }
147}