feat(cli): cut over use to source API

apps/cli/crates/onequery-cli/Cargo.toml

@@ -20,6 +20,9 @@ flate2 = "1.1.5"
 getrandom = "0.3"
 http = "1"
 http-body = "1"
+jaq-core = "3.0.0"
+jaq-json = { version = "2.0.0", features = ["serde"] }
+jaq-std = "3.0.0"
 libc = "0.2.177"
 path-absolutize = { workspace = true }
 regress = "0.10"

apps/cli/crates/onequery-cli/src/cli/args.rs

@@ -1,10 +1,10 @@
 use std::path::PathBuf;
 
+use clap::ArgAction;
 use clap::Args;
 use clap::Subcommand;
 
 use crate::transport::source_connect_provider::SourceConnectProvider;
-use crate::transport::use_source::UseSource;
 
 #[derive(Debug, Clone, Subcommand)]
 pub(crate) enum AuthSubcommand {
@@ -264,12 +264,51 @@ onequery query validate [OPTIONS] --source <SOURCE_KEY> --input <PATH|->
 
 #[derive(Debug, Clone, Args, Eq, PartialEq)]
 pub(crate) struct UseArgs {
-    /// Load skill content for this non-SQL source provider.
-    #[arg(long, value_name = "SOURCE", value_enum)]
-    pub source: UseSource,
-    /// Execute one provider-specific relay request from an inline JSON payload.
-    #[arg(long, value_name = "JSON")]
+    /// Describe or execute this connected source API.
+    #[arg(long, value_name = "SOURCE_KEY")]
+    pub source: String,
+    /// Override the inferred source API operation.
+    #[arg(long, value_name = "OPERATION")]
+    pub op: Option<String>,
+    /// Provide the selector or inferred operation target.
+    #[arg(value_name = "TARGET", allow_hyphen_values = true)]
+    pub target: Option<String>,
+    /// Override the HTTP method for `http_request` operations.
+    #[arg(short = 'X', long, value_name = "METHOD")]
+    pub method: Option<String>,
+    /// Add one request header using `KEY:VALUE`.
+    #[arg(short = 'H', long = "header", value_name = "KEY:VALUE", action = ArgAction::Append)]
+    pub headers: Vec<String>,
+    /// Add one string field patch using `KEY=VALUE`.
+    #[arg(short = 'f', long = "raw-field", value_name = "KEY=VALUE", action = ArgAction::Append)]
+    pub raw_fields: Vec<String>,
+    /// Add one typed field patch using `KEY=VALUE`.
+    #[arg(short = 'F', long = "field", value_name = "KEY=VALUE", action = ArgAction::Append)]
+    pub fields: Vec<String>,
+    /// Read the request body from a file path or stdin (`-`).
+    #[arg(long, value_name = "PATH|-")]
     pub input: Option<String>,
+    /// Follow opaque source API pagination tokens.
+    #[arg(long, default_value_t = false)]
+    pub paginate: bool,
+    /// Combine paginated JSON bodies into one array before rendering.
+    #[arg(long, default_value_t = false)]
+    pub slurp: bool,
+    /// Cap the number of paginated requests the client follows.
+    #[arg(long, value_name = "N")]
+    pub max_pages: Option<u32>,
+    /// Include status and allowed response headers in text output.
+    #[arg(short = 'i', long = "include", default_value_t = false)]
+    pub include: bool,
+    /// Suppress body output.
+    #[arg(long, default_value_t = false)]
+    pub silent: bool,
+    /// Apply a JSON selection expression after response assembly.
+    #[arg(short = 'q', long = "jq", value_name = "EXPR")]
+    pub jq: Option<String>,
+    /// Print the normalized request plan without executing it.
+    #[arg(long, default_value_t = false)]
+    pub dry_run: bool,
 }
 
 #[derive(Debug, Clone, Subcommand)]

apps/cli/crates/onequery-cli/src/cli/mod.rs

@@ -9,14 +9,14 @@ mod raw;
 #[path = "../cli_tests.rs"]
 mod tests;
 
-pub(crate) use crate::transport::use_source::UseSource;
 pub(crate) use args::AuthImportArgs;
 pub(crate) use args::AuthSessionSubcommand;
 pub(crate) use args::AuthSubcommand;
 pub(crate) use args::BackupArgs;
 pub(crate) use args::DebugSubcommand;
 pub(crate) use args::ListReadArgs;
 pub(crate) use args::OrgSubcommand;
+#[cfg(test)]
 pub(crate) use args::PaginationArgs;
 pub(crate) use args::QueryExecuteArgs;
 pub(crate) use args::QueryInputArgs;
@@ -31,6 +31,7 @@ pub(crate) use args::UseArgs;
 pub(crate) use model::Command;
 pub(crate) use model::ConfigCommand;
 pub(crate) use model::GatewayCommand;
+#[cfg(test)]
 pub(crate) use model::GlobalOptions;
 pub(crate) use model::Invocation;
 pub(crate) use model::ParseOutcome;

apps/cli/crates/onequery-cli/src/cli/model.rs

@@ -1,6 +1,6 @@
 use crate::config::RawCliConfigOverrides;
-use crate::output::CommandOutput;
 use crate::output::EffectiveOutputMode;
+use crate::output::TerminalOutput;
 
 use super::args::AuthSessionSubcommand;
 use super::args::AuthSubcommand;
@@ -15,7 +15,7 @@ use super::args::UseArgs;
 #[derive(Debug)]
 pub(crate) enum ParseOutcome {
     Invocation(Box<Invocation>),
-    Display(CommandOutput),
+    Display(TerminalOutput),
 }
 
 #[derive(Debug, Clone)]