feat(enterprise): implement job scheduler commands (#162)

- Add Get command to retrieve job scheduler configuration
- Add Update command to modify job scheduler settings
- Support stdin input with '-' flag for JSON data
- Successfully tested against Docker compose environment

Author: joshrotenberg

crates/redisctl/src/cli.rs

@@ -995,6 +995,10 @@ pub enum EnterpriseCommands {
     #[command(subcommand)]
     Crdb(EnterpriseCrdbCommands),
 
+    /// Job scheduler operations
+    #[command(subcommand, name = "job-scheduler")]
+    JobScheduler(crate::commands::enterprise::job_scheduler::JobSchedulerCommands),
+
     /// Log operations
     #[command(subcommand)]
     Logs(crate::commands::enterprise::logs::LogsCommands),

crates/redisctl/src/commands/enterprise/job_scheduler.rs

@@ -0,0 +1,80 @@
+use anyhow::Context;
+use clap::Subcommand;
+
+use crate::cli::OutputFormat;
+use crate::connection::ConnectionManager;
+use crate::error::Result as CliResult;
+
+#[derive(Debug, Clone, Subcommand)]
+pub enum JobSchedulerCommands {
+    /// Get job scheduler configuration/settings
+    Get,
+
+    /// Update job scheduler settings
+    Update {
+        /// JSON data for configuration update (use @filename or - for stdin)
+        #[arg(short, long)]
+        data: String,
+    },
+}
+
+impl JobSchedulerCommands {
+    #[allow(dead_code)]
+    pub async fn execute(
+        &self,
+        conn_mgr: &ConnectionManager,
+        profile_name: Option<&str>,
+        output_format: OutputFormat,
+        query: Option<&str>,
+    ) -> CliResult<()> {
+        let client = conn_mgr.create_enterprise_client(profile_name).await?;
+
+        match self {
+            JobSchedulerCommands::Get => {
+                // Get job scheduler configuration/settings
+                let response: serde_json::Value = client
+                    .get("/v1/job_scheduler")
+                    .await
+                    .context("Failed to get job scheduler settings")?;
+
+                let output_data = if let Some(q) = query {
+                    super::utils::apply_jmespath(&response, q)?
+                } else {
+                    response
+                };
+                super::utils::print_formatted_output(output_data, output_format)?;
+            }
+
+            JobSchedulerCommands::Update { data } => {
+                let json_data = super::utils::read_json_data(data)?;
+
+                let response: serde_json::Value = client
+                    .put("/v1/job_scheduler", &json_data)
+                    .await
+                    .context("Failed to update job scheduler settings")?;
+
+                let output_data = if let Some(q) = query {
+                    super::utils::apply_jmespath(&response, q)?
+                } else {
+                    response
+                };
+                super::utils::print_formatted_output(output_data, output_format)?;
+            }
+        }
+
+        Ok(())
+    }
+}
+
+#[allow(dead_code)]
+pub async fn handle_job_scheduler_command(
+    conn_mgr: &ConnectionManager,
+    profile_name: Option<&str>,
+    job_scheduler_cmd: JobSchedulerCommands,
+    output_format: OutputFormat,
+    query: Option<&str>,
+) -> CliResult<()> {
+    job_scheduler_cmd
+        .execute(conn_mgr, profile_name, output_format, query)
+        .await
+}

crates/redisctl/src/commands/enterprise/mod.rs

@@ -6,6 +6,7 @@ pub mod crdb;
 pub mod crdb_impl;
 pub mod database;
 pub mod database_impl;
+pub mod job_scheduler;
 pub mod logs;
 pub mod logs_impl;
 pub mod module;

crates/redisctl/src/commands/enterprise/utils.rs

@@ -92,12 +92,22 @@ pub fn confirm_action(message: &str) -> CliResult<bool> {
     }
 }
 
-/// Read JSON data from string or file
+/// Read JSON data from string, file, or stdin
 pub fn read_json_data(data: &str) -> CliResult<Value> {
-    let json_str = if let Some(file_path) = data.strip_prefix('@') {
+    let json_str = if data == "-" {
+        // Read from stdin
+        use std::io::Read;
+        let mut buffer = String::new();
+        std::io::stdin()
+            .read_to_string(&mut buffer)
+            .map_err(|e| anyhow::anyhow!("Failed to read from stdin: {}", e))?;
+        buffer
+    } else if let Some(file_path) = data.strip_prefix('@') {
+        // Read from file
         std::fs::read_to_string(file_path)
             .map_err(|e| anyhow::anyhow!("Failed to read file {}: {}", file_path, e))?
     } else {
+        // Direct JSON string
         data.to_string()
     };
 

crates/redisctl/src/main.rs

@@ -244,6 +244,16 @@ async fn execute_enterprise_command(
             )
             .await
         }
+        JobScheduler(job_scheduler_cmd) => {
+            commands::enterprise::job_scheduler::handle_job_scheduler_command(
+                conn_mgr,
+                profile,
+                job_scheduler_cmd.clone(),
+                output,
+                query,
+            )
+            .await
+        }
         Logs(logs_cmd) => {
             commands::enterprise::logs_impl::handle_logs_commands(
                 conn_mgr, profile, logs_cmd, output, query,