foundation_deployment_docker 0.1.3

//! Auto-generated API module for docker update.
//!
//! Generated by `cargo run --bin ewe_platform gen_api`.
//! DO NOT EDIT MANUALLY.
//!
//! Feature flag: `docker_update `

#![cfg(feature = "docker_update")]
#![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;

// =============================================================================
// TYPE DECLARATIONS
// =============================================================================

/// `ConfigSpec` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ConfigSpec {
    /// `Data` property.
    #[serde(rename = "Data")]
    pub data: Option<String>,
    /// `Labels` property.
    #[serde(rename = "Labels")]
    pub labels: Option<serde_json::Value>,
    /// `Name` property.
    #[serde(rename = "Name")]
    pub name: Option<String>,
    /// `Templating` property.
    #[serde(rename = "Templating")]
    pub templating: Option<Driver>,
}

/// `ContainerUpdateRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ContainerUpdateRequest {
    /// `BlkioDeviceReadBps` property.
    #[serde(rename = "BlkioDeviceReadBps")]
    pub blkio_device_read_bps: Option<Vec<ThrottleDevice>>,
    /// `BlkioDeviceReadIOps` property.
    #[serde(rename = "BlkioDeviceReadIOps")]
    pub blkio_device_read_i_ops: Option<Vec<ThrottleDevice>>,
    /// `BlkioDeviceWriteBps` property.
    #[serde(rename = "BlkioDeviceWriteBps")]
    pub blkio_device_write_bps: Option<Vec<ThrottleDevice>>,
    /// `BlkioDeviceWriteIOps` property.
    #[serde(rename = "BlkioDeviceWriteIOps")]
    pub blkio_device_write_i_ops: Option<Vec<ThrottleDevice>>,
    /// `BlkioWeight` property.
    #[serde(rename = "BlkioWeight")]
    pub blkio_weight: Option<i64>,
    /// `BlkioWeightDevice` property.
    #[serde(rename = "BlkioWeightDevice")]
    pub blkio_weight_device: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
    /// `CgroupParent` property.
    #[serde(rename = "CgroupParent")]
    pub cgroup_parent: Option<String>,
    /// `CpuCount` property.
    #[serde(rename = "CpuCount")]
    pub cpu_count: Option<i64>,
    /// `CpuPercent` property.
    #[serde(rename = "CpuPercent")]
    pub cpu_percent: Option<i64>,
    /// `CpuPeriod` property.
    #[serde(rename = "CpuPeriod")]
    pub cpu_period: Option<i64>,
    /// `CpuQuota` property.
    #[serde(rename = "CpuQuota")]
    pub cpu_quota: Option<i64>,
    /// `CpuRealtimePeriod` property.
    #[serde(rename = "CpuRealtimePeriod")]
    pub cpu_realtime_period: Option<i64>,
    /// `CpuRealtimeRuntime` property.
    #[serde(rename = "CpuRealtimeRuntime")]
    pub cpu_realtime_runtime: Option<i64>,
    /// `CpuShares` property.
    #[serde(rename = "CpuShares")]
    pub cpu_shares: Option<i64>,
    /// `CpusetCpus` property.
    #[serde(rename = "CpusetCpus")]
    pub cpuset_cpus: Option<String>,
    /// `CpusetMems` property.
    #[serde(rename = "CpusetMems")]
    pub cpuset_mems: Option<String>,
    /// `DeviceCgroupRules` property.
    #[serde(rename = "DeviceCgroupRules")]
    pub device_cgroup_rules: Option<Vec<String>>,
    /// `DeviceRequests` property.
    #[serde(rename = "DeviceRequests")]
    pub device_requests: Option<Vec<DeviceRequest>>,
    /// `Devices` property.
    #[serde(rename = "Devices")]
    pub devices: Option<Vec<DeviceMapping>>,
    /// `Init` property.
    #[serde(rename = "Init")]
    pub init: Option<bool>,
    /// `IOMaximumBandwidth` property.
    #[serde(rename = "IOMaximumBandwidth")]
    pub io_maximum_bandwidth: Option<i64>,
    /// `IOMaximumIOps` property.
    #[serde(rename = "IOMaximumIOps")]
    pub io_maximum_i_ops: Option<i64>,
    /// `Memory` property.
    #[serde(rename = "Memory")]
    pub memory: Option<i64>,
    /// `MemoryReservation` property.
    #[serde(rename = "MemoryReservation")]
    pub memory_reservation: Option<i64>,
    /// `MemorySwap` property.
    #[serde(rename = "MemorySwap")]
    pub memory_swap: Option<i64>,
    /// `MemorySwappiness` property.
    #[serde(rename = "MemorySwappiness")]
    pub memory_swappiness: Option<i64>,
    /// `NanoCpus` property.
    #[serde(rename = "NanoCpus")]
    pub nano_cpus: Option<i64>,
    /// `OomKillDisable` property.
    #[serde(rename = "OomKillDisable")]
    pub oom_kill_disable: Option<bool>,
    /// `PidsLimit` property.
    #[serde(rename = "PidsLimit")]
    pub pids_limit: Option<i64>,
    /// `RestartPolicy` property.
    #[serde(rename = "RestartPolicy")]
    pub restart_policy: Option<RestartPolicy>,
    /// `Ulimits` property.
    #[serde(rename = "Ulimits")]
    pub ulimits: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
}

/// `ContainerUpdateResponse` type.
///
/// Same shape as `super::shared::WarningsObject`.
pub type ContainerUpdateResponse = super::shared::WarningsObject;

/// `DeviceMapping` type.
///
/// Same shape as `super::shared::CgroupPermissionsPathInContainerPathOnHostObject`.
pub type DeviceMapping = super::shared::CgroupPermissionsPathInContainerPathOnHostObject;

/// `DeviceRequest` type.
///
/// Same shape as `super::shared::DeviceRequestShape`.
pub type DeviceRequest = super::shared::DeviceRequestShape;

/// `Driver` type.
///
/// Same shape as `super::shared::NameOptionsObject`.
pub type Driver = super::shared::NameOptionsObject;

/// `EndpointPortConfig` type.
///
/// Same shape as `super::shared::EndpointPortConfigShape`.
pub type EndpointPortConfig = super::shared::EndpointPortConfigShape;

/// `EndpointSpec` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct EndpointSpec {
    /// `Mode` property.
    #[serde(rename = "Mode")]
    pub mode: Option<String>,
    /// `Ports` property.
    #[serde(rename = "Ports")]
    pub ports: Option<Vec<EndpointPortConfig>>,
}

/// `GenericResources` type.
pub type GenericResources = Vec<std::collections::HashMap<String, serde_json::Value>>;

/// `HealthConfig` type.
///
/// Same shape as `super::shared::HealthConfigShape`.
pub type HealthConfig = super::shared::HealthConfigShape;

/// `Limit` type.
///
/// Same shape as `super::shared::MemoryBytesNanoCpUsPidsObject`.
pub type Limit = super::shared::MemoryBytesNanoCpUsPidsObject;

/// `Mount` type.
///
/// Same shape as `super::shared::MountShape`.
pub type Mount = super::shared::MountShape;

/// `NetworkAttachmentConfig` type.
///
/// Same shape as `super::shared::AliasesDriverOptsTargetObject`.
pub type NetworkAttachmentConfig = super::shared::AliasesDriverOptsTargetObject;

/// `NodeSpec` type.
///
/// Same shape as `super::shared::NodeSpecShape`.
pub type NodeSpec = super::shared::NodeSpecShape;

/// `Platform` type.
///
/// Same shape as `super::shared::ArchitectureOsObject`.
pub type Platform = super::shared::ArchitectureOsObject;

/// `PluginPrivilege` type.
///
/// Same shape as `super::shared::DescriptionNameValueObject`.
pub type PluginPrivilege = super::shared::DescriptionNameValueObject;

/// `ResourceObject` type.
///
/// Same shape as `super::shared::GenericResourcesMemoryBytesNanoCpUsObject`.
pub type ResourceObject = super::shared::GenericResourcesMemoryBytesNanoCpUsObject;

/// `Resources` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct Resources {
    /// `BlkioDeviceReadBps` property.
    #[serde(rename = "BlkioDeviceReadBps")]
    pub blkio_device_read_bps: Option<Vec<ThrottleDevice>>,
    /// `BlkioDeviceReadIOps` property.
    #[serde(rename = "BlkioDeviceReadIOps")]
    pub blkio_device_read_i_ops: Option<Vec<ThrottleDevice>>,
    /// `BlkioDeviceWriteBps` property.
    #[serde(rename = "BlkioDeviceWriteBps")]
    pub blkio_device_write_bps: Option<Vec<ThrottleDevice>>,
    /// `BlkioDeviceWriteIOps` property.
    #[serde(rename = "BlkioDeviceWriteIOps")]
    pub blkio_device_write_i_ops: Option<Vec<ThrottleDevice>>,
    /// `BlkioWeight` property.
    #[serde(rename = "BlkioWeight")]
    pub blkio_weight: Option<i64>,
    /// `BlkioWeightDevice` property.
    #[serde(rename = "BlkioWeightDevice")]
    pub blkio_weight_device: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
    /// `CgroupParent` property.
    #[serde(rename = "CgroupParent")]
    pub cgroup_parent: Option<String>,
    /// `CpuCount` property.
    #[serde(rename = "CpuCount")]
    pub cpu_count: Option<i64>,
    /// `CpuPercent` property.
    #[serde(rename = "CpuPercent")]
    pub cpu_percent: Option<i64>,
    /// `CpuPeriod` property.
    #[serde(rename = "CpuPeriod")]
    pub cpu_period: Option<i64>,
    /// `CpuQuota` property.
    #[serde(rename = "CpuQuota")]
    pub cpu_quota: Option<i64>,
    /// `CpuRealtimePeriod` property.
    #[serde(rename = "CpuRealtimePeriod")]
    pub cpu_realtime_period: Option<i64>,
    /// `CpuRealtimeRuntime` property.
    #[serde(rename = "CpuRealtimeRuntime")]
    pub cpu_realtime_runtime: Option<i64>,
    /// `CpuShares` property.
    #[serde(rename = "CpuShares")]
    pub cpu_shares: Option<i64>,
    /// `CpusetCpus` property.
    #[serde(rename = "CpusetCpus")]
    pub cpuset_cpus: Option<String>,
    /// `CpusetMems` property.
    #[serde(rename = "CpusetMems")]
    pub cpuset_mems: Option<String>,
    /// `DeviceCgroupRules` property.
    #[serde(rename = "DeviceCgroupRules")]
    pub device_cgroup_rules: Option<Vec<String>>,
    /// `DeviceRequests` property.
    #[serde(rename = "DeviceRequests")]
    pub device_requests: Option<Vec<DeviceRequest>>,
    /// `Devices` property.
    #[serde(rename = "Devices")]
    pub devices: Option<Vec<DeviceMapping>>,
    /// `IOMaximumBandwidth` property.
    #[serde(rename = "IOMaximumBandwidth")]
    pub io_maximum_bandwidth: Option<i64>,
    /// `IOMaximumIOps` property.
    #[serde(rename = "IOMaximumIOps")]
    pub io_maximum_i_ops: Option<i64>,
    /// `Init` property.
    #[serde(rename = "Init")]
    pub init: Option<bool>,
    /// `Memory` property.
    #[serde(rename = "Memory")]
    pub memory: Option<i64>,
    /// `MemoryReservation` property.
    #[serde(rename = "MemoryReservation")]
    pub memory_reservation: Option<i64>,
    /// `MemorySwap` property.
    #[serde(rename = "MemorySwap")]
    pub memory_swap: Option<i64>,
    /// `MemorySwappiness` property.
    #[serde(rename = "MemorySwappiness")]
    pub memory_swappiness: Option<i64>,
    /// `NanoCpus` property.
    #[serde(rename = "NanoCpus")]
    pub nano_cpus: Option<i64>,
    /// `OomKillDisable` property.
    #[serde(rename = "OomKillDisable")]
    pub oom_kill_disable: Option<bool>,
    /// `PidsLimit` property.
    #[serde(rename = "PidsLimit")]
    pub pids_limit: Option<i64>,
    /// `Ulimits` property.
    #[serde(rename = "Ulimits")]
    pub ulimits: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
}

/// `RestartPolicy` type.
///
/// Same shape as `super::shared::MaximumRetryCountNameObject`.
pub type RestartPolicy = super::shared::MaximumRetryCountNameObject;

/// `SecretSpec` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct SecretSpec {
    /// `Data` property.
    #[serde(rename = "Data")]
    pub data: Option<String>,
    /// `Driver` property.
    #[serde(rename = "Driver")]
    pub driver: Option<Driver>,
    /// `Labels` property.
    #[serde(rename = "Labels")]
    pub labels: Option<serde_json::Value>,
    /// `Name` property.
    #[serde(rename = "Name")]
    pub name: Option<String>,
    /// `Templating` property.
    #[serde(rename = "Templating")]
    pub templating: Option<Driver>,
}

/// `ServiceSpec` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ServiceSpec {
    /// `EndpointSpec` property.
    #[serde(rename = "EndpointSpec")]
    pub endpoint_spec: Option<EndpointSpec>,
    /// `Labels` property.
    #[serde(rename = "Labels")]
    pub labels: Option<serde_json::Value>,
    /// `Mode` property.
    #[serde(rename = "Mode")]
    pub mode: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// `Name` property.
    #[serde(rename = "Name")]
    pub name: Option<String>,
    /// `Networks` property.
    #[serde(rename = "Networks")]
    pub networks: Option<Vec<NetworkAttachmentConfig>>,
    /// `RollbackConfig` property.
    #[serde(rename = "RollbackConfig")]
    pub rollback_config: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// `TaskTemplate` property.
    #[serde(rename = "TaskTemplate")]
    pub task_template: Option<TaskSpec>,
    /// `UpdateConfig` property.
    #[serde(rename = "UpdateConfig")]
    pub update_config: Option<std::collections::HashMap<String, serde_json::Value>>,
}

/// `ServiceUpdateRequest` type.
///
/// Same shape as `ServiceSpec`.
pub type ServiceUpdateRequest = ServiceSpec;

/// `ServiceUpdateResponse` type.
///
/// Same shape as `super::shared::WarningsObject`.
pub type ServiceUpdateResponse = super::shared::WarningsObject;

/// `SwarmSpec` type.
///
/// Same shape as `super::shared::SwarmSpecShape`.
pub type SwarmSpec = super::shared::SwarmSpecShape;

/// `TaskSpec` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TaskSpec {
    /// `ContainerSpec` property.
    #[serde(rename = "ContainerSpec")]
    pub container_spec: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// `ForceUpdate` property.
    #[serde(rename = "ForceUpdate")]
    pub force_update: Option<i64>,
    /// `LogDriver` property.
    #[serde(rename = "LogDriver")]
    pub log_driver: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// `NetworkAttachmentSpec` property.
    #[serde(rename = "NetworkAttachmentSpec")]
    pub network_attachment_spec: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// `Networks` property.
    #[serde(rename = "Networks")]
    pub networks: Option<Vec<NetworkAttachmentConfig>>,
    /// `Placement` property.
    #[serde(rename = "Placement")]
    pub placement: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// `PluginSpec` property.
    #[serde(rename = "PluginSpec")]
    pub plugin_spec: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// `Resources` property.
    #[serde(rename = "Resources")]
    pub resources: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// `RestartPolicy` property.
    #[serde(rename = "RestartPolicy")]
    pub restart_policy: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// `Runtime` property.
    #[serde(rename = "Runtime")]
    pub runtime: Option<String>,
}

/// `ThrottleDevice` type.
///
/// Same shape as `super::shared::PathRateObject`.
pub type ThrottleDevice = super::shared::PathRateObject;

// =============================================================================
// ARGS TYPES (per-endpoint)
// =============================================================================

/// Arguments for [`ConfigUpdate_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ConfigUpdateArgs {
    /// Path parameter: `id`.
    pub id: String,
    /// Query parameter: `version`.
    pub version: Option<String>,
    /// Request body.
    pub body: ConfigSpec,
}

/// Arguments for [`ContainerUpdate_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ContainerUpdateArgs {
    /// Path parameter: `id`.
    pub id: String,
    /// Request body.
    pub body: ContainerUpdateRequest,
}

/// Arguments for [`NodeUpdate_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NodeUpdateArgs {
    /// Path parameter: `id`.
    pub id: String,
    /// Query parameter: `version`.
    pub version: Option<String>,
    /// Request body.
    pub body: NodeSpec,
}

/// Arguments for [`SecretUpdate_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SecretUpdateArgs {
    /// Path parameter: `id`.
    pub id: String,
    /// Query parameter: `version`.
    pub version: Option<String>,
    /// Request body.
    pub body: SecretSpec,
}

/// Arguments for [`ServiceUpdate_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ServiceUpdateArgs {
    /// Path parameter: `id`.
    pub id: String,
    /// Query parameter: `version`.
    pub version: Option<String>,
    /// Query parameter: `registryAuthFrom`.
    pub registry_auth_from: Option<String>,
    /// Query parameter: `rollback`.
    pub rollback: Option<String>,
    /// Request body.
    pub body: ServiceUpdateRequest,
}

/// Arguments for [`SwarmUpdate_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SwarmUpdateArgs {
    /// Query parameter: `version`.
    pub version: Option<String>,
    /// Query parameter: `rotateWorkerToken`.
    pub rotate_worker_token: Option<String>,
    /// Query parameter: `rotateManagerToken`.
    pub rotate_manager_token: Option<String>,
    /// Query parameter: `rotateManagerUnlockKey`.
    pub rotate_manager_unlock_key: Option<String>,
    /// Request body.
    pub body: SwarmSpec,
}

// =============================================================================
// CLIENT FUNCTIONS (per-endpoint)
// =============================================================================

// -----------------------------------------------------------------------------
// POST /configs/{id}/update
// -----------------------------------------------------------------------------

/// POST /configs/{id}/update.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = config_update_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn config_update_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &ConfigUpdateArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/configs/{}/update", 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("version", args.version.as_deref());

    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_without_body(client.into(), builder.build()).await
}

// -----------------------------------------------------------------------------
// POST /containers/{id}/update
// -----------------------------------------------------------------------------

/// POST /containers/{id}/update.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = container_update_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn container_update_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &ContainerUpdateArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<ContainerUpdateResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/containers/{}/update", 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
}

// -----------------------------------------------------------------------------
// POST /nodes/{id}/update
// -----------------------------------------------------------------------------

/// POST /nodes/{id}/update.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = node_update_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn node_update_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &NodeUpdateArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/nodes/{}/update", 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("version", args.version.as_deref());

    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_without_body(client.into(), builder.build()).await
}

// -----------------------------------------------------------------------------
// POST /secrets/{id}/update
// -----------------------------------------------------------------------------

/// POST /secrets/{id}/update.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = secret_update_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn secret_update_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &SecretUpdateArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/secrets/{}/update", 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("version", args.version.as_deref());

    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_without_body(client.into(), builder.build()).await
}

// -----------------------------------------------------------------------------
// POST /services/{id}/update
// -----------------------------------------------------------------------------

/// POST /services/{id}/update.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = service_update_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn service_update_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &ServiceUpdateArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<ServiceUpdateResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/services/{}/update", 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("version", args.version.as_deref());
    builder = builder.query("registryAuthFrom", args.registry_auth_from.as_deref());
    builder = builder.query("rollback", args.rollback.as_deref());

    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
}

// -----------------------------------------------------------------------------
// POST /swarm/update
// -----------------------------------------------------------------------------

/// POST /swarm/update.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = swarm_update_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn swarm_update_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &SwarmUpdateArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/swarm/update",);
    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("version", args.version.as_deref());
    builder = builder.query("rotateWorkerToken", args.rotate_worker_token.as_deref());
    builder = builder.query("rotateManagerToken", args.rotate_manager_token.as_deref());
    builder = builder.query(
        "rotateManagerUnlockKey",
        args.rotate_manager_unlock_key.as_deref(),
    );

    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_without_body(client.into(), builder.build()).await
}