#![cfg(feature = "docker_prune")]
#![allow(clippy::too_many_arguments, clippy::type_complexity)]
#![allow(clippy::missing_errors_doc, clippy::doc_markdown, clippy::useless_format)]
#![allow(unused_imports)]
use foundation_netio::{DynNetClient, PreparedRequestBuilder};
use foundation_netio::shared::client::http_client::HttpClient;
use serde::{Deserialize, Serialize};
use foundation_macros::JsonHash;
use super::shared::ApiResponse;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BuildPruneArgs {
pub reserved_space: Option<String>,
pub max_used_space: Option<String>,
pub min_free_space: Option<String>,
pub all: Option<String>,
pub filters: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ContainerPruneArgs {
pub filters: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ImagePruneArgs {
pub filters: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NetworkPruneArgs {
pub filters: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct VolumePruneArgs {
pub filters: Option<String>,
}
pub async fn build_prune_request<F>(
client: DynNetClient,
args: &BuildPruneArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/build/prune",
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("reserved-space", args.reserved_space.as_deref());
builder = builder.query("max-used-space", args.max_used_space.as_deref());
builder = builder.query("min-free-space", args.min_free_space.as_deref());
builder = builder.query("all", args.all.as_deref());
builder = builder.query("filters", args.filters.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body: None });
}
Ok(ApiResponse { status: status as u16, headers, body: () })
}
pub async fn container_prune_request<F>(
client: DynNetClient,
args: &ContainerPruneArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/containers/prune",
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("filters", args.filters.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body: None });
}
Ok(ApiResponse { status: status as u16, headers, body: () })
}
pub async fn image_prune_request<F>(
client: DynNetClient,
args: &ImagePruneArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/images/prune",
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("filters", args.filters.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body: None });
}
Ok(ApiResponse { status: status as u16, headers, body: () })
}
pub async fn network_prune_request<F>(
client: DynNetClient,
args: &NetworkPruneArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/networks/prune",
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("filters", args.filters.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body: None });
}
Ok(ApiResponse { status: status as u16, headers, body: () })
}
pub async fn volume_prune_request<F>(
client: DynNetClient,
args: &VolumePruneArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/volumes/prune",
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("filters", args.filters.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body: None });
}
Ok(ApiResponse { status: status as u16, headers, body: () })
}