From 22cea88c7eed590cae7ad3659141f7dcac092862 Mon Sep 17 00:00:00 2001 From: damocles Date: Sat, 16 May 2026 13:02:53 +0200 Subject: [PATCH] remove unused broker/coordinator methods --- hive-c0re/src/broker.rs | 16 ---------------- hive-c0re/src/coordinator.rs | 4 ---- 2 files changed, 20 deletions(-) diff --git a/hive-c0re/src/broker.rs b/hive-c0re/src/broker.rs index 7935cde..c1bae45 100644 --- a/hive-c0re/src/broker.rs +++ b/hive-c0re/src/broker.rs @@ -237,22 +237,6 @@ impl Broker { /// Get all reminders for an agent that are due now or in the past. /// Returns (id, message, file_path) tuples. - pub fn get_due_reminders(&self, agent: &str) -> Result)>> { - let conn = self.conn.lock().unwrap(); - let mut stmt = conn.prepare( - "SELECT id, message, file_path FROM reminders WHERE agent = ?1 AND due_at <= ?2 AND sent_at IS NULL ORDER BY due_at ASC" - )?; - let rows = stmt.query_map(params![agent, now_unix()], |row| { - Ok(( - row.get::<_, i64>(0)?, - row.get::<_, String>(1)?, - row.get::<_, Option>(2)?, - )) - })?; - rows.collect::>>() - .context("query reminders") - } - /// Get all due reminders across all agents in a single query. /// Returns a vec of (agent, id, message, file_path) tuples. pub fn get_all_due_reminders(&self) -> Result)>> { diff --git a/hive-c0re/src/coordinator.rs b/hive-c0re/src/coordinator.rs index 6f348cf..ad151a8 100644 --- a/hive-c0re/src/coordinator.rs +++ b/hive-c0re/src/coordinator.rs @@ -118,10 +118,6 @@ impl Coordinator { } } - pub fn list_agents(&self) -> Vec { - self.agents.lock().unwrap().keys().cloned().collect() - } - /// Mark an agent as in-progress (only one state per agent for now). pub fn set_transient(&self, name: &str, kind: TransientKind) { self.transient.lock().unwrap().insert(