Print output in json format when using global --json flag

src/cmd/bucket/create.rs

@@ -12,6 +12,7 @@ use crate::io::std::output;
 use crate::parse::Resource;
 use clap::{ArgMatches, Command};
 use reduct_rs::ReductClient;
+use serde_json::json;
 
 pub(super) fn create_bucket_cmd() -> Command {
     let cmd = Command::new("create").about("Create a bucket");
@@ -24,16 +25,31 @@ pub(super) async fn create_bucket(ctx: &CliContext, args: &ArgMatches) -> anyhow
         .unwrap()
         .clone()
         .pair()?;
+
+    let is_json = args
+        .try_get_one::<bool>("json")
+        .ok()
+        .flatten()
+        .copied()
+        .unwrap_or(false);
+
     let bucket_settings = parse_bucket_settings(args);
 
     let client: ReductClient = build_client(ctx, &alias_or_url).await?;
+
     client
         .create_bucket(&bucket_name)
         .settings(bucket_settings)
         .send()
         .await?;
 
-    output!(ctx, "Bucket '{}' created", bucket_name);
+    if !is_json {
+        output!(ctx, "Bucket '{}' created", bucket_name);
+    } else {
+        ctx.stdout()
+            .print(serde_json::to_string_pretty(&json!({})).unwrap().as_str());
+    }
+
     Ok(())
 }
 

src/main.rs

@@ -14,6 +14,7 @@ use crate::cmd::alias::{alias_cmd, alias_handler};
 use crate::cmd::attachment::{attachment_cmd, attachment_handler};
 use crate::cmd::write::{write_handler, write_record_cmd};
 use crate::context::ContextBuilder;
+use serde_json::json;
 use std::time::Duration;
 
 use crate::cmd::bucket::{bucket_cmd, bucket_handler};
@@ -69,6 +70,15 @@ fn cli() -> Command {
                 .required(false)
                 .global(true),
         )
+        .arg(
+            Arg::new("json")
+                .long("json")
+                .short('j')
+                .help("Print output in JSON format")
+                .required(false)
+                .action(SetTrue)
+                .global(true),
+        )
         .subcommand(alias_cmd())
         .subcommand(attachment_cmd())
         .subcommand(server_cmd())
@@ -111,10 +121,35 @@ async fn main() -> anyhow::Result<()> {
         _ => Ok(()),
     };
 
+    let command = matches.subcommand().unwrap().0;
+
     if let Err(err) = result {
+        // Do not output json if the command is "cp"
+        if matches.get_flag("json") && command != "cp" {
+            let json_error = print_json_error(&err);
+            eprintln!("{}", serde_json::to_string_pretty(&json_error)?);
+            std::process::exit(1);
+        }
+
         eprintln!("{}", err.to_string().red().bold(),);
         std::process::exit(1);
     }
 
     Ok(())
 }
+
+fn print_json_error(err: &anyhow::Error) -> serde_json::Value {
+    // Try to downcast to ReductError to get the status code
+    let (status_code, error_message) =
+        if let Some(reduct_err) = err.downcast_ref::<reduct_rs::ReductError>() {
+            (reduct_err.status() as i32, reduct_err.message().to_string())
+        } else {
+            // If not a ReductError, use 1 as unknown status
+            (1, err.to_string())
+        };
+
+    json!({
+        "status_code": status_code,
+        "error_message": error_message,
+    })
+}