openstack_cli_block_storage/v3/attachment/
set_327.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;
32use openstack_sdk::api::QueryAsync;
33use openstack_sdk::api::block_storage::v3::attachment::set_327;
34use openstack_types::block_storage::v3::attachment::response;
35use serde_json::Value;
36
37#[derive(Args)]
63pub struct AttachmentCommand {
64 #[command(flatten)]
66 query: QueryParameters,
67
68 #[command(flatten)]
70 path: PathParameters,
71
72 #[command(flatten)]
73 attachment: Attachment,
74}
75
76#[derive(Args)]
78struct QueryParameters {}
79
80#[derive(Args)]
82struct PathParameters {
83 #[arg(
85 help_heading = "Path parameters",
86 id = "path_param_id",
87 value_name = "ID"
88 )]
89 id: String,
90}
91#[derive(Args, Clone)]
93struct Attachment {
94 #[arg(help_heading = "Body parameters", long, value_name="key=value", value_parser=parse_key_val::<String, Value>)]
95 connector: Vec<(String, Value)>,
96}
97
98impl AttachmentCommand {
99 pub async fn take_action<C: CliArgs>(
101 &self,
102 parsed_args: &C,
103 client: &mut AsyncOpenStack,
104 ) -> Result<(), OpenStackCliError> {
105 info!("Set Attachment");
106
107 let op =
108 OutputProcessor::from_args(parsed_args, Some("block-storage.attachment"), Some("set"));
109 op.validate_args(parsed_args)?;
110
111 let mut ep_builder = set_327::Request::builder();
112 ep_builder.header(
113 http::header::HeaderName::from_static("openstack-api-version"),
114 http::header::HeaderValue::from_static("volume 3.27"),
115 );
116
117 ep_builder.id(&self.path.id);
118
119 let args = &self.attachment;
122 let mut attachment_builder = set_327::AttachmentBuilder::default();
123
124 attachment_builder.connector(args.connector.iter().cloned());
125
126 ep_builder.attachment(
127 attachment_builder
128 .build()
129 .wrap_err("error preparing the request data")?,
130 );
131
132 let ep = ep_builder
133 .build()
134 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
135
136 let data: serde_json::Value = ep.query_async(client).await?;
137
138 op.output_single::<response::set::AttachmentResponse>(data.clone())?;
139 op.show_command_hint()?;
141 Ok(())
142 }
143}