foundation_deployment_cloudflare 0.1.1

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

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

// Import shared types used by this module
use super::shared::AaaAuditLogsResponseCollection;
use super::shared::LogpushDestinationExistsResponse;
use super::shared::LogpushGetOwnershipResponse;
use super::shared::LogpushLogpushFieldResponseCollection;
use super::shared::LogpushLogpushJobResponseCollection;
use super::shared::LogpushLogpushJobResponseSingle;
use super::shared::LogpushValidateOwnershipResponse;
use super::shared::LogpushValidateResponse;
use super::shared::AaaResultInfo;
use super::shared::LogpushApiResponseCommon;
use super::shared::LogpushApiResponseSingle;
use super::shared::LogpushDataset;
use super::shared::LogpushDestinationConf;
use super::shared::LogpushEnabled;
use super::shared::LogpushErrorMessage;
use super::shared::LogpushFrequency;
use super::shared::LogpushId;
use super::shared::LogpushKind;
use super::shared::LogpushLastComplete;
use super::shared::LogpushLastError;
use super::shared::LogpushLogpullOptions;
use super::shared::LogpushLogpushJob;
use super::shared::LogpushMaxUploadBytes;
use super::shared::LogpushMaxUploadIntervalSeconds;
use super::shared::LogpushMaxUploadRecords;
use super::shared::LogpushName;
use super::shared::LogpushOutputOptions;

use super::shared::ApiResponse;

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

/// `AaaAuditLogAction` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaAuditLogAction {
    /// description property.
    pub description: Option<String>,
    /// result property.
    pub result: Option<String>,
    /// time property.
    pub time: Option<String>,
    /// type property.
    #[serde(rename = "type")]
    pub r#type: Option<String>,
}

/// `AaaAuditLogRaw` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaAuditLogRaw {
    /// cf_ray_id property.
    pub cf_ray_id: Option<String>,
    /// method property.
    pub method: Option<String>,
    /// status_code property.
    pub status_code: Option<i64>,
    /// uri property.
    pub uri: Option<String>,
    /// user_agent property.
    pub user_agent: Option<String>,
}

/// `AaaAuditLogsV2` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaAuditLogsV2 {
    /// account property.
    pub account: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// action property.
    pub action: Option<AaaAuditLogAction>,
    /// actor property.
    pub actor: Option<serde_json::Value>,
    /// id property.
    pub id: Option<AaaSchemasIdentifier>,
    /// raw property.
    #[serde(rename = "raw")]
    pub r#raw: Option<AaaAuditLogRaw>,
    /// resource property.
    pub resource: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// zone property.
    pub zone: Option<std::collections::HashMap<String, serde_json::Value>>,
}

/// `AaaAuditLogsV2ResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaAuditLogsV2ResponseCollection {
    /// `result` property.
    pub result: Option<Vec<AaaAuditLogsV2>>,
}

/// `AaaSchemasIdentifier` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSchemasIdentifier {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaSchemasMessages` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSchemasMessages {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `DeleteAccountsAccountIdLogpushJobsJobIdResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DeleteAccountsAccountIdLogpushJobsJobIdResponse {
    /// `result` property.
    pub result: Option<std::collections::HashMap<String, serde_json::Value>>,
}

/// `DeleteAccountsAccountIdLogpushValidateDestinationExistsRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DeleteAccountsAccountIdLogpushValidateDestinationExistsRequest {
    /// destination_conf property.
    pub destination_conf: LogpushDestinationConf,
}

/// `DeleteAccountsAccountIdLogpushValidateDestinationRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DeleteAccountsAccountIdLogpushValidateDestinationRequest {
    /// destination_conf property.
    pub destination_conf: LogpushDestinationConf,
}

/// `DeleteAccountsAccountIdLogsControlCmbConfigResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DeleteAccountsAccountIdLogsControlCmbConfigResponse {
    /// `result` property.
    pub result: Option<serde_json::Value>,
}

/// `DlpApiResponseCommon` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpApiResponseCommon {
    /// errors property.
    pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
    /// messages property.
    pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
    /// success property.
    pub success: bool,
}

/// `DlpApiResponseSingle` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpApiResponseSingle {
}

/// `DlpMessages` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpMessages {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `DlpPayloadLogGetResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPayloadLogGetResponse {
    /// `result` property.
    pub result: Option<DlpPayloadLogSetting>,
}

/// `DlpPayloadLogPutResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPayloadLogPutResponse {
    /// `result` property.
    pub result: Option<DlpPayloadLogSetting>,
}

/// `DlpPayloadLogSetting` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPayloadLogSetting {
    /// masking_level property.
    pub masking_level: Option<serde_json::Value>,
    /// public_key property.
    pub public_key: Option<String>,
    /// updated_at property.
    pub updated_at: String,
}

/// `DlpPayloadLogSettingUpdateLegacy` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPayloadLogSettingUpdateLegacy {
    /// masking_level property.
    pub masking_level: Option<serde_json::Value>,
    /// public_key property.
    pub public_key: Option<String>,
}

/// `LogcontrolAllowOutOfRegionAccess` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LogcontrolAllowOutOfRegionAccess {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `LogcontrolApiResponseCommon` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LogcontrolApiResponseCommon {
    /// errors property.
    pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
    /// messages property.
    pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
    /// success property.
    pub success: bool,
}

/// `LogcontrolApiResponseSingle` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LogcontrolApiResponseSingle {
}

/// `LogcontrolCmbConfig` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LogcontrolCmbConfig {
    /// allow_out_of_region_access property.
    pub allow_out_of_region_access: Option<LogcontrolAllowOutOfRegionAccess>,
    /// regions property.
    pub regions: Option<LogcontrolRegions>,
}

/// `LogcontrolCmbConfigResponseSingle` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LogcontrolCmbConfigResponseSingle {
    /// `result` property.
    pub result: Option<LogcontrolCmbConfig>,
}

/// `LogcontrolMessages` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LogcontrolMessages {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `LogcontrolRegions` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LogcontrolRegions {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `LogpushFilter` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LogpushFilter {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `LogpushMessages` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LogpushMessages {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `LogpushOwnershipChallenge` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LogpushOwnershipChallenge {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnAccountId` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnAccountId {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnCatalogSync` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCatalogSync {
    /// description property.
    pub description: String,
    /// destination_id property.
    pub destination_id: McnCatalogSyncDestinationId,
    /// destination_type property.
    pub destination_type: McnCatalogSyncDestinationType,
    /// errors property.
    pub errors: Option<serde_json::Value>,
    /// id property.
    pub id: McnCatalogSyncId,
    /// includes_discoveries_until property.
    pub includes_discoveries_until: Option<String>,
    /// last_attempted_update_at property.
    pub last_attempted_update_at: Option<String>,
    /// last_successful_update_at property.
    pub last_successful_update_at: Option<String>,
    /// last_user_update_at property.
    pub last_user_update_at: String,
    /// name property.
    pub name: String,
    /// policy property.
    pub policy: String,
    /// update_mode property.
    pub update_mode: McnCatalogSyncUpdateMode,
}

/// `McnCatalogSyncDestinationId` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCatalogSyncDestinationId {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnCatalogSyncDestinationType` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCatalogSyncDestinationType {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnCatalogSyncId` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCatalogSyncId {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnCatalogSyncUpdateMode` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCatalogSyncUpdateMode {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnCatalogSyncsPrebuiltPoliciesResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCatalogSyncsPrebuiltPoliciesResponse {
    /// `result` property.
    pub result: Option<Vec<McnCatalogSyncsPrebuiltPolicy>>,
}

/// `McnCatalogSyncsPrebuiltPolicy` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCatalogSyncsPrebuiltPolicy {
    /// applicable_destinations property.
    pub applicable_destinations: Vec<McnCatalogSyncDestinationType>,
    /// policy_description property.
    pub policy_description: String,
    /// policy_name property.
    pub policy_name: String,
    /// policy_string property.
    pub policy_string: String,
}

/// `McnCloudPlatformClient` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCloudPlatformClient {
    /// client_type property.
    pub client_type: String,
    /// id property.
    pub id: McnPlatformClientId,
    /// name property.
    pub name: String,
}

/// `McnCloudType` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCloudType {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnCost` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCost {
    /// currency property.
    pub currency: String,
    /// monthly_cost property.
    pub monthly_cost: f64,
}

/// `McnCreateCatalogSyncRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCreateCatalogSyncRequest {
    /// description property.
    pub description: Option<String>,
    /// destination_type property.
    pub destination_type: McnCatalogSyncDestinationType,
    /// name property.
    pub name: String,
    /// policy property.
    pub policy: Option<String>,
    /// update_mode property.
    pub update_mode: McnCatalogSyncUpdateMode,
}

/// `McnCreateCatalogSyncResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCreateCatalogSyncResponse {
    /// `result` property.
    pub result: Option<McnCatalogSync>,
}

/// `McnDeleteCatalogSyncResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnDeleteCatalogSyncResponse {
    /// `result` property.
    pub result: Option<McnDeletedCatalogSync>,
}

/// `McnDeletedCatalogSync` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnDeletedCatalogSync {
    /// id property.
    pub id: McnCatalogSyncId,
}

/// `McnError` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnError {
    /// code property.
    pub code: i64,
    /// documentation_url property.
    pub documentation_url: Option<String>,
    /// message property.
    pub message: String,
    /// meta property.
    pub meta: Option<McnErrorMeta>,
    /// source property.
    pub source: Option<McnErrorSource>,
}

/// `McnErrorMeta` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnErrorMeta {
    /// l10n_key property.
    pub l10n_key: Option<String>,
    /// loggable_error property.
    pub loggable_error: Option<String>,
    /// template_data property.
    pub template_data: Option<serde_json::Value>,
    /// trace_id property.
    pub trace_id: Option<String>,
}

/// `McnErrorSource` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnErrorSource {
    /// parameter property.
    pub parameter: Option<String>,
    /// parameter_value_index property.
    pub parameter_value_index: Option<i64>,
    /// pointer property.
    pub pointer: Option<String>,
}

/// `McnGoodResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnGoodResponse {
    /// `errors` property.
    pub errors: Option<Vec<McnError>>,
}

/// `McnGoodResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnGoodResponseCollection {
    /// `errors` property.
    pub errors: Option<Vec<McnError>>,
}

/// `McnListItem` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnListItem {
    /// item_type property.
    pub item_type: String,
    /// list property.
    pub list: Vec<serde_json::Value>,
}

/// `McnPlatformClientId` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnPlatformClientId {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnPolicyResult` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnPolicyResult {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnProviderId` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnProviderId {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnReadAccountCatalogSyncResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnReadAccountCatalogSyncResponse {
    /// `result` property.
    pub result: Option<McnCatalogSync>,
}

/// `McnReadAccountCatalogSyncsResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnReadAccountCatalogSyncsResponse {
    /// `result` property.
    pub result: Option<Vec<McnCatalogSync>>,
}

/// `McnReadAccountResourceResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnReadAccountResourceResponse {
    /// `result` property.
    pub result: Option<McnResourceDetails>,
}

/// `McnReadAccountResourcesResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnReadAccountResourcesResponse {
    /// `result` property.
    pub result: Option<Vec<McnResourceDetails>>,
    /// `result_info` property.
    pub result_info: Option<McnResultInfo>,
}

/// `McnRefreshCatalogSyncResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnRefreshCatalogSyncResponse {
    /// `result` property.
    pub result: Option<McnPolicyResult>,
}

/// `McnResourceDetails` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourceDetails {
    /// account_id property.
    pub account_id: McnAccountId,
    /// cloud_type property.
    pub cloud_type: McnCloudType,
    /// config property.
    pub config: serde_json::Value,
    /// deployment_provider property.
    pub deployment_provider: McnProviderId,
    /// id property.
    pub id: McnResourceId,
    /// managed property.
    pub managed: bool,
    /// managed_by property.
    pub managed_by: Option<Vec<McnCloudPlatformClient>>,
    /// monthly_cost_estimate property.
    pub monthly_cost_estimate: McnCost,
    /// name property.
    pub name: String,
    /// native_id property.
    pub native_id: String,
    /// observations property.
    pub observations: serde_json::Value,
    /// provider_ids property.
    pub provider_ids: Vec<McnProviderId>,
    /// provider_names_by_id property.
    pub provider_names_by_id: serde_json::Value,
    /// region property.
    pub region: String,
    /// resource_group property.
    pub resource_group: String,
    /// resource_type property.
    pub resource_type: McnResourceType,
    /// sections property.
    pub sections: Vec<McnResourceDetailsSection>,
    /// state property.
    pub state: serde_json::Value,
    /// tags property.
    pub tags: serde_json::Value,
    /// updated_at property.
    pub updated_at: String,
    /// url property.
    pub url: String,
}

/// `McnResourceDetailsSection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourceDetailsSection {
    /// help_text property.
    pub help_text: Option<String>,
    /// hidden_items property.
    pub hidden_items: Vec<McnResourceDetailsSectionItem>,
    /// name property.
    pub name: String,
    /// visible_items property.
    pub visible_items: Vec<McnResourceDetailsSectionItem>,
}

/// `McnResourceDetailsSectionItem` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourceDetailsSectionItem {
    /// helpText property.
    #[serde(rename = "helpText")]
    pub help_text: Option<String>,
    /// name property.
    pub name: Option<String>,
    /// value property.
    pub value: Option<serde_json::Value>,
}

/// `McnResourceId` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourceId {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnResourcePreview` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourcePreview {
    /// cloud_type property.
    pub cloud_type: McnCloudType,
    /// detail property.
    pub detail: String,
    /// id property.
    pub id: McnResourceId,
    /// name property.
    pub name: String,
    /// resource_type property.
    pub resource_type: McnResourceType,
    /// title property.
    pub title: String,
}

/// `McnResourcePreviewItem` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourcePreviewItem {
    /// item_type property.
    pub item_type: String,
    /// resource_preview property.
    pub resource_preview: McnResourcePreview,
}

/// `McnResourceType` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourceType {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnResourcesCatalogPolicyPreview` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourcesCatalogPolicyPreview {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `McnResourcesCatalogPolicyPreviewRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourcesCatalogPolicyPreviewRequest {
    /// policy property.
    pub policy: String,
}

/// `McnResourcesCatalogPolicyPreviewResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourcesCatalogPolicyPreviewResponse {
    /// `result` property.
    pub result: Option<McnResourcesCatalogPolicyPreview>,
}

/// `McnResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResponse {
    /// messages property.
    pub messages: Vec<McnError>,
    /// success property.
    pub success: bool,
}

/// `McnResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResponseCollection {
    /// messages property.
    pub messages: Vec<McnError>,
    /// result_info property.
    pub result_info: Option<McnResultInfo>,
    /// success property.
    pub success: bool,
}

/// `McnResultInfo` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResultInfo {
    /// count property.
    pub count: i64,
    /// page property.
    pub page: i64,
    /// per_page property.
    pub per_page: i64,
    /// total_count property.
    pub total_count: i64,
    /// total_pages property.
    pub total_pages: Option<i64>,
}

/// `McnStringItem` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnStringItem {
    /// item_type property.
    pub item_type: String,
    /// string property.
    pub string: String,
}

/// `McnUpdateCatalogSyncRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnUpdateCatalogSyncRequest {
    /// description property.
    pub description: Option<String>,
    /// name property.
    pub name: Option<String>,
    /// policy property.
    pub policy: Option<String>,
    /// update_mode property.
    pub update_mode: Option<McnCatalogSyncUpdateMode>,
}

/// `McnUpdateCatalogSyncResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnUpdateCatalogSyncResponse {
    /// `result` property.
    pub result: Option<McnCatalogSync>,
}

/// `McnYamlDiff` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnYamlDiff {
    /// diff property.
    pub diff: String,
    /// left_description property.
    pub left_description: String,
    /// left_yaml property.
    pub left_yaml: String,
    /// right_description property.
    pub right_description: String,
    /// right_yaml property.
    pub right_yaml: String,
}

/// `McnYamlDiffItem` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnYamlDiffItem {
    /// item_type property.
    pub item_type: String,
    /// yaml_diff property.
    pub yaml_diff: McnYamlDiff,
}

/// `McnYamlItem` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnYamlItem {
    /// item_type property.
    pub item_type: String,
    /// yaml property.
    pub yaml: String,
}

/// `PostAccountsAccountIdLogpushJobsRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushJobsRequest {
    /// dataset property.
    pub dataset: Option<LogpushDataset>,
    /// destination_conf property.
    pub destination_conf: LogpushDestinationConf,
    /// enabled property.
    pub enabled: Option<LogpushEnabled>,
    /// filter property.
    pub filter: Option<LogpushFilter>,
    /// frequency property.
    pub frequency: Option<LogpushFrequency>,
    /// kind property.
    pub kind: Option<LogpushKind>,
    /// logpull_options property.
    pub logpull_options: Option<LogpushLogpullOptions>,
    /// max_upload_bytes property.
    pub max_upload_bytes: Option<LogpushMaxUploadBytes>,
    /// max_upload_interval_seconds property.
    pub max_upload_interval_seconds: Option<LogpushMaxUploadIntervalSeconds>,
    /// max_upload_records property.
    pub max_upload_records: Option<LogpushMaxUploadRecords>,
    /// name property.
    pub name: Option<LogpushName>,
    /// output_options property.
    pub output_options: Option<LogpushOutputOptions>,
    /// ownership_challenge property.
    pub ownership_challenge: Option<LogpushOwnershipChallenge>,
}

/// `PostAccountsAccountIdLogpushOwnershipRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushOwnershipRequest {
    /// destination_conf property.
    pub destination_conf: LogpushDestinationConf,
}

/// `PostAccountsAccountIdLogpushOwnershipValidateRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushOwnershipValidateRequest {
    /// destination_conf property.
    pub destination_conf: LogpushDestinationConf,
    /// ownership_challenge property.
    pub ownership_challenge: LogpushOwnershipChallenge,
}

/// `PostAccountsAccountIdLogpushValidateOriginRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushValidateOriginRequest {
    /// logpull_options property.
    pub logpull_options: Option<LogpushLogpullOptions>,
}

/// `PutAccountsAccountIdLogpushJobsJobIdRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PutAccountsAccountIdLogpushJobsJobIdRequest {
    /// destination_conf property.
    pub destination_conf: Option<LogpushDestinationConf>,
    /// enabled property.
    pub enabled: Option<LogpushEnabled>,
    /// filter property.
    pub filter: Option<LogpushFilter>,
    /// frequency property.
    pub frequency: Option<LogpushFrequency>,
    /// kind property.
    pub kind: Option<LogpushKind>,
    /// logpull_options property.
    pub logpull_options: Option<LogpushLogpullOptions>,
    /// max_upload_bytes property.
    pub max_upload_bytes: Option<LogpushMaxUploadBytes>,
    /// max_upload_interval_seconds property.
    pub max_upload_interval_seconds: Option<LogpushMaxUploadIntervalSeconds>,
    /// max_upload_records property.
    pub max_upload_records: Option<LogpushMaxUploadRecords>,
    /// name property.
    pub name: Option<LogpushName>,
    /// output_options property.
    pub output_options: Option<LogpushOutputOptions>,
    /// ownership_challenge property.
    pub ownership_challenge: Option<LogpushOwnershipChallenge>,
}

/// `R2SlurperApiV4Error` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct R2SlurperApiV4Error {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `R2SlurperApiV4Message` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct R2SlurperApiV4Message {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `R2SlurperApiV4Success` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct R2SlurperApiV4Success {
    /// errors property.
    pub errors: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
    /// messages property.
    pub messages: Option<Vec<String>>,
    /// success property.
    pub success: Option<bool>,
}

/// `R2SlurperJobLogResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct R2SlurperJobLogResponse {
    /// createdAt property.
    #[serde(rename = "createdAt")]
    pub created_at: Option<String>,
    /// job property.
    pub job: Option<String>,
    /// logType property.
    #[serde(rename = "logType")]
    pub log_type: Option<String>,
    /// message property.
    pub message: Option<String>,
    /// objectKey property.
    #[serde(rename = "objectKey")]
    pub object_key: Option<String>,
}

/// `SlurperGetJobLogsResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct SlurperGetJobLogsResponse {
    /// `result` property.
    pub result: Option<Vec<R2SlurperJobLogResponse>>,
}

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

/// Arguments for [`audit-logs-get-account-audit-logs_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AuditLogsGetAccountAuditLogsArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `id`.
    pub id: Option<String>,
    /// Query parameter: `export`.
    pub export: Option<String>,
    /// Query parameter: `action.type`.
    pub action_type: Option<String>,
    /// Query parameter: `actor.ip`.
    pub actor_ip: Option<String>,
    /// Query parameter: `actor.email`.
    pub actor_email: Option<String>,
    /// Query parameter: `since`.
    pub since: Option<String>,
    /// Query parameter: `before`.
    pub before: Option<String>,
    /// Query parameter: `zone.name`.
    pub zone_name: Option<String>,
    /// Query parameter: `direction`.
    pub direction: Option<String>,
    /// Query parameter: `per_page`.
    pub per_page: Option<String>,
    /// Query parameter: `page`.
    pub page: Option<String>,
    /// Query parameter: `hide_user_logs`.
    pub hide_user_logs: Option<String>,
}

/// Arguments for [`dlp-payload-log-get_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpPayloadLogGetArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`dlp-payload-log-put_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpPayloadLogPutArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: DlpPayloadLogSettingUpdateLegacy,
}

/// Arguments for [`get-accounts-account_id-logpush-datasets-dataset_id-fields_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetAccountsAccountIdLogpushDatasetsDatasetIdFieldsArgs {
    /// Path parameter: `dataset_id`.
    pub dataset_id: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`get-accounts-account_id-logpush-datasets-dataset_id-jobs_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetAccountsAccountIdLogpushDatasetsDatasetIdJobsArgs {
    /// Path parameter: `dataset_id`.
    pub dataset_id: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`get-accounts-account_id-logpush-jobs_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetAccountsAccountIdLogpushJobsArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`post-accounts-account_id-logpush-jobs_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushJobsArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: PostAccountsAccountIdLogpushJobsRequest,
}

/// Arguments for [`get-accounts-account_id-logpush-jobs-job_id_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetAccountsAccountIdLogpushJobsJobIdArgs {
    /// Path parameter: `job_id`.
    pub job_id: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`put-accounts-account_id-logpush-jobs-job_id_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PutAccountsAccountIdLogpushJobsJobIdArgs {
    /// Path parameter: `job_id`.
    pub job_id: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: PutAccountsAccountIdLogpushJobsJobIdRequest,
}

/// Arguments for [`delete-accounts-account_id-logpush-jobs-job_id_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteAccountsAccountIdLogpushJobsJobIdArgs {
    /// Path parameter: `job_id`.
    pub job_id: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`post-accounts-account_id-logpush-ownership_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushOwnershipArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: PostAccountsAccountIdLogpushOwnershipRequest,
}

/// Arguments for [`post-accounts-account_id-logpush-ownership-validate_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushOwnershipValidateArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: PostAccountsAccountIdLogpushOwnershipValidateRequest,
}

/// Arguments for [`delete-accounts-account_id-logpush-validate-destination_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteAccountsAccountIdLogpushValidateDestinationArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: DeleteAccountsAccountIdLogpushValidateDestinationRequest,
}

/// Arguments for [`delete-accounts-account_id-logpush-validate-destination-exists_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteAccountsAccountIdLogpushValidateDestinationExistsArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: DeleteAccountsAccountIdLogpushValidateDestinationExistsRequest,
}

/// Arguments for [`post-accounts-account_id-logpush-validate-origin_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushValidateOriginArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: PostAccountsAccountIdLogpushValidateOriginRequest,
}

/// Arguments for [`audit-logs-v2-get-account-audit-logs_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AuditLogsV2GetAccountAuditLogsArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `account_name`.
    pub account_name: Option<String>,
    /// Query parameter: `action_result`.
    pub action_result: Option<String>,
    /// Query parameter: `action_type`.
    pub action_type: Option<String>,
    /// Query parameter: `actor_context`.
    pub actor_context: Option<String>,
    /// Query parameter: `actor_email`.
    pub actor_email: Option<String>,
    /// Query parameter: `actor_id`.
    pub actor_id: Option<String>,
    /// Query parameter: `actor_ip_address`.
    pub actor_ip_address: Option<String>,
    /// Query parameter: `actor_token_id`.
    pub actor_token_id: Option<String>,
    /// Query parameter: `actor_token_name`.
    pub actor_token_name: Option<String>,
    /// Query parameter: `actor_type`.
    pub actor_type: Option<String>,
    /// Query parameter: `audit_log_id`.
    pub audit_log_id: Option<String>,
    /// Query parameter: `id`.
    pub id: Option<String>,
    /// Query parameter: `raw_cf_ray_id`.
    pub raw_cf_ray_id: Option<String>,
    /// Query parameter: `raw_method`.
    pub raw_method: Option<String>,
    /// Query parameter: `raw_status_code`.
    pub raw_status_code: Option<String>,
    /// Query parameter: `raw_uri`.
    pub raw_uri: Option<String>,
    /// Query parameter: `resource_id`.
    pub resource_id: Option<String>,
    /// Query parameter: `resource_product`.
    pub resource_product: Option<String>,
    /// Query parameter: `resource_type`.
    pub resource_type: Option<String>,
    /// Query parameter: `resource_scope`.
    pub resource_scope: Option<String>,
    /// Query parameter: `zone_id`.
    pub zone_id: Option<String>,
    /// Query parameter: `zone_name`.
    pub zone_name: Option<String>,
    /// Query parameter: `account_name.not`.
    pub account_name_not: Option<String>,
    /// Query parameter: `action_result.not`.
    pub action_result_not: Option<String>,
    /// Query parameter: `action_type.not`.
    pub action_type_not: Option<String>,
    /// Query parameter: `actor_context.not`.
    pub actor_context_not: Option<String>,
    /// Query parameter: `actor_email.not`.
    pub actor_email_not: Option<String>,
    /// Query parameter: `actor_id.not`.
    pub actor_id_not: Option<String>,
    /// Query parameter: `actor_ip_address.not`.
    pub actor_ip_address_not: Option<String>,
    /// Query parameter: `actor_token_id.not`.
    pub actor_token_id_not: Option<String>,
    /// Query parameter: `actor_token_name.not`.
    pub actor_token_name_not: Option<String>,
    /// Query parameter: `actor_type.not`.
    pub actor_type_not: Option<String>,
    /// Query parameter: `audit_log_id.not`.
    pub audit_log_id_not: Option<String>,
    /// Query parameter: `id.not`.
    pub id_not: Option<String>,
    /// Query parameter: `raw_cf_ray_id.not`.
    pub raw_cf_ray_id_not: Option<String>,
    /// Query parameter: `raw_method.not`.
    pub raw_method_not: Option<String>,
    /// Query parameter: `raw_status_code.not`.
    pub raw_status_code_not: Option<String>,
    /// Query parameter: `raw_uri.not`.
    pub raw_uri_not: Option<String>,
    /// Query parameter: `resource_id.not`.
    pub resource_id_not: Option<String>,
    /// Query parameter: `resource_product.not`.
    pub resource_product_not: Option<String>,
    /// Query parameter: `resource_type.not`.
    pub resource_type_not: Option<String>,
    /// Query parameter: `resource_scope.not`.
    pub resource_scope_not: Option<String>,
    /// Query parameter: `zone_id.not`.
    pub zone_id_not: Option<String>,
    /// Query parameter: `zone_name.not`.
    pub zone_name_not: Option<String>,
    /// Query parameter: `since`.
    pub since: Option<String>,
    /// Query parameter: `before`.
    pub before: Option<String>,
    /// Query parameter: `direction`.
    pub direction: Option<String>,
    /// Query parameter: `limit`.
    pub limit: Option<String>,
    /// Query parameter: `cursor`.
    pub cursor: Option<String>,
}

/// Arguments for [`get-accounts-account_id-logs-control-cmb-config_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetAccountsAccountIdLogsControlCmbConfigArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`post-accounts-account_id-logs-control-cmb-config_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostAccountsAccountIdLogsControlCmbConfigArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: LogcontrolCmbConfig,
}

/// Arguments for [`delete-accounts-account_id-logs-control-cmb-config_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteAccountsAccountIdLogsControlCmbConfigArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`catalog-syncs-list_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsListArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`catalog-syncs-create_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsCreateArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: McnCreateCatalogSyncRequest,
}

/// Arguments for [`catalog-syncs-prebuilt-policies-list_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsPrebuiltPoliciesListArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `destination_type`.
    pub destination_type: Option<String>,
}

/// Arguments for [`catalog-syncs-read_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsReadArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `sync_id`.
    pub sync_id: String,
}

/// Arguments for [`catalog-syncs-update_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsUpdateArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `sync_id`.
    pub sync_id: String,
    /// Request body.
    pub body: McnUpdateCatalogSyncRequest,
}

/// Arguments for [`catalog-syncs-patch_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsPatchArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `sync_id`.
    pub sync_id: String,
    /// Request body.
    pub body: McnUpdateCatalogSyncRequest,
}

/// Arguments for [`catalog-syncs-delete_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsDeleteArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `sync_id`.
    pub sync_id: String,
    /// Query parameter: `delete_destination`.
    pub delete_destination: Option<String>,
}

/// Arguments for [`catalog-syncs-refresh_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsRefreshArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `sync_id`.
    pub sync_id: String,
}

/// Arguments for [`resources-catalog-list_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ResourcesCatalogListArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `provider_id`.
    pub provider_id: Option<String>,
    /// Query parameter: `resource_type`.
    pub resource_type: Option<String>,
    /// Query parameter: `resource_id`.
    pub resource_id: Option<String>,
    /// Query parameter: `region`.
    pub region: Option<String>,
    /// Query parameter: `resource_group`.
    pub resource_group: Option<String>,
    /// Query parameter: `managed`.
    pub managed: Option<String>,
    /// Query parameter: `search`.
    pub search: Option<String>,
    /// Query parameter: `order_by`.
    pub order_by: Option<String>,
    /// Query parameter: `desc`.
    pub desc: Option<String>,
    /// Query parameter: `per_page`.
    pub per_page: Option<String>,
    /// Query parameter: `page`.
    pub page: Option<String>,
    /// Query parameter: `cloudflare`.
    pub cloudflare: Option<String>,
    /// Query parameter: `v2`.
    pub v2: Option<String>,
}

/// Arguments for [`resources-catalog-export_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ResourcesCatalogExportArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `provider_id`.
    pub provider_id: Option<String>,
    /// Query parameter: `resource_type`.
    pub resource_type: Option<String>,
    /// Query parameter: `resource_id`.
    pub resource_id: Option<String>,
    /// Query parameter: `region`.
    pub region: Option<String>,
    /// Query parameter: `resource_group`.
    pub resource_group: Option<String>,
    /// Query parameter: `search`.
    pub search: Option<String>,
    /// Query parameter: `order_by`.
    pub order_by: Option<String>,
    /// Query parameter: `desc`.
    pub desc: Option<String>,
    /// Query parameter: `v2`.
    pub v2: Option<String>,
}

/// Arguments for [`resources-catalog-policy-preview_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ResourcesCatalogPolicyPreviewArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: McnResourcesCatalogPolicyPreviewRequest,
}

/// Arguments for [`resources-catalog-read_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ResourcesCatalogReadArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `resource_id`.
    pub resource_id: String,
    /// Query parameter: `v2`.
    pub v2: Option<String>,
}

/// Arguments for [`slurper-get-job-logs_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SlurperGetJobLogsArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `job_id`.
    pub job_id: String,
    /// Query parameter: `limit`.
    pub limit: Option<String>,
    /// Query parameter: `offset`.
    pub offset: Option<String>,
}

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

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/audit_logs
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/audit_logs.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = audit_logs_get_account_audit_logs_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn audit_logs_get_account_audit_logs_request<F>(
    client: DynNetClient,
    args: &AuditLogsGetAccountAuditLogsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<AaaAuditLogsResponseCollection>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/audit_logs",
        args.account_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()))?;

    builder = builder.query("id", args.id.as_deref());
    builder = builder.query("export", args.export.as_deref());
    builder = builder.query("action.type", args.action_type.as_deref());
    builder = builder.query("actor.ip", args.actor_ip.as_deref());
    builder = builder.query("actor.email", args.actor_email.as_deref());
    builder = builder.query("since", args.since.as_deref());
    builder = builder.query("before", args.before.as_deref());
    builder = builder.query("zone.name", args.zone_name.as_deref());
    builder = builder.query("direction", args.direction.as_deref());
    builder = builder.query("per_page", args.per_page.as_deref());
    builder = builder.query("page", args.page.as_deref());
    builder = builder.query("hide_user_logs", args.hide_user_logs.as_deref());

    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: AaaAuditLogsResponseCollection = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/dlp/payload_log
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/dlp/payload_log.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = dlp_payload_log_get_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn dlp_payload_log_get_request<F>(
    client: DynNetClient,
    args: &DlpPayloadLogGetArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<DlpPayloadLogGetResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/dlp/payload_log",
        args.account_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: DlpPayloadLogGetResponse = 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 })
}

// -----------------------------------------------------------------------------
// PUT /accounts/{account_id}/dlp/payload_log
// -----------------------------------------------------------------------------

/// PUT /accounts/{account_id}/dlp/payload_log.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = dlp_payload_log_put_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn dlp_payload_log_put_request<F>(
    client: DynNetClient,
    args: &DlpPayloadLogPutArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<DlpPayloadLogPutResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/dlp/payload_log",
        args.account_id,
    );
    let endpoint_url = format!("{}{}", base_url, path);

    let mut builder = PreparedRequestBuilder::put(&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 {
        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: DlpPayloadLogPutResponse = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/logpush/datasets/{dataset_id}/fields
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/logpush/datasets/{dataset_id}/fields.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = get_accounts_account_id_logpush_datasets_dataset_id_fields_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn get_accounts_account_id_logpush_datasets_dataset_id_fields_request<F>(
    client: DynNetClient,
    args: &GetAccountsAccountIdLogpushDatasetsDatasetIdFieldsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushFieldResponseCollection>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/datasets/{}/fields",
        args.account_id,
        args.dataset_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: LogpushLogpushFieldResponseCollection = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/logpush/datasets/{dataset_id}/jobs
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/logpush/datasets/{dataset_id}/jobs.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = get_accounts_account_id_logpush_datasets_dataset_id_jobs_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn get_accounts_account_id_logpush_datasets_dataset_id_jobs_request<F>(
    client: DynNetClient,
    args: &GetAccountsAccountIdLogpushDatasetsDatasetIdJobsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushJobResponseCollection>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/datasets/{}/jobs",
        args.account_id,
        args.dataset_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: LogpushLogpushJobResponseCollection = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/logpush/jobs
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/logpush/jobs.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = get_accounts_account_id_logpush_jobs_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn get_accounts_account_id_logpush_jobs_request<F>(
    client: DynNetClient,
    args: &GetAccountsAccountIdLogpushJobsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushJobResponseCollection>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/jobs",
        args.account_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: LogpushLogpushJobResponseCollection = 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 })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/logpush/jobs
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/logpush/jobs.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = post_accounts_account_id_logpush_jobs_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn post_accounts_account_id_logpush_jobs_request<F>(
    client: DynNetClient,
    args: &PostAccountsAccountIdLogpushJobsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushJobResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/jobs",
        args.account_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 {
        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: LogpushLogpushJobResponseSingle = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/logpush/jobs/{job_id}
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/logpush/jobs/{job_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = get_accounts_account_id_logpush_jobs_job_id_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn get_accounts_account_id_logpush_jobs_job_id_request<F>(
    client: DynNetClient,
    args: &GetAccountsAccountIdLogpushJobsJobIdArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushJobResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/jobs/{}",
        args.account_id,
        args.job_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: LogpushLogpushJobResponseSingle = 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 })
}

// -----------------------------------------------------------------------------
// PUT /accounts/{account_id}/logpush/jobs/{job_id}
// -----------------------------------------------------------------------------

/// PUT /accounts/{account_id}/logpush/jobs/{job_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = put_accounts_account_id_logpush_jobs_job_id_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn put_accounts_account_id_logpush_jobs_job_id_request<F>(
    client: DynNetClient,
    args: &PutAccountsAccountIdLogpushJobsJobIdArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushJobResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/jobs/{}",
        args.account_id,
        args.job_id,
    );
    let endpoint_url = format!("{}{}", base_url, path);

    let mut builder = PreparedRequestBuilder::put(&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 {
        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: LogpushLogpushJobResponseSingle = 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 })
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/logpush/jobs/{job_id}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/logpush/jobs/{job_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = delete_accounts_account_id_logpush_jobs_job_id_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn delete_accounts_account_id_logpush_jobs_job_id_request<F>(
    client: DynNetClient,
    args: &DeleteAccountsAccountIdLogpushJobsJobIdArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<DeleteAccountsAccountIdLogpushJobsJobIdResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/jobs/{}",
        args.account_id,
        args.job_id,
    );
    let endpoint_url = format!("{}{}", base_url, path);

    let mut builder = PreparedRequestBuilder::delete(&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: DeleteAccountsAccountIdLogpushJobsJobIdResponse = 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 })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/logpush/ownership
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/logpush/ownership.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = post_accounts_account_id_logpush_ownership_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn post_accounts_account_id_logpush_ownership_request<F>(
    client: DynNetClient,
    args: &PostAccountsAccountIdLogpushOwnershipArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushGetOwnershipResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/ownership",
        args.account_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 {
        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: LogpushGetOwnershipResponse = 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 })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/logpush/ownership/validate
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/logpush/ownership/validate.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = post_accounts_account_id_logpush_ownership_validate_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn post_accounts_account_id_logpush_ownership_validate_request<F>(
    client: DynNetClient,
    args: &PostAccountsAccountIdLogpushOwnershipValidateArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushValidateOwnershipResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/ownership/validate",
        args.account_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 {
        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: LogpushValidateOwnershipResponse = 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 })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/logpush/validate/destination
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/logpush/validate/destination.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = delete_accounts_account_id_logpush_validate_destination_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn delete_accounts_account_id_logpush_validate_destination_request<F>(
    client: DynNetClient,
    args: &DeleteAccountsAccountIdLogpushValidateDestinationArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushValidateResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/validate/destination",
        args.account_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 {
        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: LogpushValidateResponse = 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 })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/logpush/validate/destination/exists
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/logpush/validate/destination/exists.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = delete_accounts_account_id_logpush_validate_destination_exists_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn delete_accounts_account_id_logpush_validate_destination_exists_request<F>(
    client: DynNetClient,
    args: &DeleteAccountsAccountIdLogpushValidateDestinationExistsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushDestinationExistsResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/validate/destination/exists",
        args.account_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 {
        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: LogpushDestinationExistsResponse = 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 })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/logpush/validate/origin
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/logpush/validate/origin.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = post_accounts_account_id_logpush_validate_origin_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn post_accounts_account_id_logpush_validate_origin_request<F>(
    client: DynNetClient,
    args: &PostAccountsAccountIdLogpushValidateOriginArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushValidateResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logpush/validate/origin",
        args.account_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 {
        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: LogpushValidateResponse = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/logs/audit
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/logs/audit.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = audit_logs_v2_get_account_audit_logs_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn audit_logs_v2_get_account_audit_logs_request<F>(
    client: DynNetClient,
    args: &AuditLogsV2GetAccountAuditLogsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<AaaAuditLogsV2ResponseCollection>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logs/audit",
        args.account_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()))?;

    builder = builder.query("account_name", args.account_name.as_deref());
    builder = builder.query("action_result", args.action_result.as_deref());
    builder = builder.query("action_type", args.action_type.as_deref());
    builder = builder.query("actor_context", args.actor_context.as_deref());
    builder = builder.query("actor_email", args.actor_email.as_deref());
    builder = builder.query("actor_id", args.actor_id.as_deref());
    builder = builder.query("actor_ip_address", args.actor_ip_address.as_deref());
    builder = builder.query("actor_token_id", args.actor_token_id.as_deref());
    builder = builder.query("actor_token_name", args.actor_token_name.as_deref());
    builder = builder.query("actor_type", args.actor_type.as_deref());
    builder = builder.query("audit_log_id", args.audit_log_id.as_deref());
    builder = builder.query("id", args.id.as_deref());
    builder = builder.query("raw_cf_ray_id", args.raw_cf_ray_id.as_deref());
    builder = builder.query("raw_method", args.raw_method.as_deref());
    builder = builder.query("raw_status_code", args.raw_status_code.as_deref());
    builder = builder.query("raw_uri", args.raw_uri.as_deref());
    builder = builder.query("resource_id", args.resource_id.as_deref());
    builder = builder.query("resource_product", args.resource_product.as_deref());
    builder = builder.query("resource_type", args.resource_type.as_deref());
    builder = builder.query("resource_scope", args.resource_scope.as_deref());
    builder = builder.query("zone_id", args.zone_id.as_deref());
    builder = builder.query("zone_name", args.zone_name.as_deref());
    builder = builder.query("account_name.not", args.account_name_not.as_deref());
    builder = builder.query("action_result.not", args.action_result_not.as_deref());
    builder = builder.query("action_type.not", args.action_type_not.as_deref());
    builder = builder.query("actor_context.not", args.actor_context_not.as_deref());
    builder = builder.query("actor_email.not", args.actor_email_not.as_deref());
    builder = builder.query("actor_id.not", args.actor_id_not.as_deref());
    builder = builder.query("actor_ip_address.not", args.actor_ip_address_not.as_deref());
    builder = builder.query("actor_token_id.not", args.actor_token_id_not.as_deref());
    builder = builder.query("actor_token_name.not", args.actor_token_name_not.as_deref());
    builder = builder.query("actor_type.not", args.actor_type_not.as_deref());
    builder = builder.query("audit_log_id.not", args.audit_log_id_not.as_deref());
    builder = builder.query("id.not", args.id_not.as_deref());
    builder = builder.query("raw_cf_ray_id.not", args.raw_cf_ray_id_not.as_deref());
    builder = builder.query("raw_method.not", args.raw_method_not.as_deref());
    builder = builder.query("raw_status_code.not", args.raw_status_code_not.as_deref());
    builder = builder.query("raw_uri.not", args.raw_uri_not.as_deref());
    builder = builder.query("resource_id.not", args.resource_id_not.as_deref());
    builder = builder.query("resource_product.not", args.resource_product_not.as_deref());
    builder = builder.query("resource_type.not", args.resource_type_not.as_deref());
    builder = builder.query("resource_scope.not", args.resource_scope_not.as_deref());
    builder = builder.query("zone_id.not", args.zone_id_not.as_deref());
    builder = builder.query("zone_name.not", args.zone_name_not.as_deref());
    builder = builder.query("since", args.since.as_deref());
    builder = builder.query("before", args.before.as_deref());
    builder = builder.query("direction", args.direction.as_deref());
    builder = builder.query("limit", args.limit.as_deref());
    builder = builder.query("cursor", args.cursor.as_deref());

    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: AaaAuditLogsV2ResponseCollection = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/logs/control/cmb/config
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/logs/control/cmb/config.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = get_accounts_account_id_logs_control_cmb_config_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn get_accounts_account_id_logs_control_cmb_config_request<F>(
    client: DynNetClient,
    args: &GetAccountsAccountIdLogsControlCmbConfigArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogcontrolCmbConfigResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logs/control/cmb/config",
        args.account_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: LogcontrolCmbConfigResponseSingle = 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 })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/logs/control/cmb/config
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/logs/control/cmb/config.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = post_accounts_account_id_logs_control_cmb_config_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn post_accounts_account_id_logs_control_cmb_config_request<F>(
    client: DynNetClient,
    args: &PostAccountsAccountIdLogsControlCmbConfigArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<LogcontrolCmbConfigResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logs/control/cmb/config",
        args.account_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 {
        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: LogcontrolCmbConfigResponseSingle = 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 })
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/logs/control/cmb/config
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/logs/control/cmb/config.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = delete_accounts_account_id_logs_control_cmb_config_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn delete_accounts_account_id_logs_control_cmb_config_request<F>(
    client: DynNetClient,
    args: &DeleteAccountsAccountIdLogsControlCmbConfigArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<DeleteAccountsAccountIdLogsControlCmbConfigResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/logs/control/cmb/config",
        args.account_id,
    );
    let endpoint_url = format!("{}{}", base_url, path);

    let mut builder = PreparedRequestBuilder::delete(&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: DeleteAccountsAccountIdLogsControlCmbConfigResponse = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/magic/cloud/catalog-syncs
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/magic/cloud/catalog-syncs.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = catalog_syncs_list_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn catalog_syncs_list_request<F>(
    client: DynNetClient,
    args: &CatalogSyncsListArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<McnReadAccountCatalogSyncsResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/catalog-syncs",
        args.account_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: McnReadAccountCatalogSyncsResponse = 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 })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/magic/cloud/catalog-syncs
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/magic/cloud/catalog-syncs.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = catalog_syncs_create_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn catalog_syncs_create_request<F>(
    client: DynNetClient,
    args: &CatalogSyncsCreateArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<McnCreateCatalogSyncResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/catalog-syncs",
        args.account_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 {
        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: McnCreateCatalogSyncResponse = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/magic/cloud/catalog-syncs/prebuilt-policies
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/magic/cloud/catalog-syncs/prebuilt-policies.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = catalog_syncs_prebuilt_policies_list_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn catalog_syncs_prebuilt_policies_list_request<F>(
    client: DynNetClient,
    args: &CatalogSyncsPrebuiltPoliciesListArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<McnCatalogSyncsPrebuiltPoliciesResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/catalog-syncs/prebuilt-policies",
        args.account_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()))?;

    builder = builder.query("destination_type", args.destination_type.as_deref());

    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: McnCatalogSyncsPrebuiltPoliciesResponse = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/magic/cloud/catalog-syncs/{sync_id}
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/magic/cloud/catalog-syncs/{sync_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = catalog_syncs_read_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn catalog_syncs_read_request<F>(
    client: DynNetClient,
    args: &CatalogSyncsReadArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<McnReadAccountCatalogSyncResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/catalog-syncs/{}",
        args.account_id,
        args.sync_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: McnReadAccountCatalogSyncResponse = 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 })
}

// -----------------------------------------------------------------------------
// PUT /accounts/{account_id}/magic/cloud/catalog-syncs/{sync_id}
// -----------------------------------------------------------------------------

/// PUT /accounts/{account_id}/magic/cloud/catalog-syncs/{sync_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = catalog_syncs_update_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn catalog_syncs_update_request<F>(
    client: DynNetClient,
    args: &CatalogSyncsUpdateArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<McnUpdateCatalogSyncResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/catalog-syncs/{}",
        args.account_id,
        args.sync_id,
    );
    let endpoint_url = format!("{}{}", base_url, path);

    let mut builder = PreparedRequestBuilder::put(&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 {
        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: McnUpdateCatalogSyncResponse = 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 })
}

// -----------------------------------------------------------------------------
// PATCH /accounts/{account_id}/magic/cloud/catalog-syncs/{sync_id}
// -----------------------------------------------------------------------------

/// PATCH /accounts/{account_id}/magic/cloud/catalog-syncs/{sync_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = catalog_syncs_patch_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn catalog_syncs_patch_request<F>(
    client: DynNetClient,
    args: &CatalogSyncsPatchArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<McnUpdateCatalogSyncResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/catalog-syncs/{}",
        args.account_id,
        args.sync_id,
    );
    let endpoint_url = format!("{}{}", base_url, path);

    let mut builder = PreparedRequestBuilder::patch(&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 {
        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: McnUpdateCatalogSyncResponse = 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 })
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/magic/cloud/catalog-syncs/{sync_id}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/magic/cloud/catalog-syncs/{sync_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = catalog_syncs_delete_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn catalog_syncs_delete_request<F>(
    client: DynNetClient,
    args: &CatalogSyncsDeleteArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<McnDeleteCatalogSyncResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/catalog-syncs/{}",
        args.account_id,
        args.sync_id,
    );
    let endpoint_url = format!("{}{}", base_url, path);

    let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
        .map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;

    builder = builder.query("delete_destination", args.delete_destination.as_deref());

    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: McnDeleteCatalogSyncResponse = 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 })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/magic/cloud/catalog-syncs/{sync_id}/refresh
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/magic/cloud/catalog-syncs/{sync_id}/refresh.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = catalog_syncs_refresh_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn catalog_syncs_refresh_request<F>(
    client: DynNetClient,
    args: &CatalogSyncsRefreshArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<McnRefreshCatalogSyncResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/catalog-syncs/{}/refresh",
        args.account_id,
        args.sync_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()))?;

    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: McnRefreshCatalogSyncResponse = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/magic/cloud/resources
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/magic/cloud/resources.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = resources_catalog_list_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn resources_catalog_list_request<F>(
    client: DynNetClient,
    args: &ResourcesCatalogListArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<McnReadAccountResourcesResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/resources",
        args.account_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()))?;

    builder = builder.query("provider_id", args.provider_id.as_deref());
    builder = builder.query("resource_type", args.resource_type.as_deref());
    builder = builder.query("resource_id", args.resource_id.as_deref());
    builder = builder.query("region", args.region.as_deref());
    builder = builder.query("resource_group", args.resource_group.as_deref());
    builder = builder.query("managed", args.managed.as_deref());
    builder = builder.query("search", args.search.as_deref());
    builder = builder.query("order_by", args.order_by.as_deref());
    builder = builder.query("desc", args.desc.as_deref());
    builder = builder.query("per_page", args.per_page.as_deref());
    builder = builder.query("page", args.page.as_deref());
    builder = builder.query("cloudflare", args.cloudflare.as_deref());
    builder = builder.query("v2", args.v2.as_deref());

    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: McnReadAccountResourcesResponse = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/magic/cloud/resources/export
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/magic/cloud/resources/export.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = resources_catalog_export_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn resources_catalog_export_request<F>(
    client: DynNetClient,
    args: &ResourcesCatalogExportArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/resources/export",
        args.account_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()))?;

    builder = builder.query("provider_id", args.provider_id.as_deref());
    builder = builder.query("resource_type", args.resource_type.as_deref());
    builder = builder.query("resource_id", args.resource_id.as_deref());
    builder = builder.query("region", args.region.as_deref());
    builder = builder.query("resource_group", args.resource_group.as_deref());
    builder = builder.query("search", args.search.as_deref());
    builder = builder.query("order_by", args.order_by.as_deref());
    builder = builder.query("desc", args.desc.as_deref());
    builder = builder.query("v2", args.v2.as_deref());

    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 });
    }
    Ok(ApiResponse { status: status as u16, headers, body: () })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/magic/cloud/resources/policy-preview
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/magic/cloud/resources/policy-preview.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = resources_catalog_policy_preview_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn resources_catalog_policy_preview_request<F>(
    client: DynNetClient,
    args: &ResourcesCatalogPolicyPreviewArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<McnResourcesCatalogPolicyPreviewResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/resources/policy-preview",
        args.account_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 {
        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: McnResourcesCatalogPolicyPreviewResponse = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/magic/cloud/resources/{resource_id}
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/magic/cloud/resources/{resource_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = resources_catalog_read_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn resources_catalog_read_request<F>(
    client: DynNetClient,
    args: &ResourcesCatalogReadArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<McnReadAccountResourceResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/magic/cloud/resources/{}",
        args.account_id,
        args.resource_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()))?;

    builder = builder.query("v2", args.v2.as_deref());

    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: McnReadAccountResourceResponse = 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 })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/slurper/jobs/{job_id}/logs
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/slurper/jobs/{job_id}/logs.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `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 = slurper_get_job_logs_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn slurper_get_job_logs_request<F>(
    client: DynNetClient,
    args: &SlurperGetJobLogsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<SlurperGetJobLogsResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/slurper/jobs/{}/logs",
        args.account_id,
        args.job_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()))?;

    builder = builder.query("limit", args.limit.as_deref());
    builder = builder.query("offset", args.offset.as_deref());

    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: SlurperGetJobLogsResponse = 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 })
}