cli loading interface

.typos.toml

@@ -9,3 +9,4 @@ serde = "serde"
 reqwest = "reqwest"
 clippy = "clippy"
 streamable = "streamable"
+indicatif = "indicatif"

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "deepwiki-cli"
-version = "0.1.1"
+version = "0.2.0"
 edition = "2021"
 description = "CLI for DeepWiki — query GitHub repo wikis without MCP overhead"
 license = "MIT"
@@ -15,6 +15,7 @@ path = "src/main.rs"
 [dependencies]
 anyhow = "1.0"
 clap = { version = "4", features = ["derive"] }
+indicatif = "0.17"
 rmcp = { version = "0.17", features = ["transport-streamable-http-client-reqwest", "client", "reqwest"] }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"

src/main.rs

@@ -1,11 +1,13 @@
 mod cli;
 mod client;
 mod output;
+mod spinner;
 
 use anyhow::Result;
 use clap::Parser;
 use cli::{Cli, Command};
 use client::DeepWikiClient;
+use spinner::Spinner;
 
 #[tokio::main]
 async fn main() {
@@ -27,20 +29,31 @@ async fn run() -> Result<()> {
         return Ok(());
     }
 
+    let spinner = Spinner::start("Connecting to DeepWiki...");
     let client = DeepWikiClient::connect().await?;
 
+    spinner.set_message(&command_spinner_message(&cli.command));
     let text = match &cli.command {
         Command::Ask { repo, question } => client.ask_question(repo, question).await?,
         Command::Structure { repo } => client.read_wiki_structure(repo).await?,
         Command::Read { repo } => client.read_wiki_contents(repo).await?,
     };
+    spinner.finish();
 
     println!("{}", output::format_for_claude(&text, repo, query_type));
     client.cancel().await?;
 
     Ok(())
 }
 
+fn command_spinner_message(command: &Command) -> String {
+    match command {
+        Command::Ask { repo, .. } => format!("Asking DeepWiki about {}...", repo),
+        Command::Structure { repo } => format!("Fetching wiki structure for {}...", repo),
+        Command::Read { repo } => format!("Reading wiki contents for {}...", repo),
+    }
+}
+
 fn repo_and_query_type(command: &Command) -> (&str, &str) {
     match command {
         Command::Ask { repo, .. } => (repo, "ask"),

src/spinner.rs

@@ -0,0 +1,58 @@
+use indicatif::{ProgressBar, ProgressDrawTarget, ProgressStyle};
+use std::time::Duration;
+
+const TICK_INTERVAL: Duration = Duration::from_millis(80);
+
+pub struct Spinner {
+    bar: ProgressBar,
+}
+
+impl Spinner {
+    pub fn start(message: &str) -> Self {
+        let bar = ProgressBar::new_spinner();
+        bar.set_draw_target(ProgressDrawTarget::stderr());
+        bar.set_style(
+            ProgressStyle::default_spinner()
+                .tick_strings(&["⠋", "⠙", "⠹", "⠸", "⠼", "⠴", "⠦", "⠧", "⠇", "⠏"])
+                .template("{spinner} {msg}")
+                .expect("template should be valid"),
+        );
+        bar.set_message(message.to_string());
+        bar.enable_steady_tick(TICK_INTERVAL);
+        Self { bar }
+    }
+
+    pub fn set_message(&self, message: &str) {
+        self.bar.set_message(message.to_string());
+    }
+
+    pub fn finish(self) {
+        self.bar.finish_and_clear();
+    }
+}
+
+impl Drop for Spinner {
+    fn drop(&mut self) {
+        if !self.bar.is_finished() {
+            self.bar.finish_and_clear();
+        }
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn spinner_starts_and_finishes_without_panic() {
+        let spinner = Spinner::start("test message");
+        spinner.set_message("updated message");
+        spinner.finish();
+    }
+
+    #[test]
+    fn spinner_drop_cleans_up() {
+        let spinner = Spinner::start("test message");
+        drop(spinner);
+    }
+}