feat: route clarification replies over stdio (A6) (#360)

Author: efecnc

src-tauri/crates/altai-cli/src/serve/mod.rs

@@ -27,7 +27,7 @@ pub async fn run(workspace: WorkspacePaths) -> Result<(), String> {
         event_sink.clone() as Arc<dyn altai_agent_service::AgentEventSink>,
         run_coordinator.clone(),
     ));
-    let service = Arc::new(AgentService::with_coordinator(host, run_coordinator.clone()));
+    let service = Arc::new(AgentService::with_coordinator(host.clone(), run_coordinator.clone()));
 
     let mut stdin = tokio::io::stdin();
     let mut decoder = FrameDecoder::new(FrameLimits::default());
@@ -96,6 +96,7 @@ pub async fn run(workspace: WorkspacePaths) -> Result<(), String> {
                                 "run/cancel",
                                 "run/steer",
                                 "run/replay",
+                                "clarification/respond",
                                 "context/compact",
                                 "checkpoints/list",
                                 "checkpoints/restore",
@@ -434,6 +435,21 @@ pub async fn run(workspace: WorkspacePaths) -> Result<(), String> {
                 "run/replay" if initialized => {
                     handle_run_replay(&workspace, &writer, id, params).await?;
                 }
+                "clarification/respond" if initialized => {
+                    let params = params
+                        .and_then(|value| value.as_object().cloned())
+                        .unwrap_or_default();
+                    let chat_id = params.get("chat_id").and_then(Value::as_str).unwrap_or("");
+                    let text = params.get("text").and_then(Value::as_str).unwrap_or("");
+                    if chat_id.trim().is_empty() || chat_id.len() > 256 || text.trim().is_empty() || text.len() > 16_384 {
+                        respond(&writer, id, None, Some(error_value(-32602, "invalid_clarification_response"))).await?;
+                        continue;
+                    }
+                    match host.deliver_clarification_reply(chat_id, text.to_string()).await {
+                        Ok(()) => respond(&writer, id, Some(json!({"accepted": true})), None).await?,
+                        Err(error) => respond(&writer, id, None, Some(error_value(-32002, &error))).await?,
+                    }
+                }
                 "context/compact" if initialized => {
                     let params = params
                         .and_then(|value| value.as_object().cloned())

src-tauri/crates/altai-cli/src/stdio_host.rs

@@ -65,6 +65,27 @@ impl StdioHost {
         }
     }
 
+    /// Deliver a reply only when this stdio chat has a live clarification wait.
+    /// The hub removes the pending slot before delivery, making repeated replies
+    /// fail rather than resuming the same tool twice.
+    pub async fn deliver_clarification_reply(
+        &self,
+        chat_id: &str,
+        text: String,
+    ) -> Result<(), String> {
+        let workspace_root = self.workspace.root.to_string_lossy().to_string();
+        let services = self.workspace_bundle_inner(&workspace_root).await?;
+        let session_key = isanagent::bus::clarification_session_key("stdio", chat_id, None);
+        if services
+            .clarification_hub
+            .try_deliver_reply(&session_key, text)
+        {
+            Ok(())
+        } else {
+            Err("clarification_not_pending".to_string())
+        }
+    }
+
     async fn workspace_bundle_inner(
         &self,
         workspace_root: &str,

src-tauri/crates/altai-cli/tests/serve_stdio.rs

@@ -143,6 +143,19 @@ fn config_update_persists_a_non_secret_model_setting() {
     let _stderr = process.shutdown();
 }
 
+#[test]
+fn clarification_response_rejects_a_non_pending_ticket() {
+    let workspace = tempfile::tempdir().expect("workspace");
+    let mut process = ServeProcess::spawn(workspace.path(), false);
+    process.frame(initialize(json!(1)));
+    assert_eq!(process.next()["id"], 1);
+    process.frame(json!({"jsonrpc":"2.0","id":2,"method":"clarification/respond","params":{"chat_id":"chat-test","text":"yes"}}));
+    assert_eq!(process.next()["error"]["message"], "clarification_not_pending");
+    process.frame(json!({"jsonrpc":"2.0","id":3,"method":"shutdown"}));
+    assert_eq!(process.next()["id"], 3);
+    let _stderr = process.shutdown();
+}
+
 #[test]
 fn compiled_stdio_handles_split_and_multiple_frames_with_ordered_terminal_stream() {
     let workspace = tempfile::tempdir().expect("workspace");