use clap::Args;
use tracing::info;
use openstack_cli_core::cli::CliArgs;
use openstack_cli_core::error::OpenStackCliError;
use openstack_cli_core::output::OutputProcessor;
use openstack_sdk::AsyncOpenStack;
use openstack_cli_core::common::download_file;
use openstack_sdk::api::QueryAsync;
use openstack_sdk::api::download;
use openstack_sdk::api::find;
use openstack_sdk::api::image::v2::image::file::download;
use openstack_sdk::api::image::v2::image::find;
#[derive(Args)]
#[command(about = "Download binary image data")]
pub struct FileCommand {
#[command(flatten)]
query: QueryParameters,
#[command(flatten)]
headers: HeaderParameters,
#[command(flatten)]
path: PathParameters,
#[arg(long)]
file: Option<String>,
}
#[derive(Args)]
struct QueryParameters {}
#[derive(Args)]
struct HeaderParameters {
#[arg(long)]
range: Option<String>,
}
#[derive(Args)]
struct PathParameters {
#[arg(
help_heading = "Path parameters",
id = "path_param_image_id",
value_name = "IMAGE_ID"
)]
image_id: String,
}
impl FileCommand {
pub async fn take_action<C: CliArgs>(
&self,
parsed_args: &C,
client: &mut AsyncOpenStack,
) -> Result<(), OpenStackCliError> {
info!("Download File");
let op =
OutputProcessor::from_args(parsed_args, Some("image.image/file"), Some("download"));
op.validate_args(parsed_args)?;
let find_ep = find::Request::builder()
.id(&self.path.image_id)
.build()
.map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
let image_data: serde_json::Value = find(find_ep).query_async(client).await?;
let image_id = image_data["id"]
.as_str()
.ok_or_else(|| eyre::eyre!("image ID must be a string"))?
.to_string();
let image_name = image_data["name"]
.as_str()
.ok_or_else(|| eyre::eyre!("image name must be a string"))?
.to_string();
let ep = download::Request::builder()
.image_id(image_id)
.build()
.map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
let (headers, data) = download(ep).query_async(client).await?;
let size: u64 = headers
.get("content-length")
.and_then(|x| {
x.to_str()
.inspect_err(|e| {
tracing::warn!("content-length header cannot be treated as string: {}", e)
})
.ok()
})
.unwrap_or("0")
.parse()
.inspect_err(|e| {
tracing::warn!("content-length header mut represent u64 number: {}", e)
})
.unwrap_or_default();
download_file(self.file.clone().unwrap_or(image_name), size, data).await?;
op.show_command_hint()?;
Ok(())
}
}