#![cfg(feature = "docker_exec")]
#![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::IDResponse;
use super::shared::ApiResponse;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ContainerExecRequest {
#[serde(rename = "AttachStderr")]
pub attach_stderr: Option<bool>,
#[serde(rename = "AttachStdin")]
pub attach_stdin: Option<bool>,
#[serde(rename = "AttachStdout")]
pub attach_stdout: Option<bool>,
#[serde(rename = "Cmd")]
pub cmd: Option<Vec<String>>,
#[serde(rename = "ConsoleSize")]
pub console_size: Option<Vec<i64>>,
#[serde(rename = "DetachKeys")]
pub detach_keys: Option<String>,
#[serde(rename = "Env")]
pub env: Option<Vec<String>>,
#[serde(rename = "Privileged")]
pub privileged: Option<bool>,
#[serde(rename = "Tty")]
pub tty: Option<bool>,
#[serde(rename = "User")]
pub user: Option<String>,
#[serde(rename = "WorkingDir")]
pub working_dir: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ContainerExecArgs {
pub id: String,
pub body: ContainerExecRequest,
}
pub async fn container_exec_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ContainerExecArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<IDResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/containers/{}/exec", 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
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}