openstack_cli_block_storage/v3/group/
create_313.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::block_storage::v3::group::create_313;
33use openstack_types::block_storage::v3::group::response;
34
35#[derive(Args)]
37pub struct GroupCommand {
38 #[command(flatten)]
40 query: QueryParameters,
41
42 #[command(flatten)]
44 path: PathParameters,
45
46 #[command(flatten)]
48 group: Group,
49}
50
51#[derive(Args)]
53struct QueryParameters {}
54
55#[derive(Args)]
57struct PathParameters {}
58#[derive(Args, Clone)]
60struct Group {
61 #[arg(help_heading = "Body parameters", long)]
63 availability_zone: Option<String>,
64
65 #[arg(help_heading = "Body parameters", long, action = clap::ArgAction::SetTrue, conflicts_with = "availability_zone")]
67 no_availability_zone: bool,
68
69 #[arg(help_heading = "Body parameters", long)]
71 description: Option<String>,
72
73 #[arg(help_heading = "Body parameters", long, action = clap::ArgAction::SetTrue, conflicts_with = "description")]
75 no_description: bool,
76
77 #[arg(help_heading = "Body parameters", long)]
79 group_type: String,
80
81 #[arg(help_heading = "Body parameters", long)]
83 name: Option<String>,
84
85 #[arg(help_heading = "Body parameters", long, action = clap::ArgAction::SetTrue, conflicts_with = "name")]
87 no_name: bool,
88
89 #[arg(action=clap::ArgAction::Append, help_heading = "Body parameters", long)]
97 volume_types: Vec<String>,
98}
99
100impl GroupCommand {
101 pub async fn take_action<C: CliArgs>(
103 &self,
104 parsed_args: &C,
105 client: &mut AsyncOpenStack,
106 ) -> Result<(), OpenStackCliError> {
107 info!("Create Group");
108
109 let op =
110 OutputProcessor::from_args(parsed_args, Some("block-storage.group"), Some("create"));
111 op.validate_args(parsed_args)?;
112
113 let mut ep_builder = create_313::Request::builder();
114 ep_builder.header(
115 http::header::HeaderName::from_static("openstack-api-version"),
116 http::header::HeaderValue::from_static("volume 3.13"),
117 );
118
119 let args = &self.group;
122 let mut group_builder = create_313::GroupBuilder::default();
123 if let Some(val) = &args.availability_zone {
124 group_builder.availability_zone(Some(val.into()));
125 } else if args.no_availability_zone {
126 group_builder.availability_zone(None);
127 }
128
129 if let Some(val) = &args.description {
130 group_builder.description(Some(val.into()));
131 } else if args.no_description {
132 group_builder.description(None);
133 }
134
135 group_builder.group_type(&args.group_type);
136
137 if let Some(val) = &args.name {
138 group_builder.name(Some(val.into()));
139 } else if args.no_name {
140 group_builder.name(None);
141 }
142
143 group_builder.volume_types(args.volume_types.iter().map(Into::into).collect::<Vec<_>>());
144
145 ep_builder.group(
146 group_builder
147 .build()
148 .wrap_err("error preparing the request data")?,
149 );
150
151 let ep = ep_builder
152 .build()
153 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
154
155 let data: serde_json::Value = ep.query_async(client).await?;
156
157 op.output_single::<response::create::GroupResponse>(data.clone())?;
158 op.show_command_hint()?;
160 Ok(())
161 }
162}