redis_cloud/flexible/

databases.rs

//! Database management operations for Pro subscriptions
//!
//! This module provides comprehensive database management functionality for Redis Cloud
//! Pro subscriptions, including creation, configuration, backup, import/export, and
//! monitoring capabilities.
//!
//! # Overview
//!
//! Pro databases offer the full range of Redis Cloud features including high availability,
//! auto-scaling, clustering, modules, and advanced data persistence options. They can be
//! deployed across multiple cloud providers and regions.
//!
//! # Key Features
//!
//! - **Database Lifecycle**: Create, update, delete, and manage databases
//! - **Backup & Restore**: Automated and on-demand backup operations
//! - **Import/Export**: Import data from RDB files or other Redis instances
//! - **Modules**: Support for `RedisJSON`, `RediSearch`, `RedisGraph`, `RedisTimeSeries`, `RedisBloom`
//! - **High Availability**: Replication, auto-failover, and clustering support
//! - **Monitoring**: Metrics, alerts, and performance insights
//! - **Security**: TLS, password protection, and ACL support
//!
//! # Database Configuration Options
//!
//! - Memory limits from 250MB to 500GB+
//! - Support for Redis OSS Cluster API
//! - Data persistence: AOF, snapshot, or both
//! - Data eviction policies
//! - Replication and clustering
//! - Custom Redis versions
//!
//! # Example Usage
//!
//! ```no_run
//! use redis_cloud::{CloudClient, DatabaseHandler};
//!
//! # async fn example() -> Result<(), Box<dyn std::error::Error>> {
//! let client = CloudClient::builder()
//!     .api_key("your-api-key")
//!     .api_secret("your-api-secret")
//!     .build()?;
//!
//! let handler = DatabaseHandler::new(client);
//!
//! // List all databases in a subscription (subscription ID 123)
//! let databases = handler.get_subscription_databases(123, None, None).await?;
//!
//! // Get specific database details
//! let database = handler.get_subscription_database_by_id(123, 456).await?;
//! # Ok(())
//! # }
//! ```

use crate::types::Link;
pub use crate::types::{CloudTag, CloudTags, DatabaseTrafficStateResponse, Tag, TaskStateUpdate};
use crate::{CloudClient, Result};
use async_stream::try_stream;
use futures_core::Stream;
use serde::{Deserialize, Deserializer, Serialize};
use serde_json::Value;
use std::collections::HashMap;
use typed_builder::TypedBuilder;

// ============================================================================
// Models
// ============================================================================

/// `RedisLabs` Account Subscription Databases information
///
/// Response from GET /subscriptions/{subscriptionId}/databases
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct AccountSubscriptionDatabases {
    /// Account ID
    #[serde(skip_serializing_if = "Option::is_none")]
    pub account_id: Option<i32>,

    /// Subscription information with nested databases array.
    /// The API returns this as an array, each element containing subscriptionId, databases, and links.
    #[serde(default, deserialize_with = "deserialize_subscription_info")]
    pub subscription: Vec<SubscriptionDatabasesInfo>,

    /// HATEOAS links for API navigation
    #[serde(skip_serializing_if = "Option::is_none")]
    pub links: Option<Vec<Link>>,
}

/// Subscription databases info returned within `AccountSubscriptionDatabases`
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct SubscriptionDatabasesInfo {
    /// Subscription ID
    pub subscription_id: i32,

    /// Number of databases (may not always be present)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub number_of_databases: Option<i32>,

    /// List of databases in this subscription
    #[serde(default)]
    pub databases: Vec<Database>,

    /// HATEOAS links
    #[serde(skip_serializing_if = "Option::is_none")]
    pub links: Option<Vec<Link>>,
}

/// Custom deserializer that handles both object and array formats for subscription field.
/// The API returns an array, but some test mocks use an object format.
fn deserialize_subscription_info<'de, D>(
    deserializer: D,
) -> std::result::Result<Vec<SubscriptionDatabasesInfo>, D::Error>
where
    D: Deserializer<'de>,
{
    let value: Option<Value> = Option::deserialize(deserializer)?;

    match value {
        None => Ok(Vec::new()),
        Some(Value::Array(arr)) => {
            serde_json::from_value(Value::Array(arr)).map_err(serde::de::Error::custom)
        }
        Some(Value::Object(obj)) => {
            // Single object - wrap in array
            let item: SubscriptionDatabasesInfo =
                serde_json::from_value(Value::Object(obj)).map_err(serde::de::Error::custom)?;
            Ok(vec![item])
        }
        Some(other) => Err(serde::de::Error::custom(format!(
            "expected array or object for subscription, got {other:?}"
        ))),
    }
}

/// Optional. Expected read and write throughput for this region.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct LocalThroughput {
    /// Specify one of the selected cloud provider regions for the subscription.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub region: Option<String>,

    /// Write operations for this region per second. Default: 1000 ops/sec
    #[serde(skip_serializing_if = "Option::is_none")]
    pub write_operations_per_second: Option<i64>,

    /// Read operations for this region per second. Default: 1000 ops/sec
    #[serde(skip_serializing_if = "Option::is_none")]
    pub read_operations_per_second: Option<i64>,
}

/// Database tag update request message
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseTagUpdateRequest {
    /// Subscription ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub subscription_id: Option<i32>,

    /// Database ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub database_id: Option<i32>,

    /// Tag key being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub key: Option<String>,

    /// Database tag value
    pub value: String,

    /// Read-only on the response; populated by the server with the
    /// operation type (e.g. `"UPDATE_DATABASE_TAG"`).
    #[serde(skip_serializing_if = "Option::is_none")]
    pub command_type: Option<String>,
}

/// Active-Active database flush request message
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct CrdbFlushRequest {
    /// Subscription ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub subscription_id: Option<i32>,

    /// Database ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub database_id: Option<i32>,

    /// Read-only on the response; populated by the server with the
    /// operation type (e.g. `"FLUSH_CRDB"`).
    #[serde(skip_serializing_if = "Option::is_none")]
    pub command_type: Option<String>,
}

/// Database certificate
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseCertificate {
    /// An X.509 PEM (base64) encoded server certificate with new line characters replaced by '\n'.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub public_certificate_pem_string: Option<String>,
}

/// Database tags update request message
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseTagsUpdateRequest {
    /// Subscription ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub subscription_id: Option<i32>,

    /// Database ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub database_id: Option<i32>,

    /// List of database tags.
    pub tags: Vec<Tag>,

    /// Read-only on the response; populated by the server with the
    /// operation type (e.g. `"UPDATE_DATABASE_TAGS"`).
    #[serde(skip_serializing_if = "Option::is_none")]
    pub command_type: Option<String>,
}

/// Optional. This database will be a replica of the specified Redis databases, provided as a list of objects with endpoint and certificate details.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseSyncSourceSpec {
    /// Redis URI of a source database. Example format: 'redis://user:password@host:port'. If the URI provided is a Redis Cloud database, only host and port should be provided. Example: '<redis://endpoint1:6379>'.
    pub endpoint: String,

    /// Defines if encryption should be used to connect to the sync source. If not set the source is a Redis Cloud database, it will automatically detect if the source uses encryption.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub encryption: Option<bool>,

    /// TLS/SSL certificate chain of the sync source. If not set and the source is a Redis Cloud database, it will automatically detect the certificate to use.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub server_cert: Option<String>,
}

/// Optional. A list of client TLS/SSL certificates. If specified, mTLS authentication will be required to authenticate user connections. If set to an empty list, TLS client certificates will be removed and mTLS will not be required. TLS connection may still apply, depending on the value of 'enableTls'.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseCertificateSpec {
    /// Client certificate public key in PEM format, with new line characters replaced with '\n'.
    pub public_certificate_pem_string: String,
}

/// `BdbVersionUpgradeStatus`
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct BdbVersionUpgradeStatus {
    /// Database identifier.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub database_id: Option<i32>,

    /// Target Redis version of the upgrade.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub target_redis_version: Option<String>,

    /// Upgrade progress (0.0 - 100.0).
    #[serde(skip_serializing_if = "Option::is_none")]
    pub progress: Option<f64>,

    /// Current upgrade status (e.g. `"in-progress"`, `"completed"`, `"failed"`).
    #[serde(skip_serializing_if = "Option::is_none")]
    pub upgrade_status: Option<String>,
}

/// Active-Active database update local properties request message
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct CrdbUpdatePropertiesRequest {
    /// Subscription ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub subscription_id: Option<i32>,

    /// Database ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub database_id: Option<i32>,

    /// Optional. Updated database name. Database name is limited to 40 characters or less and must include only letters, digits, and hyphens ('-'). It must start with a letter and end with a letter or digit.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub name: Option<String>,

    /// Optional. When 'false': Creates a deployment plan and deploys it, updating any resources required by the plan. When 'true': creates a read-only deployment plan and does not update any resources. Default: 'false'
    #[serde(skip_serializing_if = "Option::is_none")]
    pub dry_run: Option<bool>,

    /// Optional. Total memory in GB, including replication and other overhead. You cannot set both datasetSizeInGb and totalMemoryInGb.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub memory_limit_in_gb: Option<f64>,

    /// Optional. The maximum amount of data in the dataset for this database in GB. You cannot set both datasetSizeInGb and totalMemoryInGb. If ‘replication’ is 'true', the database’s total memory will be twice as large as the datasetSizeInGb.If ‘replication’ is false, the database’s total memory will be the datasetSizeInGb value.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub dataset_size_in_gb: Option<f64>,

    /// Optional. Support Redis [OSS Cluster API](https://redis.io/docs/latest/operate/rc/databases/configuration/clustering/#oss-cluster-api). Default: 'false'
    #[serde(skip_serializing_if = "Option::is_none")]
    pub support_oss_cluster_api: Option<bool>,

    /// Optional. If set to 'true', the database will use the external endpoint for OSS Cluster API. This setting blocks the database's private endpoint. Can only be set if 'supportOSSClusterAPI' is 'true'.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub use_external_endpoint_for_oss_cluster_api: Option<bool>,

    /// Optional. A public key client TLS/SSL certificate with new line characters replaced with '\n'. If specified, mTLS authentication will be required to authenticate user connections if it is not already required. If set to an empty string, TLS client certificates will be removed and mTLS will not be required. TLS connection may still apply, depending on the value of 'enableTls'.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub client_ssl_certificate: Option<String>,

    /// Optional. A list of client TLS/SSL certificates. If specified, mTLS authentication will be required to authenticate user connections. If set to an empty list, TLS client certificates will be removed and mTLS will not be required. TLS connection may still apply, depending on the value of 'enableTls'.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub client_tls_certificates: Option<Vec<DatabaseCertificateSpec>>,

    /// Optional. When 'true', requires TLS authentication for all connections - mTLS with valid clientTlsCertificates, regular TLS when clientTlsCertificates is not provided. If enableTls is set to 'false' while mTLS is required, it will remove the mTLS requirement and erase previously provided clientTlsCertificates.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub enable_tls: Option<bool>,

    /// Optional. Type and rate of data persistence in all regions that don't set local 'dataPersistence'.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub global_data_persistence: Option<String>,

    /// Optional. Changes the password used to access the database in all regions that don't set a local 'password'.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub global_password: Option<String>,

    /// Optional. List of source IP addresses or subnet masks to allow in all regions that don't set local 'sourceIp' settings. If set, Redis clients will be able to connect to this database only from within the specified source IP addresses ranges. Example: ['192.168.10.0/32', '192.168.12.0/24']
    #[serde(skip_serializing_if = "Option::is_none")]
    pub global_source_ip: Option<Vec<String>>,

    /// Optional. Redis database alert settings in all regions that don't set local 'alerts'.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub global_alerts: Option<Vec<DatabaseAlertSpec>>,

    /// Optional. A list of regions and local settings to update.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub regions: Option<Vec<LocalRegionProperties>>,

    /// Optional. Data eviction policy.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub data_eviction_policy: Option<String>,

    /// Read-only on the response; populated by the server with the
    /// operation type (e.g. `"UPDATE_CRDB"`).
    #[serde(skip_serializing_if = "Option::is_none")]
    pub command_type: Option<String>,
}

/// Database slowlog entry
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseSlowLogEntry {
    /// Slowlog entry identifier.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub id: Option<i32>,

    /// Timestamp when the command began executing.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub start_time: Option<String>,

    /// Execution duration in microseconds.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub duration: Option<i32>,

    /// Command arguments captured for this slowlog entry.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub arguments: Option<String>,
}

/// Database tag
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseTagCreateRequest {
    /// Database tag key.
    pub key: String,

    /// Database tag value.
    pub value: String,

    /// Subscription ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub subscription_id: Option<i32>,

    /// Database ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub database_id: Option<i32>,

    /// Read-only on the response; populated by the server with the
    /// operation type (e.g. `"CREATE_DATABASE_TAG"`).
    #[serde(skip_serializing_if = "Option::is_none")]
    pub command_type: Option<String>,
}

/// Optional. Throughput measurement method.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct DatabaseThroughputSpec {
    /// Throughput measurement method. Use 'operations-per-second' for all new databases.
    pub by: String,

    /// Throughput value in the selected measurement method.
    pub value: i64,
}

/// Optional. Changes Remote backup configuration details.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseBackupConfig {
    /// Optional. Determine if backup should be active. Default: null
    #[serde(skip_serializing_if = "Option::is_none")]
    pub active: Option<bool>,

    /// Required when active is 'true'. Defines the interval between backups. Format: 'every-x-hours', where x is one of 24, 12, 6, 4, 2, or 1. Example: "every-4-hours"
    #[serde(skip_serializing_if = "Option::is_none")]
    pub interval: Option<String>,

    /// Alternate request field name for [`Self::interval`] that the API also
    /// accepts (`backupInterval`). Prefer `interval`, which is the documented
    /// form in the OpenAPI spec.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub backup_interval: Option<String>,

    /// Optional. Hour when the backup starts. Available only for "every-12-hours" and "every-24-hours" backup intervals. Specified as an hour in 24-hour UTC time. Example: "14:00" is 2 PM UTC.
    #[serde(rename = "timeUTC", skip_serializing_if = "Option::is_none")]
    pub time_utc: Option<String>,

    /// Alternate request field name for [`Self::time_utc`] that the API also
    /// accepts (`databaseBackupTimeUTC`). Prefer `time_utc`, which is the
    /// documented form in the OpenAPI spec.
    #[serde(
        rename = "databaseBackupTimeUTC",
        skip_serializing_if = "Option::is_none"
    )]
    pub database_backup_time_utc: Option<String>,

    /// Required when active is 'true'. Type of storage to host backup files. Can be "aws-s3", "google-blob-storage", "azure-blob-storage", or "ftp". See [Set up backup storage locations](https://redis.io/docs/latest/operate/rc/databases/back-up-data/#set-up-backup-storage-locations) to learn how to set up backup storage locations.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub storage_type: Option<String>,

    /// Alternate request field name for [`Self::storage_type`] that the API
    /// also accepts (`backupStorageType`). Prefer `storage_type`, which is the
    /// documented form in the OpenAPI spec.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub backup_storage_type: Option<String>,

    /// Required when active is 'true'. Path to the backup storage location.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub storage_path: Option<String>,
}

/// Optional. Redis advanced capabilities (also known as modules) to be provisioned in the database. Use GET /database-modules to get a list of available advanced capabilities.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct DatabaseModuleSpec {
    /// Redis advanced capability name. Use GET /database-modules for a list of available capabilities.
    pub name: String,

    /// Optional. Redis advanced capability parameters. Use GET /database-modules to get the available capabilities and their parameters.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub parameters: Option<HashMap<String, Value>>,
}

/// Optional. Changes Replica Of (also known as Active-Passive) configuration details.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct ReplicaOfSpec {
    /// Optional. This database will be a replica of the specified Redis databases, provided as a list of objects with endpoint and certificate details.
    pub sync_sources: Vec<DatabaseSyncSourceSpec>,
}

/// Regex rule for custom hashing policy
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct RegexRule {
    /// The ordinal/order of this rule
    pub ordinal: i32,

    /// The regex pattern for this rule
    pub pattern: String,
}

/// Backup configuration status (response)
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct Backup {
    /// Whether remote backup is enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub enable_remote_backup: Option<bool>,

    /// Backup time in UTC
    #[serde(skip_serializing_if = "Option::is_none")]
    pub time_utc: Option<String>,

    /// Backup interval (e.g., "every-24-hours", "every-12-hours")
    #[serde(skip_serializing_if = "Option::is_none")]
    pub interval: Option<String>,

    /// Backup destination path
    #[serde(skip_serializing_if = "Option::is_none")]
    pub destination: Option<String>,
}

/// Security configuration (response)
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct Security {
    /// Whether default Redis user is enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub enable_default_user: Option<bool>,

    /// Whether SSL client authentication is enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub ssl_client_authentication: Option<bool>,

    /// Whether TLS client authentication is enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tls_client_authentication: Option<bool>,

    /// List of source IP addresses allowed to connect
    #[serde(skip_serializing_if = "Option::is_none")]
    pub source_ips: Option<Vec<String>>,

    /// Database password (masked in responses)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub password: Option<String>,

    /// Whether TLS is enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub enable_tls: Option<bool>,
}

/// Clustering configuration (response)
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct Clustering {
    /// Number of shards
    #[serde(skip_serializing_if = "Option::is_none")]
    pub number_of_shards: Option<i32>,

    /// Regex rules for custom hashing
    #[serde(skip_serializing_if = "Option::is_none")]
    pub regex_rules: Option<Vec<RegexRule>>,

    /// Hashing policy
    #[serde(skip_serializing_if = "Option::is_none")]
    pub hashing_policy: Option<String>,
}

/// Active-Active (CRDB) database information
///
/// Represents an Active-Active database with global settings and per-region configurations.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct ActiveActiveDatabase {
    /// Database ID
    #[serde(skip_serializing_if = "Option::is_none")]
    pub database_id: Option<i32>,

    /// Database name
    #[serde(skip_serializing_if = "Option::is_none")]
    pub name: Option<String>,

    /// Database protocol
    #[serde(skip_serializing_if = "Option::is_none")]
    pub protocol: Option<String>,

    /// Database status
    #[serde(skip_serializing_if = "Option::is_none")]
    pub status: Option<String>,

    /// Redis version
    #[serde(skip_serializing_if = "Option::is_none")]
    pub redis_version: Option<String>,

    /// Memory storage type
    #[serde(skip_serializing_if = "Option::is_none")]
    pub memory_storage: Option<String>,

    /// Whether this is an Active-Active database
    #[serde(skip_serializing_if = "Option::is_none")]
    pub active_active_redis: Option<bool>,

    /// Timestamp when database was activated
    #[serde(skip_serializing_if = "Option::is_none")]
    pub activated_on: Option<String>,

    /// Timestamp of last modification
    #[serde(skip_serializing_if = "Option::is_none")]
    pub last_modified: Option<String>,

    /// Support for OSS Cluster API
    #[serde(skip_serializing_if = "Option::is_none")]
    pub support_oss_cluster_api: Option<bool>,

    /// Use external endpoint for OSS Cluster API
    #[serde(skip_serializing_if = "Option::is_none")]
    pub use_external_endpoint_for_oss_cluster_api: Option<bool>,

    /// Whether replication is enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub replication: Option<bool>,

    /// Data eviction policy
    #[serde(skip_serializing_if = "Option::is_none")]
    pub data_eviction_policy: Option<String>,

    /// Security configuration
    #[serde(skip_serializing_if = "Option::is_none")]
    pub security: Option<Security>,

    /// Redis modules enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub modules: Option<Vec<DatabaseModuleSpec>>,

    /// Global data persistence setting
    #[serde(skip_serializing_if = "Option::is_none")]
    pub global_data_persistence: Option<String>,

    /// Global source IP allowlist
    #[serde(skip_serializing_if = "Option::is_none")]
    pub global_source_ip: Option<Vec<String>>,

    /// Global password
    #[serde(skip_serializing_if = "Option::is_none")]
    pub global_password: Option<String>,

    /// Global alert configurations
    #[serde(skip_serializing_if = "Option::is_none")]
    pub global_alerts: Option<Vec<DatabaseAlertSpec>>,

    /// Global enable default user setting
    #[serde(skip_serializing_if = "Option::is_none")]
    pub global_enable_default_user: Option<bool>,

    /// Per-region CRDB database configurations
    #[serde(skip_serializing_if = "Option::is_none")]
    pub crdb_databases: Option<Vec<CrdbDatabase>>,

    /// Whether automatic minor version upgrades are enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub auto_minor_version_upgrade: Option<bool>,
}

/// Per-region configuration for an Active-Active (CRDB) database
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct CrdbDatabase {
    /// Cloud provider
    #[serde(skip_serializing_if = "Option::is_none")]
    pub provider: Option<String>,

    /// Cloud region
    #[serde(skip_serializing_if = "Option::is_none")]
    pub region: Option<String>,

    /// Redis version compliance
    #[serde(skip_serializing_if = "Option::is_none")]
    pub redis_version_compliance: Option<String>,

    /// Public endpoint
    #[serde(skip_serializing_if = "Option::is_none")]
    pub public_endpoint: Option<String>,

    /// Private endpoint
    #[serde(skip_serializing_if = "Option::is_none")]
    pub private_endpoint: Option<String>,

    /// Memory limit in GB
    #[serde(skip_serializing_if = "Option::is_none")]
    pub memory_limit_in_gb: Option<f64>,

    /// Dataset size in GB
    #[serde(skip_serializing_if = "Option::is_none")]
    pub dataset_size_in_gb: Option<f64>,

    /// Memory used in MB
    #[serde(skip_serializing_if = "Option::is_none")]
    pub memory_used_in_mb: Option<f64>,

    /// Read operations per second
    #[serde(skip_serializing_if = "Option::is_none")]
    pub read_operations_per_second: Option<i32>,

    /// Write operations per second
    #[serde(skip_serializing_if = "Option::is_none")]
    pub write_operations_per_second: Option<i32>,

    /// Data persistence setting for this region
    #[serde(skip_serializing_if = "Option::is_none")]
    pub data_persistence: Option<String>,

    /// Alert configurations for this region
    #[serde(skip_serializing_if = "Option::is_none")]
    pub alerts: Option<Vec<DatabaseAlertSpec>>,

    /// Security configuration for this region
    #[serde(skip_serializing_if = "Option::is_none")]
    pub security: Option<Security>,

    /// Backup configuration for this region
    #[serde(skip_serializing_if = "Option::is_none")]
    pub backup: Option<Backup>,

    /// Query performance factor
    #[serde(skip_serializing_if = "Option::is_none")]
    pub query_performance_factor: Option<String>,
}

/// Database backup request message
///
/// # Example
///
/// ```
/// use redis_cloud::flexible::databases::DatabaseBackupRequest;
///
/// let request = DatabaseBackupRequest::builder()
///     .region_name("us-east-1")
///     .build();
/// ```
#[derive(Debug, Clone, Serialize, Deserialize, TypedBuilder)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseBackupRequest {
    /// Subscription ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub subscription_id: Option<i32>,

    /// Database ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub database_id: Option<i32>,

    /// Required for Active-Active databases. Name of the cloud provider region to back up. When backing up an Active-Active database, you must back up each region separately.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub region_name: Option<String>,

    /// Optional. Manually backs up data to this location, instead of the set 'remoteBackup' location.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub adhoc_backup_path: Option<String>,

    /// Read-only on the response; populated by the server with the
    /// operation type (e.g. `"BACKUP_DATABASE"`).
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub command_type: Option<String>,
}

/// Database
///
/// Represents a Redis Cloud database with all known API fields as first-class struct members.
/// The `extra` field is reserved only for truly unknown/future fields that may be added to the API.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct Database {
    /// Database ID - always present in API responses
    pub database_id: i32,

    /// Database name
    #[serde(skip_serializing_if = "Option::is_none")]
    pub name: Option<String>,

    /// Database status (e.g., "active", "pending", "error", "draft")
    #[serde(skip_serializing_if = "Option::is_none")]
    pub status: Option<String>,

    /// Cloud provider (e.g., "AWS", "GCP", "Azure")
    #[serde(skip_serializing_if = "Option::is_none")]
    pub provider: Option<String>,

    /// Cloud region (e.g., "us-east-1", "europe-west1")
    #[serde(skip_serializing_if = "Option::is_none")]
    pub region: Option<String>,

    /// Redis version (e.g., "7.2", "7.0")
    #[serde(skip_serializing_if = "Option::is_none")]
    pub redis_version: Option<String>,

    /// Redis Serialization Protocol version
    #[serde(skip_serializing_if = "Option::is_none")]
    pub resp_version: Option<String>,

    /// Total memory limit in GB (including replication and overhead)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub memory_limit_in_gb: Option<f64>,

    /// Dataset size in GB (actual data size, excluding replication)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub dataset_size_in_gb: Option<f64>,

    /// Memory used in MB
    #[serde(skip_serializing_if = "Option::is_none")]
    pub memory_used_in_mb: Option<f64>,

    /// Private endpoint for database connections
    #[serde(skip_serializing_if = "Option::is_none")]
    pub private_endpoint: Option<String>,

    /// Public endpoint for database connections (if enabled)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub public_endpoint: Option<String>,

    /// TCP port on which the database is available
    #[serde(skip_serializing_if = "Option::is_none")]
    pub port: Option<i32>,

    /// Data eviction policy (e.g., "volatile-lru", "allkeys-lru", "noeviction")
    #[serde(skip_serializing_if = "Option::is_none")]
    pub data_eviction_policy: Option<String>,

    /// Data persistence setting (e.g., "aof-every-1-sec", "snapshot-every-1-hour", "none")
    #[serde(skip_serializing_if = "Option::is_none")]
    pub data_persistence: Option<String>,

    /// Whether replication is enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub replication: Option<bool>,

    /// Protocol used (e.g., "redis", "memcached")
    #[serde(skip_serializing_if = "Option::is_none")]
    pub protocol: Option<String>,

    /// Support for OSS Cluster API
    #[serde(skip_serializing_if = "Option::is_none")]
    pub support_oss_cluster_api: Option<bool>,

    /// Use external endpoint for OSS Cluster API
    #[serde(skip_serializing_if = "Option::is_none")]
    pub use_external_endpoint_for_oss_cluster_api: Option<bool>,

    /// Whether TLS is enabled for connections
    #[serde(skip_serializing_if = "Option::is_none")]
    pub enable_tls: Option<bool>,

    /// Throughput measurement configuration
    #[serde(skip_serializing_if = "Option::is_none")]
    pub throughput_measurement: Option<DatabaseThroughputSpec>,

    /// Local throughput measurement for Active-Active databases
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_throughput_measurement: Option<Vec<LocalThroughput>>,

    /// Average item size in bytes (for Auto Tiering)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub average_item_size_in_bytes: Option<i64>,

    /// Path to periodic backup storage location
    #[serde(skip_serializing_if = "Option::is_none")]
    pub periodic_backup_path: Option<String>,

    /// Remote backup configuration
    #[serde(skip_serializing_if = "Option::is_none")]
    pub remote_backup: Option<DatabaseBackupConfig>,

    /// List of source IP addresses or subnet masks allowed to connect
    #[serde(skip_serializing_if = "Option::is_none")]
    pub source_ip: Option<Vec<String>>,

    /// Client TLS/SSL certificate (deprecated, use `client_tls_certificates`)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub client_ssl_certificate: Option<String>,

    /// List of client TLS/SSL certificates for mTLS authentication
    #[serde(skip_serializing_if = "Option::is_none")]
    pub client_tls_certificates: Option<Vec<DatabaseCertificateSpec>>,

    /// Database password (masked in responses for security)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub password: Option<String>,

    /// Memcached SASL username
    #[serde(skip_serializing_if = "Option::is_none")]
    pub sasl_username: Option<String>,

    /// Memcached SASL password (masked in responses)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub sasl_password: Option<String>,

    /// Database alert configurations
    #[serde(skip_serializing_if = "Option::is_none")]
    pub alerts: Option<Vec<DatabaseAlertSpec>>,

    /// Redis modules/capabilities enabled on this database
    #[serde(skip_serializing_if = "Option::is_none")]
    pub modules: Option<Vec<DatabaseModuleSpec>>,

    /// Database hashing policy for clustering
    #[serde(skip_serializing_if = "Option::is_none")]
    pub sharding_type: Option<String>,

    /// Query performance factor (for search and query databases)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub query_performance_factor: Option<String>,

    /// List of databases this database is a replica of
    #[serde(skip_serializing_if = "Option::is_none")]
    pub replica_of: Option<Vec<String>>,

    /// Replica configuration
    #[serde(skip_serializing_if = "Option::is_none")]
    pub replica: Option<ReplicaOfSpec>,

    /// Whether default Redis user is enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub enable_default_user: Option<bool>,

    /// Whether this is an Active-Active (CRDB) database
    #[serde(skip_serializing_if = "Option::is_none")]
    pub active_active_redis: Option<bool>,

    /// Memory storage type: "ram" or "ram-and-flash" (Auto Tiering)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub memory_storage: Option<String>,

    /// Redis version compliance status
    #[serde(skip_serializing_if = "Option::is_none")]
    pub redis_version_compliance: Option<String>,

    /// Whether automatic minor version upgrades are enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub auto_minor_version_upgrade: Option<bool>,

    /// Number of shards in the database cluster
    #[serde(skip_serializing_if = "Option::is_none")]
    pub number_of_shards: Option<i32>,

    /// Regex rules for custom hashing policy
    #[serde(skip_serializing_if = "Option::is_none")]
    pub regex_rules: Option<Vec<RegexRule>>,

    /// Whether SSL client authentication is enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub ssl_client_authentication: Option<bool>,

    /// Whether TLS client authentication is enabled
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tls_client_authentication: Option<bool>,

    /// Timestamp when the database was activated.
    ///
    /// Wire field is `activatedOn` per the OpenAPI spec. The previous Rust
    /// name (`activated`) serialized as `activated`, so real responses
    /// silently deserialized to `None`.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub activated_on: Option<String>,

    /// Timestamp of last modification
    #[serde(skip_serializing_if = "Option::is_none")]
    pub last_modified: Option<String>,

    /// HATEOAS links for API navigation
    #[serde(skip_serializing_if = "Option::is_none")]
    pub links: Option<Vec<Link>>,
}

/// Optional. Changes Redis database alert details.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct DatabaseAlertSpec {
    /// Alert type. Available options depend on Plan type. See [Configure alerts](https://redis.io/docs/latest/operate/rc/databases/monitor-performance/#configure-metric-alerts) for more information.
    pub name: String,

    /// Value over which an alert will be sent. Default values and range depend on the alert type. See [Configure alerts](https://redis.io/docs/latest/operate/rc/databases/monitor-performance/#configure-metric-alerts) for more information.
    pub value: i32,
}

/// Request structure for creating a new Pro database
///
/// Contains all configuration options for creating a database in a Pro subscription,
/// including memory settings, replication, persistence, modules, and networking.
///
/// # Example
///
/// ```
/// use redis_cloud::flexible::databases::DatabaseCreateRequest;
///
/// let request = DatabaseCreateRequest::builder()
///     .name("my-database")
///     .memory_limit_in_gb(1.0)
///     .replication(true)
///     .build();
/// ```
#[derive(Debug, Clone, Serialize, Deserialize, TypedBuilder)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseCreateRequest {
    /// Subscription ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub subscription_id: Option<i32>,

    /// Optional. When 'false': Creates a deployment plan and deploys it, creating any resources required by the plan. When 'true': creates a read-only deployment plan and does not create any resources. Default: 'false'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub dry_run: Option<bool>,

    /// Name of the database. Database name is limited to 40 characters or less and must include only letters, digits, and hyphens ('-'). It must start with a letter and end with a letter or digit.
    #[builder(setter(into))]
    pub name: String,

    /// Optional. Database protocol. Only set to 'memcached' if you have a legacy application. Default: 'redis'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub protocol: Option<String>,

    /// Optional. TCP port on which the database is available (10000-19999). Generated automatically if not set.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub port: Option<i32>,

    /// Optional. Total memory in GB, including replication and other overhead. You cannot set both datasetSizeInGb and totalMemoryInGb.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub memory_limit_in_gb: Option<f64>,

    /// Optional. The maximum amount of data in the dataset for this database in GB. You cannot set both datasetSizeInGb and totalMemoryInGb. If 'replication' is 'true', the database's total memory will be twice as large as the datasetSizeInGb. If 'replication' is false, the database's total memory will be the datasetSizeInGb value.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub dataset_size_in_gb: Option<f64>,

    /// Optional. If specified, redisVersion defines the Redis database version. If omitted, the Redis version will be set to the default version (available in 'GET /subscriptions/redis-versions')
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub redis_version: Option<String>,

    /// Optional. Redis Serialization Protocol version. Must be compatible with Redis version.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub resp_version: Option<String>,

    /// Optional. Support [OSS Cluster API](https://redis.io/docs/latest/operate/rc/databases/configuration/clustering/#oss-cluster-api). Default: 'false'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub support_oss_cluster_api: Option<bool>,

    /// Optional. If set to 'true', the database will use the external endpoint for OSS Cluster API. This setting blocks the database's private endpoint. Can only be set if 'supportOSSClusterAPI' is 'true'. Default: 'false'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub use_external_endpoint_for_oss_cluster_api: Option<bool>,

    /// Optional. Type and rate of data persistence in persistent storage. Default: 'none'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub data_persistence: Option<String>,

    /// Optional. Data eviction policy. Default: 'volatile-lru'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub data_eviction_policy: Option<String>,

    /// Optional. Sets database replication. Default: 'true'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub replication: Option<bool>,

    /// Optional. This database will be a replica of the specified Redis databases provided as one or more URI(s). Example: 'redis://user:password@host:port'. If the URI provided is a Redis Cloud database, only host and port should be provided. Example: ['<redis://endpoint1:6379>', '<redis://endpoint2:6380>'].
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub replica_of: Option<Vec<String>>,

    /// Optional. Replica-of (Active-Passive) configuration. See [`ReplicaOfSpec`].
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub replica: Option<ReplicaOfSpec>,

    /// Optional. Throughput measurement spec. See [`DatabaseThroughputSpec`].
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub throughput_measurement: Option<DatabaseThroughputSpec>,

    /// Optional. Expected throughput per region for an Active-Active database. Default: 1000 read and write ops/sec for each region
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub local_throughput_measurement: Option<Vec<LocalThroughput>>,

    /// Optional. Relevant only to ram-and-flash (also known as Auto Tiering) subscriptions. Estimated average size in bytes of the items stored in the database. Default: 1000
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub average_item_size_in_bytes: Option<i64>,

    /// Optional. The path to a backup storage location. If specified, the database will back up every 24 hours to this location, and you can manually back up the database to this location at any time.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub periodic_backup_path: Option<String>,

    /// Optional. Remote backup configuration. See [`DatabaseBackupConfig`].
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub remote_backup: Option<DatabaseBackupConfig>,

    /// Optional. List of source IP addresses or subnet masks to allow. If specified, Redis clients will be able to connect to this database only from within the specified source IP addresses ranges. Example: '['192.168.10.0/32', '192.168.12.0/24']'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub source_ip: Option<Vec<String>>,

    /// Optional. A public key client TLS/SSL certificate with new line characters replaced with '\n'. If specified, mTLS authentication will be required to authenticate user connections. Default: 'null'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub client_ssl_certificate: Option<String>,

    /// Optional. A list of client TLS/SSL certificates. If specified, mTLS authentication will be required to authenticate user connections.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub client_tls_certificates: Option<Vec<DatabaseCertificateSpec>>,

    /// Optional. When 'true', requires TLS authentication for all connections - mTLS with valid clientTlsCertificates, regular TLS when clientTlsCertificates is not provided. Default: 'false'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub enable_tls: Option<bool>,

    /// Optional. Password to access the database. If not set, a random 32-character alphanumeric password will be automatically generated. Can only be set if 'protocol' is 'redis'.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub password: Option<String>,

    /// Optional. Memcached (SASL) Username to access the database. If not set, the username will be set to a 'mc-' prefix followed by a random 5 character long alphanumeric. Can only be set if 'protocol' is 'memcached'.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub sasl_username: Option<String>,

    /// Optional. Memcached (SASL) Password to access the database. If not set, a random 32 character long alphanumeric password will be automatically generated. Can only be set if 'protocol' is 'memcached'.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub sasl_password: Option<String>,

    /// Optional. Redis database alert details.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub alerts: Option<Vec<DatabaseAlertSpec>>,

    /// Optional. Redis advanced capabilities (also known as modules) to be provisioned in the database. Use GET /database-modules to get a list of available advanced capabilities.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub modules: Option<Vec<DatabaseModuleSpec>>,

    /// Optional. Database [Hashing policy](https://redis.io/docs/latest/operate/rc/databases/configuration/clustering/#manage-the-hashing-policy).
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub sharding_type: Option<String>,

    /// Read-only on the response; populated by the server with the
    /// operation type (e.g. `"CREATE_DATABASE"`).
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub command_type: Option<String>,

    /// Optional. The query performance factor adds extra compute power specifically for search and query databases. You can increase your queries per second by the selected factor.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub query_performance_factor: Option<String>,
}

/// Database import request
///
/// # Example
///
/// ```
/// use redis_cloud::flexible::databases::DatabaseImportRequest;
///
/// let request = DatabaseImportRequest::builder()
///     .source_type("aws-s3")
///     .import_from_uri(vec!["s3://bucket/backup.rdb".to_string()])
///     .build();
/// ```
#[derive(Debug, Clone, Serialize, Deserialize, TypedBuilder)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseImportRequest {
    /// Subscription ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub subscription_id: Option<i32>,

    /// Database ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub database_id: Option<i32>,

    /// Type of storage from which to import the database RDB file or Redis data.
    #[builder(setter(into))]
    pub source_type: String,

    /// One or more paths to source data files or Redis databases, as appropriate to specified source type.
    pub import_from_uri: Vec<String>,

    /// Read-only on the response; populated by the server with the
    /// operation type (e.g. `"IMPORT_DATABASE"`).
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub command_type: Option<String>,
}

/// Upgrades the specified Pro database to a later Redis version.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseUpgradeRedisVersionRequest {
    /// Database ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub database_id: Option<i32>,

    /// Subscription ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub subscription_id: Option<i32>,

    /// The target Redis version the database will be upgraded to. Use GET /subscriptions/redis-versions to get a list of available Redis versions.
    pub target_redis_version: String,

    /// Read-only on the response; populated by the server with the
    /// operation type (e.g. `"UPGRADE_DATABASE_REDIS_VERSION"`).
    #[serde(skip_serializing_if = "Option::is_none")]
    pub command_type: Option<String>,
}

/// `DatabaseSlowLogEntries`
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct DatabaseSlowLogEntries {
    /// Slowlog entries returned for the database.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub entries: Option<Vec<DatabaseSlowLogEntry>>,

    /// HATEOAS links
    #[serde(skip_serializing_if = "Option::is_none")]
    pub links: Option<Vec<Link>>,
}

/// Optional. A list of regions and local settings to update.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct LocalRegionProperties {
    /// Required. Name of the region to update.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub region: Option<String>,

    /// Optional. Remote backup configuration for this region. See [`DatabaseBackupConfig`].
    #[serde(skip_serializing_if = "Option::is_none")]
    pub remote_backup: Option<DatabaseBackupConfig>,

    /// Optional. Local throughput settings for this region. See [`LocalThroughput`].
    #[serde(skip_serializing_if = "Option::is_none")]
    pub local_throughput_measurement: Option<LocalThroughput>,

    /// Optional. Type and rate of data persistence for this region. If set, 'globalDataPersistence' will not apply to this region.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub data_persistence: Option<String>,

    /// Optional. Changes the password used to access the database in this region. If set, 'globalPassword' will not apply to this region.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub password: Option<String>,

    /// Optional. List of source IP addresses or subnet masks to allow in this region. If set, Redis clients will be able to connect to the database in this region only from within the specified source IP addresses ranges, and 'globalSourceIp' will not apply to this region. Example: ['192.168.10.0/32', '192.168.12.0/24']
    #[serde(skip_serializing_if = "Option::is_none")]
    pub source_ip: Option<Vec<String>>,

    /// Optional. Redis database alert settings for this region. If set, 'glboalAlerts' will not apply to this region.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub alerts: Option<Vec<DatabaseAlertSpec>>,

    /// Optional. Redis Serialization Protocol version for this region. Must be compatible with Redis version.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub resp_version: Option<String>,
}

/// Database update request
///
/// # Example
///
/// ```
/// use redis_cloud::flexible::databases::DatabaseUpdateRequest;
///
/// let request = DatabaseUpdateRequest::builder()
///     .name("updated-name")
///     .memory_limit_in_gb(2.0)
///     .build();
/// ```
#[derive(Debug, Clone, Serialize, Deserialize, TypedBuilder)]
#[serde(rename_all = "camelCase")]
pub struct DatabaseUpdateRequest {
    /// Subscription ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub subscription_id: Option<i32>,

    /// Database ID being updated. Server-populated from the path.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub database_id: Option<i32>,

    /// Optional. When 'false': Creates a deployment plan and deploys it, updating any resources required by the plan. When 'true': creates a read-only deployment plan and does not update any resources. Default: 'false'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub dry_run: Option<bool>,

    /// Optional. Updated database name.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub name: Option<String>,

    /// Optional. Total memory in GB, including replication and other overhead. You cannot set both datasetSizeInGb and totalMemoryInGb.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub memory_limit_in_gb: Option<f64>,

    /// Optional. The maximum amount of data in the dataset for this database in GB. You cannot set both datasetSizeInGb and totalMemoryInGb. If 'replication' is 'true', the database's total memory will be twice as large as the datasetSizeInGb.If 'replication' is false, the database's total memory will be the datasetSizeInGb value.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub dataset_size_in_gb: Option<f64>,

    /// Optional. Redis Serialization Protocol version. Must be compatible with Redis version.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub resp_version: Option<String>,

    /// Optional. Throughput measurement spec. See [`DatabaseThroughputSpec`].
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub throughput_measurement: Option<DatabaseThroughputSpec>,

    /// Optional. Type and rate of data persistence in persistent storage.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub data_persistence: Option<String>,

    /// Optional. Data eviction policy.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub data_eviction_policy: Option<String>,

    /// Optional. Turns database replication on or off.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub replication: Option<bool>,

    /// Optional. Hashing policy Regex rules. Used only if 'shardingType' is 'custom-regex-rules'.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub regex_rules: Option<Vec<String>>,

    /// Optional. This database will be a replica of the specified Redis databases provided as one or more URI(s). Example: 'redis://user:password@host:port'. If the URI provided is a Redis Cloud database, only host and port should be provided. Example: ['<redis://endpoint1:6379>', '<redis://endpoint2:6380>'].
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub replica_of: Option<Vec<String>>,

    /// Optional. Replica-of (Active-Passive) configuration. See [`ReplicaOfSpec`].
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub replica: Option<ReplicaOfSpec>,

    /// Optional. Support Redis [OSS Cluster API](https://redis.io/docs/latest/operate/rc/databases/configuration/clustering/#oss-cluster-api).
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub support_oss_cluster_api: Option<bool>,

    /// Optional. If set to 'true', the database will use the external endpoint for OSS Cluster API. This setting blocks the database's private endpoint. Can only be set if 'supportOSSClusterAPI' is 'true'.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub use_external_endpoint_for_oss_cluster_api: Option<bool>,

    /// Optional. Changes the password used to access the database with the 'default' user. Can only be set if 'protocol' is 'redis'.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub password: Option<String>,

    /// Optional. Changes the Memcached (SASL) username to access the database. Can only be set if 'protocol' is 'memcached'.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub sasl_username: Option<String>,

    /// Optional. Changes the Memcached (SASL) password to access the database. Can only be set if 'protocol' is 'memcached'.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub sasl_password: Option<String>,

    /// Optional. List of source IP addresses or subnet masks to allow. If specified, Redis clients will be able to connect to this database only from within the specified source IP addresses ranges. Example: '['192.168.10.0/32', '192.168.12.0/24']'
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub source_ip: Option<Vec<String>>,

    /// Optional. A public key client TLS/SSL certificate with new line characters replaced with '\n'. If specified, mTLS authentication will be required to authenticate user connections if it is not already required. If set to an empty string, TLS client certificates will be removed and mTLS will not be required. TLS connection may still apply, depending on the value of 'enableTls'.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub client_ssl_certificate: Option<String>,

    /// Optional. A list of client TLS/SSL certificates. If specified, mTLS authentication will be required to authenticate user connections. If set to an empty list, TLS client certificates will be removed and mTLS will not be required. TLS connection may still apply, depending on the value of 'enableTls'.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub client_tls_certificates: Option<Vec<DatabaseCertificateSpec>>,

    /// Optional. When 'true', requires TLS authentication for all connections - mTLS with valid clientTlsCertificates, regular TLS when clientTlsCertificates is not provided. If enableTls is set to 'false' while mTLS is required, it will remove the mTLS requirement and erase previously provided clientTlsCertificates.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub enable_tls: Option<bool>,

    /// Optional. When 'true', allows connecting to the database with the 'default' user. When 'false', only defined access control users can connect to the database. Can only be set if 'protocol' is 'redis'.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub enable_default_user: Option<bool>,

    /// Optional. Changes the backup location path. If specified, the database will back up every 24 hours to this location, and you can manually back up the database to this location at any time. If set to an empty string, the backup path will be removed.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub periodic_backup_path: Option<String>,

    /// Optional. Remote backup configuration. See [`DatabaseBackupConfig`].
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub remote_backup: Option<DatabaseBackupConfig>,

    /// Optional. Changes Redis database alert details.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option))]
    pub alerts: Option<Vec<DatabaseAlertSpec>>,

    /// Read-only on the response; populated by the server with the
    /// operation type (e.g. `"UPDATE_DATABASE"`).
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub command_type: Option<String>,

    /// Optional. Changes the query performance factor. The query performance factor adds extra compute power specifically for search and query databases. You can increase your queries per second by the selected factor.
    #[serde(skip_serializing_if = "Option::is_none")]
    #[builder(default, setter(strip_option, into))]
    pub query_performance_factor: Option<String>,
}

// ============================================================================
// Handler
// ============================================================================

/// Handler for Pro database operations
///
/// Manages database lifecycle, configuration, backup/restore, import/export,
/// and monitoring for Redis Cloud Pro subscriptions.
pub struct DatabaseHandler {
    client: CloudClient,
}

impl DatabaseHandler {
    /// Create a new handler
    #[must_use]
    pub fn new(client: CloudClient) -> Self {
        Self { client }
    }

    /// Get all databases in a Pro subscription
    ///
    /// Gets a list of all databases in the specified Pro subscription.
    ///
    /// GET /subscriptions/{subscriptionId}/databases
    ///
    /// # Arguments
    ///
    /// * `subscription_id` - The subscription ID
    /// * `offset` - Optional offset for pagination
    /// * `limit` - Optional limit for pagination
    ///
    /// # Example
    ///
    /// ```no_run
    /// use redis_cloud::CloudClient;
    ///
    /// # async fn example() -> redis_cloud::Result<()> {
    /// let client = CloudClient::builder()
    ///     .api_key("your-api-key")
    ///     .api_secret("your-api-secret")
    ///     .build()?;
    ///
    /// // Get all databases in subscription 123
    /// let databases = client.databases().get_subscription_databases(123, None, None).await?;
    ///
    /// // With pagination
    /// let page = client.databases().get_subscription_databases(123, Some(0), Some(10)).await?;
    /// # Ok(())
    /// # }
    /// ```
    pub async fn get_subscription_databases(
        &self,
        subscription_id: i32,
        offset: Option<i32>,
        limit: Option<i32>,
    ) -> Result<AccountSubscriptionDatabases> {
        let mut query = Vec::new();
        if let Some(v) = offset {
            query.push(format!("offset={v}"));
        }
        if let Some(v) = limit {
            query.push(format!("limit={v}"));
        }
        let query_string = if query.is_empty() {
            String::new()
        } else {
            format!("?{}", query.join("&"))
        };
        self.client
            .get(&format!(
                "/subscriptions/{subscription_id}/databases{query_string}"
            ))
            .await
    }

    /// Create Pro database in existing subscription
    /// Creates a new database in an existing Pro subscription.
    ///
    /// POST /subscriptions/{subscriptionId}/databases
    pub async fn create_database(
        &self,
        subscription_id: i32,
        request: &DatabaseCreateRequest,
    ) -> Result<TaskStateUpdate> {
        self.client
            .post(
                &format!("/subscriptions/{subscription_id}/databases"),
                request,
            )
            .await
    }

    /// Delete Pro database
    /// Deletes a database from a Pro subscription.
    ///
    /// DELETE /subscriptions/{subscriptionId}/databases/{databaseId}
    pub async fn delete_database_by_id(
        &self,
        subscription_id: i32,
        database_id: i32,
    ) -> Result<TaskStateUpdate> {
        let response = self
            .client
            .delete_raw(&format!(
                "/subscriptions/{subscription_id}/databases/{database_id}"
            ))
            .await?;
        serde_json::from_value(response).map_err(Into::into)
    }

    /// Get a single Pro database
    ///
    /// Gets details and settings of a single database in a Pro subscription.
    ///
    /// GET /subscriptions/{subscriptionId}/databases/{databaseId}
    ///
    /// # Example
    ///
    /// ```no_run
    /// use redis_cloud::CloudClient;
    ///
    /// # async fn example() -> redis_cloud::Result<()> {
    /// let client = CloudClient::builder()
    ///     .api_key("your-api-key")
    ///     .api_secret("your-api-secret")
    ///     .build()?;
    ///
    /// let database = client.databases().get_subscription_database_by_id(123, 456).await?;
    ///
    /// println!("Database: {} (status: {:?})",
    ///     database.name.unwrap_or_default(),
    ///     database.status);
    /// # Ok(())
    /// # }
    /// ```
    pub async fn get_subscription_database_by_id(
        &self,
        subscription_id: i32,
        database_id: i32,
    ) -> Result<Database> {
        self.client
            .get(&format!(
                "/subscriptions/{subscription_id}/databases/{database_id}"
            ))
            .await
    }

    /// Update Pro database
    /// Updates an existing Pro database.
    ///
    /// PUT /subscriptions/{subscriptionId}/databases/{databaseId}
    pub async fn update_database(
        &self,
        subscription_id: i32,
        database_id: i32,
        request: &DatabaseUpdateRequest,
    ) -> Result<TaskStateUpdate> {
        self.client
            .put(
                &format!("/subscriptions/{subscription_id}/databases/{database_id}"),
                request,
            )
            .await
    }

    /// Get Pro database backup status
    /// Gets information on the latest backup attempt for this Pro database.
    ///
    /// GET /subscriptions/{subscriptionId}/databases/{databaseId}/backup
    pub async fn get_database_backup_status(
        &self,
        subscription_id: i32,
        database_id: i32,
        region_name: Option<String>,
    ) -> Result<TaskStateUpdate> {
        let mut query = Vec::new();
        if let Some(v) = region_name {
            query.push(format!("regionName={v}"));
        }
        let query_string = if query.is_empty() {
            String::new()
        } else {
            format!("?{}", query.join("&"))
        };
        self.client
            .get(&format!(
                "/subscriptions/{subscription_id}/databases/{database_id}/backup{query_string}"
            ))
            .await
    }

    /// Back up Pro database
    /// Manually back up the specified Pro database to a backup path. By default, backups will be stored in the 'remoteBackup' location for this database.
    ///
    /// POST /subscriptions/{subscriptionId}/databases/{databaseId}/backup
    pub async fn backup_database(
        &self,
        subscription_id: i32,
        database_id: i32,
        request: &DatabaseBackupRequest,
    ) -> Result<TaskStateUpdate> {
        self.client
            .post(
                &format!("/subscriptions/{subscription_id}/databases/{database_id}/backup"),
                request,
            )
            .await
    }

    /// Get Pro database TLS certificate
    /// Gets the X.509 PEM (base64) encoded server certificate for TLS connection to the database. Requires 'enableTLS' to be 'true' for the database.
    ///
    /// GET /subscriptions/{subscriptionId}/databases/{databaseId}/certificate
    pub async fn get_subscription_database_certificate(
        &self,
        subscription_id: i32,
        database_id: i32,
    ) -> Result<DatabaseCertificate> {
        self.client
            .get(&format!(
                "/subscriptions/{subscription_id}/databases/{database_id}/certificate"
            ))
            .await
    }

    /// Flush Pro database
    /// Deletes all data from the specified Pro database.
    ///
    /// PUT /subscriptions/{subscriptionId}/databases/{databaseId}/flush
    pub async fn flush_crdb(
        &self,
        subscription_id: i32,
        database_id: i32,
        request: &CrdbFlushRequest,
    ) -> Result<TaskStateUpdate> {
        self.client
            .put(
                &format!("/subscriptions/{subscription_id}/databases/{database_id}/flush"),
                request,
            )
            .await
    }

    /// Get Pro database import status
    /// Gets information on the latest import attempt for this Pro database.
    ///
    /// GET /subscriptions/{subscriptionId}/databases/{databaseId}/import
    pub async fn get_database_import_status(
        &self,
        subscription_id: i32,
        database_id: i32,
    ) -> Result<TaskStateUpdate> {
        self.client
            .get(&format!(
                "/subscriptions/{subscription_id}/databases/{database_id}/import"
            ))
            .await
    }

    /// Import data to a Pro database
    /// Imports data from an RDB file or from a different Redis database into this Pro database. WARNING: Importing data into a database removes all existing data from the database.
    ///
    /// POST /subscriptions/{subscriptionId}/databases/{databaseId}/import
    pub async fn import_database(
        &self,
        subscription_id: i32,
        database_id: i32,
        request: &DatabaseImportRequest,
    ) -> Result<TaskStateUpdate> {
        self.client
            .post(
                &format!("/subscriptions/{subscription_id}/databases/{database_id}/import"),
                request,
            )
            .await
    }

    /// Update Active-Active database
    /// (Active-Active databases only) Updates database properties for an Active-Active database.
    ///
    /// PUT /subscriptions/{subscriptionId}/databases/{databaseId}/regions
    pub async fn update_crdb_local_properties(
        &self,
        subscription_id: i32,
        database_id: i32,
        request: &CrdbUpdatePropertiesRequest,
    ) -> Result<TaskStateUpdate> {
        self.client
            .put(
                &format!("/subscriptions/{subscription_id}/databases/{database_id}/regions"),
                request,
            )
            .await
    }

    /// Get database slowlog
    /// Gets the slowlog for a specific database.
    ///
    /// GET /subscriptions/{subscriptionId}/databases/{databaseId}/slow-log
    pub async fn get_slow_log(
        &self,
        subscription_id: i32,
        database_id: i32,
        region_name: Option<String>,
    ) -> Result<DatabaseSlowLogEntries> {
        let mut query = Vec::new();
        if let Some(v) = region_name {
            query.push(format!("regionName={v}"));
        }
        let query_string = if query.is_empty() {
            String::new()
        } else {
            format!("?{}", query.join("&"))
        };
        self.client
            .get(&format!(
                "/subscriptions/{subscription_id}/databases/{database_id}/slow-log{query_string}"
            ))
            .await
    }

    /// Get database tags
    /// Gets a list of all database tags.
    ///
    /// GET /subscriptions/{subscriptionId}/databases/{databaseId}/tags
    pub async fn get_tags(&self, subscription_id: i32, database_id: i32) -> Result<CloudTags> {
        self.client
            .get(&format!(
                "/subscriptions/{subscription_id}/databases/{database_id}/tags"
            ))
            .await
    }

    /// Add a database tag
    /// Adds a single database tag to a database.
    ///
    /// POST /subscriptions/{subscriptionId}/databases/{databaseId}/tags
    pub async fn create_tag(
        &self,
        subscription_id: i32,
        database_id: i32,
        request: &DatabaseTagCreateRequest,
    ) -> Result<CloudTag> {
        self.client
            .post(
                &format!("/subscriptions/{subscription_id}/databases/{database_id}/tags"),
                request,
            )
            .await
    }

    /// Overwrite database tags
    /// Overwrites all tags on the database.
    ///
    /// PUT /subscriptions/{subscriptionId}/databases/{databaseId}/tags
    pub async fn update_tags(
        &self,
        subscription_id: i32,
        database_id: i32,
        request: &DatabaseTagsUpdateRequest,
    ) -> Result<CloudTags> {
        self.client
            .put(
                &format!("/subscriptions/{subscription_id}/databases/{database_id}/tags"),
                request,
            )
            .await
    }

    /// Delete database tag
    /// Removes the specified tag from the database.
    ///
    /// DELETE /subscriptions/{subscriptionId}/databases/{databaseId}/tags/{tagKey}
    pub async fn delete_tag(
        &self,
        subscription_id: i32,
        database_id: i32,
        tag_key: String,
    ) -> Result<HashMap<String, Value>> {
        let response = self
            .client
            .delete_raw(&format!(
                "/subscriptions/{subscription_id}/databases/{database_id}/tags/{tag_key}"
            ))
            .await?;
        serde_json::from_value(response).map_err(Into::into)
    }

    /// Update database tag value
    /// Updates the value of the specified database tag.
    ///
    /// PUT /subscriptions/{subscriptionId}/databases/{databaseId}/tags/{tagKey}
    pub async fn update_tag(
        &self,
        subscription_id: i32,
        database_id: i32,
        tag_key: String,
        request: &DatabaseTagUpdateRequest,
    ) -> Result<CloudTag> {
        self.client
            .put(
                &format!("/subscriptions/{subscription_id}/databases/{database_id}/tags/{tag_key}"),
                request,
            )
            .await
    }

    /// Get Pro database version upgrade status
    /// Gets information on the latest upgrade attempt for this Pro database.
    ///
    /// GET /subscriptions/{subscriptionId}/databases/{databaseId}/upgrade
    pub async fn get_database_redis_version_upgrade_status(
        &self,
        subscription_id: i32,
        database_id: i32,
    ) -> Result<BdbVersionUpgradeStatus> {
        self.client
            .get(&format!(
                "/subscriptions/{subscription_id}/databases/{database_id}/upgrade"
            ))
            .await
    }

    /// Upgrade Pro database version
    ///
    /// POST /subscriptions/{subscriptionId}/databases/{databaseId}/upgrade
    pub async fn upgrade_database_redis_version(
        &self,
        subscription_id: i32,
        database_id: i32,
        request: &DatabaseUpgradeRedisVersionRequest,
    ) -> Result<TaskStateUpdate> {
        self.client
            .post(
                &format!("/subscriptions/{subscription_id}/databases/{database_id}/upgrade"),
                request,
            )
            .await
    }

    /// Get available target Redis versions for upgrade
    /// Gets a list of Redis versions that the database can be upgraded to.
    ///
    /// GET /subscriptions/{subscriptionId}/databases/{databaseId}/available-target-versions
    pub async fn get_available_target_versions(
        &self,
        subscription_id: i32,
        database_id: i32,
    ) -> Result<Value> {
        self.client
            .get_raw(&format!(
                "/subscriptions/{subscription_id}/databases/{database_id}/available-target-versions"
            ))
            .await
    }

    /// Flush Pro database (standard, non-Active-Active)
    /// Deletes all data from the specified Pro database.
    ///
    /// PUT /subscriptions/{subscriptionId}/databases/{databaseId}/flush
    pub async fn flush_database(
        &self,
        subscription_id: i32,
        database_id: i32,
    ) -> Result<TaskStateUpdate> {
        // Empty body for standard flush
        self.client
            .put_raw(
                &format!("/subscriptions/{subscription_id}/databases/{database_id}/flush"),
                serde_json::json!({}),
            )
            .await
            .and_then(|v| serde_json::from_value(v).map_err(Into::into))
    }

    // ========================================================================
    // Pagination Helpers
    // ========================================================================

    /// Stream all databases in a Pro subscription
    ///
    /// Returns an async stream that automatically handles pagination, yielding
    /// individual [`Database`] items. This is useful when you need to process
    /// a large number of databases without loading them all into memory at once.
    ///
    /// # Arguments
    ///
    /// * `subscription_id` - The subscription ID
    ///
    /// # Example
    ///
    /// ```no_run
    /// use redis_cloud::CloudClient;
    /// use futures::StreamExt;
    /// use std::pin::pin;
    ///
    /// # async fn example() -> redis_cloud::Result<()> {
    /// let client = CloudClient::builder()
    ///     .api_key("your-api-key")
    ///     .api_secret("your-api-secret")
    ///     .build()?;
    ///
    /// let handler = client.databases();
    /// let mut stream = pin!(handler.stream_databases(123));
    /// while let Some(result) = stream.next().await {
    ///     let database = result?;
    ///     println!("Database: {} (ID: {})", database.name.unwrap_or_default(), database.database_id);
    /// }
    /// # Ok(())
    /// # }
    /// ```
    pub fn stream_databases(
        &self,
        subscription_id: i32,
    ) -> impl Stream<Item = Result<Database>> + '_ {
        self.stream_databases_with_page_size(subscription_id, 100)
    }

    /// Stream all databases with custom page size
    ///
    /// Like [`stream_databases`](Self::stream_databases), but allows specifying
    /// the page size for API requests.
    ///
    /// # Arguments
    ///
    /// * `subscription_id` - The subscription ID
    /// * `page_size` - Number of databases to fetch per API request
    pub fn stream_databases_with_page_size(
        &self,
        subscription_id: i32,
        page_size: i32,
    ) -> impl Stream<Item = Result<Database>> + '_ {
        try_stream! {
            let mut offset = 0;

            loop {
                let response = self
                    .get_subscription_databases(subscription_id, Some(offset), Some(page_size))
                    .await?;

                // Extract databases from the response
                let databases = Self::extract_databases_from_response(&response);

                if databases.is_empty() {
                    break;
                }

                let count = databases.len();
                for db in databases {
                    yield db;
                }

                // If we got fewer than page_size, we've reached the end
                #[allow(clippy::cast_sign_loss)]
                if count < page_size as usize {
                    break;
                }

                offset += page_size;
            }
        }
    }

    /// Get all databases in a subscription (collected)
    ///
    /// Fetches all databases by automatically handling pagination and returns
    /// them as a single vector. Use [`stream_databases`](Self::stream_databases)
    /// if you prefer to process databases one at a time.
    ///
    /// # Arguments
    ///
    /// * `subscription_id` - The subscription ID
    ///
    /// # Example
    ///
    /// ```no_run
    /// use redis_cloud::CloudClient;
    ///
    /// # async fn example() -> redis_cloud::Result<()> {
    /// let client = CloudClient::builder()
    ///     .api_key("your-api-key")
    ///     .api_secret("your-api-secret")
    ///     .build()?;
    ///
    /// let all_databases = client.databases().get_all_databases(123).await?;
    /// println!("Total databases: {}", all_databases.len());
    /// # Ok(())
    /// # }
    /// ```
    pub async fn get_all_databases(&self, subscription_id: i32) -> Result<Vec<Database>> {
        let mut databases = Vec::new();
        let mut offset = 0;
        let page_size = 100;

        loop {
            let response = self
                .get_subscription_databases(subscription_id, Some(offset), Some(page_size))
                .await?;

            let page = Self::extract_databases_from_response(&response);
            let count = page.len();
            databases.extend(page);

            #[allow(clippy::cast_sign_loss)]
            if count < page_size as usize {
                break;
            }
            offset += page_size;
        }

        Ok(databases)
    }

    /// Extract databases from an `AccountSubscriptionDatabases` response
    fn extract_databases_from_response(response: &AccountSubscriptionDatabases) -> Vec<Database> {
        response
            .subscription
            .first()
            .map(|sub| sub.databases.clone())
            .unwrap_or_default()
    }

    // ========================================================================
    // Simplified API Methods
    // ========================================================================

    /// List databases in a subscription (simplified)
    ///
    /// Returns a flat list of databases, unwrapping the nested API response.
    /// This is a convenience method that wraps [`get_subscription_databases`](Self::get_subscription_databases).
    ///
    /// # Arguments
    ///
    /// * `subscription_id` - The subscription ID
    ///
    /// # Example
    ///
    /// ```no_run
    /// use redis_cloud::CloudClient;
    ///
    /// # async fn example() -> redis_cloud::Result<()> {
    /// let client = CloudClient::builder()
    ///     .api_key("your-api-key")
    ///     .api_secret("your-api-secret")
    ///     .build()?;
    ///
    /// let databases = client.databases().list(123).await?;
    /// for db in databases {
    ///     println!("Database: {} (ID: {})", db.name.unwrap_or_default(), db.database_id);
    /// }
    /// # Ok(())
    /// # }
    /// ```
    pub async fn list(&self, subscription_id: i32) -> Result<Vec<Database>> {
        let response = self
            .get_subscription_databases(subscription_id, None, None)
            .await?;
        Ok(Self::extract_databases_from_response(&response))
    }

    /// Get a database by ID (simplified)
    ///
    /// Alias for [`get_subscription_database_by_id`](Self::get_subscription_database_by_id).
    ///
    /// # Arguments
    ///
    /// * `subscription_id` - The subscription ID
    /// * `database_id` - The database ID
    ///
    /// # Example
    ///
    /// ```no_run
    /// use redis_cloud::CloudClient;
    ///
    /// # async fn example() -> redis_cloud::Result<()> {
    /// let client = CloudClient::builder()
    ///     .api_key("your-api-key")
    ///     .api_secret("your-api-secret")
    ///     .build()?;
    ///
    /// let database = client.databases().get(123, 456).await?;
    /// println!("Database: {} (status: {:?})", database.name.unwrap_or_default(), database.status);
    /// # Ok(())
    /// # }
    /// ```
    pub async fn get(&self, subscription_id: i32, database_id: i32) -> Result<Database> {
        self.get_subscription_database_by_id(subscription_id, database_id)
            .await
    }

    /// Create a database (simplified)
    ///
    /// Alias for [`create_database`](Self::create_database).
    ///
    /// # Arguments
    ///
    /// * `subscription_id` - The subscription ID
    /// * `request` - The database creation request
    ///
    /// # Example
    ///
    /// ```no_run
    /// use redis_cloud::CloudClient;
    /// use redis_cloud::flexible::databases::DatabaseCreateRequest;
    ///
    /// # async fn example() -> redis_cloud::Result<()> {
    /// let client = CloudClient::builder()
    ///     .api_key("your-api-key")
    ///     .api_secret("your-api-secret")
    ///     .build()?;
    ///
    /// let request = DatabaseCreateRequest::builder()
    ///     .name("my-database")
    ///     .memory_limit_in_gb(1.0)
    ///     .build();
    ///
    /// let task = client.databases().create(123, &request).await?;
    /// println!("Task ID: {:?}", task.task_id);
    /// # Ok(())
    /// # }
    /// ```
    pub async fn create(
        &self,
        subscription_id: i32,
        request: &DatabaseCreateRequest,
    ) -> Result<TaskStateUpdate> {
        self.create_database(subscription_id, request).await
    }

    /// Update a database (simplified)
    ///
    /// Alias for [`update_database`](Self::update_database).
    ///
    /// # Arguments
    ///
    /// * `subscription_id` - The subscription ID
    /// * `database_id` - The database ID
    /// * `request` - The database update request
    ///
    /// # Example
    ///
    /// ```no_run
    /// use redis_cloud::CloudClient;
    /// use redis_cloud::flexible::databases::DatabaseUpdateRequest;
    ///
    /// # async fn example() -> redis_cloud::Result<()> {
    /// let client = CloudClient::builder()
    ///     .api_key("your-api-key")
    ///     .api_secret("your-api-secret")
    ///     .build()?;
    ///
    /// let request = DatabaseUpdateRequest::builder()
    ///     .name("updated-name")
    ///     .build();
    ///
    /// let task = client.databases().update(123, 456, &request).await?;
    /// println!("Task ID: {:?}", task.task_id);
    /// # Ok(())
    /// # }
    /// ```
    pub async fn update(
        &self,
        subscription_id: i32,
        database_id: i32,
        request: &DatabaseUpdateRequest,
    ) -> Result<TaskStateUpdate> {
        self.update_database(subscription_id, database_id, request)
            .await
    }

    /// Delete a database (simplified)
    ///
    /// Alias for [`delete_database_by_id`](Self::delete_database_by_id).
    ///
    /// # Arguments
    ///
    /// * `subscription_id` - The subscription ID
    /// * `database_id` - The database ID
    ///
    /// # Example
    ///
    /// ```no_run
    /// use redis_cloud::CloudClient;
    ///
    /// # async fn example() -> redis_cloud::Result<()> {
    /// let client = CloudClient::builder()
    ///     .api_key("your-api-key")
    ///     .api_secret("your-api-secret")
    ///     .build()?;
    ///
    /// let task = client.databases().delete(123, 456).await?;
    /// println!("Task ID: {:?}", task.task_id);
    /// # Ok(())
    /// # }
    /// ```
    pub async fn delete(&self, subscription_id: i32, database_id: i32) -> Result<TaskStateUpdate> {
        self.delete_database_by_id(subscription_id, database_id)
            .await
    }

    /// Get Pro database traffic state
    /// Gets the current traffic state for this Pro database, including whether
    /// traffic is stopped and whether it can be resumed.
    ///
    /// GET /subscriptions/{subscriptionId}/databases/{databaseId}/traffic
    pub async fn get_traffic(
        &self,
        subscription_id: i32,
        database_id: i32,
    ) -> Result<DatabaseTrafficStateResponse> {
        self.client
            .get(&format!(
                "/subscriptions/{subscription_id}/databases/{database_id}/traffic"
            ))
            .await
    }

    /// Resume Pro database traffic
    /// Resumes traffic to this Pro database after it has been stopped.
    ///
    /// POST /subscriptions/{subscriptionId}/databases/{databaseId}/traffic/resume
    pub async fn resume_traffic(&self, subscription_id: i32, database_id: i32) -> Result<()> {
        self.client
            .post(
                &format!("/subscriptions/{subscription_id}/databases/{database_id}/traffic/resume"),
                &serde_json::json!({}),
            )
            .await
    }
}