#![cfg(feature = "cloudflare_tenants")]
#![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 OrganizationsApiAccount {
pub created_on: String,
pub id: String,
pub name: Option<String>,
pub settings: std::collections::HashMap<String, serde_json::Value>,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct OrganizationsApiTenant {
pub cdate: String,
pub customer_id: Option<String>,
pub edate: String,
pub tenant_contacts: std::collections::HashMap<String, serde_json::Value>,
pub tenant_labels: Vec<String>,
pub tenant_metadata: std::collections::HashMap<String, serde_json::Value>,
pub tenant_name: String,
pub tenant_network: serde_json::Value,
pub tenant_status: String,
pub tenant_tag: String,
pub tenant_type: String,
pub tenant_units: Vec<OrganizationsApiTenantUnit>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct OrganizationsApiTenantUnit {
pub unit_memberships: Vec<serde_json::Value>,
pub unit_metadata: serde_json::Value,
pub unit_name: String,
pub unit_status: String,
pub unit_tag: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct OrganizationsApiV4Message {
pub code: i64,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TenantsListAccountsResponse {
pub errors: Vec<serde_json::Value>,
pub messages: Vec<OrganizationsApiV4Message>,
pub result: Vec<OrganizationsApiAccount>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TenantsRetrieveTenantResponse {
pub errors: Vec<serde_json::Value>,
pub messages: Vec<OrganizationsApiV4Message>,
pub result: OrganizationsApiTenant,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TenantsValidAccountTypesResponse {
pub errors: Vec<serde_json::Value>,
pub messages: Vec<OrganizationsApiV4Message>,
pub result: Vec<String>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TenantsRetrieveTenantArgs {
pub tenant_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TenantsValidAccountTypesArgs {
pub tenant_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TenantsListAccountsArgs {
pub tenant_id: String,
}
pub async fn tenants_retrieve_tenant_request<F>(
client: DynNetClient,
args: &TenantsRetrieveTenantArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TenantsRetrieveTenantResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/tenants/{}",
args.tenant_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.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 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: TenantsRetrieveTenantResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn tenants_valid_account_types_request<F>(
client: DynNetClient,
args: &TenantsValidAccountTypesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TenantsValidAccountTypesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/tenants/{}/account_types",
args.tenant_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.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 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: TenantsValidAccountTypesResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn tenants_list_accounts_request<F>(
client: DynNetClient,
args: &TenantsListAccountsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TenantsListAccountsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/tenants/{}/accounts",
args.tenant_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.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 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: TenantsListAccountsResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}