feat: support slurping inputs

Cargo.toml

@@ -9,20 +9,22 @@ license = "Apache-2.0/MIT"
 categories = ["api-bindings"]
 keywords = ["json", "jq", "query"]
 readme = "README.md"
-edition = "2018"
+edition = "2021"
 
 [features]
 default = []
 bundled = ["jq-sys/bundled"]
 
 [dependencies]
+itertools = "0.12.1"
 jq-sys = "0.2.*"
 
 [dev-dependencies]
 criterion = "0.2"
 serde_json = "1.0"
 matches = "0.1.8"
 error-chain = "0.12.*"
+clap = { version = "4.5.4", features = ["derive"] }
 
 [package.metadata.docs.rs]
 features = ["bundled"]

examples/simple-cli.rs

@@ -1,13 +1,46 @@
-extern crate jq_rs;
-use std::env;
+use clap::Parser;
+use jq_rs::Chunks;
 
-fn main() {
-    let mut args = env::args().skip(1);
+#[derive(Parser)]
+struct Args {
+    #[arg(short)]
+    slurp: bool,
+    /// Concatenate multiple inputs together directly, instead of treating them as separate inputs.
+    #[arg(long)]
+    concat: bool,
+    program: String,
+    inputs: Vec<String>,
+}
+
+fn main() -> jq_rs::Result<()> {
+    let args = Args::parse();
 
-    let program = args.next().expect("jq program");
-    let input = args.next().expect("data input");
-    match jq_rs::run(&program, &input) {
-        Ok(s) => print!("{}", s), // The output will include a trailing newline
-        Err(e) => eprintln!("{}", e),
+    let mut program = jq_rs::compile(&args.program)?;
+
+    if args.slurp {
+        let mut outputs = Vec::new();
+        match program.run_slurp(
+            Chunks(
+                args.inputs
+                    .iter()
+                    .map(String::as_bytes)
+                    .flat_map(|input| [input, if args.concat { b"" } else { b"\n" }]),
+            ),
+            |value| outputs.push(value),
+        ) {
+            Ok(()) => {
+                for item in outputs {
+                    println!("{}", item.as_dump_string().unwrap());
+                }
+            },
+            Err(e) => eprintln!("{}", e),
+        }
+    } else {
+        match program.run(args.inputs.get(0).map(String::as_str).unwrap_or("")) {
+            Ok(s) => print!("{}", s), // The output will include a trailing newline
+            Err(e) => eprintln!("{}", e),
+        }
     }
+
+    Ok(())
 }