operator inbox view on dashboard; agent ui doesn't clobber typing

hive-c0re/src/broker.rs

@@ -28,6 +28,16 @@ CREATE INDEX IF NOT EXISTS idx_messages_undelivered
 /// may drop events past this; we send a `lagged` notice in their stream.
 const EVENT_CHANNEL: usize = 256;
 
+/// One row in a `recent_for()` query — the broker's flat view of a
+/// message addressed to a given recipient.
+#[derive(Debug, Clone, Serialize)]
+pub struct InboxRow {
+    pub id: i64,
+    pub from: String,
+    pub body: String,
+    pub at: i64,
+}
+
 #[derive(Debug, Clone, Serialize)]
 #[serde(rename_all = "snake_case", tag = "kind")]
 pub enum MessageEvent {
@@ -86,6 +96,32 @@ impl Broker {
         Ok(())
     }
 
+    /// Latest `limit` messages addressed to `recipient`, newest-first.
+    /// Includes delivered + undelivered alike — used for the operator
+    /// inbox view on the dashboard. Caller decides what to show.
+    pub fn recent_for(&self, recipient: &str, limit: u64) -> Result<Vec<InboxRow>> {
+        let conn = self.conn.lock().unwrap();
+        let limit_i =
+            i64::try_from(limit.min(i64::MAX as u64)).unwrap_or(i64::MAX);
+        let mut stmt = conn.prepare(
+            "SELECT id, sender, body, sent_at
+               FROM messages
+              WHERE recipient = ?1
+              ORDER BY id DESC
+              LIMIT ?2",
+        )?;
+        let rows = stmt.query_map(params![recipient, limit_i], |row| {
+            Ok(InboxRow {
+                id: row.get(0)?,
+                from: row.get(1)?,
+                body: row.get(2)?,
+                at: row.get(3)?,
+            })
+        })?;
+        rows.collect::<rusqlite::Result<Vec<_>>>()
+            .map_err(Into::into)
+    }
+
     /// Number of undelivered messages addressed to `recipient`. Non-mutating
     /// — used by the harness to surface "N unread" in tool-result status
     /// lines without popping the queue.