NB - Native Browser Bridge

@@ -2620,22 +2620,12 @@ function dispatch(verb, args) {   }); } -async function onHostFrame(frame) {-  // Re-enter the ORIGINATING caller's context: this reply arrives on the extension socket, outside the-  // HTTP request's async scope, so ALS is empty here. Without this, every badge paint / window-identity-  // / caption we fire from the reply path would forward "self" instead of the thread that asked.-  const _p0 = (frame && frame.id != null) ? pending.get(frame.id) : null;-  if (_p0 && _p0.caller) return callerCtx.run(_p0.caller, () => onHostFrameInner(frame));-  return onHostFrameInner(frame);-}-async function onHostFrameInner(frame) {-  if (frame && frame.id != null && pending.has(frame.id)) {-    const p = pending.get(frame.id);-    clearTimeout(p.timer);-    pending.delete(frame.id);-    if (p.startedAt) activityStop(frame.id, p.verb, true, Date.now() - p.startedAt);-    if (frame.ok) {-      let payload = frame.payload || {};+// Everything that happens to a successful reply between the extension answering and the caller+// hearing it: file spill for screenshots/recordings, finder spill, taskbar/badge bookkeeping, the+// activity row, auto-flash, visible-open announcements. Best-effort by contract: the caller in+// onHostFrameInner wraps this in try/catch and ALWAYS resolves the reply (2026-09-03).+async function decorateReply(p, frame, payloadIn, setPayload) {+  let payload = payloadIn;       // Screenshot file-save: huge base64 over the relay times out, so when the caller passes       // toFile:true we write the PNG to a laptop temp file here and return its path instead of the       // base64. Pull it with `adom-bridge pull_file` (binary chunked) - fast + no relay timeout.@@ -2713,7 +2703,12 @@ async function onHostFrameInner(frame) {         }         if (sid) clearBadge(sid); // stop the idle-expiry timer for a closed session         // clear the badge on any spawned windows this close/cleanup removed-        for (const wid of (payload.alsoClosedSpawned || []).concat((payload.closed || []).map((c) => c.windowId).filter(Boolean))) {+        // nbrowser_close_window replies closed:true (a boolean); nbrowser_cleanup replies closed:[{windowId}].+        // Calling .map on the boolean threw here, the throw was swallowed inside the async frame handler,+        // and the reply was never sent: every nbrowser_close_window timed out at ab's 30s while the window+        // had in fact closed (found 2026-09-03; the battery's close row had been passing on a stale build).+        const closedList = Array.isArray(payload.closed) ? payload.closed : [];+        for (const wid of (payload.alsoClosedSpawned || []).concat(closedList.map((c) => c && c.windowId).filter(Boolean))) {           const sh = spawnHwnd.get(wid); if (sh) { taskbar(sh, { overlay: { badge: 'none' }, flash: 'stop' }); spawnHwnd.delete(wid); }         }       }@@ -2734,11 +2729,35 @@ async function onHostFrameInner(frame) {       if (p.crossThreadWarn && payload && typeof payload === 'object') payload._concurrentAgents = p.crossThreadWarn;       const sid = payload && payload.sessionId;       logActivity({ verb: p.verb, sessionId: sid || null, thread: sessionThread.get(sid) || null, profile: p.profileKey || null, ok: payload && payload.ok !== false, errorCode: (payload && payload.errorCode) || null, ...(p._internal ? { internal: true } : {}) });+  setPayload(payload);+}++async function onHostFrame(frame) {+  // Re-enter the ORIGINATING caller's context: this reply arrives on the extension socket, outside the+  // HTTP request's async scope, so ALS is empty here. Without this, every badge paint / window-identity+  // / caption we fire from the reply path would forward "self" instead of the thread that asked.+  const _p0 = (frame && frame.id != null) ? pending.get(frame.id) : null;+  if (_p0 && _p0.caller) return callerCtx.run(_p0.caller, () => onHostFrameInner(frame));+  return onHostFrameInner(frame);+}+async function onHostFrameInner(frame) {+  if (frame && frame.id != null && pending.has(frame.id)) {+    const p = pending.get(frame.id);+    clearTimeout(p.timer);+    pending.delete(frame.id);+    if (p.startedAt) activityStop(frame.id, p.verb, true, Date.now() - p.startedAt);+    if (frame.ok) {+      let payload = frame.payload || {};+      // Any exception in the decoration below used to reject this async handler silently and the caller+      // timed out even though the extension had answered. Decoration is best-effort; the reply is not.+      try { await decorateReply(p, frame, payload, (v) => { payload = v; }); }+      catch (e) { payload._postError = String((e && e.message) || e); }       resolve_ok(p.resolve, payload);-    } else {-      logActivity({ verb: p.verb, sessionId: null, profile: p.profileKey || null, ok: false, errorCode: 'error', error: String(frame.error || '').slice(0, 120) });-      p.resolve({ success: false, error: frame.error || 'unknown error', _hint: frame._hint });+      return;     }+    // frame.ok === false: the extension refused or threw; pass its error and teaching hint through verbatim.+    logActivity({ verb: p.verb, sessionId: null, profile: p.profileKey || null, ok: false, errorCode: 'error', error: String(frame.error || '').slice(0, 120) });+    p.resolve({ success: false, error: frame.error || 'unknown error', _hint: frame._hint });     return;   }   // Unsolicited events are surfaced to the AI via nbrowser_events (the extension buffers them).