feat(cloud): add upgrade endpoints for Essentials databases (#488)

Adds Redis version upgrade operations for Essentials (fixed) databases:
- Add get_upgrade_status method to FixedDatabaseHandler
- Add upgrade_redis_version method to FixedDatabaseHandler
- Add UpgradeStatus CLI command for fixed-database
- Add UpgradeRedis CLI command for fixed-database with async support
- Add CLI tests for new commands

Closes #470

Author: joshrotenberg

crates/redis-cloud/src/fixed/databases.rs

@@ -1218,4 +1218,45 @@ impl FixedDatabaseHandler {
             ))
             .await
     }
+
+    /// Get Essentials database version upgrade status
+    /// Gets information on the latest upgrade attempt for this Essentials database.
+    ///
+    /// GET /fixed/subscriptions/{subscriptionId}/databases/{databaseId}/upgrade
+    pub async fn get_upgrade_status(
+        &self,
+        subscription_id: i32,
+        database_id: i32,
+    ) -> Result<Value> {
+        self.client
+            .get_raw(&format!(
+                "/fixed/subscriptions/{}/databases/{}/upgrade",
+                subscription_id, database_id
+            ))
+            .await
+    }
+
+    /// Upgrade Essentials database Redis version
+    /// Upgrades the specified Essentials database to a later Redis version.
+    ///
+    /// POST /fixed/subscriptions/{subscriptionId}/databases/{databaseId}/upgrade
+    pub async fn upgrade_redis_version(
+        &self,
+        subscription_id: i32,
+        database_id: i32,
+        target_version: &str,
+    ) -> Result<Value> {
+        let request = serde_json::json!({
+            "targetVersion": target_version
+        });
+        self.client
+            .post_raw(
+                &format!(
+                    "/fixed/subscriptions/{}/databases/{}/upgrade",
+                    subscription_id, database_id
+                ),
+                request,
+            )
+            .await
+    }
 }

crates/redisctl/src/cli/cloud.rs

@@ -656,6 +656,24 @@ pub enum CloudFixedDatabaseCommands {
         /// Database ID (format: subscription_id:database_id)
         id: String,
     },
+    /// Get Redis version upgrade status
+    #[command(name = "upgrade-status")]
+    UpgradeStatus {
+        /// Database ID (format: subscription_id:database_id)
+        id: String,
+    },
+    /// Upgrade Redis version
+    #[command(name = "upgrade-redis")]
+    UpgradeRedis {
+        /// Database ID (format: subscription_id:database_id)
+        id: String,
+        /// Target Redis version
+        #[arg(long)]
+        version: String,
+        /// Async operation options
+        #[command(flatten)]
+        async_ops: crate::commands::cloud::async_utils::AsyncOperationArgs,
+    },
 }
 
 /// Cloud Fixed Subscription Commands

crates/redisctl/src/commands/cloud/fixed_database.rs

@@ -400,6 +400,7 @@ pub async fn handle_fixed_database_command(
             eprintln!("Tag '{}' deleted successfully", key);
             Ok(())
         }
+
         CloudFixedDatabaseCommands::AvailableVersions { id } => {
             let (subscription_id, database_id) = parse_fixed_database_id(id)?;
 
@@ -412,5 +413,41 @@ pub async fn handle_fixed_database_command(
             print_formatted_output(data, output_format)?;
             Ok(())
         }
+
+        CloudFixedDatabaseCommands::UpgradeStatus { id } => {
+            let (subscription_id, database_id) = parse_fixed_database_id(id)?;
+            let result = handler
+                .get_upgrade_status(subscription_id, database_id)
+                .await
+                .context("Failed to get upgrade status")?;
+
+            let data = handle_output(result, output_format, query)?;
+            print_formatted_output(data, output_format)?;
+            Ok(())
+        }
+
+        CloudFixedDatabaseCommands::UpgradeRedis {
+            id,
+            version,
+            async_ops,
+        } => {
+            let (subscription_id, database_id) = parse_fixed_database_id(id)?;
+
+            let result = handler
+                .upgrade_redis_version(subscription_id, database_id, version)
+                .await
+                .context("Failed to upgrade Redis version")?;
+
+            handle_async_response(
+                conn_mgr,
+                profile_name,
+                result,
+                async_ops,
+                output_format,
+                query,
+                "Redis version upgrade initiated",
+            )
+            .await
+        }
     }
 }

crates/redisctl/tests/cli_basic_tests.rs

@@ -2782,3 +2782,29 @@ fn test_cloud_database_update_tag_help() {
         .stdout(predicate::str::contains("--key"))
         .stdout(predicate::str::contains("--value"));
 }
+
+#[test]
+fn test_cloud_fixed_database_upgrade_status_help() {
+    redisctl()
+        .arg("cloud")
+        .arg("fixed-database")
+        .arg("upgrade-status")
+        .arg("--help")
+        .assert()
+        .success()
+        .stdout(predicate::str::contains("upgrade status"))
+        .stdout(predicate::str::contains("subscription_id:database_id"));
+}
+
+#[test]
+fn test_cloud_fixed_database_upgrade_redis_help() {
+    redisctl()
+        .arg("cloud")
+        .arg("fixed-database")
+        .arg("upgrade-redis")
+        .arg("--help")
+        .assert()
+        .success()
+        .stdout(predicate::str::contains("Upgrade Redis version"))
+        .stdout(predicate::str::contains("--version"));
+}