use async_trait::async_trait;
use clap::Args;
use serde::{Deserialize, Serialize};
use tracing::info;
use crate::output::OutputProcessor;
use crate::Cli;
use structable::StructTableOptions;
use crate::StructTable;
use crate::{OSCCommand, OpenStackCliError};
use openstack_sdk::AsyncOpenStack;
use openstack_sdk::api::compute::v2::server::virtual_interface::get;
use openstack_sdk::api::QueryAsync;
use serde_json::Value;
use std::collections::HashMap;
#[derive(Args, Clone, Debug)]
#[command(about = "List Virtual Interfaces")]
pub struct VirtualInterfaceArgs {
#[command(flatten)]
query: QueryParameters,
#[command(flatten)]
path: PathParameters,
}
#[derive(Args, Clone, Debug)]
pub struct QueryParameters {}
#[derive(Args, Clone, Debug)]
pub struct PathParameters {
#[arg()]
server_id: String,
}
pub struct VirtualInterfaceCmd {
pub args: VirtualInterfaceArgs,
}
#[derive(Deserialize, Debug, Clone, Serialize)]
pub struct ResponseData(HashMap<String, serde_json::Value>);
impl StructTable for ResponseData {
fn build(&self, _options: &OutputConfig) -> (Vec<String>, Vec<Vec<String>>) {
let headers: Vec<String> = Vec::from(["Name".to_string(), "Value".to_string()]);
let mut rows: Vec<Vec<String>> = Vec::new();
rows.extend(self.0.iter().map(|(k, v)| {
Vec::from([
k.clone(),
serde_json::to_string(&v).expect("Is a valid data"),
])
}));
(headers, rows)
}
}
#[async_trait]
impl OSCCommand for VirtualInterfaceCmd {
async fn take_action(
&self,
parsed_args: &Cli,
client: &mut AsyncOpenStack,
) -> Result<(), OpenStackCliError> {
info!("Get VirtualInterface with {:?}", self.args);
let op = OutputProcessor::from_args(parsed_args);
op.validate_args(parsed_args)?;
info!("Parsed args: {:?}", self.args);
let mut ep_builder = get::Request::builder();
ep_builder.server_id(&self.args.path.server_id);
let ep = ep_builder
.build()
.map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
let data = ep.query_async(client).await?;
op.output_single::<ResponseData>(data)?;
Ok(())
}
}