[restatectl] Use clap_stdin

tools/restatectl/Cargo.toml

@@ -25,6 +25,7 @@ bytestring = { workspace = true }
 chrono = { workspace = true }
 clap = { version = "4.1", features = ["derive", "env", "wrap_help", "color"] }
 clap-verbosity-flag = { version = "2.0.1" }
+clap-stdin = "0.5.1"
 cling = { version = "0.1.0", default-features = false, features = ["derive"] }
 crossterm = { version = "0.27.0" }
 ctrlc = { version = "3.4" }

tools/restatectl/src/commands/metadata/put.rs

@@ -10,11 +10,12 @@
 
 use crate::commands::metadata::patch::{patch_value, PatchValueOpts};
 use crate::commands::metadata::MetadataCommonOpts;
+use anyhow::anyhow;
 use clap::Parser;
+use clap_stdin::FileOrStdin;
 use cling::{Collect, Run};
 use serde_json::Value;
 use std::collections::HashMap;
-use std::fs;
 
 #[derive(Run, Parser, Collect, Clone, Debug)]
 #[clap()]
@@ -27,13 +28,9 @@ pub struct PutValueOpts {
     #[arg(short, long)]
     key: String,
 
-    /// The JSON document to store
+    /// The JSON document to store, can be read from stdin or a file path
     #[arg(short, long)]
-    doc: Option<String>,
-
-    /// The local path to the JSON document to store
-    #[arg(short, long)]
-    path: Option<String>,
+    content: FileOrStdin,
 
     /// Expected version for conditional update
     #[arg(short = 'e', long)]
@@ -47,14 +44,7 @@ pub struct PutValueOpts {
 async fn put_value(opts: &PutValueOpts) -> anyhow::Result<()> {
     let opts = opts.clone();
 
-    let doc_body = if let Some(doc) = opts.doc {
-        doc
-    } else if let Some(path) = opts.path {
-        fs::read_to_string(path)
-            .map_err(|e| anyhow::anyhow!("Unable to read the document: {}", e))?
-    } else {
-        anyhow::bail!("Please specify either doc or path");
-    };
+    let doc_body = opts.content.contents().map_err(|e| anyhow!(e))?;
 
     let mut doc: Value = serde_json::from_str(&doc_body)
         .map_err(|e| anyhow::anyhow!("Parsing JSON value: {}", e))?;