foundation_deployment_cloudflare 0.1.1

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

#![cfg(feature = "cloudflare_analytics")]
#![allow(clippy::too_many_arguments, clippy::type_complexity)]
#![allow(clippy::missing_errors_doc, clippy::doc_markdown, clippy::useless_format)]
#![allow(unused_imports)]

use foundation_netio::{DynNetClient, PreparedRequestBuilder};
use foundation_netio::shared::client::http_client::HttpClient;
use serde::{Deserialize, Serialize};
use foundation_macros::JsonHash;

use super::shared::ApiResponse;

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

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

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

/// `RumCreateRuleRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RumCreateRuleRequest {
    /// host property.
    pub host: Option<String>,
    /// inclusive property.
    pub inclusive: Option<bool>,
    /// is_paused property.
    pub is_paused: Option<bool>,
    /// paths property.
    pub paths: Option<Vec<String>>,
}

/// `RumCreateSiteRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RumCreateSiteRequest {
    /// auto_install property.
    pub auto_install: Option<RumAutoInstall>,
    /// host property.
    pub host: Option<RumHost>,
    /// zone_tag property.
    pub zone_tag: Option<RumZoneTag>,
}

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

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

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

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

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

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

/// `RumRule` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RumRule {
    /// created property.
    pub created: Option<RumTimestamp>,
    /// host property.
    pub host: Option<String>,
    /// id property.
    pub id: Option<RumRuleIdentifier>,
    /// inclusive property.
    pub inclusive: Option<bool>,
    /// is_paused property.
    pub is_paused: Option<bool>,
    /// paths property.
    pub paths: Option<Vec<String>>,
    /// priority property.
    pub priority: Option<f64>,
}

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

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

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

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

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

/// `RumRuleset` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RumRuleset {
    /// enabled property.
    pub enabled: Option<bool>,
    /// id property.
    pub id: Option<RumRulesetIdentifier>,
    /// zone_name property.
    pub zone_name: Option<String>,
    /// zone_tag property.
    pub zone_tag: Option<RumZoneTag>,
}

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

/// `RumSite` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RumSite {
    /// auto_install property.
    pub auto_install: Option<RumAutoInstall>,
    /// created property.
    pub created: Option<RumTimestamp>,
    /// rules property.
    pub rules: Option<Vec<RumRule>>,
    /// ruleset property.
    pub ruleset: Option<RumRuleset>,
    /// site_tag property.
    pub site_tag: Option<RumSiteTag>,
    /// site_token property.
    pub site_token: Option<RumSiteToken>,
    /// snippet property.
    pub snippet: Option<RumSnippet>,
}

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

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

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

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

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

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

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

/// `RumUpdateSiteRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RumUpdateSiteRequest {
    /// auto_install property.
    pub auto_install: Option<RumAutoInstall>,
    /// enabled property.
    pub enabled: Option<RumEnabled>,
    /// host property.
    pub host: Option<RumHost>,
    /// lite property.
    pub lite: Option<RumLite>,
    /// zone_tag property.
    pub zone_tag: Option<RumZoneTag>,
}

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

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

/// Arguments for [`web-analytics-create-site_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WebAnalyticsCreateSiteArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: RumCreateSiteRequest,
}

/// Arguments for [`web-analytics-list-sites_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WebAnalyticsListSitesArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `per_page`.
    pub per_page: Option<String>,
    /// Query parameter: `page`.
    pub page: Option<String>,
    /// Query parameter: `order_by`.
    pub order_by: Option<String>,
}

/// Arguments for [`web-analytics-get-site_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WebAnalyticsGetSiteArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `site_id`.
    pub site_id: String,
}

/// Arguments for [`web-analytics-update-site_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WebAnalyticsUpdateSiteArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `site_id`.
    pub site_id: String,
    /// Request body.
    pub body: RumUpdateSiteRequest,
}

/// Arguments for [`web-analytics-delete-site_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WebAnalyticsDeleteSiteArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `site_id`.
    pub site_id: String,
}

/// Arguments for [`web-analytics-create-rule_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WebAnalyticsCreateRuleArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `ruleset_id`.
    pub ruleset_id: String,
    /// Request body.
    pub body: RumCreateRuleRequest,
}

/// Arguments for [`web-analytics-update-rule_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WebAnalyticsUpdateRuleArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `ruleset_id`.
    pub ruleset_id: String,
    /// Path parameter: `rule_id`.
    pub rule_id: String,
    /// Request body.
    pub body: RumCreateRuleRequest,
}

/// Arguments for [`web-analytics-delete-rule_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WebAnalyticsDeleteRuleArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `ruleset_id`.
    pub ruleset_id: String,
    /// Path parameter: `rule_id`.
    pub rule_id: String,
}

/// Arguments for [`web-analytics-list-rules_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WebAnalyticsListRulesArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `ruleset_id`.
    pub ruleset_id: String,
}

/// Arguments for [`web-analytics-modify-rules_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WebAnalyticsModifyRulesArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `ruleset_id`.
    pub ruleset_id: String,
    /// Request body.
    pub body: RumModifyRulesRequest,
}

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

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/rum/site_info
// -----------------------------------------------------------------------------

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

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

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

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

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

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

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

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

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

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