flesh out native query cli interface

crates/cli/Cargo.toml

@@ -4,7 +4,7 @@ edition = "2021"
 version.workspace = true
 
 [features]
-native-query-subcommand = []
+native-query-subcommand = ["dep:pretty", "dep:nom"]
 
 [dependencies]
 configuration = { path = "../configuration" }
@@ -19,8 +19,9 @@ futures-util = "0.3.28"
 indexmap = { workspace = true }
 itertools = { workspace = true }
 ndc-models = { workspace = true }
-nom = "^7.1.3"
+nom = { version = "^7.1.3", optional = true }
 nonempty = "^0.10.0"
+pretty = { version = "^0.12.3", features = ["termcolor"], optional = true }
 ref-cast = { workspace = true }
 regex = "^1.11.1"
 serde = { workspace = true }

crates/cli/src/exit_codes.rs

@@ -4,7 +4,9 @@ pub enum ExitCode {
     CouldNotReadConfiguration,
     CouldNotProcessAggregationPipeline,
     ErrorWriting,
+    InvalidArguments,
     RefusedToOverwrite,
+    ResourceNotFound,
 }
 
 impl From<ExitCode> for i32 {
@@ -14,7 +16,9 @@ impl From<ExitCode> for i32 {
             ExitCode::CouldNotReadConfiguration => 202,
             ExitCode::CouldNotProcessAggregationPipeline => 205,
             ExitCode::ErrorWriting => 204,
+            ExitCode::InvalidArguments => 400,
             ExitCode::RefusedToOverwrite => 203,
+            ExitCode::ResourceNotFound => 404,
         }
     }
 }

crates/cli/src/lib.rs

@@ -43,6 +43,7 @@ pub enum Command {
 pub struct Context {
     pub path: PathBuf,
     pub connection_uri: Option<String>,
+    pub display_color: bool,
 }
 
 /// Run a command in a given directory.

crates/cli/src/main.rs

@@ -31,6 +31,10 @@ pub struct Args {
     )]
     pub connection_uri: Option<String>,
 
+    /// Disable color in command output.
+    #[arg(long = "no-color", short = 'C')]
+    pub no_color: bool,
+
     /// The command to invoke.
     #[command(subcommand)]
     pub subcommand: Command,
@@ -49,6 +53,7 @@ pub async fn main() -> anyhow::Result<()> {
     let context = Context {
         path,
         connection_uri: args.connection_uri,
+        display_color: !args.no_color,
     };
     run(args.subcommand, &context).await?;
     Ok(())

crates/cli/src/native_query/error.rs

@@ -87,10 +87,10 @@ pub enum Error {
     #[error("Type inference is not currently implemented for the aggregation expression operator, {0}. Please file a bug report, and declare types for your native query by hand for the time being.")]
     UnknownAggregationOperator(String),
 
-    #[error("Type inference is not currently implemented for {stage}, stage number {} in your aggregation pipeline. Please file a bug report, and declare types for your native query by hand for the time being.", stage_index + 1)]
+    #[error("Type inference is not currently implemented for{} stage number {} in your aggregation pipeline. Please file a bug report, and declare types for your native query by hand for the time being.", match stage_name { Some(name) => format!(" {name},"), None => "".to_string() }, stage_index + 1)]
     UnknownAggregationStage {
         stage_index: usize,
-        stage: bson::Document,
+        stage_name: Option<&'static str>,
     },
 
     #[error("Native query input collection, \"{0}\", is not defined in the connector schema")]