openstack_cli_network/v2/subnetpool/
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::subnetpool::find;
34use openstack_sdk::api::network::v2::subnetpool::set;
35use openstack_types::network::v2::subnetpool::response;
36
37#[derive(Args)]
43#[command(about = "Update subnet pool")]
44pub struct SubnetpoolCommand {
45 #[command(flatten)]
47 query: QueryParameters,
48
49 #[command(flatten)]
51 path: PathParameters,
52
53 #[command(flatten)]
55 subnetpool: Subnetpool,
56}
57
58#[derive(Args)]
60struct QueryParameters {}
61
62#[derive(Args)]
64struct PathParameters {
65 #[arg(
67 help_heading = "Path parameters",
68 id = "path_param_id",
69 value_name = "ID"
70 )]
71 id: String,
72}
73#[derive(Args, Clone)]
75struct Subnetpool {
76 #[arg(help_heading = "Body parameters", long)]
78 address_scope_id: Option<String>,
79
80 #[arg(help_heading = "Body parameters", long, action = clap::ArgAction::SetTrue, conflicts_with = "address_scope_id")]
82 no_address_scope_id: bool,
83
84 #[arg(help_heading = "Body parameters", long)]
88 default_prefixlen: Option<u32>,
89
90 #[arg(help_heading = "Body parameters", long)]
97 default_quota: Option<u32>,
98
99 #[arg(help_heading = "Body parameters", long)]
102 description: Option<String>,
103
104 #[arg(action=clap::ArgAction::Set, help_heading = "Body parameters", long)]
106 is_default: Option<bool>,
107
108 #[arg(help_heading = "Body parameters", long)]
112 max_prefixlen: Option<u32>,
113
114 #[arg(help_heading = "Body parameters", long)]
117 min_prefixlen: Option<u32>,
118
119 #[arg(help_heading = "Body parameters", long)]
121 name: Option<String>,
122
123 #[arg(action=clap::ArgAction::Append, help_heading = "Body parameters", long)]
130 prefixes: Option<Vec<String>>,
131}
132
133impl SubnetpoolCommand {
134 pub async fn take_action<C: CliArgs>(
136 &self,
137 parsed_args: &C,
138 client: &mut AsyncOpenStack,
139 ) -> Result<(), OpenStackCliError> {
140 info!("Set Subnetpool");
141
142 let op = OutputProcessor::from_args(parsed_args, Some("network.subnetpool"), Some("set"));
143 op.validate_args(parsed_args)?;
144
145 let mut find_builder = find::Request::builder();
146
147 find_builder.id(&self.path.id);
148
149 let find_ep = find_builder
150 .build()
151 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
152 let find_data: serde_json::Value = find(find_ep).query_async(client).await?;
153
154 let mut ep_builder = set::Request::builder();
155
156 let resource_id = find_data["id"]
157 .as_str()
158 .ok_or_else(|| eyre::eyre!("resource ID must be a string"))?
159 .to_string();
160 ep_builder.id(resource_id.clone());
161
162 let args = &self.subnetpool;
165 let mut subnetpool_builder = set::SubnetpoolBuilder::default();
166 if let Some(val) = &args.address_scope_id {
167 subnetpool_builder.address_scope_id(Some(val.into()));
168 } else if args.no_address_scope_id {
169 subnetpool_builder.address_scope_id(None);
170 }
171
172 if let Some(val) = &args.default_prefixlen {
173 subnetpool_builder.default_prefixlen(*val);
174 }
175
176 if let Some(val) = &args.default_quota {
177 subnetpool_builder.default_quota(*val);
178 }
179
180 if let Some(val) = &args.description {
181 subnetpool_builder.description(val);
182 }
183
184 if let Some(val) = &args.is_default {
185 subnetpool_builder.is_default(*val);
186 }
187
188 if let Some(val) = &args.max_prefixlen {
189 subnetpool_builder.max_prefixlen(*val);
190 }
191
192 if let Some(val) = &args.min_prefixlen {
193 subnetpool_builder.min_prefixlen(*val);
194 }
195
196 if let Some(val) = &args.name {
197 subnetpool_builder.name(val);
198 }
199
200 if let Some(val) = &args.prefixes {
201 subnetpool_builder.prefixes(val.iter().map(Into::into).collect::<Vec<_>>());
202 }
203
204 ep_builder.subnetpool(
205 subnetpool_builder
206 .build()
207 .wrap_err("error preparing the request data")?,
208 );
209
210 let ep = ep_builder
211 .build()
212 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
213
214 let data: serde_json::Value = ep.query_async(client).await?;
215
216 op.output_single::<response::set::SubnetpoolResponse>(data.clone())?;
217 op.show_command_hint()?;
219 Ok(())
220 }
221}