openstack_cli_network/v2/router/conntrack_helper/
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 clap::ValueEnum;
32use openstack_sdk::api::QueryAsync;
33use openstack_sdk::api::network::v2::router::conntrack_helper::set;
34use openstack_types::network::v2::router::conntrack_helper::response;
35
36#[derive(Args)]
42#[command(about = "Update a conntrack helper")]
43pub struct ConntrackHelperCommand {
44 #[command(flatten)]
46 query: QueryParameters,
47
48 #[command(flatten)]
50 path: PathParameters,
51
52 #[command(flatten)]
53 conntrack_helper: ConntrackHelper,
54}
55
56#[derive(Args)]
58struct QueryParameters {}
59
60#[derive(Args)]
62struct PathParameters {
63 #[arg(
65 help_heading = "Path parameters",
66 id = "path_param_id",
67 value_name = "ID"
68 )]
69 id: String,
70
71 #[arg(
74 help_heading = "Path parameters",
75 id = "path_param_router_id",
76 value_name = "ROUTER_ID"
77 )]
78 router_id: String,
79}
80
81#[derive(Clone, Eq, Ord, PartialEq, PartialOrd, ValueEnum)]
82enum Protocol {
83 Dccp,
84 Icmp,
85 Ipv6Icmp,
86 Sctp,
87 Tcp,
88 Udp,
89}
90
91#[derive(Args, Clone)]
93struct ConntrackHelper {
94 #[arg(help_heading = "Body parameters", long)]
96 helper: Option<String>,
97
98 #[arg(help_heading = "Body parameters", long)]
100 port: Option<i32>,
101
102 #[arg(help_heading = "Body parameters", long)]
104 protocol: Option<Protocol>,
105}
106
107impl ConntrackHelperCommand {
108 pub async fn take_action<C: CliArgs>(
110 &self,
111 parsed_args: &C,
112 client: &mut AsyncOpenStack,
113 ) -> Result<(), OpenStackCliError> {
114 info!("Set ConntrackHelper");
115
116 let op = OutputProcessor::from_args(
117 parsed_args,
118 Some("network.router/conntrack_helper"),
119 Some("set"),
120 );
121 op.validate_args(parsed_args)?;
122
123 let mut ep_builder = set::Request::builder();
124
125 ep_builder.id(&self.path.id);
126 ep_builder.router_id(&self.path.router_id);
127
128 let args = &self.conntrack_helper;
131 let mut conntrack_helper_builder = set::ConntrackHelperBuilder::default();
132 if let Some(val) = &args.helper {
133 conntrack_helper_builder.helper(val);
134 }
135
136 if let Some(val) = &args.port {
137 conntrack_helper_builder.port(*val);
138 }
139
140 if let Some(val) = &args.protocol {
141 let tmp = match val {
142 Protocol::Dccp => set::Protocol::Dccp,
143 Protocol::Icmp => set::Protocol::Icmp,
144 Protocol::Ipv6Icmp => set::Protocol::Ipv6Icmp,
145 Protocol::Sctp => set::Protocol::Sctp,
146 Protocol::Tcp => set::Protocol::Tcp,
147 Protocol::Udp => set::Protocol::Udp,
148 };
149 conntrack_helper_builder.protocol(tmp);
150 }
151
152 ep_builder.conntrack_helper(
153 conntrack_helper_builder
154 .build()
155 .wrap_err("error preparing the request data")?,
156 );
157
158 let ep = ep_builder
159 .build()
160 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
161
162 let data: serde_json::Value = ep.query_async(client).await?;
163
164 op.output_single::<response::set::ConntrackHelperResponse>(data.clone())?;
165 op.show_command_hint()?;
167 Ok(())
168 }
169}