#![cfg(feature = "docker_wait")]
#![allow(clippy::too_many_arguments, clippy::type_complexity)]
#![allow(
clippy::missing_errors_doc,
clippy::doc_markdown,
clippy::useless_format
)]
#![allow(unused_imports)]
use foundation_macros::JsonHash;
use foundation_netio::shared::client::http_client::HttpClient;
use foundation_netio::{DynNetClient, PreparedRequestBuilder};
use serde::{Deserialize, Serialize};
use super::shared::ApiResponse;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ContainerWaitExitError {
#[serde(rename = "Message")]
pub message: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ContainerWaitResponse {
#[serde(rename = "Error")]
pub error: Option<ContainerWaitExitError>,
#[serde(rename = "StatusCode")]
pub status_code: i64,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ContainerWaitArgs {
pub id: String,
pub condition: Option<String>,
}
pub async fn container_wait_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ContainerWaitArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ContainerWaitResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/containers/{}/wait", args.id,);
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("condition", args.condition.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}