foundation_deployment_cloudflare 0.1.2

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

#![cfg(feature = "cloudflare_billing")]
#![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::BillSubsApiSubscriptionV2;
use super::shared::BillSubsApiComponentValue;
use super::shared::BillSubsApiCurrency;
use super::shared::BillSubsApiCurrentPeriodEnd;
use super::shared::BillSubsApiCurrentPeriodStart;
use super::shared::BillSubsApiFrequency;
use super::shared::BillSubsApiIdentifier;
use super::shared::BillSubsApiName;
use super::shared::BillSubsApiPrice;
use super::shared::BillSubsApiRatePlan;
use super::shared::BillSubsApiSchemasIdentifier;
use super::shared::BillSubsApiState;
use super::shared::BillSubsApiZone;

use super::shared::ApiResponse;

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

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

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

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

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

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

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

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

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

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

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

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

/// `BillableUsageApiUsageRecord` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BillableUsageApiUsageRecord {
    /// BillingCurrency property.
    #[serde(rename = "BillingCurrency")]
    pub billing_currency: String,
    /// BillingPeriodStart property.
    #[serde(rename = "BillingPeriodStart")]
    pub billing_period_start: String,
    /// ChargePeriodEnd property.
    #[serde(rename = "ChargePeriodEnd")]
    pub charge_period_end: String,
    /// ChargePeriodStart property.
    #[serde(rename = "ChargePeriodStart")]
    pub charge_period_start: String,
    /// ConsumedQuantity property.
    #[serde(rename = "ConsumedQuantity")]
    pub consumed_quantity: f64,
    /// ConsumedUnit property.
    #[serde(rename = "ConsumedUnit")]
    pub consumed_unit: String,
    /// ContractedCost property.
    #[serde(rename = "ContractedCost")]
    pub contracted_cost: f64,
    /// CumulatedContractedCost property.
    #[serde(rename = "CumulatedContractedCost")]
    pub cumulated_contracted_cost: f64,
    /// CumulatedPricingQuantity property.
    #[serde(rename = "CumulatedPricingQuantity")]
    pub cumulated_pricing_quantity: i64,
    /// PricingQuantity property.
    #[serde(rename = "PricingQuantity")]
    pub pricing_quantity: i64,
    /// ServiceName property.
    #[serde(rename = "ServiceName")]
    pub service_name: String,
}

/// `BillableUsageApiUsageResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BillableUsageApiUsageResponse {
    /// errors property.
    pub errors: Option<Vec<BillableUsageApiMessage>>,
    /// messages property.
    pub messages: Option<Vec<BillableUsageApiMessage>>,
    /// result property.
    pub result: Vec<BillableUsageApiUsageRecord>,
    /// success property.
    pub success: bool,
}

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

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

/// `MqApiV4Success` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MqApiV4Success {
    /// 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>,
}

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

/// `MqEventDestinationQueue` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MqEventDestinationQueue {
    /// queue_id property.
    pub queue_id: String,
    /// type property.
    #[serde(rename = "type")]
    pub r#type: String,
}

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

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

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

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

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

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

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

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

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

/// `MqEventSubscription` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MqEventSubscription {
    /// created_at property.
    pub created_at: String,
    /// destination property.
    pub destination: MqEventDestination,
    /// enabled property.
    pub enabled: bool,
    /// events property.
    pub events: Vec<String>,
    /// id property.
    pub id: String,
    /// modified_at property.
    pub modified_at: String,
    /// name property.
    pub name: String,
    /// source property.
    pub source: MqEventSource,
}

/// `PayPerCrawlApiNoResultResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PayPerCrawlApiNoResultResponse {
    /// errors property.
    pub errors: Option<Vec<Box<PayPerCrawlMsg>>>,
    /// messages property.
    pub messages: Option<Vec<Box<PayPerCrawlMsg>>>,
    /// result_info property.
    pub result_info: Option<PayPerCrawlResultInfo>,
    /// success property.
    pub success: Option<bool>,
}

/// `PayPerCrawlCreateStripeConfigResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PayPerCrawlCreateStripeConfigResponse {
    /// errors property.
    pub errors: Option<Vec<Box<PayPerCrawlMsg>>>,
    /// messages property.
    pub messages: Option<Vec<Box<PayPerCrawlMsg>>>,
    /// result property.
    pub result: Option<PayPerCrawlStripeConnectResp>,
    /// result_info property.
    pub result_info: Option<PayPerCrawlResultInfo>,
    /// success property.
    pub success: Option<bool>,
}

/// `PayPerCrawlDaricZoneCanBeEnabled` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PayPerCrawlDaricZoneCanBeEnabled {
    /// can_be_enabled property.
    pub can_be_enabled: Option<bool>,
    /// id property.
    pub id: Option<String>,
}

/// `PayPerCrawlGetStripeConfigResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PayPerCrawlGetStripeConfigResponse {
    /// errors property.
    pub errors: Option<Vec<Box<PayPerCrawlMsg>>>,
    /// messages property.
    pub messages: Option<Vec<Box<PayPerCrawlMsg>>>,
    /// result property.
    pub result: Option<PayPerCrawlStripeConnection>,
    /// result_info property.
    pub result_info: Option<PayPerCrawlResultInfo>,
    /// success property.
    pub success: Option<bool>,
}

/// `PayPerCrawlMsg` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PayPerCrawlMsg {
    /// code property.
    pub code: Option<i64>,
    /// documentation_url property.
    pub documentation_url: Option<String>,
    /// error_chain property.
    pub error_chain: Option<Vec<Box<PayPerCrawlMsg>>>,
    /// message property.
    pub message: Option<String>,
    /// meta property.
    pub meta: Option<serde_json::Value>,
    /// source property.
    pub source: Option<PayPerCrawlSource>,
}

/// `PayPerCrawlQueryZonesCanBeEnabledResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PayPerCrawlQueryZonesCanBeEnabledResponse {
    /// errors property.
    pub errors: Option<Vec<Box<PayPerCrawlMsg>>>,
    /// messages property.
    pub messages: Option<Vec<Box<PayPerCrawlMsg>>>,
    /// result property.
    pub result: Option<PayPerCrawlZonesCanBeEnabledPayload>,
    /// result_info property.
    pub result_info: Option<PayPerCrawlResultInfo>,
    /// success property.
    pub success: Option<bool>,
}

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

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

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

/// `PayPerCrawlStripeConnection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PayPerCrawlStripeConnection {
    /// connect_status property.
    pub connect_status: Option<String>,
    /// stripe_account_id property.
    pub stripe_account_id: Option<String>,
}

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

/// `SubscriptionsCreateRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct SubscriptionsCreateRequest {
    /// destination property.
    pub destination: Option<MqEventDestination>,
    /// enabled property.
    pub enabled: Option<bool>,
    /// events property.
    pub events: Option<Vec<String>>,
    /// name property.
    pub name: Option<String>,
    /// source property.
    pub source: Option<MqEventSource>,
}

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

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

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

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

/// `SubscriptionsPatchRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct SubscriptionsPatchRequest {
    /// destination property.
    pub destination: Option<MqEventDestination>,
    /// enabled property.
    pub enabled: Option<bool>,
    /// events property.
    pub events: Option<Vec<String>>,
    /// name property.
    pub name: Option<String>,
}

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

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

/// Arguments for [`billable-usage-get-paygo-account-usage_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BillableUsageGetPaygoAccountUsageArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `from`.
    pub from: Option<String>,
    /// Query parameter: `to`.
    pub to: Option<String>,
}

/// Arguments for [`subscriptions-list_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SubscriptionsListArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `page`.
    pub page: Option<String>,
    /// Query parameter: `per_page`.
    pub per_page: Option<String>,
    /// Query parameter: `order`.
    pub order: Option<String>,
    /// Query parameter: `direction`.
    pub direction: Option<String>,
}

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

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

/// Arguments for [`subscriptions-patch_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SubscriptionsPatchArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `subscription_id`.
    pub subscription_id: String,
    /// Request body.
    pub body: SubscriptionsPatchRequest,
}

/// Arguments for [`subscriptions-delete_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SubscriptionsDeleteArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `subscription_id`.
    pub subscription_id: String,
}

/// Arguments for [`pay-per-crawl.crawlerGetStripeConfig_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PayPerCrawlCrawlerGetStripeConfigArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`pay-per-crawl.crawlerCreateStripeConfig_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PayPerCrawlCrawlerCreateStripeConfigArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`pay-per-crawl.crawlerDeleteStripeConfig_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PayPerCrawlCrawlerDeleteStripeConfigArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`pay-per-crawl.publisherGetStripeConfig_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PayPerCrawlPublisherGetStripeConfigArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`pay-per-crawl.publisherCreateStripeConfig_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PayPerCrawlPublisherCreateStripeConfigArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`pay-per-crawl.publisherDeleteStripeConfig_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PayPerCrawlPublisherDeleteStripeConfigArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`pay-per-crawl.setZonesCanBeEnabled_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PayPerCrawlSetZonesCanBeEnabledArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`pay-per-crawl.queryZonesCanBeEnabled_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PayPerCrawlQueryZonesCanBeEnabledArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`account-subscriptions-list-subscriptions_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountSubscriptionsListSubscriptionsArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`account-subscriptions-create-subscription_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountSubscriptionsCreateSubscriptionArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: BillSubsApiSubscriptionV2,
}

/// Arguments for [`account-subscriptions-update-subscription_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountSubscriptionsUpdateSubscriptionArgs {
    /// Path parameter: `subscription_identifier`.
    pub subscription_identifier: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: BillSubsApiSubscriptionV2,
}

/// Arguments for [`account-subscriptions-delete-subscription_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountSubscriptionsDeleteSubscriptionArgs {
    /// Path parameter: `subscription_identifier`.
    pub subscription_identifier: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
}

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

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/billing/usage/paygo
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/billing/usage/paygo.
///
/// 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 = billable_usage_get_paygo_account_usage_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn billable_usage_get_paygo_account_usage_request<F>(
    client: DynNetClient,
    args: &BillableUsageGetPaygoAccountUsageArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<BillableUsageApiUsageResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/billing/usage/paygo",
        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("from", args.from.as_deref());
    builder = builder.query("to", args.to.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: BillableUsageApiUsageResponse = 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}/event_subscriptions/subscriptions
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/event_subscriptions/subscriptions.
///
/// 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 = subscriptions_list_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn subscriptions_list_request<F>(
    client: DynNetClient,
    args: &SubscriptionsListArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<SubscriptionsListResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/event_subscriptions/subscriptions",
        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("page", args.page.as_deref());
    builder = builder.query("per_page", args.per_page.as_deref());
    builder = builder.query("order", args.order.as_deref());
    builder = builder.query("direction", args.direction.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: SubscriptionsListResponse = 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}/event_subscriptions/subscriptions
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/event_subscriptions/subscriptions.
///
/// 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 = subscriptions_create_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn subscriptions_create_request<F>(
    client: DynNetClient,
    args: &SubscriptionsCreateArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<SubscriptionsCreateResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/event_subscriptions/subscriptions",
        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: SubscriptionsCreateResponse = 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}/event_subscriptions/subscriptions/{subscription_id}
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/event_subscriptions/subscriptions/{subscription_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 = subscriptions_get_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn subscriptions_get_request<F>(
    client: DynNetClient,
    args: &SubscriptionsGetArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<SubscriptionsGetResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/event_subscriptions/subscriptions/{}",
        args.account_id,
        args.subscription_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: SubscriptionsGetResponse = 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}/event_subscriptions/subscriptions/{subscription_id}
// -----------------------------------------------------------------------------

/// PATCH /accounts/{account_id}/event_subscriptions/subscriptions/{subscription_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 = subscriptions_patch_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn subscriptions_patch_request<F>(
    client: DynNetClient,
    args: &SubscriptionsPatchArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<SubscriptionsPatchResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/event_subscriptions/subscriptions/{}",
        args.account_id,
        args.subscription_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: SubscriptionsPatchResponse = 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}/event_subscriptions/subscriptions/{subscription_id}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/event_subscriptions/subscriptions/{subscription_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 = subscriptions_delete_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn subscriptions_delete_request<F>(
    client: DynNetClient,
    args: &SubscriptionsDeleteArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<SubscriptionsDeleteResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/event_subscriptions/subscriptions/{}",
        args.account_id,
        args.subscription_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: SubscriptionsDeleteResponse = 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}/pay-per-crawl/crawler/stripe
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/pay-per-crawl/crawler/stripe.
///
/// 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 = pay_per_crawl_crawler_get_stripe_config_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn pay_per_crawl_crawler_get_stripe_config_request<F>(
    client: DynNetClient,
    args: &PayPerCrawlCrawlerGetStripeConfigArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<PayPerCrawlGetStripeConfigResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/pay-per-crawl/crawler/stripe",
        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: PayPerCrawlGetStripeConfigResponse = 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}/pay-per-crawl/crawler/stripe
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/pay-per-crawl/crawler/stripe.
///
/// 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 = pay_per_crawl_crawler_create_stripe_config_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn pay_per_crawl_crawler_create_stripe_config_request<F>(
    client: DynNetClient,
    args: &PayPerCrawlCrawlerCreateStripeConfigArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<PayPerCrawlCreateStripeConfigResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/pay-per-crawl/crawler/stripe",
        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()))?;

    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: PayPerCrawlCreateStripeConfigResponse = 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}/pay-per-crawl/crawler/stripe
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/pay-per-crawl/crawler/stripe.
///
/// 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 = pay_per_crawl_crawler_delete_stripe_config_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn pay_per_crawl_crawler_delete_stripe_config_request<F>(
    client: DynNetClient,
    args: &PayPerCrawlCrawlerDeleteStripeConfigArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<PayPerCrawlApiNoResultResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/pay-per-crawl/crawler/stripe",
        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: PayPerCrawlApiNoResultResponse = 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}/pay-per-crawl/publisher/stripe
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/pay-per-crawl/publisher/stripe.
///
/// 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 = pay_per_crawl_publisher_get_stripe_config_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn pay_per_crawl_publisher_get_stripe_config_request<F>(
    client: DynNetClient,
    args: &PayPerCrawlPublisherGetStripeConfigArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<PayPerCrawlGetStripeConfigResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/pay-per-crawl/publisher/stripe",
        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: PayPerCrawlGetStripeConfigResponse = 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}/pay-per-crawl/publisher/stripe
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/pay-per-crawl/publisher/stripe.
///
/// 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 = pay_per_crawl_publisher_create_stripe_config_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn pay_per_crawl_publisher_create_stripe_config_request<F>(
    client: DynNetClient,
    args: &PayPerCrawlPublisherCreateStripeConfigArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<PayPerCrawlCreateStripeConfigResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/pay-per-crawl/publisher/stripe",
        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()))?;

    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: PayPerCrawlCreateStripeConfigResponse = 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}/pay-per-crawl/publisher/stripe
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/pay-per-crawl/publisher/stripe.
///
/// 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 = pay_per_crawl_publisher_delete_stripe_config_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn pay_per_crawl_publisher_delete_stripe_config_request<F>(
    client: DynNetClient,
    args: &PayPerCrawlPublisherDeleteStripeConfigArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<PayPerCrawlApiNoResultResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/pay-per-crawl/publisher/stripe",
        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: PayPerCrawlApiNoResultResponse = 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}/pay-per-crawl/zones_can_be_enabled
// -----------------------------------------------------------------------------

/// PATCH /accounts/{account_id}/pay-per-crawl/zones_can_be_enabled.
///
/// 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 = pay_per_crawl_set_zones_can_be_enabled_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn pay_per_crawl_set_zones_can_be_enabled_request<F>(
    client: DynNetClient,
    args: &PayPerCrawlSetZonesCanBeEnabledArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<PayPerCrawlApiNoResultResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/pay-per-crawl/zones_can_be_enabled",
        args.account_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()))?;

    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: PayPerCrawlApiNoResultResponse = 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}/pay-per-crawl/zones_can_be_enabled/query
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/pay-per-crawl/zones_can_be_enabled/query.
///
/// 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 = pay_per_crawl_query_zones_can_be_enabled_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn pay_per_crawl_query_zones_can_be_enabled_request<F>(
    client: DynNetClient,
    args: &PayPerCrawlQueryZonesCanBeEnabledArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<PayPerCrawlQueryZonesCanBeEnabledResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/pay-per-crawl/zones_can_be_enabled/query",
        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()))?;

    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: PayPerCrawlQueryZonesCanBeEnabledResponse = 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}/subscriptions
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/subscriptions.
///
/// 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 = account_subscriptions_list_subscriptions_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn account_subscriptions_list_subscriptions_request<F>(
    client: DynNetClient,
    args: &AccountSubscriptionsListSubscriptionsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<BillSubsApiAccountSubscriptionResponseCollection>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/subscriptions",
        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: BillSubsApiAccountSubscriptionResponseCollection = 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}/subscriptions
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/subscriptions.
///
/// 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 = account_subscriptions_create_subscription_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn account_subscriptions_create_subscription_request<F>(
    client: DynNetClient,
    args: &AccountSubscriptionsCreateSubscriptionArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<BillSubsApiAccountSubscriptionResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/subscriptions",
        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: BillSubsApiAccountSubscriptionResponseSingle = 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}/subscriptions/{subscription_identifier}
// -----------------------------------------------------------------------------

/// PUT /accounts/{account_id}/subscriptions/{subscription_identifier}.
///
/// 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 = account_subscriptions_update_subscription_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn account_subscriptions_update_subscription_request<F>(
    client: DynNetClient,
    args: &AccountSubscriptionsUpdateSubscriptionArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<BillSubsApiAccountSubscriptionResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/subscriptions/{}",
        args.account_id,
        args.subscription_identifier,
    );
    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: BillSubsApiAccountSubscriptionResponseSingle = 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}/subscriptions/{subscription_identifier}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/subscriptions/{subscription_identifier}.
///
/// 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 = account_subscriptions_delete_subscription_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn account_subscriptions_delete_subscription_request<F>(
    client: DynNetClient,
    args: &AccountSubscriptionsDeleteSubscriptionArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<AccountSubscriptionsDeleteSubscriptionResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/subscriptions/{}",
        args.account_id,
        args.subscription_identifier,
    );
    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: AccountSubscriptionsDeleteSubscriptionResponse = 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 })
}