Struct NodeDatabase 

pub struct NodeDatabase { /* private fields */ }

Implementations

impl NodeDatabase

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

Open (or create) the node database.

Errors

Returns an error if the database cannot be opened or initialized.

pub fn init_schema(&self) -> Result<()>

Initialize the database schema, creating tables and indexes if they don’t exist.

Errors

Returns an error if the database mutex is poisoned or if a SQL operation fails.

pub fn save_lifecycle(&self, state: &DaemonState) -> Result<()>

Persist the daemon lifecycle state.

Errors

Returns an error if the database cannot be written.

pub fn load_lifecycle(&self) -> Result<Option<DaemonState>>

Load the daemon lifecycle state, returning None if absent.

Errors

Returns an error if the database cannot be read.

pub fn remove_lifecycle(&self) -> Result<()>

Remove the daemon lifecycle state.

Errors

Returns an error if the database cannot be written.

pub fn save_status(&self, report: &DaemonStatusReport) -> Result<()>

Persist the daemon status report.

Errors

Returns an error if the database cannot be written.

pub fn load_status(&self) -> Result<Option<DaemonStatusReport>>

Load the daemon status report, returning None if absent.

Errors

Returns an error if the database cannot be read.

pub fn remove_status(&self) -> Result<()>

Remove all daemon status data.

Errors

Returns an error if the database cannot be written.

pub fn upsert_folder_mount(&self, namespace_id: &str, path: &Path) -> Result<()>

Record (or update) the mount directory for a folder namespace.

The registry is advisory: ls/find/sort use it to resolve a filesystem path back to a managed folder, but always filter by live FolderManager membership before trusting a row.

Errors

Returns an error if the database cannot be written.

pub fn load_folder_mounts(&self) -> Result<Vec<(String, PathBuf)>>

Load all registered folder mount paths as (namespace_id, path) pairs.

Errors

Returns an error if the database cannot be read.

pub fn remove_folder_mount(&self, namespace_id: &str) -> Result<()>

Remove a folder’s mount registration (e.g. on leave).

Errors

Returns an error if the database cannot be written.

pub fn create_network(&self, network: &Network) -> Result<()>

Create a network entry in the database.

Errors

Returns an error if the database cannot be written.

pub fn delete_network(&self, id: NetworkId) -> Result<()>

Delete a network from the database.

Errors

Returns an error if the network is not found or the database cannot be written.

pub fn set_network_doc_ticket( &self, id: NetworkId, doc_ticket: &Option<String>, ) -> Result<()>

Update the membership-doc ticket stored for a network.

Errors

Returns an error if the database cannot be written.

pub fn add_member(&self, network_id: NetworkId, member: PublicKey) -> Result<()>

Add a member to a network.

Errors

Returns an error if the database cannot be written.

pub fn remove_member( &self, network_id: NetworkId, member: &PublicKey, ) -> Result<bool>

Remove a member from a network.

Errors

Returns an error if the database cannot be written.

pub fn add_folder_to_network( &self, network_id: NetworkId, namespace_id: NamespaceId, ) -> Result<()>

Add a folder to a network.

Errors

Returns an error if the database cannot be written.

pub fn remove_folder_from_network( &self, network_id: NetworkId, namespace_id: NamespaceId, ) -> Result<()>

Remove a folder from a network.

Errors

Returns an error if the database cannot be written.

pub fn list_networks(&self) -> Result<Vec<Network>>

List all networks from the database.

Errors

Returns an error if the database cannot be read.

pub fn get_collection_state(&self) -> Result<CollectionState>

Get the installed collection state.

Errors

Returns an error if the database cannot be read.

pub fn install_collection( &self, collection_id: Uuid, manifest_hash: &Hash, version: &str, path: &Path, ) -> Result<()>

Install a collection version in the database.

Errors

Returns an error if the database cannot be written.

pub fn switch_collection_version( &self, collection_id: Uuid, version: &str, ) -> Result<()>

Switch the active version of a collection.

Errors

Returns an error if the database cannot be written.

pub fn remove_collection_version( &self, collection_id: Uuid, version: &str, ) -> Result<()>

Remove a collection version from the database.

Errors

Returns an error if the database cannot be written.

pub fn get_config(&self, key: &str) -> Result<Option<String>>

Get a configuration value.

Errors

Returns an error if the database cannot be read.

pub fn set_config(&self, key: &str, value: &str) -> Result<()>

Set a configuration value.

Errors

Returns an error if the database cannot be written.

pub fn load_app_config(&self) -> Result<AppConfig>

Load the application configuration.

Errors

Returns an error if the database cannot be read or the config cannot be parsed.

pub fn save_app_config(&self, config: &AppConfig) -> Result<()>

Save the application configuration.

Errors

Returns an error if the config cannot be serialized or the database cannot be written.

pub fn load_filter_engine(&self) -> Result<Option<FilterEngine>>

Load the filter engine state.

Errors

Returns an error if the database cannot be read or the filter engine cannot be created.

pub fn save_filter_rules(&self, rules: &[FilterEntry]) -> Result<()>

Save filter rules to the database.

Errors

Returns an error if the database cannot be written.

pub fn load_subscriptions(&self) -> Result<HashSet<Hash>>

Load all public subscription hashes and their sizes.

Errors

Returns an error if the database cannot be read.

pub fn load_subscriptions_with_sizes(&self) -> Result<Vec<(Hash, u64)>>

Load subscription hashes with their cached sizes.

Errors

Returns an error if the database cannot be read.

pub fn save_subscription(&self, hash: &Hash, size: u64) -> Result<()>

Persist a public blob subscription.

Errors

Returns an error if the database cannot be written.

pub fn remove_subscription(&self, hash: &Hash) -> Result<()>

Remove a public blob subscription.

Errors

Returns an error if the database cannot be written.

pub fn add_share( &self, namespace_id: &str, access: &str, ticket: &str, ) -> Result<()>

Persist a folder share record (upsert by namespace + access).

Errors

Returns an error if the database write fails.

pub fn remove_share(&self, namespace_id: &str, access: &str) -> Result<()>

Remove a persisted folder share record.

Errors

Returns an error if the database write fails.

pub fn list_shares(&self) -> Result<Vec<(String, String, String)>>

Load all persisted folder share records as (namespace_id, access, ticket).

Errors

Returns an error if the database cannot be read.

pub fn save_workspace_manifest( &self, source_path: &str, manifest_bytes: &[u8], collection_id: &str, ) -> Result<()>

Save a workspace manifest (serialized bytes) keyed by source path.

Errors

Returns an error if the database write fails.

pub fn load_workspace_manifest( &self, source_path: &str, ) -> Result<Option<Vec<u8>>>

Load a workspace manifest by source path.

Errors

Returns an error if the database query fails.

pub fn delete_workspace_manifest(&self, source_path: &str) -> Result<()>

Delete a workspace manifest.

Errors

Returns an error if the database write fails.

pub fn record_blob_folder( &self, content_hash: &[u8; 32], namespace_id: &str, entry_key: &[u8], ) -> Result<()>

Record a blob→folder association.

Errors

Returns an error if the database write fails.

pub fn remove_blob_folder( &self, content_hash: &[u8; 32], namespace_id: &str, entry_key: &[u8], ) -> Result<()>

Remove a blob→folder association.

Errors

Returns an error if the database write fails.

pub fn folders_for_network(&self, network_id: &str) -> Result<Vec<String>>

List all namespace IDs associated with a network.

Errors

Returns an error if the database query fails.

pub fn networks_for_folder(&self, namespace_id: &str) -> Result<Vec<String>>

List all network IDs that contain a given folder namespace.

Errors

Returns an error if the database query fails.

pub fn members_of_network(&self, network_id: &str) -> Result<Vec<String>>

List all member PublicKey strings for a network.

Errors

Returns an error if the database query fails.

pub fn is_peer_network_member(&self, peer_public_key: &str) -> Result<bool>

Returns true if the given peer is a member of any network. For the per-network daemon model, a daemon only manages ONE network.

Errors

Returns an error if the database query fails.

pub fn upsert_storage_root(&self, root: &StorageRootRecord) -> Result<()>

Add or update a configured materialization root.

Errors

Returns an error if the database write fails.

pub fn list_storage_roots(&self) -> Result<Vec<StorageRootRecord>>

List configured materialization roots.

Errors

Returns an error if the database query fails.

pub fn remove_storage_root(&self, id: &str) -> Result<()>

Remove a storage root.

Errors

Returns an error if the database write fails.

pub fn enqueue_transfer_job(&self, job: &NewTransferJob<'_>) -> Result<String>

Enqueue a materialization or fetch job and return its durable ID.

Errors

Returns an error if the database write fails.

pub fn list_transfer_jobs( &self, namespace_id: Option<&str>, state: Option<&str>, ) -> Result<Vec<TransferJobRecord>>

List durable transfer jobs, optionally scoped by namespace and state.

Errors

Returns an error if the database query fails.

pub fn update_transfer_job_state( &self, id: &str, state: &str, error_message: Option<&str>, ) -> Result<()>

Update a job lifecycle state and optional error.

Errors

Returns an error if the database write fails.

pub fn transition_transfer_job_state( &self, id: &str, expected_state: &str, state: &str, error_message: Option<&str>, ) -> Result<bool>

Transition a job only if it is still in the expected state.

Errors

Returns an error if the database write fails.

pub fn assign_transfer_job( &self, id: &str, root_id: &str, destination: &Path, ) -> Result<()>

Assign a queued job to a root and its stable materialization path.

Errors

Returns an error if the database write fails.

pub fn update_transfer_job_progress( &self, id: &str, bytes_transferred: u64, peer_count: u64, eta_seconds: Option<u64>, retries: u32, ) -> Result<()>

Update per-job transfer counters and retry metadata.

Errors

Returns an error if the database write fails.

pub fn retry_transfer_job(&self, id: &str) -> Result<()>

Requeue a failed or paused job while recording a retry attempt.

Errors

Returns an error if the database write fails.

pub fn recover_transfer_jobs(&self) -> Result<usize>

Requeue jobs interrupted by a daemon restart.

Errors

Returns an error if the database write fails.

pub fn reserved_transfer_bytes(&self, root_id: &str) -> Result<u64>

Return bytes reserved by pending jobs for a root.

Errors

Returns an error if the database query fails.

pub fn create_sync_checkpoint( &self, namespace_id: &str, session_id: &str, ) -> Result<()>

Create a new sync checkpoint session.

Errors

Returns an error if the database write fails.

pub fn upsert_sync_entry(&self, p: &SyncEntryParams<'_>) -> Result<()>

Upsert a sync entry progress record.

Errors

Returns an error if the database write fails.

pub fn list_sync_entries( &self, namespace_id: &str, session_id: &str, status: &str, ) -> Result<Vec<EntryProgress>>

List sync entries for a session filtered by status.

Errors

Returns an error if the database query fails.

pub fn get_checkpoint_progress( &self, namespace_id: &str, session_id: &str, ) -> Result<CheckpointProgress>

Get checkpoint progress for a session.

Errors

Returns an error if the database query fails.

pub fn update_checkpoint_status( &self, namespace_id: &str, session_id: &str, status: &str, ) -> Result<()>

Update checkpoint status.

Errors

Returns an error if the database write fails.

pub fn find_unfinished_checkpoint( &self, namespace_id: &str, ) -> Result<Option<String>>

Find the most recent unfinished checkpoint for a namespace.

Errors

Returns an error if the database query fails.

pub fn delete_sync_checkpoint( &self, namespace_id: &str, session_id: &str, ) -> Result<()>

Delete a sync checkpoint and its entries.

Errors

Returns an error if the database write fails.

pub fn clean_stale_checkpoints(&self, max_age_secs: i64) -> Result<usize>

Clean up stale (dangling) checkpoints older than the given number of seconds.

Errors

Returns an error if the database write fails.

pub fn vacuum(&self) -> Result<()>

Run VACUUM to reclaim space.

Errors

Returns an error if the database operation fails.

pub fn size_on_disk(&self) -> Result<u64>

Return estimated database size in bytes.

Errors

Returns an error if the file metadata cannot be read.

pub fn freelist_count(&self) -> Result<i64>

Return the freelist page count (indicates whether VACUUM would help).

Errors

Returns an error if the database operation fails.

pub fn check_integrity(&self) -> Result<Vec<String>>

Run integrity_check PRAGMA. Returns list of errors (empty = healthy).

Errors

Returns an error if the database operation fails.

Trait Implementations

impl Clone for NodeDatabase

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeDatabase

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

Formats the value using the given formatter.

impl Vacuumable for NodeDatabase

fn vacuum(&self) -> Result<()>

Run VACUUM to reclaim space.

fn freelist_count(&self) -> Result<i64>

Return the freelist page count (indicates whether VACUUM would help).