experimental batch command in cli

Signed-off-by: Yujong Lee <yujonglee.dev@gmail.com>

Author: yujonglee

apps/cli/src/commands/batch.rs

@@ -0,0 +1,67 @@
+use std::sync::Arc;
+
+use hypr_listener2_core::{BatchEvent, BatchParams, BatchProvider, BatchRuntime};
+
+pub struct Args {
+    pub file: String,
+    pub provider: BatchProvider,
+    pub base_url: String,
+    pub api_key: String,
+    pub model: Option<String>,
+    pub language: String,
+    pub keywords: Vec<String>,
+}
+
+struct CliBatchRuntime;
+
+impl BatchRuntime for CliBatchRuntime {
+    fn emit(&self, event: BatchEvent) {
+        match &event {
+            BatchEvent::BatchStarted { .. } => {
+                eprintln!("Transcribing...");
+            }
+            BatchEvent::BatchResponseStreamed { percentage, .. } => {
+                eprintln!("Progress: {:.0}%", percentage * 100.0);
+            }
+            BatchEvent::BatchResponse { response, .. } => {
+                for channel in &response.results.channels {
+                    for alt in &channel.alternatives {
+                        if !alt.transcript.is_empty() {
+                            println!("{}", alt.transcript);
+                        }
+                    }
+                }
+            }
+            BatchEvent::BatchFailed { error, .. } => {
+                eprintln!("Error: {error}");
+            }
+        }
+    }
+}
+
+pub async fn run(args: Args) {
+    let languages = vec![
+        args.language
+            .parse::<hypr_language::Language>()
+            .expect("invalid language code"),
+    ];
+
+    let session_id = uuid::Uuid::new_v4().to_string();
+    let runtime = Arc::new(CliBatchRuntime);
+
+    let params = BatchParams {
+        session_id,
+        provider: args.provider,
+        file_path: args.file,
+        model: args.model,
+        base_url: args.base_url,
+        api_key: args.api_key,
+        languages,
+        keywords: args.keywords,
+    };
+
+    if let Err(e) = hypr_listener2_core::run_batch(runtime, params).await {
+        eprintln!("Batch transcription failed: {e}");
+        std::process::exit(1);
+    }
+}

apps/cli/src/commands/mod.rs

@@ -1,2 +1,3 @@
 pub mod auth;
+pub mod batch;
 pub mod tui;

apps/cli/src/main.rs

@@ -31,6 +31,12 @@ struct Cli {
 #[derive(Subcommand)]
 enum Commands {
     Auth,
+    Batch {
+        #[arg(long)]
+        file: String,
+        #[arg(long)]
+        provider: String,
+    },
 }
 
 #[tokio::main]
@@ -39,6 +45,32 @@ async fn main() {
 
     match cli.command {
         Some(Commands::Auth) => commands::auth::run(),
+        Some(Commands::Batch { file, provider }) => {
+            let base_url = cli.base_url.unwrap_or_else(|| {
+                eprintln!("error: --base-url (or CHAR_BASE_URL) is required");
+                std::process::exit(1);
+            });
+
+            let provider = provider.parse().unwrap_or_else(|_| {
+                eprintln!("error: unknown provider '{provider}'. expected: deepgram, soniox, assemblyai, am, cactus");
+                std::process::exit(1);
+            });
+
+            commands::batch::run(commands::batch::Args {
+                file,
+                provider,
+                base_url,
+                api_key: cli.api_key,
+                model: if cli.model.is_empty() {
+                    None
+                } else {
+                    Some(cli.model)
+                },
+                language: cli.language,
+                keywords: vec![],
+            })
+            .await;
+        }
         None => {
             let base_url = cli.base_url.unwrap_or_else(|| {
                 eprintln!("error: --base-url (or CHAR_BASE_URL) is required");

crates/listener2-core/Cargo.toml

@@ -20,6 +20,7 @@ owhisper-interface = { workspace = true }
 
 serde = { workspace = true }
 specta = { workspace = true, optional = true }
+strum = { workspace = true, features = ["derive"] }
 thiserror = { workspace = true }
 
 ractor = { workspace = true, features = ["async-trait"] }

crates/listener2-core/src/batch.rs

@@ -21,9 +21,10 @@ const DEFAULT_CHUNK_MS: u64 = 500;
 const DEFAULT_DELAY_MS: u64 = 20;
 const DEVICE_FINGERPRINT_HEADER: &str = "x-device-fingerprint";
 
-#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
+#[derive(Debug, Clone, serde::Serialize, serde::Deserialize, strum::Display, strum::EnumString)]
 #[cfg_attr(feature = "specta", derive(specta::Type))]
 #[serde(rename_all = "lowercase")]
+#[strum(serialize_all = "lowercase")]
 pub enum BatchProvider {
     Deepgram,
     Soniox,