Struct Db 

pub struct Db { /* private fields */ }

Async wrapper around a single SQLite connection.

Holds an optional notifier so that every task insert performed via storage::tasks::insert reaches the scheduler — not just inserts from the MCP tool layer. Without this, tasks inserted from background workers or fetcher paths would sit running forever in the inserting process, since the orphan scanner deliberately excludes live servers.pid rows.

Implementations

impl Db

pub async fn upsert_server_self( &self, pid: i64, version: String, ) -> Result<(), StorageError>

Upsert the current process’s row. If a row already exists for pid (from a crashed prior run of this PID), its started_at is reset.

pub async fn heartbeat_server(&self, pid: i64) -> Result<(), StorageError>

Refresh last_heartbeat for pid. If no row exists, this is a no-op (logged at the caller).

pub async fn reap_stale_servers( &self, threshold: Duration, ) -> Result<usize, StorageError>

Delete rows whose last_heartbeat is older than threshold ago. Returns the number of rows removed.

pub async fn delete_server_self(&self, pid: i64) -> Result<(), StorageError>

Remove the row for pid (idempotent).

pub async fn list_servers(&self) -> Result<Vec<ServerRow>, StorageError>

Read all rows. Used by tests and by future M3 integration scenarios.

impl Db

pub fn set_new_task_sender(&self, tx: NewTaskNotify)

Install the scheduler-bound new-task notifier. Called once, after the scheduler channel exists, by mcp::server::serve_stdio.

pub fn path(&self) -> &Path

Path the underlying SQLite file was opened from.

Used by register_tasks_update_hook to open a dedicated sibling connection on which the update_hook is installed.

impl Db

pub async fn open(path: impl AsRef<Path>) -> Result<Self, StorageError>

Open the database at path, applying any pending migrations.

pub async fn schema_version(&self) -> Result<u32, StorageError>

Current schema version (for rover doctor and tests).

Trait Implementations

impl Clone for Db

fn clone(&self) -> Db

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Db

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.