openstack_cli_compute/v2/aggregate/
set_metadata.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_cli_core::common::parse_key_val_opt;
32use openstack_sdk::api::QueryAsync;
33use openstack_sdk::api::compute::v2::aggregate::set_metadata;
34use openstack_types::compute::v2::aggregate::response;
35
36#[derive(Args)]
38pub struct AggregateCommand {
39 #[command(flatten)]
41 query: QueryParameters,
42
43 #[command(flatten)]
45 path: PathParameters,
46
47 #[command(flatten)]
48 set_metadata: SetMetadata,
49}
50
51#[derive(Args)]
53struct QueryParameters {}
54
55#[derive(Args)]
57struct PathParameters {
58 #[arg(
60 help_heading = "Path parameters",
61 id = "path_param_id",
62 value_name = "ID"
63 )]
64 id: String,
65}
66#[derive(Args, Clone)]
68struct SetMetadata {
69 #[arg(help_heading = "Body parameters", long, value_name="key=value", value_parser=parse_key_val_opt::<String, String>)]
70 metadata: Vec<(String, Option<String>)>,
71}
72
73impl AggregateCommand {
74 pub async fn take_action<C: CliArgs>(
76 &self,
77 parsed_args: &C,
78 client: &mut AsyncOpenStack,
79 ) -> Result<(), OpenStackCliError> {
80 info!("Action Aggregate");
81
82 let op = OutputProcessor::from_args(
83 parsed_args,
84 Some("compute.aggregate"),
85 Some("set_metadata"),
86 );
87 op.validate_args(parsed_args)?;
88
89 let mut ep_builder = set_metadata::Request::builder();
90
91 ep_builder.id(&self.path.id);
92
93 let args = &self.set_metadata;
96 let mut set_metadata_builder = set_metadata::SetMetadataBuilder::default();
97
98 set_metadata_builder.metadata(
99 args.metadata
100 .iter()
101 .cloned()
102 .map(|(k, v)| (k, v.map(Into::into))),
103 );
104
105 ep_builder.set_metadata(
106 set_metadata_builder
107 .build()
108 .wrap_err("error preparing the request data")?,
109 );
110
111 let ep = ep_builder
112 .build()
113 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
114
115 let data: serde_json::Value = ep.query_async(client).await?;
116
117 op.output_single::<response::set_metadata_21::AggregateResponse>(data.clone())
118 .or_else(|_| {
119 op.output_single::<response::set_metadata_241::AggregateResponse>(data.clone())
120 })?;
121 op.show_command_hint()?;
123 Ok(())
124 }
125}