feat(ccb): align TUI event flow + tool surface to ccb internals

Complete the ccb-alignment window: TUI event flow refactor, tool
userFacingName convention, component extraction, and fuzzy matching.

TUI (crates/tui):
- translate_event / apply_event reducer split (#13)
- content_buffer mirror fix for streaming chunks (#22)
- Renderable trait + component extraction: Header, MessageList,
  InputArea, BottomBar, StatusLine (Phase 1)
- AppEvent bus + FrameRequester (Phase 2)
- Overlay trait + stack: CommandPalette, HistorySearch, ModelPicker,
  Transcript, GlobalSearch, ApprovalQueue (Phases 3-7)
- EventBroker pause/resume for external editor (Phase 5)
- Theme system consolidation with new role fields (#12, #21)
- Delete ContextualKeybindings dead code (#17, #18)
- Delete response_started + render_thinking_state dead code (#23, #24)

Tools (crates/tools):
- Adopt ccb userFacingName convention: Bash->Run, Grep->Search,
  Read->Read (path . lines N-M), PowerShell, etc.
- Extract str_utils::truncate_chars for codepoint-safe truncation
- Fix byte-slice panics in tool summary truncation (#10, #20)

Core + API + Agent + CLI:
- Wire ApprovalQueue + ModelPicker SwitchSession (#4)
- Dedupe strip_trailing_tool_json + TOOL_ARG_INDEX_BASE (#5)
- Fix BLOCKER: translate_agent_event empty tool name (#9)
- Fix run_repl missing registry arg under --no-default-features

Dependencies:
- Add nucleo-matcher 0.3 for fuzzy matching (#11, #15)

Docs:
- Bump test count to 3900+ and crate count to 17 in README/README.zh-CN

Verified end-to-end: cargo build + test (3934+ pass) + clippy clean,
non-interactive -p mode + live interactive TUI via winpty driving real
Windows conpty, all tool-use cells rendering correct ccb wrappers.

Author: lingcoder

Cargo.lock

@@ -107,6 +107,7 @@ unicode-width = "0.2"
 strip-ansi-escapes = "0.2"
 jsonc-parser = { version = "0.32", features = ["serde"] }
 schemars = "1"
+nucleo-matcher = "0.3"
 
 # ─── 测试 ───
 tempfile = "3"

Cargo.toml

@@ -17,7 +17,7 @@
 
 ---
 
-> **Status: Active Development** -- 49 built-in tools, 6 permission modes, extended thinking, multi-agent coordination, structured message TUI with 187 spinner verbs, 3800+ tests across 17 crates, 110k+ LOC. Zero `todo!()` macros.
+> **Status: Active Development** -- 49 built-in tools, 6 permission modes, extended thinking, multi-agent coordination, structured message TUI with 187 spinner verbs, 3900+ tests across 17 crates, 110k+ LOC. Zero `todo!()` macros.
 
 ## What is Crab Code?
 
@@ -153,7 +153,7 @@ Plus tool-level filtering with `--allowedTools` / `--disallowedTools` supporting
 
 ## Architecture
 
-4-layer, 16-crate Rust workspace:
+4-layer, 17-crate Rust workspace:
 
 ```
 Layer 4 (Entry)     cli          daemon        xtask
@@ -209,7 +209,7 @@ crab auth login                   # Configure authentication
 
 ```bash
 cargo build --workspace                    # Build all
-cargo test --workspace                     # Run all tests (3800+)
+cargo test --workspace                     # Run all tests (3900+)
 cargo clippy --workspace -- -D warnings    # Lint
 cargo fmt --all --check                    # Check formatting
 cargo run --bin crab                       # Run CLI

README.md

@@ -17,7 +17,7 @@
 
 ---
 
-> **状态：积极开发中** -- 49 个内置工具、6 种权限模式、扩展思维、多 Agent 协调、结构化消息模型 TUI（187 spinner verbs），17 个 crate 共 3800+ 测试、11 万行代码。零 `todo!()` 残留。
+> **状态：积极开发中** -- 49 个内置工具、6 种权限模式、扩展思维、多 Agent 协调、结构化消息模型 TUI（187 spinner verbs），17 个 crate 共 3900+ 测试、11 万行代码。零 `todo!()` 残留。
 
 ## 什么是 Crab Code？
 
@@ -153,7 +153,7 @@ Crab Code 支持 Claude Code 的 `settings.json` 格式，包括 `env` 字段：
 
 ## 架构
 
-4 层 16 crate 的 Rust workspace：
+4 层 17 crate 的 Rust workspace：
 
 ```
 第 4 层（入口）    cli          daemon        xtask
@@ -209,7 +209,7 @@ crab auth login                   # 配置认证
 
 ```bash
 cargo build --workspace                    # 构建全部
-cargo test --workspace                     # 运行所有测试（3800+）
+cargo test --workspace                     # 运行所有测试（3900+）
 cargo clippy --workspace -- -D warnings    # Lint 检查
 cargo fmt --all --check                    # 格式检查
 cargo run --bin crab                       # 运行 CLI

README.zh-CN.md

@@ -75,6 +75,7 @@ pub async fn execute_tool_calls(
                         .send(Event::ToolUseStart {
                             id: id.clone(),
                             name: name.clone(),
+                            input: input.clone(),
                         })
                         .await;
                     let result = executor.execute(&name, input, ctx).await;
@@ -111,6 +112,7 @@ pub async fn execute_tool_calls(
                 .send(Event::ToolUseStart {
                     id: id.clone(),
                     name: name.clone(),
+                    input: input.clone(),
                 })
                 .await;
             let output = ToolOutput::error(
@@ -146,6 +148,7 @@ pub async fn execute_tool_calls(
                         .send(Event::ToolUseStart {
                             id: id.clone(),
                             name: name.clone(),
+                            input: input.clone(),
                         })
                         .await;
                     let output = ToolOutput::error(format!("<hook-blocked> {msg}"));
@@ -174,6 +177,7 @@ pub async fn execute_tool_calls(
             .send(Event::ToolUseStart {
                 id: id.clone(),
                 name: name.clone(),
+                input: input.clone(),
             })
             .await;
 

crates/agent/src/engine/tool_orchestration.rs

@@ -462,6 +462,7 @@ async fn execute_tool_calls(
                         .send(Event::ToolUseStart {
                             id: id.clone(),
                             name: name.clone(),
+                            input: input.clone(),
                         })
                         .await;
                     let result = executor.execute(&name, input, ctx).await;
@@ -499,6 +500,7 @@ async fn execute_tool_calls(
                 .send(Event::ToolUseStart {
                     id: id.clone(),
                     name: name.clone(),
+                    input: input.clone(),
                 })
                 .await;
             let output = ToolOutput::error(
@@ -534,6 +536,7 @@ async fn execute_tool_calls(
                         .send(Event::ToolUseStart {
                             id: id.clone(),
                             name: name.clone(),
+                            input: input.clone(),
                         })
                         .await;
                     let output = ToolOutput::error(format!("<hook-blocked> {msg}"));
@@ -562,6 +565,7 @@ async fn execute_tool_calls(
             .send(Event::ToolUseStart {
                 id: id.clone(),
                 name: name.clone(),
+                input: input.clone(),
             })
             .await;
 

crates/agent/src/query_loop.rs

@@ -1,5 +1,6 @@
 //! Conversion between Chat Completions API types and internal types.
 
+use crab_core::event::TOOL_ARG_INDEX_BASE;
 use crab_core::message::{ContentBlock, Message, Role};
 use crab_core::model::TokenUsage;
 
@@ -248,8 +249,18 @@ pub fn chunk_to_stream_event(chunk: &ChatCompletionChunk) -> Vec<StreamEvent> {
     let mut events = Vec::new();
 
     for choice in &chunk.choices {
+        let has_tool_calls = choice
+            .delta
+            .tool_calls
+            .as_ref()
+            .is_some_and(|tc| !tc.is_empty());
+
+        // When tool_calls are present alongside content, the content is
+        // redundant tool-parameter JSON (DeepSeek behaviour). Skip it to
+        // avoid polluting assistant text with raw JSON.
         if let Some(content) = &choice.delta.content
             && !content.is_empty()
+            && !has_tool_calls
         {
             events.push(StreamEvent::ContentDelta {
                 index: choice.index,
@@ -259,8 +270,8 @@ pub fn chunk_to_stream_event(chunk: &ChatCompletionChunk) -> Vec<StreamEvent> {
 
         if let Some(tool_calls) = &choice.delta.tool_calls {
             for tc in tool_calls {
-                // Use index offset 1000+ to avoid colliding with text content block indices
-                let tool_index = 1000 + tc.index;
+                // Use index offset to avoid colliding with text content block indices
+                let tool_index = TOOL_ARG_INDEX_BASE + tc.index;
 
                 // First chunk for a tool call: has id + function.name
                 if tc.id.is_some() {

crates/api/src/openai/convert.rs

@@ -328,11 +328,12 @@ fn event_to_value(event: &Event) -> serde_json::Value {
                 "delta": delta,
             })
         }
-        Event::ToolUseStart { id, name } => {
+        Event::ToolUseStart { id, name, input } => {
             serde_json::json!({
                 "type": "tool_use_start",
                 "id": id,
                 "name": name,
+                "input": input,
             })
         }
         Event::ToolResult { id, output } => {
@@ -429,6 +430,7 @@ mod tests {
         let event = Event::ToolUseStart {
             id: "tu_1".into(),
             name: "bash".into(),
+            input: serde_json::json!({"command": "ls"}),
         };
         let value = event_to_value(&event);
         assert_eq!(value["type"], "tool_use_start");

crates/cli/src/commands/run.rs

@@ -891,7 +891,8 @@ async fn run_single_shot(
     output_format: OutputFormat,
 ) -> anyhow::Result<()> {
     let event_rx = take_event_rx(session);
-    let printer = tokio::spawn(print_events(event_rx, output_format));
+    let registry = session.executor.registry_arc();
+    let printer = tokio::spawn(print_events(event_rx, output_format, registry));
 
     let result = session.handle_user_input(prompt).await;
     // Replace the event_tx with a dummy so the printer's rx sees all senders dropped.
@@ -943,7 +944,8 @@ async fn run_repl(
         let effective_input = resolve_slash_command(input, skill_registry);
 
         let event_rx = take_event_rx(session);
-        let printer = tokio::spawn(print_events(event_rx, OutputFormat::Text));
+        let registry = session.executor.registry_arc();
+        let printer = tokio::spawn(print_events(event_rx, OutputFormat::Text, registry));
 
         match session.handle_user_input(&effective_input).await {
             Ok(()) => {}
@@ -975,7 +977,11 @@ fn take_event_rx(session: &mut AgentSession) -> mpsc::Receiver<Event> {
 ///
 /// `OutputFormat::Json` and `StreamJson` emit NDJSON to stdout.
 /// `OutputFormat::Text` uses colored human-readable output.
-async fn print_events(mut rx: mpsc::Receiver<Event>, output_format: OutputFormat) {
+async fn print_events(
+    mut rx: mpsc::Receiver<Event>,
+    output_format: OutputFormat,
+    registry: Arc<crab_tools::registry::ToolRegistry>,
+) {
     let mut stdout = std::io::stdout();
     let mut spinner: Option<Spinner> = None;
 
@@ -993,18 +999,25 @@ async fn print_events(mut rx: mpsc::Receiver<Event>, output_format: OutputFormat
         }
 
         match event {
-            Event::ContentDelta { delta, .. } => {
-                if let Some(mut s) = spinner.take() {
-                    s.stop();
+            Event::ContentDelta { index, delta } => {
+                // Only print text content (index 0), not tool arguments (index 1000+)
+                if index == 0 {
+                    if let Some(mut s) = spinner.take() {
+                        s.stop();
+                    }
+                    print!("{delta}");
+                    let _ = stdout.flush();
                 }
-                print!("{delta}");
-                let _ = stdout.flush();
             }
-            Event::ToolUseStart { name, .. } => {
+            Event::ToolUseStart { name, input, .. } => {
                 if let Some(mut s) = spinner.take() {
                     s.stop();
                 }
-                eprintln!("{} {}", "tool:".cyan().bold(), name.cyan());
+                let summary = registry
+                    .get(&name)
+                    .and_then(|tool| tool.format_use_summary(&input))
+                    .unwrap_or_else(|| name.clone());
+                eprintln!("{} {}", "tool:".cyan().bold(), summary.cyan());
                 spinner = Some(Spinner::start(&format!("running {name}...")));
             }
             Event::ToolOutputDelta { id: _, delta } => {
@@ -1161,10 +1174,11 @@ fn event_to_json(event: &Event) -> Option<Value> {
                 "cache_creation_tokens": usage.cache_creation_tokens,
             },
         })),
-        Event::ToolUseStart { name, id } => Some(json!({
+        Event::ToolUseStart { name, id, input } => Some(json!({
             "type": "tool_use_start",
             "tool": name,
             "id": id,
+            "input": input,
         })),
         Event::ToolUseInput { id, input } => Some(json!({
             "type": "tool_use_input",
@@ -1622,6 +1636,7 @@ mod tests {
             Event::ToolUseStart {
                 id: "t".into(),
                 name: "n".into(),
+                input: Value::Null,
             },
             Event::ToolUseInput {
                 id: "t".into(),

crates/cli/src/main.rs

@@ -2,6 +2,17 @@ use crate::model::TokenUsage;
 use crate::tool::ToolOutput;
 use serde_json::Value;
 
+/// Streaming content-block index offset for `tool_calls` entries.
+///
+/// Used by `OpenAI`-compatible providers (`DeepSeek` in particular) to
+/// encode `tool_calls` entries. Tool-call chunks arrive with indices
+/// `>= TOOL_ARG_INDEX_BASE` so they can be multiplexed with text `content`
+/// blocks (indices `0..TOOL_ARG_INDEX_BASE`) in a single streaming event.
+/// Consumers of `Event::ContentDelta` that render text should filter
+/// indices `>= TOOL_ARG_INDEX_BASE` to avoid leaking raw tool-call JSON
+/// into the message body.
+pub const TOOL_ARG_INDEX_BASE: usize = 1000;
+
 /// Domain events for agent-to-UI communication.
 ///
 /// All variants are `Clone + Send + 'static` to support
@@ -29,7 +40,13 @@ pub enum Event {
 
     // ─── Tool execution ───
     /// A tool call has started.
-    ToolUseStart { id: String, name: String },
+    ToolUseStart {
+        id: String,
+        name: String,
+        /// Tool input parameters (for rendering hooks).
+        #[serde(default)]
+        input: Value,
+    },
 
     /// Incremental tool input (streaming).
     ToolUseInput { id: String, input: Value },
@@ -300,6 +317,7 @@ mod tests {
         serde_roundtrip(&Event::ToolUseStart {
             id: "tu_1".into(),
             name: "bash".into(),
+            input: serde_json::json!({"command": "ls"}),
         });
     }
 
@@ -450,4 +468,13 @@ mod tests {
             delta: "Step 1: analyze the problem".into(),
         });
     }
+
+    #[test]
+    fn tool_arg_index_base_is_stable() {
+        // Locks the constant to 1000. If a future change raises this value,
+        // it must be a conscious review — the constant is load-bearing for
+        // both the OpenAI-compatible streaming producer (crab-api) and the
+        // text-rendering consumers (crab-tui).
+        assert_eq!(TOOL_ARG_INDEX_BASE, 1000);
+    }
 }