feat(datasets): Add datasets commands to create, list, and view datasets in CLI

Cargo.toml

@@ -27,6 +27,8 @@ rand = "0.8"
 sha2 = "0.10"
 tiny_http = "0.12"
 comfy-table = "7"
+indicatif = "0.17"
+nix = { version = "0.29", features = ["fs"] }
 flate2 = "1"
 tar = "0.4"
 semver = "1"

src/command.rs

@@ -16,8 +16,19 @@ pub enum Commands {
 
     /// Manage datasets
     Datasets {
+        /// Dataset ID to show details
+        id: Option<String>,
+
+        /// Workspace ID (defaults to first workspace from login)
+        #[arg(long)]
+        workspace_id: Option<String>,
+
+        /// Output format (used with dataset ID)
+        #[arg(long, default_value = "table", value_parser = ["table", "json", "yaml"])]
+        format: String,
+
         #[command(subcommand)]
-        command: DatasetsCommands,
+        command: Option<DatasetsCommands>,
     },
 
     /// Execute a SQL query
@@ -159,111 +170,38 @@ pub enum DatasetsCommands {
         #[arg(long)]
         workspace_id: Option<String>,
 
-        /// Output format
-        #[arg(long, default_value = "yaml", value_parser = ["table", "json", "yaml"])]
-        format: String,
-    },
-
-    /// Get details for a specific dataset
-    Get {
-        /// Workspace ID (defaults to first workspace from login)
-        #[arg(long)]
-        workspace_id: Option<String>,
-
-        /// Dataset ID
-        dataset_id: String,
-
-        /// Output format
-        #[arg(long, default_value = "yaml", value_parser = ["table", "json", "yaml"])]
-        format: String,
-    },
-
-    /// Create a new dataset in a workspace
-    Create {
-        /// Workspace ID (defaults to first workspace from login)
-        #[arg(long)]
-        workspace_id: Option<String>,
-
-        /// Dataset name
-        #[arg(long)]
-        name: String,
-
-        /// SQL query for the dataset
+        /// Maximum number of results (default: 100, max: 1000)
         #[arg(long)]
-        sql: Option<String>,
+        limit: Option<u32>,
 
-        /// Connection ID for the dataset
+        /// Pagination offset
         #[arg(long)]
-        connection_id: Option<String>,
+        offset: Option<u32>,
 
         /// Output format
-        #[arg(long, default_value = "yaml", value_parser = ["table", "json", "yaml"])]
+        #[arg(long, default_value = "table", value_parser = ["table", "json", "yaml"])]
         format: String,
     },
 
-    /// Update a dataset in a workspace
-    Update {
+    /// Create a new dataset from a file or piped stdin
+    Create {
         /// Workspace ID (defaults to first workspace from login)
         #[arg(long)]
         workspace_id: Option<String>,
 
-        /// Dataset ID
-        dataset_id: String,
-
-        /// New dataset name
+        /// Dataset label (derived from filename if omitted)
         #[arg(long)]
-        name: Option<String>,
+        label: Option<String>,
 
-        /// New SQL query for the dataset
+        /// Table name (derived from label if omitted)
         #[arg(long)]
-        query: Option<String>,
-
-        /// Output format
-        #[arg(long, default_value = "yaml", value_parser = ["table", "json", "yaml"])]
-        format: String,
-    },
+        table_name: Option<String>,
 
-    /// Delete a dataset from a workspace
-    Delete {
-        /// Workspace ID (defaults to first workspace from login)
+        /// Path to a file to upload (omit to read from stdin)
         #[arg(long)]
-        workspace_id: Option<String>,
-
-        /// Dataset ID
-        dataset_id: String,
+        file: Option<String>,
     },
 
-    /// Update the SQL query for a dataset
-    UpdateSql {
-        /// Workspace ID (defaults to first workspace from login)
-        #[arg(long)]
-        workspace_id: Option<String>,
-
-        /// Dataset ID
-        dataset_id: String,
-
-        /// New SQL query for the dataset
-        #[arg(long)]
-        sql: String,
-
-        /// Output format
-        #[arg(long, default_value = "yaml", value_parser = ["table", "json", "yaml"])]
-        format: String,
-    },
-
-    /// Execute a dataset
-    Execute {
-        /// Workspace ID (defaults to first workspace from login)
-        #[arg(long)]
-        workspace_id: Option<String>,
-
-        /// Dataset ID
-        dataset_id: String,
-
-        /// Output format
-        #[arg(long, default_value = "yaml", value_parser = ["table", "json", "yaml"])]
-        format: String,
-    },
 }