Machine sessions hidden.
'; ++ for (const id of ['waiting', 'seen', 'sessions']) $(id).replaceChildren(); ++ for (const id of ['waiting-count', 'seen-count', 'session-count']) $(id).textContent = '–'; ++ $('footer').textContent = 'Mosaic Stack'; ++ $('status').textContent = 'Machine sessions hidden. Turn on Show machine sessions to read this machine\'s board scan.'; ++ fresh(); ++ } ++ function showMachine() { $('show-machine').checked = machine; document.body.classList.toggle('machine-off', !machine); } ++ $('show-machine').onchange = e => { ++ machine = e.target.checked; showMachine(); ++ try { localStorage.setItem('mosaic-console-board', JSON.stringify({ machine })); } catch {} ++ if (machine) { $('status').textContent = 'Loading board…'; fresh(); refresh(); } else hideMachine(); ++ }; ++ showMachine(); ++ if (!machine) hideMachine(); + $('refresh').onclick = refresh; + $('pause').onclick = () => { paused = !paused; $('pause').textContent = paused ? 'Resume' : 'Pause'; $('pause').setAttribute('aria-pressed', String(paused)); schedule(); if (data) render(); }; + $('hide-offline').onchange = $('hide-seen').onchange = render; +@@ -373,6 +412,7 @@ + if (result.delivered && drafts.get(id) === text) { drafts.delete(id); if (inView && box.value === text) box.value = ''; } + if (result.delivered && !paused) await refresh(); + } catch (err) { ++ if (err.signedOut) { receipts.set(id, { error: `Signed out: ${err.message}. Not sent.` }); return; } + // A 4xx is a refusal before anything ran (the Console's, or the board's: see replyToRow), so + // nothing was sent. No answer, an unreadable one, a 5xx or a 408 (a proxy can answer it + // after forwarding) leaves delivery unknown. +@@ -388,5 +428,20 @@ + const next = { ArrowDown: i + 1, ArrowUp: i - 1, Home: 0, End: buttons.length - 1 }[e.key]; + if (next !== undefined) { e.preventDefault(); buttons[next]?.focus(); } + }); +- api('/api/config').then(config => { board = config.board; $('board-url').textContent = `Board: ${board}`; }).catch(error).finally(refresh); ++ // Signed out: everything drawn from a Console read goes, because none of it can be refreshed. The ++ // line says so once; the send form (bus.js) keeps its draft and receipt. Reload is the way back. ++ document.addEventListener('mosaic-signed-out', () => { ++ if (out()) return; ++ document.body.classList.add('signed-out'); ++ clearTimeout(timer); convGen++; ++ if (conv) { $('conv-log').replaceChildren(); conv = null; showConversation(false); } ++ data = null; selected = null; project = null; inspect(); ++ for (const id of ['projects', 'waiting', 'seen', 'sessions']) $(id).replaceChildren(); ++ $('refresh').disabled = $('pause').disabled = true; ++ const line = $('signed-out'); ++ line.innerHTML = 'Signed out. Reload the page to sign in.
'; line.hidden = false; ++ // Focus moves to the line only if what had it is gone or disabled, never out of a form being typed in. ++ setTimeout(() => { const a = document.activeElement; if (!a || a === document.body || a.disabled || !a.getClientRects().length) line.focus(); }); ++ }); ++ api('/api/config').then(config => { board = config.board; $('board-url').textContent = `Board: ${board}`; }).catch(err => { if (machine) error(err); }).finally(refresh); + })(); +diff --git a/packages/webui/src/public/bus.js b/packages/webui/src/public/bus.js +index 8b4bcf43..e5a8e179 100644 +--- a/packages/webui/src/public/bus.js ++++ b/packages/webui/src/public/bus.js +@@ -24,24 +24,32 @@ + // can show what was read before, labelled as such. + const last = new Map(); + class ReadError extends Error { constructor(code, message, status) { super(message); this.code = code; this.status = status; } } ++ // Row 95 (#1589): every Console fetch takes `redirect: 'manual'`. A redirect comes only from the ++ // sign-in proxy, so the session ended: app.js's listener sets body.signed-out and draws the line, ++ // and from then on no read is made. A signed-out read throws code `signed-out`, which no view shows. ++ const out = () => document.body.classList.contains('signed-out'); ++ const signOut = () => { if (!out()) document.dispatchEvent(new Event('mosaic-signed-out')); }; ++ const signedOut = () => new ReadError('signed-out', 'The sign-in proxy redirected the read.', 0); + // `replies` takes a message id as `id`; trail takes `subject`. + async function fetchRead(verb, subject) { ++ if (out()) throw signedOut(); + let res, body; +- try { +- res = await fetch(`/api/bus/${verb}${subject === undefined ? '' : `?${verb === 'replies' ? 'id' : 'subject'}=${enc(subject)}`}`, { cache: 'no-store' }); +- body = await res.json(); +- } catch { throw new ReadError('unreachable', 'The Console server did not answer.', 0); } ++ try { res = await fetch(`/api/bus/${verb}${subject === undefined ? '' : `?${verb === 'replies' ? 'id' : 'subject'}=${enc(subject)}`}`, { cache: 'no-store', redirect: 'manual' }); } ++ catch { throw new ReadError('unreachable', 'The Console server did not answer.', 0); } ++ if (res.type === 'opaqueredirect') { signOut(); throw signedOut(); } ++ try { body = await res.json(); } catch { throw new ReadError('unreachable', 'The Console server did not answer.', 0); } + if (!res.ok || !body || !Array.isArray(body.rows)) throw new ReadError(typeof body?.error === 'string' ? body.error : 'invalid-response', typeof body?.message === 'string' ? body.message : `HTTP ${res.status}`, res.status); + return { rows: body.rows, at: body.at }; + } + // Row 54 (#1543): the queue, business and settings reads (src/reads.mjs), GET only. Their + // error carries the module's own message, which the server has already redacted. + async function fetchApi(path) { ++ if (out()) throw signedOut(); ++ const unreachable = () => Object.assign(new ReadError('unreachable', 'The Console server did not answer.', 0), { module: true }); + let res, body; +- try { +- res = await fetch(`/api/${path}`, { cache: 'no-store' }); +- body = await res.json(); +- } catch { throw Object.assign(new ReadError('unreachable', 'The Console server did not answer.', 0), { module: true }); } ++ try { res = await fetch(`/api/${path}`, { cache: 'no-store', redirect: 'manual' }); } catch { throw unreachable(); } ++ if (res.type === 'opaqueredirect') { signOut(); throw signedOut(); } ++ try { body = await res.json(); } catch { throw unreachable(); } + if (!res.ok || !body || typeof body !== 'object' || Array.isArray(body)) throw Object.assign(new ReadError(typeof body?.error === 'string' ? body.error : 'invalid-response', typeof body?.message === 'string' ? body.message : `HTTP ${res.status}`, res.status), { module: true }); + return body; + } +@@ -263,7 +271,7 @@ + const options = roles ? roles.map(r => ``).join('') : ''; + const r = receipt; + const said = !r ? '' : r.kind === 'sent' +- ? `Sent to ${txt(r.to)} ${when(r.at)}, message ${txt(short(r.id))}. Its trail.
Sent to ${txt(r.to)} ${when(r.at)}, message ${txt(short(r.id))}. Its trail.
Not sent to ${txt(r.to)}: ${txt(r.message)}${r.message.includes(`(${r.code})`) ? '' : ` (${txt(r.code)})`}. The draft is kept.
Outcome unknown: the message to ${txt(r.to)} may have been sent. Nothing was sent again, and the draft is kept. The bus gave no message id, so there is no trail to link: before sending again, look for it on the role's side or in the bus trail from a terminal.
`; +@@ -407,6 +415,38 @@ + const d = asks[0]; + return `Input needed: ${txt(first(d.question))} ${txt(short(d.id))}${d.blocking ? ` ${blockChip('blocking')}` : ''}${asks.length > 1 ? ` +${esc(asks.length - 1)} more` : ''}`; + } ++ // Row 95 (#1589): the Board's first section, the stack's seats: each held role from the bus ++ // `agents` read, a claim with no address included. Message opens the send form addressed to the ++ // role, so it shows only where a send can pass (`send` in /api/config). A refusal keeps nothing; ++ // any other failure keeps the last read, labelled with its time, as the bus pages do. ++ let heldErr = null, heldHtml = null, focusSend = false; ++ function heldTable(claims) { ++ const cols = ['Role', 'State', 'Attention', 'Address', 'Holder', 'Held since']; ++ const rows = claims.map(c => `| ${h} | `).join('')}${canSend ? 'Message | ' : ''}
|---|
Read from the bus ${when(r.at)}.${canSend ? '' : ' Messaging a role needs a Console started with --send behind the sign-in proxy; this one only reads.'}
Loading board…
Loading board…
The stack's seats: each role a run holds on the bus, from the bus agents read. Machine sessions are under Show machine sessions.
The board refused the read, so Console shows nothing rather than a guess. The reason is above.