openstack_cli_network/v2/security_group/
list.rs1use clap::Args;
23use tracing::info;
24
25use openstack_cli_core::cli::CliArgs;
26use openstack_cli_core::error::OpenStackCliError;
27use openstack_cli_core::output::OutputProcessor;
28use openstack_sdk::AsyncOpenStack;
29
30use openstack_sdk::api::QueryAsync;
31use openstack_sdk::api::network::v2::security_group::list;
32use openstack_sdk::api::{Pagination, paged};
33use openstack_types::network::v2::security_group::response;
34
35#[derive(Args)]
57#[command(about = "List security groups")]
58pub struct SecurityGroupsCommand {
59 #[command(flatten)]
61 query: QueryParameters,
62
63 #[command(flatten)]
65 path: PathParameters,
66
67 #[arg(long, default_value_t = 10000)]
69 max_items: usize,
70}
71
72#[derive(Args)]
74struct QueryParameters {
75 #[arg(help_heading = "Query parameters", long)]
77 description: Option<String>,
78
79 #[arg(help_heading = "Query parameters", long)]
81 id: Option<String>,
82
83 #[arg(
88 help_heading = "Query parameters",
89 long("page-size"),
90 visible_alias("limit")
91 )]
92 limit: Option<u32>,
93
94 #[arg(help_heading = "Query parameters", long)]
98 marker: Option<String>,
99
100 #[arg(help_heading = "Query parameters", long)]
102 name: Option<String>,
103
104 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
106 not_tags: Option<Vec<String>>,
107
108 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
110 not_tags_any: Option<Vec<String>>,
111
112 #[arg(action=clap::ArgAction::Set, help_heading = "Query parameters", long)]
114 page_reverse: Option<bool>,
115
116 #[arg(help_heading = "Query parameters", long)]
118 revision_number: Option<String>,
119
120 #[arg(action=clap::ArgAction::Set, help_heading = "Query parameters", long)]
122 shared: Option<bool>,
123
124 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
127 sort_dir: Option<Vec<String>>,
128
129 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
132 sort_key: Option<Vec<String>>,
133
134 #[arg(action=clap::ArgAction::Set, help_heading = "Query parameters", long)]
136 stateful: Option<bool>,
137
138 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
140 tags: Option<Vec<String>>,
141
142 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
144 tags_any: Option<Vec<String>>,
145
146 #[arg(help_heading = "Query parameters", long)]
148 tenant_id: Option<String>,
149}
150
151#[derive(Args)]
153struct PathParameters {}
154
155impl SecurityGroupsCommand {
156 pub async fn take_action<C: CliArgs>(
158 &self,
159 parsed_args: &C,
160 client: &mut AsyncOpenStack,
161 ) -> Result<(), OpenStackCliError> {
162 info!("List SecurityGroups");
163
164 let op =
165 OutputProcessor::from_args(parsed_args, Some("network.security_group"), Some("list"));
166 op.validate_args(parsed_args)?;
167
168 let mut ep_builder = list::Request::builder();
169
170 if let Some(val) = &self.query.limit {
172 ep_builder.limit(*val);
173 }
174 if let Some(val) = &self.query.marker {
175 ep_builder.marker(val);
176 }
177 if let Some(val) = &self.query.page_reverse {
178 ep_builder.page_reverse(*val);
179 }
180 if let Some(val) = &self.query.description {
181 ep_builder.description(val);
182 }
183 if let Some(val) = &self.query.id {
184 ep_builder.id(val);
185 }
186 if let Some(val) = &self.query.name {
187 ep_builder.name(val);
188 }
189 if let Some(val) = &self.query.not_tags {
190 ep_builder.not_tags(val.iter());
191 }
192 if let Some(val) = &self.query.not_tags_any {
193 ep_builder.not_tags_any(val.iter());
194 }
195 if let Some(val) = &self.query.revision_number {
196 ep_builder.revision_number(val);
197 }
198 if let Some(val) = &self.query.shared {
199 ep_builder.shared(*val);
200 }
201 if let Some(val) = &self.query.stateful {
202 ep_builder.stateful(*val);
203 }
204 if let Some(val) = &self.query.tags {
205 ep_builder.tags(val.iter());
206 }
207 if let Some(val) = &self.query.tags_any {
208 ep_builder.tags_any(val.iter());
209 }
210 if let Some(val) = &self.query.tenant_id {
211 ep_builder.tenant_id(val);
212 }
213 if let Some(val) = &self.query.sort_dir {
214 ep_builder.sort_dir(val.iter());
215 }
216 if let Some(val) = &self.query.sort_key {
217 ep_builder.sort_key(val.iter());
218 }
219
220 let ep = ep_builder
221 .build()
222 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
223
224 let data: Vec<serde_json::Value> = paged(ep, Pagination::Limit(self.max_items))
225 .query_async(client)
226 .await?;
227
228 op.output_list::<response::list::SecurityGroupResponse>(data.clone())?;
229 op.show_command_hint()?;
231 Ok(())
232 }
233}