Pup - the AI's own browser

@@ -12409,16 +12409,61 @@ const DEMO_PROMPT = 'Run the pup demo and show me what pup can do on my machine.   + '5. Read the pup dashboard LED status and tell me each light. If anything is not green, name the exact verb that fixes it and offer to run it.\n\n'   + 'Then close the demo window so nothing is left on my desktop.'; -// The local Hydrogen control API. The bridge runs ON the desktop, so this is a plain loopback call-// with nothing to route and no desktop to disambiguate.-let HYDROGEN_CTL = 'http://127.0.0.1:47084';-try {-  const u = fs.readFileSync(path.join(os.homedir(), '.adom', 'hydrogen-control-url'), 'utf8').trim();-  if (u) HYDROGEN_CTL = u.replace(/\/$/, '');-} catch (e) {}-function hydrogenGet(urlPath, timeoutMs) {+// The local Hydrogen control API. THE PORT IS DYNAMIC AND MUST BE DISCOVERED (v2.0.351).+// This used to hardcode 47084 with a fallback to ~/.adom/hydrogen-control-url. Both are+// CONTAINER-side facts that I inherited when the say-strip moved from the container helper into+// this bridge, and neither holds on the desktop: there is no hydrogen-control-url file there, and+// ah's control API was actually on 63549. So every call to Hydrogen from this bridge was hitting a+// closed port. The version gate failed OPEN (an unreachable probe is treated as "cannot read, do+// not block"), so it looked healthy while gating nothing, and the module's send relay answered 502.+// Found by the module's checkSend probe, which exists for exactly this: a missing gate reads as an+// allowed gate rather than as an error.+//+// The discovery responder answers on one of four fixed candidates and its body carries the real+// control_url. Probe, cache, and RE-PROBE whenever a call fails, because the port moves when ah+// restarts and a cached value is stale from that moment on.+const HYDROGEN_DISCOVERY_PORTS = [47080, 48080, 49180, 50280];+let HYDROGEN_CTL = null;+let _ctlAt = 0;+function _httpGetJson(url, timeoutMs) {   return new Promise((resolve) => {-    const req = http.get(HYDROGEN_CTL + urlPath, { timeout: timeoutMs || 2500 }, (res2) => {+    const req = http.get(url, { timeout: timeoutMs || 1500 }, (r) => {+      let b = ''; r.on('data', d => { b += d; });+      r.on('end', () => { let j = null; try { j = JSON.parse(b); } catch (e) {} resolve(j); });+    });+    req.on('error', () => resolve(null));+    req.on('timeout', () => { req.destroy(); resolve(null); });+  });+}+async function hydrogenControlUrl(force) {+  if (!force && HYDROGEN_CTL && Date.now() - _ctlAt < 300000) return HYDROGEN_CTL;+  // In a container the workspace file is authoritative and costs nothing to read.+  try {+    const u = fs.readFileSync(path.join(os.homedir(), '.adom', 'hydrogen-control-url'), 'utf8').trim();+    if (u) { HYDROGEN_CTL = u.replace(/\/$/, ''); _ctlAt = Date.now(); return HYDROGEN_CTL; }+  } catch (e) {}+  for (const port of HYDROGEN_DISCOVERY_PORTS) {+    const j = await _httpGetJson(`http://127.0.0.1:${port}/`, 1200);+    if (j && j.control_url) {+      HYDROGEN_CTL = String(j.control_url).replace(/\/$/, '');+      _ctlAt = Date.now();+      console.log(`[hydrogen] control API discovered at ${HYDROGEN_CTL} (via responder on ${port})`);+      return HYDROGEN_CTL;+    }+  }+  HYDROGEN_CTL = null;+  return null;+}+async function hydrogenGet(urlPath, timeoutMs) {+  let r = await _hydrogenGetOnce(await hydrogenControlUrl(false), urlPath, timeoutMs);+  // A dead port means the cached URL is stale (ah restarted), not that Hydrogen is gone.+  if (!r.status) r = await _hydrogenGetOnce(await hydrogenControlUrl(true), urlPath, timeoutMs);+  return r;+}+function _hydrogenGetOnce(base, urlPath, timeoutMs) {+  if (!base) return Promise.resolve({ status: 0, error: 'hydrogen control API not discovered' });+  return new Promise((resolve) => {+    const req = http.get(base + urlPath, { timeout: timeoutMs || 2500 }, (res2) => {       let b = ''; res2.on('data', (d) => { b += d; });       res2.on('end', () => { let j = null; try { j = JSON.parse(b); } catch (e) {} resolve({ status: res2.statusCode, json: j, raw: b, contentType: res2.headers['content-type'] || null }); });     });@@ -12426,10 +12471,16 @@ function hydrogenGet(urlPath, timeoutMs) {     req.on('timeout', () => { req.destroy(); resolve({ status: 0, error: 'timeout' }); });   }); }-function hydrogenPost(urlPath, bodyObj, timeoutMs) {+async function hydrogenPost(urlPath, bodyObj, timeoutMs) {+  let r = await _hydrogenPostOnce(await hydrogenControlUrl(false), urlPath, bodyObj, timeoutMs);+  if (!r.status) r = await _hydrogenPostOnce(await hydrogenControlUrl(true), urlPath, bodyObj, timeoutMs);+  return r;+}+function _hydrogenPostOnce(base, urlPath, bodyObj, timeoutMs) {+  if (!base) return Promise.resolve({ status: 0, error: 'hydrogen control API not discovered' });   return new Promise((resolve) => {     const data = JSON.stringify(bodyObj);-    const req = http.request(HYDROGEN_CTL + urlPath, { method: 'POST', timeout: timeoutMs || 4000,+    const req = http.request(base + urlPath, { method: 'POST', timeout: timeoutMs || 4000,       headers: { 'content-type': 'application/json', 'content-length': Buffer.byteLength(data) } }, (res2) => {       let b = ''; res2.on('data', (d) => { b += d; });       res2.on('end', () => { let j = null; try { j = JSON.parse(b); } catch (e) {} resolve({ status: res2.statusCode, json: j, raw: b, contentType: res2.headers['content-type'] || null }); });