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 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 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 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], is_public: bool, ) -> 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 can_access_blob(&self, hash: &Hash, member: &str) -> Result<bool>

Check if a blob hash is accessible in any network the local node belongs to. Check if a blob is accessible in any network the member belongs to.

Errors

Returns an error if the database query fails.

pub fn can_access_blob_in_network( &self, content_hash: &[u8; 32], member: &str, ) -> Result<bool>

Check if a blob (by raw hash bytes) is accessible in any network.

Errors

Returns an error if the database query fails.

pub fn can_access_folder( &self, namespace_id: &str, member: &str, ) -> Result<bool>

Check if the local node can access a folder namespace through any network.

Errors

Returns an error if the database query 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 is_blob_public(&self, content_hash: &[u8; 32]) -> Result<bool>

Returns true if the blob is marked as public (PublicReadOnly sync mode).

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) -> NodeDatabase

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).