Fusion - the Fusion 360 Bridge

@@ -303,7 +303,7 @@ def _find_adom_desktop_cli() -> str | None:     return None  -def _cli_notify_all(title: str, body: str, level: str) -> dict:+def _cli_notify_all(title: str, body: str, level: str, buttons=None) -> dict:     """Deliver a toast to EVERY connected desktop via `adom-bridge --target all notify_user`. This is     the reliable cross-AD path when the bridge's in-process ad_client is down (headless VM): the CLI     joins the relay itself and `--target all` reaches the user's real machine (not just this VM).@@ -316,9 +316,16 @@ def _cli_notify_all(title: str, body: str, level: str) -> dict:     # STICKY by default: a human-wall alert must NOT vanish in a few seconds (John 2026-07-14 - the     # first toasts disappeared before he noticed them). scenario:reminder keeps it on screen until the     # user acts; it REQUIRES >=1 button, so include one. durationLong is a belt-and-suspenders ~25s.+    # ⛔ A NOTICE THAT OFFERS AN ACTION MUST CARRY THE CHOICE (John, 2026-08-28: "i just+    # clicked 'got it' on the restart notice, but why do you not give me a choice? i have+    # no idea if 'got it' means you're restarting or not"). The default single "Got it"+    # stays for plain FYI toasts, but a caller with a real decision passes its own+    # buttons and reads the click back via notify_response. Never print a promise+    # ("we will save your documents first") on a toast whose only button is an+    # acknowledgement - that is the text making an offer the UI cannot keep.     payload = json.dumps({"title": title, "body": body, "level": level,                           "scenario": "reminder", "durationLong": True,-                          "buttons": [{"label": "Got it"}]})+                          "buttons": buttons or [{"label": "Got it"}]})     try:         r = _sp.run([exe, "--target", "all", "notify_user", payload],                     capture_output=True, text=True, timeout=30,@@ -328,11 +335,68 @@ def _cli_notify_all(title: str, body: str, level: str) -> dict:         # 'displayed'/'ok' in the output as delivered. The Windows exe may print nothing yet still         # deliver, so a clean exit code is accepted too.         delivered = (r.returncode == 0) or ("displayed" in out) or ('"status": "ok"' in out) or ("status':'ok" in out)-        return {"delivered": bool(delivered), "targets": "all", "error": None if delivered else out[:200]}+        nid = None+        try:+            import re as _re+            m = _re.search(r'"id"\s*:\s*"([0-9a-f]{8,})"', out)+            nid = m.group(1) if m else None+        except Exception:+            pass+        return {"delivered": bool(delivered), "targets": "all", "id": nid,+                "error": None if delivered else out[:200]}     except Exception as e:         return {"delivered": False, "error": str(e)[:200]}  +def _watch_restart_choice(notification_id: str, timeout_s: float = 1800.0):+    """Wait (in the background) for the user's answer to the restart notice and honour it.++    "Save and restart" -> fusion_restart_for_addin {save:true}, which saves first and+    REFUSES rather than discarding a never-saved document. "I'll handle it" -> nothing:+    the user keeps control and the offer is simply recorded. Either way the choice lands+    in the action ledger, so "why did my Fusion restart" has an answer with a timestamp.+    """+    import threading as _th++    def _run():+        import time as _t+        deadline = _t.time() + timeout_s+        exe = _find_adom_desktop_cli()+        while exe and _t.time() < deadline:+            try:+                import subprocess as _sp, json as _js+                r = _sp.run([exe, "--target", "all", "notify_response",+                             _js.dumps({"id": notification_id})],+                            capture_output=True, text=True, timeout=30,+                            creationflags=getattr(_sp, "CREATE_NO_WINDOW", 0))+                out = (r.stdout or "")+                i = out.find("{")+                x = _js.loads(out[i:]) if i >= 0 else {}+                x = x.get("data") or x+                btn = x.get("buttonId") or x.get("button") or x.get("response")+                if x.get("pending") is False or btn or x.get("dismissed"):+                    if btn in ("restart", "Save and restart"):+                        _bridge_action_ledger("restart_choice", {"choice": "restart",+                                                                  "notification": notification_id})+                        res = _handle_restart_for_addin(detect_fusion(), {"save": True})+                        _bridge_action_ledger("restart_for_addin_result",+                                              {"success": res.get("success"),+                                               "errorCode": res.get("errorCode")})+                        if not res.get("success"):+                            _cli_notify_all("Fusion restart did not complete",+                                            str(res.get("error") or res.get("errorCode"))[:200],+                                            "error")+                    else:+                        _bridge_action_ledger("restart_choice",+                                              {"choice": btn or "dismissed",+                                               "notification": notification_id})+                    return+            except Exception:+                pass+            _t.sleep(3)+    _th.Thread(target=_run, daemon=True).start()++ def _addin_restart_info(fire_toast: bool = True) -> dict:     """Everything a CALLER needs to tell a HUMAN that Fusion must restart, plus a toast. @@ -402,10 +466,20 @@ def _addin_restart_info(fire_toast: bool = True) -> dict:                             "first." % (info["openDocuments"],                                         (", %d unsaved" % info["unsavedDocuments"])                                         if info.get("unsavedDocuments") else ""))-                r = _cli_notify_all("Fusion needs a restart", body, "info")+                # Two real choices, and the bridge honours whichever is pressed. A user who+                # is mid-work keeps control with "I'll handle it"; one who wants it done gets+                # the save + restart the message promises. There is no button that means+                # "you have been told", because that leaves the user exactly where Adonis was.+                r = _cli_notify_all(+                    "Fusion needs a restart", body, "info",+                    buttons=[{"label": "Save and restart", "id": "restart"},+                             {"label": "I'll handle it", "id": "later"}])                 info["toast"] = {"delivered": bool(r.get("delivered")),-                                 "error": r.get("error")}-                f.write_text(_js.dumps({"at": _t.time()}))+                                 "id": r.get("id"), "error": r.get("error"),+                                 "choices": ["Save and restart", "I'll handle it"]}+                f.write_text(_js.dumps({"at": _t.time(), "id": r.get("id")}))+                if r.get("id"):+                    _watch_restart_choice(r["id"])             else:                 info["toast"] = {"delivered": False, "suppressed": "already toasted recently"}         except Exception as e: