vinzenz/hyperhive
vinzenz/hyperhive
Watch
0
0
Fork
You've already forked hyperhive
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 2

fix: view-queue link + agent inbox shows unread messages only

Browse source 
fix(dashboard): update 'view queue' link to /builds.html

The build queue moved to its own /builds.html page. The queue-summary
'view queue →' link in tabs.js still pointed at /core.html, so clicking
it landed on the wrong page.

fix(broker): filter agent inbox to unread (acked_at IS NULL)

recent_for was returning all messages regardless of ack state, so the
agent inbox showed everything even after 'mark all read'. Now filters
to acked_at IS NULL — mirroring exactly what mark_all_read drains —
so the inbox empties on reload after the operator drains it.
This commit is contained in:
iris 2026-07-01 18:31:32 +02:00 • committed by mara
commit 5264828091
3 changed files with 8 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

8
frontend/packages/agent/src/app.js
View file

@ -1133,11 +1133,9 @@ window.marked = marked;
return wrap; return wrap;
} }
// "mark all read" header row drains the host broker's pending + // "mark all read" header row drains the host broker's pending +
// delivered-unacked rows for this agent. Visible rows here are // delivered-unacked rows for this agent. The inbox shows only
// the most-recent-N regardless of ack state, so the list itself // unread (acked_at IS NULL) rows, so after the drain + refreshState()
// doesn't visually empty on click — the status pill confirms // the list empties (matching the operator's expectation).
// the drain count, and the next turn_start's "unread" badge
// will read zero.
wrap.append(buildInboxMarkAllRow(currentLabel, () => { wrap.append(buildInboxMarkAllRow(currentLabel, () => {
// Refresh state so any UI surface that DOES depend on // Refresh state so any UI surface that DOES depend on
// delivery state (eg future per-status filters) picks up // delivery state (eg future per-status filters) picks up

2
frontend/packages/dashboard/src/tabs.js
View file

@ -826,7 +826,7 @@ window.marked = marked;
el('span', { class: 'glyph spinner' }, '◐'), ' ', el('span', { class: 'glyph spinner' }, '◐'), ' ',
el('strong', {}, 'build queue'), ' — ', el('strong', {}, 'build queue'), ' — ',
parts.join(' · '), ' ', parts.join(' · '), ' ',
el('a', { class: 'queue-summary-link', href: '/core.html' }, 'view queue →'), el('a', { class: 'queue-summary-link', href: '/builds.html' }, 'view queue →'),
)); ));
} }

7
hive-c0re/src/broker.rs
View file

@ -339,9 +339,9 @@ impl Broker {
Ok(batch) Ok(batch)
} }
/// Latest `limit` messages addressed to `recipient`, newest-first. /// Unread (unacked) messages addressed to `recipient`, newest-first.
/// Includes delivered + undelivered alike — used for the operator /// Filters to `acked_at IS NULL` so the agent inbox view clears after
/// inbox view on the dashboard. Caller decides what to show. /// "mark all read" — mirroring exactly what `mark_all_read` will drain.
pub fn recent_for(&self, recipient: &str, limit: u64) -> Result<Vec<InboxRow>> { pub fn recent_for(&self, recipient: &str, limit: u64) -> Result<Vec<InboxRow>> {
let conn = self.conn.lock().unwrap(); let conn = self.conn.lock().unwrap();
let limit_i = i64::try_from(limit.min(i64::MAX as u64)).unwrap_or(i64::MAX); let limit_i = i64::try_from(limit.min(i64::MAX as u64)).unwrap_or(i64::MAX);
@ -349,6 +349,7 @@ impl Broker {
"SELECT id, sender, body, sent_at, in_reply_to "SELECT id, sender, body, sent_at, in_reply_to
FROM messages FROM messages
WHERE recipient = ?1 WHERE recipient = ?1
AND acked_at IS NULL
ORDER BY id DESC ORDER BY id DESC
LIMIT ?2", LIMIT ?2",
)?; )?;