openstack_cli_compute/v2/aggregate/
set_21.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::compute::v2::aggregate::find;
33use openstack_sdk::api::compute::v2::aggregate::set_21;
34use openstack_sdk::api::find;
35use openstack_types::compute::v2::aggregate::response;
36
37#[derive(Args)]
46#[command(about = "Update Aggregate (microversion = 2.1)")]
47pub struct AggregateCommand {
48 #[command(flatten)]
50 query: QueryParameters,
51
52 #[command(flatten)]
54 path: PathParameters,
55
56 #[command(flatten)]
58 aggregate: Aggregate,
59}
60
61#[derive(Args)]
63struct QueryParameters {}
64
65#[derive(Args)]
67struct PathParameters {
68 #[arg(
70 help_heading = "Path parameters",
71 id = "path_param_id",
72 value_name = "ID"
73 )]
74 id: String,
75}
76#[derive(Args, Clone)]
78struct Aggregate {
79 #[arg(help_heading = "Body parameters", long)]
90 availability_zone: Option<String>,
91
92 #[arg(help_heading = "Body parameters", long, action = clap::ArgAction::SetTrue, conflicts_with = "availability_zone")]
94 no_availability_zone: bool,
95
96 #[arg(help_heading = "Body parameters", long)]
98 name: Option<String>,
99}
100
101impl AggregateCommand {
102 pub async fn take_action<C: CliArgs>(
104 &self,
105 parsed_args: &C,
106 client: &mut AsyncOpenStack,
107 ) -> Result<(), OpenStackCliError> {
108 info!("Set Aggregate");
109
110 let op = OutputProcessor::from_args(parsed_args, Some("compute.aggregate"), Some("set"));
111 op.validate_args(parsed_args)?;
112
113 let mut find_builder = find::Request::builder();
114
115 find_builder.id(&self.path.id);
116 find_builder.header(
117 http::header::HeaderName::from_static("openstack-api-version"),
118 http::header::HeaderValue::from_static("compute 2.1"),
119 );
120
121 let find_ep = find_builder
122 .build()
123 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
124 let find_data: serde_json::Value = find(find_ep).query_async(client).await?;
125
126 let mut ep_builder = set_21::Request::builder();
127 ep_builder.header(
128 http::header::HeaderName::from_static("openstack-api-version"),
129 http::header::HeaderValue::from_static("compute 2.1"),
130 );
131
132 let resource_id = find_data["id"]
133 .as_str()
134 .ok_or_else(|| eyre::eyre!("resource ID must be a string"))?
135 .to_string();
136 ep_builder.id(resource_id.clone());
137
138 let args = &self.aggregate;
141 let mut aggregate_builder = set_21::AggregateBuilder::default();
142 if let Some(val) = &args.availability_zone {
143 aggregate_builder.availability_zone(Some(val.into()));
144 } else if args.no_availability_zone {
145 aggregate_builder.availability_zone(None);
146 }
147
148 if let Some(val) = &args.name {
149 aggregate_builder.name(val);
150 }
151
152 ep_builder.aggregate(
153 aggregate_builder
154 .build()
155 .wrap_err("error preparing the request data")?,
156 );
157
158 let ep = ep_builder
159 .build()
160 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
161
162 let data: serde_json::Value = ep.query_async(client).await?;
163
164 op.output_single::<response::set_21::AggregateResponse>(data.clone())?;
165 op.show_command_hint()?;
167 Ok(())
168 }
169}