#![cfg(feature = "docker_connect")]
#![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, Deserialize, JsonHash)]
pub struct EndpointIPAMConfig {
#[serde(rename = "IPv4Address")]
pub i_pv4_address: Option<String>,
#[serde(rename = "IPv6Address")]
pub i_pv6_address: Option<String>,
#[serde(rename = "LinkLocalIPs")]
pub link_local_i_ps: Option<Vec<String>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct EndpointSettings {
#[serde(rename = "Aliases")]
pub aliases: Option<Vec<String>>,
#[serde(rename = "DNSNames")]
pub dns_names: Option<Vec<String>>,
#[serde(rename = "DriverOpts")]
pub driver_opts: Option<serde_json::Value>,
#[serde(rename = "EndpointID")]
pub endpoint_id: Option<String>,
#[serde(rename = "Gateway")]
pub gateway: Option<String>,
#[serde(rename = "GlobalIPv6Address")]
pub global_i_pv6_address: Option<String>,
#[serde(rename = "GlobalIPv6PrefixLen")]
pub global_i_pv6_prefix_len: Option<i64>,
#[serde(rename = "GwPriority")]
pub gw_priority: Option<i64>,
#[serde(rename = "IPAMConfig")]
pub ipam_config: Option<EndpointIPAMConfig>,
#[serde(rename = "IPAddress")]
pub ip_address: Option<String>,
#[serde(rename = "IPPrefixLen")]
pub ip_prefix_len: Option<i64>,
#[serde(rename = "IPv6Gateway")]
pub i_pv6_gateway: Option<String>,
#[serde(rename = "Links")]
pub links: Option<Vec<String>>,
#[serde(rename = "MacAddress")]
pub mac_address: Option<String>,
#[serde(rename = "NetworkID")]
pub network_id: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NetworkConnectRequest {
#[serde(rename = "Container")]
pub container: String,
#[serde(rename = "EndpointConfig")]
pub endpoint_config: Option<EndpointSettings>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NetworkConnectArgs {
pub id: String,
pub body: NetworkConnectRequest,
}
pub async fn network_connect_request<F>(
client: DynNetClient,
args: &NetworkConnectArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/networks/{}/connect",
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);
}
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: () })
}