Struct IndexingDatabase 

pub struct IndexingDatabase { /* private fields */ }

Thread-safe SQLite database used by the indexing service.

Implementations

impl IndexingDatabase

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

Open or create an indexing database.

Errors

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

pub fn in_memory() -> Result<Self>

Create an isolated in-memory indexing database.

Errors

Returns an error if SQLite cannot initialize the schema.

pub fn path(&self) -> &Path

pub fn schema_version(&self) -> Result<String>

Return the persisted indexing schema version.

Errors

Returns an error if the schema metadata cannot be read.

pub fn has_fts5(&self) -> Result<bool>

Return whether the SQLite FTS5 virtual table is available.

Errors

Returns an error if the schema cannot be queried.

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

Return the names of schema objects owned by the index.

Errors

Returns an error if SQLite cannot query its schema.

pub fn has_table(&self, name: &str) -> Result<bool>

Return whether a schema table or view exists.

Errors

Returns an error if SQLite cannot query its schema.

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

Return the number of opted-in folders.

Errors

Returns an error if SQLite cannot query the database.

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

Return the number of indexed entries.

Errors

Returns an error if SQLite cannot query the database.

pub fn is_folder_enabled(&self, namespace_id: NamespaceId) -> Result<bool>

Return whether a namespace is currently opted into indexing.

Errors

Returns an error if SQLite cannot query the database.

pub fn upsert_entry( &self, namespace_id: NamespaceId, key: impl AsRef<[u8]>, hash: Hash, size: u64, ) -> Result<IndexedEntry>

Insert or update an entry in the index.

Errors

Returns an error if the database cannot persist the entry.

pub fn remove_entry( &self, namespace_id: NamespaceId, key: impl AsRef<[u8]>, ) -> Result<bool>

Remove an indexed entry if it exists.

Errors

Returns an error if the database cannot remove the entry.

pub fn search(&self, query: &str, limit: usize) -> Result<Vec<IndexedEntry>>

Search indexed paths and metadata using SQLite FTS5.

An empty query returns the most recently updated entries. FTS5 query syntax is passed through for non-empty queries.

Errors

Returns an error if the query is invalid or SQLite cannot read results.

pub fn enable_catalog( &self, namespace_id: NamespaceId, label: &str, ) -> Result<()>

Register a catalog that is published or subscribed to locally.

Errors

Returns an error if the catalog metadata cannot be stored.

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

Return the number of known catalogs.

Errors

Returns an error if SQLite cannot query the database.

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

Return all known catalogs with their namespace identifiers and labels.

Errors

Returns an error if the catalog metadata cannot be read.

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

Return the number of records imported from catalogs.

Errors

Returns an error if SQLite cannot query the database.

pub fn upsert_catalog_record( &self, record: &CatalogRecord, ) -> Result<CatalogRecord>

Insert or update a record received from a catalog.

Errors

Returns an error if the catalog is not registered or the record cannot be persisted.

pub fn search_catalogs( &self, query: &str, limit: usize, ) -> Result<Vec<CatalogRecord>>

Search all subscribed catalogs with SQLite FTS5.

An empty query returns the most recently updated catalog records.

Errors

Returns an error if the query is invalid or SQLite cannot read results.

pub fn global_search( &self, query: &str, limit: usize, ) -> Result<Vec<CatalogRecord>>

Search all known catalogs. This is an alias for Self::search_catalogs.

Errors

Returns an error if the query is invalid or SQLite cannot read results.

pub fn catalog_search( &self, query: &str, limit: usize, ) -> Result<Vec<CatalogRecord>>

Search all known catalogs. Alias for Self::search_catalogs.

Errors

Returns an error if the query is invalid or SQLite cannot read results.

pub fn append_wot_metadata(&self, entry: &MetadataEntry) -> Result<bool>

Append a signed Web-of-Trust metadata entry to the local index.

Errors

Returns an error if the entry is invalid or SQLite cannot persist it.

pub fn search_wot_metadata( &self, query: &str, limit: usize, ) -> Result<Vec<MetadataEntry>>

Search accepted Web-of-Trust metadata using SQLite FTS5.

Errors

Returns an error if the query is invalid or metadata cannot be read.

pub fn disable_catalog(&self, namespace_id: NamespaceId) -> Result<()>

Remove a catalog and all records imported from it.

Errors

Returns an error if the catalog cannot be removed.

pub fn enable_folder( &self, namespace_id: NamespaceId, label: &str, ) -> Result<()>

Register a namespace for local indexing.

Errors

Returns an error if the folder metadata cannot be stored.

pub fn disable_folder(&self, namespace_id: NamespaceId) -> Result<()>

Remove a namespace and its indexed entries.

Errors

Returns an error if the folder metadata or entries cannot be removed.

pub fn save_denylist_rules(&self, rules: &[DenylistRule]) -> Result<()>

Persist denylist rules to the database.

Errors

Returns an error if the rules cannot be saved.

pub fn load_denylist_rules(&self) -> Result<Vec<DenylistRule>>

Load persisted denylist rules from the database.

Errors

Returns an error if the rules cannot be read.

pub fn load_filter_lists(&self) -> Result<Vec<FilterList>>

Load persisted filter list subscriptions from the database.

Errors

Returns an error if the filter lists cannot be read.

pub fn upsert_filter_list(&self, list: &FilterList) -> Result<()>

Upsert a filter list subscription.

Errors

Returns an error if the filter list cannot be persisted.

pub fn load_links( &self, ) -> Result<(Vec<MutablePointer>, Vec<String>, Vec<PrivateLink>)>

Load stable links from the database.

Errors

Returns an error if the links cannot be read.

pub fn save_links( &self, pointers: &[MutablePointer], mirrors: &[String], revoked: &[PrivateLink], ) -> Result<()>

Save stable links to the database.

Errors

Returns an error if the links cannot be persisted.

pub fn upsert_link_pointer(&self, pointer: &MutablePointer) -> Result<()>

Upsert a single mutable pointer to the stable links table.

Errors

Returns an error if the pointer cannot be persisted.

pub fn upsert_link_mirror(&self, ticket: &str) -> Result<()>

Insert a single mirror ticket.

Errors

Returns an error if the mirror cannot be persisted.

pub fn save_leases(&self, leases: &[ProviderLease]) -> Result<()>

Save provider leases to the database.

Errors

Returns an error if the leases cannot be persisted.

pub fn load_leases(&self) -> Result<Vec<ProviderLease>>

Load provider leases from the database.

Errors

Returns an error if the leases cannot be read.

pub fn save_trust_delegations( &self, delegations: &[TrustDelegation], ) -> Result<()>

Save trust delegations to the database.

Errors

Returns an error if the delegations cannot be persisted.

pub fn load_trust_delegations(&self) -> Result<Vec<TrustDelegation>>

Load trust delegations from the database.

Errors

Returns an error if the delegations cannot be read.

pub fn save_moderation_records( &self, records: &[ModerationRecord], ) -> Result<()>

Save moderation records to the database.

Errors

Returns an error if the records cannot be persisted.

pub fn load_moderation_records(&self) -> Result<Vec<ModerationRecord>>

Load moderation records from the database.

Errors

Returns an error if the records cannot be read.

pub fn save_attestations(&self, attestations: &[Attestation]) -> Result<()>

Save attestations to the database.

Errors

Returns an error if the attestations cannot be persisted.

pub fn load_attestations(&self) -> Result<Vec<Attestation>>

Load attestations from the database.

Errors

Returns an error if the attestations cannot be read.

pub fn save_content_reports(&self, reports: &[ReportRecord]) -> Result<()>

Save content reports to the database.

Errors

Returns an error if the reports cannot be persisted.

pub fn load_content_reports(&self) -> Result<Vec<ReportRecord>>

Load content reports from the database.

Errors

Returns an error if the reports cannot be read.

pub fn save_provider_bans(&self, bans: &[BanRecord]) -> Result<()>

Save provider bans to the database.

Errors

Returns an error if the bans cannot be persisted.

pub fn load_provider_bans(&self) -> Result<Vec<BanRecord>>

Load provider bans from the database.

Errors

Returns an error if the bans cannot be read.

pub fn insert_provider_lease(&self, lease: &ProviderLease) -> Result<()>

Insert or replace a single provider lease.

Errors

Returns an error if the lease cannot be persisted.

pub fn load_active_leases(&self, now: u64) -> Result<Vec<ProviderLease>>

Load active (non-expired) provider leases from the database.

Errors

Returns an error if the leases cannot be read.

pub fn insert_provider_ban(&self, ban: &BanRecord) -> Result<()>

Insert or replace a single provider ban record.

Errors

Returns an error if the ban cannot be persisted.

pub fn load_active_bans(&self, now: u64) -> Result<Vec<BanRecord>>

Load active (non-expired) provider bans from the database.

Errors

Returns an error if the bans cannot be read.

pub fn load_all_reputations( &self, ) -> Result<HashMap<PublicKey, ProviderReputation>>

Load all provider reputations from the database.

Errors

Returns an error if the reputations cannot be read.

pub fn load_signal_sequences( &self, ) -> Result<HashMap<(PublicKey, PublicKey), u64>>

Load all signal sequence numbers from the database.

Errors

Returns an error if the sequences cannot be read.

pub fn upsert_reputation( &self, provider: &PublicKey, rep: &ProviderReputation, auto_ban_until: Option<u64>, auto_ban_count: u32, ) -> Result<()>

Upsert a provider reputation record.

Errors

Returns an error if the record cannot be persisted.

pub fn delete_stale_reputations(&self, now: u64, ttl_secs: u64) -> Result<()>

Delete stale reputation records last active before the given TTL.

Errors

Returns an error if the deletion fails.

pub fn load_auto_bans(&self) -> Result<HashMap<PublicKey, (Option<u64>, u32)>>

Load auto-ban information for all providers.

Returns a map of provider to (auto_ban_until, auto_ban_count).

Errors

Returns an error if the data cannot be read.

pub fn upsert_signal_sequence( &self, reporter: &PublicKey, provider: &PublicKey, sequence: u64, ) -> Result<()>

Upsert a provider signal sequence tracker.

Errors

Returns an error if the sequence cannot be persisted.

pub fn save_provider_trust_records( &self, records: &[ProviderTrustRecord], ) -> Result<()>

Save provider trust records to the database.

Errors

Returns an error if the records cannot be persisted.

pub fn load_provider_trust_records(&self) -> Result<Vec<ProviderTrustRecord>>

Load provider trust records from the database.

Errors

Returns an error if the records cannot be read.

pub fn save_provider_trust_signals( &self, signals: &[ProviderTrustSignal], ) -> Result<()>

Save provider trust signals to the database.

Errors

Returns an error if the signals cannot be persisted.

pub fn load_provider_trust_signals(&self) -> Result<Vec<ProviderTrustSignal>>

Load provider trust signals from the database.

Errors

Returns an error if the signals cannot be read.

pub fn save_trust_streams(&self, streams: &[String]) -> Result<()>

Save trust streams to the database.

Errors

Returns an error if the streams cannot be persisted.

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

Load trust streams from the database.

Errors

Returns an error if the streams cannot be read.

Trait Implementations

impl Clone for IndexingDatabase

fn clone(&self) -> IndexingDatabase

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IndexingDatabase

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

Formats the value using the given formatter.