style(mcp): rustfmt Store trait additions
This commit is contained in:
1 parent
8caeb818a7
commit
59742e4fdf
1 file changed
+16
-4
@@ -302,7 +302,10 @@ pub trait Store: Send + Sync {
|
|||||||
/// Confirmed action items for a meeting (FR-MCP-2 `get_action_items`) —
|
/// Confirmed action items for a meeting (FR-MCP-2 `get_action_items`) —
|
||||||
/// distinct from `list_pending_reminders` (which is filtered to
|
/// distinct from `list_pending_reminders` (which is filtered to
|
||||||
/// unfired-reminder rows across *all* meetings for the startup reconcile).
|
/// unfired-reminder rows across *all* meetings for the startup reconcile).
|
||||||
async fn list_action_items(&self, meeting_id: &MeetingId) -> Result<Vec<ActionItem>, StoreError>;
|
async fn list_action_items(
|
||||||
|
&self,
|
||||||
|
meeting_id: &MeetingId,
|
||||||
|
) -> Result<Vec<ActionItem>, StoreError>;
|
||||||
/// Appends one row to the audit log (FR-MCP-5). Every MCP tool read calls
|
/// Appends one row to the audit log (FR-MCP-5). Every MCP tool read calls
|
||||||
/// this, regardless of whether the read was actually allowed to see
|
/// this, regardless of whether the read was actually allowed to see
|
||||||
/// anything — the audit trail is "what an agent asked for", not just
|
/// anything — the audit trail is "what an agent asked for", not just
|
||||||
@@ -314,7 +317,10 @@ pub trait Store: Send + Sync {
|
|||||||
client: Option<&str>,
|
client: Option<&str>,
|
||||||
) -> Result<(), StoreError>;
|
) -> Result<(), StoreError>;
|
||||||
/// Most recent audit rows first, optionally capped (`mcp_access_log` command).
|
/// Most recent audit rows first, optionally capped (`mcp_access_log` command).
|
||||||
async fn list_mcp_access_log(&self, limit: Option<u32>) -> Result<Vec<McpAccessEntry>, StoreError>;
|
async fn list_mcp_access_log(
|
||||||
|
&self,
|
||||||
|
limit: Option<u32>,
|
||||||
|
) -> Result<Vec<McpAccessEntry>, StoreError>;
|
||||||
}
|
}
|
||||||
|
|
||||||
/// SQLite-backed store. Migrations live in `migrations/` (`sqlx::migrate!`).
|
/// SQLite-backed store. Migrations live in `migrations/` (`sqlx::migrate!`).
|
||||||
@@ -1503,7 +1509,10 @@ impl Store for SqliteStore {
|
|||||||
Ok(rows)
|
Ok(rows)
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn list_action_items(&self, meeting_id: &MeetingId) -> Result<Vec<ActionItem>, StoreError> {
|
async fn list_action_items(
|
||||||
|
&self,
|
||||||
|
meeting_id: &MeetingId,
|
||||||
|
) -> Result<Vec<ActionItem>, StoreError> {
|
||||||
let rows = sqlx::query(
|
let rows = sqlx::query(
|
||||||
"SELECT id, text, owner, due_at, confirmed, reminder_set FROM action_items \
|
"SELECT id, text, owner, due_at, confirmed, reminder_set FROM action_items \
|
||||||
WHERE meeting_id = ? ORDER BY created_at ASC",
|
WHERE meeting_id = ? ORDER BY created_at ASC",
|
||||||
@@ -1543,7 +1552,10 @@ impl Store for SqliteStore {
|
|||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn list_mcp_access_log(&self, limit: Option<u32>) -> Result<Vec<McpAccessEntry>, StoreError> {
|
async fn list_mcp_access_log(
|
||||||
|
&self,
|
||||||
|
limit: Option<u32>,
|
||||||
|
) -> Result<Vec<McpAccessEntry>, StoreError> {
|
||||||
let cap: i64 = limit.map(i64::from).unwrap_or(200).max(1);
|
let cap: i64 = limit.map(i64::from).unwrap_or(200).max(1);
|
||||||
let rows = sqlx::query(
|
let rows = sqlx::query(
|
||||||
"SELECT at, tool, meeting_id, client FROM mcp_access_log ORDER BY at DESC LIMIT ?",
|
"SELECT at, tool, meeting_id, client FROM mcp_access_log ORDER BY at DESC LIMIT ?",
|
||||||
|
|||||||
Reference in new issue
Block a user