openstack_cli_network/v2/security_group/
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::security_group::find;
34use openstack_sdk::api::network::v2::security_group::set;
35use openstack_types::network::v2::security_group::response;
36
37#[derive(Args)]
43#[command(about = "Update security group")]
44pub struct SecurityGroupCommand {
45 #[command(flatten)]
47 query: QueryParameters,
48
49 #[command(flatten)]
51 path: PathParameters,
52
53 #[command(flatten)]
55 security_group: SecurityGroup,
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 SecurityGroup {
76 #[arg(help_heading = "Body parameters", long)]
79 description: Option<String>,
80
81 #[arg(help_heading = "Body parameters", long)]
83 name: Option<String>,
84
85 #[arg(action=clap::ArgAction::Set, help_heading = "Body parameters", long)]
86 stateful: Option<bool>,
87}
88
89impl SecurityGroupCommand {
90 pub async fn take_action<C: CliArgs>(
92 &self,
93 parsed_args: &C,
94 client: &mut AsyncOpenStack,
95 ) -> Result<(), OpenStackCliError> {
96 info!("Set SecurityGroup");
97
98 let op =
99 OutputProcessor::from_args(parsed_args, Some("network.security_group"), Some("set"));
100 op.validate_args(parsed_args)?;
101
102 let mut find_builder = find::Request::builder();
103
104 find_builder.id(&self.path.id);
105
106 let find_ep = find_builder
107 .build()
108 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
109 let find_data: serde_json::Value = find(find_ep).query_async(client).await?;
110
111 let mut ep_builder = set::Request::builder();
112
113 let resource_id = find_data["id"]
114 .as_str()
115 .ok_or_else(|| eyre::eyre!("resource ID must be a string"))?
116 .to_string();
117 ep_builder.id(resource_id.clone());
118
119 let args = &self.security_group;
122 let mut security_group_builder = set::SecurityGroupBuilder::default();
123 if let Some(val) = &args.description {
124 security_group_builder.description(val);
125 }
126
127 if let Some(val) = &args.name {
128 security_group_builder.name(val);
129 }
130
131 if let Some(val) = &args.stateful {
132 security_group_builder.stateful(*val);
133 }
134
135 ep_builder.security_group(
136 security_group_builder
137 .build()
138 .wrap_err("error preparing the request data")?,
139 );
140
141 let ep = ep_builder
142 .build()
143 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
144
145 let data: serde_json::Value = ep.query_async(client).await?;
146
147 op.output_single::<response::set::SecurityGroupResponse>(data.clone())?;
148 op.show_command_hint()?;
150 Ok(())
151 }
152}