Fusion - the Fusion 360 Bridge

@@ -1262,55 +1262,84 @@ fn url_for(port: u16) -> String { }  /// Stage a "say it" phrase into this app's AI thread via the Hydrogen control API-/// (127.0.0.1:47084). Thread found by its `app:adom/fusion-bridge` tag; run-prompt is-/// called with submit:false so the phrase only lands in the input box - the user submits.+/// (127.0.0.1:47084). Lookup order per the Dock Bar guide (project-e7, measured live+/// 2026-08-23): CENSUS FIRST (GET /ai-threads - the OPEN threads; history EXCLUDES open+/// threads by design, so history-only returned empty in exactly the common case), then+/// HISTORY for closed threads (resume, then stage). run-prompt is always submit:false -+/// the phrase only lands in the input box, the user submits. /// Every failure is a graceful {ok:false, why} the UI turns into a copy fallback.-fn stage_say_phrase(phrase: &str) -> serde_json::Value {-    let hy = "http://127.0.0.1:47084";-    // 1. find the thread sid by app tag+fn hy_get(path: &str) -> Option<serde_json::Value> {     let out = Command::new("curl")-        .args(["-s", "-m", "2",-               &format!("{}/ai-threads/history?tag=app:adom/fusion-bridge", hy)])-        .output();-    let hist = match out {-        Ok(o) if !o.stdout.is_empty() => String::from_utf8_lossy(&o.stdout).to_string(),-        _ => return serde_json::json!({"ok": false, "why": "Hydrogen control API unreachable (not WSL2/mirrored networking?)"}),-    };-    let v: serde_json::Value = match serde_json::from_str(&hist) {-        Ok(v) => v,-        Err(_) => return serde_json::json!({"ok": false, "why": "control API answered non-JSON"}),-    };-    // The sid may sit at several depths depending on the endpoint's shape - take the first-    // "sid" string found anywhere (same envelope-drift defense as the bridge's _find_controls_any).-    fn first_sid(v: &serde_json::Value) -> Option<String> {-        match v {-            serde_json::Value::Object(m) => {-                if let Some(s) = m.get("sid").and_then(|s| s.as_str()) {-                    return Some(s.to_string());-                }-                m.values().find_map(first_sid)-            }-            serde_json::Value::Array(a) => a.iter().find_map(first_sid),-            _ => None,-        }-    }-    let sid = match first_sid(&v) {-        Some(s) => s,-        None => return serde_json::json!({"ok": false, "why": "no AI thread tagged app:adom/fusion-bridge yet - open the app from the dock once"}),-    };-    // 2. stage the phrase, never submit-    let payload = serde_json::json!({"sid": sid, "prompt": phrase, "submit": false}).to_string();+        .args(["-s", "-m", "2", &format!("http://127.0.0.1:47084{}", path)])+        .output().ok()?;+    if out.stdout.is_empty() { return None; }+    serde_json::from_slice(&out.stdout).ok()+}++fn hy_post(path: &str, payload: &serde_json::Value) -> Option<serde_json::Value> {     let out = Command::new("curl")         .args(["-s", "-m", "3", "-X", "POST", "-H", "Content-Type: application/json",-               "-d", &payload, &format!("{}/ai-threads/run-prompt", hy)])-        .output();-    match out {-        Ok(o) if o.status.success() && !o.stdout.is_empty() => {-            serde_json::json!({"ok": true, "staged": true, "sid": sid,-                "_hint": "phrase staged in the app's AI thread input - the user presses Enter to run it"})+               "-d", &payload.to_string(), &format!("http://127.0.0.1:47084{}", path)])+        .output().ok()?;+    if out.stdout.is_empty() { return None; }+    serde_json::from_slice(&out.stdout).ok()+}++fn stage_say_phrase(phrase: &str) -> serde_json::Value {+    const TAG: &str = "app:adom/fusion-bridge";+    // 1. CENSUS: open threads. Shape: {"ok":true,"groups":[{"threads":[{"tid","sid"|null,"tags":[...]}]}]}+    let census = hy_get("/ai-threads");+    if census.is_none() {+        return serde_json::json!({"ok": false,+            "why": "Hydrogen control API unreachable (not WSL2/mirrored networking?)"});+    }+    let census = census.unwrap();+    let open_row = census["groups"].as_array().into_iter().flatten()+        .flat_map(|g| g["threads"].as_array().cloned().unwrap_or_default())+        .find(|t| t["tags"].as_array().map_or(false,+            |tags| tags.iter().any(|x| x.as_str() == Some(TAG))));+    if let Some(row) = open_row {+        // Address by sid when present; tid when sid is null (thread open but no session yet).+        let mut payload = serde_json::json!({"prompt": phrase, "submit": false});+        if let Some(sid) = row["sid"].as_str() {+            payload["sid"] = serde_json::json!(sid);+        } else if let Some(tid) = row["tid"].as_str() {+            payload["tid"] = serde_json::json!(tid);+        } else {+            return serde_json::json!({"ok": false, "why": "census row has neither sid nor tid"});+        }+        return match hy_post("/ai-threads/run-prompt", &payload) {+            Some(r) if r["ok"].as_bool() != Some(false) =>+                serde_json::json!({"ok": true, "staged": true, "via": "census",+                    "_hint": "phrase staged in the open app thread's input - the user presses Enter"}),+            _ => serde_json::json!({"ok": false, "why": "run-prompt failed on the open thread"}),+        };+    }+    // 2. HISTORY: closed threads. Shape: {"ok":true,"items":[{"ai","id","title","updated_ms"}]}+    let hist = hy_get(&format!("/ai-threads/history?tag={}", TAG));+    if let Some(item) = hist.as_ref()+        .and_then(|h| h["items"].as_array())+        .and_then(|a| a.first()) {+        let (ai, id) = (item["ai"].as_str().unwrap_or("claude"),+                        item["id"].as_str().unwrap_or(""));+        if !id.is_empty() {+            // Resume reopens the thread tab - the user clicked Try, so that IS their intent.+            let resumed = hy_post("/ai-threads/resume", &serde_json::json!({"ai": ai, "id": id}));+            if resumed.map_or(false, |r| r["ok"].as_bool() != Some(false)) {+                let staged = hy_post("/ai-threads/run-prompt",+                    &serde_json::json!({"sid": id, "prompt": phrase, "submit": false}));+                if staged.map_or(false, |r| r["ok"].as_bool() != Some(false)) {+                    return serde_json::json!({"ok": true, "staged": true, "via": "history+resume",+                        "_hint": "reopened the app thread and staged the phrase - the user presses Enter"});+                }+            }+            return serde_json::json!({"ok": false,+                "why": "app thread exists but is closed and resume/stage failed"});         }-        _ => serde_json::json!({"ok": false, "why": "run-prompt call failed"}),     }+    // 3. Neither: honest copy fallback.+    serde_json::json!({"ok": false,+        "why": "no AI thread tagged app:adom/fusion-bridge yet - open the app from the dock once"}) }  /// Probe 8930-8940 for an already-serving FUSION dashboard. "dashboardVersion" alone is