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

refactor(#2077): drop impl-history from broker/dashboard/mcp comments

Browse source
This commit is contained in:
damocles 2026-06-29 00:18:35 +02:00 • committed by mara
commit 72c4bb18c9
3 changed files with 8 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

5
hive-ag3nt/src/mcp.rs
View file

@ -535,9 +535,8 @@ fn format_age_secs(secs: u64) -> String {
} }
/// Common envelope around every MCP tool handler: pre-log → run → /// Common envelope around every MCP tool handler: pre-log → run →
/// post-log. The inbox-status hint used to be appended to every tool /// post-log. Tool results stay clean — the inbox-status hint lives in
/// result; that lives in the wake prompt + UI header now, so tool /// the wake prompt + UI header, not appended here.
/// results stay clean.
pub async fn run_tool_envelope<F>(tool: &'static str, args: String, body: F) -> String pub async fn run_tool_envelope<F>(tool: &'static str, args: String, body: F) -> String
where where
F: Future<Output = String>, F: Future<Output = String>,

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

@ -1260,8 +1260,8 @@ mod tests {
} }
/// Convenience wrapper for tests that want single-pop semantics /// Convenience wrapper for tests that want single-pop semantics
/// — the broker only exposes `recv_batch` publicly now, so /// — the broker only exposes `recv_batch` publicly, so tests
/// every test that used to call `recv` goes through here. /// funnel single pops through here.
fn pop_one(broker: &Broker, recipient: &str) -> Option<Delivery> { fn pop_one(broker: &Broker, recipient: &str) -> Option<Delivery> {
let mut batch = broker.recv_batch(recipient, 1).unwrap(); let mut batch = broker.recv_batch(recipient, 1).unwrap();
batch.pop() batch.pop()

11
hive-c0re/src/dashboard.rs
View file

@ -563,13 +563,10 @@ async fn api_state(headers: HeaderMap, State(state): State<AppState>) -> axum::J
let tombstones = build_tombstone_views(&state.coord, &containers, &transient_snapshot); let tombstones = build_tombstone_views(&state.coord, &containers, &transient_snapshot);
let port_conflicts = build_port_conflicts(&containers); let port_conflicts = build_port_conflicts(&containers);
// operator_inbox used to be served here as a 50-row array; the // Both operator-targeted and peer threads surface on the dashboard
// dashboard now derives it client-side from the message stream // (the client filters by target). Each row is wrapped in QuestionView
// (terminal backfill + live SSE), so the snapshot stops shipping it. // so the snapshot carries the same file_refs the live event variants
// Both operator-targeted and peer threads now surface on the // attach.
// dashboard. Client filters by target client-side. Each row is
// wrapped in QuestionView so the snapshot carries the same
// file_refs the live event variants attach.
let questions: Vec<QuestionView> = let questions: Vec<QuestionView> =
log_default("questions.pending_all", state.coord.questions.pending_all()) log_default("questions.pending_all", state.coord.questions.pending_all())
.into_iter() .into_iter()